\ddlmZmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZmZddlmZdd lmZmZdd lmZdd lmZdd lmZeZ ddededeedeedeedeeeefdeedefdZ ddededeedeedeedeeeefdeedefdZy ))OptionalMapping) ClientOptions) Credentials) BatchSettings)AsyncSinglePublisherImpl)SinglePublisherImpl)AsyncSinglePublisherSinglePublisher)PublisherClientId)make_publisherDEFAULT_BATCHING_SETTINGS)merge_metadata)pubsub_context) TopicPathNtopic transportper_partition_batching_settings credentialsclient_optionsmetadata client_idreturnchttdfd}t|S)a Make a new publisher for the given topic. Args: topic: The topic to publish to. transport: The transport type to use. per_partition_batching_settings: Settings for batching messages on each partition. The default is reasonable for most cases. credentials: The credentials to use to connect. GOOGLE_DEFAULT_CREDENTIALS is used if None. client_options: Other options to pass to the client. Note that if you pass any you must set api_endpoint. metadata: Additional metadata to send with the RPC. client_id: 128-bit unique client id. If set, enables publish idempotency for the session. Returns: A new AsyncPublisher. Throws: GoogleApiCallException on any error determining topic structure. CLOUD_PUBSUB_SHIM) frameworkc (tS)Nrrrrrrr)make_wire_publisher)rrrrrrrsNlib/third_party/google/cloud/pubsublite/cloudpubsub/internal/make_publisher.pyunderlying_factoryz0make_async_publisher..underlying_factoryIs%",K#)  )rrr)rrrrrrrr!s``````` r make_async_publisherr#,s/6n7JKXVH    $$6 77r"c 8tt|||||||S)a Make a new publisher for the given topic. Args: topic: The topic to publish to. transport: The transport type to use. per_partition_batching_settings: Settings for batching messages on each partition. The default is reasonable for most cases. credentials: The credentials to use to connect. GOOGLE_DEFAULT_CREDENTIALS is used if None. client_options: Other options to pass to the client. Note that if you pass any you must set api_endpoint. metadata: Additional metadata to send with the RPC. client_id: 128-bit unique client id. If set, enables publish idempotency for the session. Returns: A new Publisher. Throws: GoogleApiCallException on any error determining topic structure. r)r r#rs r r r Ws.6 ,K#)   r")NNNNN)typingrrgoogle.api_core.client_optionsrgoogle.auth.credentialsrgoogle.cloud.pubsub_v1.typesrAgoogle.cloud.pubsublite.cloudpubsub.internal.async_publisher_implr;google.cloud.pubsublite.cloudpubsub.internal.publisher_implr =google.cloud.pubsublite.cloudpubsub.internal.single_publisherr r 4google.cloud.pubsublite.internal.publisher_client_idr 4google.cloud.pubsublite.internal.wire.make_publisherr rrWIRE_DEFAULT_BATCHING4google.cloud.pubsublite.internal.wire.merge_metadatar4google.cloud.pubsublite.internal.wire.pubsub_contextrgoogle.cloud.pubsublite.typesrstrr#r"r r4sP%8/6SPO32 @D)-.2,0-1(8 (8(8&.m%<(8+& (8 ]+ (8 wsCx() (8)*(8(8\@D)-.2,0-1% %%&.m%<%+& % ]+ % wsCx() %)*%%r"