
    J                     B    d dl mZmZ d dlmZ d dlmZ  G d de      Zy)    )ABCabstractmethod)	Partition)PubSubMessagec                   *    e Zd ZdZededefd       Zy)RoutingPolicyz#A policy for how to route messages.messagereturnc                     t               )z
        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routezRoutingPolicy.route   s     "##    N)__name__
__module____qualname____doc__r   r   r   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   