
    J                     B    S SK JrJr  S SKJr  S SKJr   " S S\5      rg)    )ABCabstractmethod)	Partition)PubSubMessagec                   4    \ rS rSrSr\S\S\4S j5       rSr	g)RoutingPolicy   z#A policy for how to route messages.messagereturnc                     [        5       e)zr
Route a message to a given partition.
Args:
  message: The message to route

Returns: The partition to route to

)NotImplementedError)selfr
   s     Glib/third_party/google/cloud/pubsublite/internal/wire/routing_policy.pyrouteRoutingPolicy.route   s     "##     N)
__name__
__module____qualname____firstlineno____doc__r   r   r   r   __static_attributes__r   r   r   r   r      s%    -	$] 	$y 	$ 	$r   r   N)abcr   r   'google.cloud.pubsublite.types.partitionr   'google.cloud.pubsublite_v1.types.commonr   r   r   r   r   <module>r      s    $ = A$C $r   