Console
    Contact Us Start free

    Package Methods (1.12.0)

    Summary of entries of Methods for pubsublite.

    google.cloud.pubsublite.admin_client.AdminClient

      AdminClient 
 ( 
 region 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 location 
 . 
 CloudRegion 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 typing 
 . 
 Optional 
 [ 
 str 
 ] 
 = 
 None 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 )

    Create a new AdminClient.

    See more: google.cloud.pubsublite.admin_client.AdminClient

    google.cloud.pubsublite.admin_client.AdminClient.create_reservation

      create_reservation 
 ( 
 reservation 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Reservation 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Reservation

    Create a reservation, returns the created reservation.

    See more: google.cloud.pubsublite.admin_client.AdminClient.create_reservation

    google.cloud.pubsublite.admin_client.AdminClient.create_subscription

      create_subscription 
 ( 
 subscription 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Subscription 
 , 
 target 
 : 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 backlog_location 
 . 
 BacklogLocation 
 , 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 backlog_location 
 . 
 PublishTime 
 , 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 backlog_location 
 . 
 EventTime 
 , 
 ] 
 = 
 BacklogLocation 
 . 
 END 
 , 
 starting_offset 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 backlog_location 
 . 
 BacklogLocation 
 ] 
 = 
 None 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Subscription

    Create a subscription, returns the created subscription.

    See more: google.cloud.pubsublite.admin_client.AdminClient.create_subscription

    google.cloud.pubsublite.admin_client.AdminClient.create_topic

      create_topic 
 ( 
 topic 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Topic 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Topic

    Create a topic, returns the created topic.

    See more: google.cloud.pubsublite.admin_client.AdminClient.create_topic

    google.cloud.pubsublite.admin_client.AdminClient.delete_reservation

      delete_reservation 
 ( 
 reservation_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 ReservationPath 
 , 
 )

    Delete a reservation and all associated messages.

    See more: google.cloud.pubsublite.admin_client.AdminClient.delete_reservation

    google.cloud.pubsublite.admin_client.AdminClient.delete_subscription

      delete_subscription 
 ( 
 subscription_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 SubscriptionPath 
 , 
 )

    Delete a subscription and all associated messages.

    See more: google.cloud.pubsublite.admin_client.AdminClient.delete_subscription

    google.cloud.pubsublite.admin_client.AdminClient.delete_topic

      delete_topic 
 ( 
 topic_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 TopicPath 
 )

    Delete a topic and all associated messages.

    See more: google.cloud.pubsublite.admin_client.AdminClient.delete_topic

    google.cloud.pubsublite.admin_client.AdminClient.get_reservation

      get_reservation 
 ( 
 reservation_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 ReservationPath 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Reservation

    Get the reservation object from the server.

    See more: google.cloud.pubsublite.admin_client.AdminClient.get_reservation

    google.cloud.pubsublite.admin_client.AdminClient.get_subscription

      get_subscription 
 ( 
 subscription_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 SubscriptionPath 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Subscription

    Get the subscription object from the server.

    See more: google.cloud.pubsublite.admin_client.AdminClient.get_subscription

    google.cloud.pubsublite.admin_client.AdminClient.get_topic

      get_topic 
 ( 
 topic_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 TopicPath 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Topic

    Get the topic object from the server.

    See more: google.cloud.pubsublite.admin_client.AdminClient.get_topic

    google.cloud.pubsublite.admin_client.AdminClient.get_topic_partition_count

      get_topic_partition_count 
 ( 
 topic_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 TopicPath 
 , 
 ) 
 - 
> int

    Get the number of partitions in the provided topic.

    See more: google.cloud.pubsublite.admin_client.AdminClient.get_topic_partition_count

    google.cloud.pubsublite.admin_client.AdminClient.list_reservation_topics

      list_reservation_topics 
 ( 
 reservation_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 ReservationPath 
 , 
 ) 
 - 
> typing 
 . 
 List 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 TopicPath 
 ]

    List the subscriptions that exist for a given reservation.

    See more: google.cloud.pubsublite.admin_client.AdminClient.list_reservation_topics

    google.cloud.pubsublite.admin_client.AdminClient.list_reservations

      list_reservations 
 ( 
 location_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 LocationPath 
 , 
 ) 
 - 
> typing 
 . 
 List 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Reservation 
 ]

    List the Pub/Sub lite reservations that exist for a project in a given location.

    See more: google.cloud.pubsublite.admin_client.AdminClient.list_reservations

    google.cloud.pubsublite.admin_client.AdminClient.list_subscriptions

      list_subscriptions 
 ( 
 location_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 LocationPath 
 , 
 ) 
 - 
> typing 
 . 
 List 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Subscription 
 ]

    List the Pub/Sub lite subscriptions that exist for a project in a given location.

    See more: google.cloud.pubsublite.admin_client.AdminClient.list_subscriptions

    google.cloud.pubsublite.admin_client.AdminClient.list_topic_subscriptions

      list_topic_subscriptions 
 ( 
 topic_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 TopicPath 
 , 
 ) 
 - 
> typing 
 . 
 List 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 SubscriptionPath 
 ]

    List the subscriptions that exist for a given topic.

    See more: google.cloud.pubsublite.admin_client.AdminClient.list_topic_subscriptions

    google.cloud.pubsublite.admin_client.AdminClient.list_topics

      list_topics 
 ( 
 location_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 LocationPath 
 , 
 ) 
 - 
> typing 
 . 
 List 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Topic 
 ]

    List the Pub/Sub lite topics that exist for a project in a given location.

    See more: google.cloud.pubsublite.admin_client.AdminClient.list_topics

    google.cloud.pubsublite.admin_client.AdminClient.region

      region 
 () 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 location 
 . 
 CloudRegion

    The region this client is for.

    See more: google.cloud.pubsublite.admin_client.AdminClient.region

    google.cloud.pubsublite.admin_client.AdminClient.seek_subscription

      seek_subscription 
 ( 
 subscription_path 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 SubscriptionPath 
 , 
 target 
 : 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 backlog_location 
 . 
 BacklogLocation 
 , 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 backlog_location 
 . 
 PublishTime 
 , 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 backlog_location 
 . 
 EventTime 
 , 
 ], 
 ) 
 - 
> google 
 . 
 api_core 
 . 
 operation 
 . 
 Operation

    Initiate an out-of-band seek for a subscription to a specified target.

    See more: google.cloud.pubsublite.admin_client.AdminClient.seek_subscription

    google.cloud.pubsublite.admin_client.AdminClient.update_reservation

      update_reservation 
 ( 
 reservation 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Reservation 
 , 
 update_mask 
 : 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Reservation

    Update the masked fields of the provided reservation.

    See more: google.cloud.pubsublite.admin_client.AdminClient.update_reservation

    google.cloud.pubsublite.admin_client.AdminClient.update_subscription

      update_subscription 
 ( 
 subscription 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Subscription 
 , 
 update_mask 
 : 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Subscription

    Update the masked fields of the provided subscription.

    See more: google.cloud.pubsublite.admin_client.AdminClient.update_subscription

    google.cloud.pubsublite.admin_client.AdminClient.update_topic

      update_topic 
 ( 
 topic 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Topic 
 , 
 update_mask 
 : 
 google 
 . 
 protobuf 
 . 
 field_mask_pb2 
 . 
 FieldMask 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Topic

    Update the masked fields of the provided topic.

    See more: google.cloud.pubsublite.admin_client.AdminClient.update_topic

    google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient

      AsyncPublisherClient 
 ( 
 * 
 , 
 per_partition_batching_settings 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsub_v1 
 . 
 types 
 . 
 BatchSettings 
 ] 
 = 
 None 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 str 
 = 
 "grpc_asyncio" 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 enable_idempotence 
 : 
 bool 
 = 
 False 
 )

    Create a new AsyncPublisherClient.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient

    google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient.__aenter__

      __aenter__ 
 ()

    Return self upon entering the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient. aenter

    google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient.__aexit__

      __aexit__ 
 ( 
 exc_type 
 , 
 exc_value 
 , 
 traceback 
 )

    Raise any exception triggered within the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient. aexit

    google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient.publish

      publish 
 ( 
 topic 
 : 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 TopicPath 
 , 
 str 
 ], 
 data 
 : 
 bytes 
 , 
 ordering_key 
 : 
 str 
 = 
 "" 
 , 
 ** 
 attrs 
 : 
 typing 
 . 
 Mapping 
 [ 
 str 
 , 
 str 
 ] 
 ) 
 - 
> str

    Publish a message.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.AsyncPublisherClient.publish

    google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient

      PublisherClient 
 ( 
 * 
 , 
 per_partition_batching_settings 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsub_v1 
 . 
 types 
 . 
 BatchSettings 
 ] 
 = 
 None 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 str 
 = 
 "grpc_asyncio" 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 , 
 enable_idempotence 
 : 
 bool 
 = 
 False 
 )

    Create a new PublisherClient.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient

    google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient.__enter__

      __enter__ 
 ()

    Return self upon entering the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient. enter

    google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient.__exit__

      __exit__ 
 ( 
 exc_type 
 , 
 exc_value 
 , 
 traceback 
 )

    Raise any exception triggered within the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient. exit

    google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient.publish

      publish 
 ( 
 topic 
 : 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 TopicPath 
 , 
 str 
 ], 
 data 
 : 
 bytes 
 , 
 ordering_key 
 : 
 str 
 = 
 "" 
 , 
 ** 
 attrs 
 : 
 typing 
 . 
 Mapping 
 [ 
 str 
 , 
 str 
 ] 
 ) 
 - 
> concurrent 
 . 
 futures 
 . 
 _base 
 . 
 Future 
 [ 
 str 
 ]

    Publish a message.

    See more: google.cloud.pubsublite.cloudpubsub.publisher_client.PublisherClient.publish

    google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient

      AsyncSubscriberClient 
 ( 
 * 
 , 
 nack_handler 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 cloudpubsub 
 . 
 nack_handler 
 . 
 NackHandler 
 ] 
 = 
 None 
 , 
 reassignment_handler 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 cloudpubsub 
 . 
 reassignment_handler 
 . 
 ReassignmentHandler 
 ] 
 = 
 None 
 , 
 message_transformer 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 cloudpubsub 
 . 
 message_transformer 
 . 
 MessageTransformer 
 ] 
 = 
 None 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 str 
 = 
 "grpc_asyncio" 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 )

    Create a new AsyncSubscriberClient.

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient

    google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient.__aenter__

      __aenter__ 
 ()

    Return self upon entering the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient. aenter

    google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient.__aexit__

      __aexit__ 
 ( 
 exc_type 
 , 
 exc_value 
 , 
 traceback 
 )

    Raise any exception triggered within the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient. aexit

    google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient.subscribe

      subscribe 
 ( 
 subscription 
 : 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 SubscriptionPath 
 , 
 str 
 ], 
 per_partition_flow_control_settings 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 flow_control_settings 
 . 
 FlowControlSettings 
 , 
 fixed_partitions 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Set 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 partition 
 . 
 Partition 
 ] 
 ] 
 = 
 None 
 , 
 ) 
 - 
> typing 
 . 
 AsyncIterator 
 [ 
 google 
 . 
 cloud 
 . 
 pubsub_v1 
 . 
 subscriber 
 . 
 message 
 . 
 Message 
 ]

    Read messages from a subscription.

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.AsyncSubscriberClient.subscribe

    google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient

      SubscriberClient 
 ( 
 * 
 , 
 executor 
 : 
 typing 
 . 
 Optional 
 [ 
 concurrent 
 . 
 futures 
 . 
 thread 
 . 
 ThreadPoolExecutor 
 ] 
 = 
 None 
 , 
 nack_handler 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 cloudpubsub 
 . 
 nack_handler 
 . 
 NackHandler 
 ] 
 = 
 None 
 , 
 reassignment_handler 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 cloudpubsub 
 . 
 reassignment_handler 
 . 
 ReassignmentHandler 
 ] 
 = 
 None 
 , 
 message_transformer 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 cloudpubsub 
 . 
 message_transformer 
 . 
 MessageTransformer 
 ] 
 = 
 None 
 , 
 credentials 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 auth 
 . 
 credentials 
 . 
 Credentials 
 ] 
 = 
 None 
 , 
 transport 
 : 
 str 
 = 
 "grpc_asyncio" 
 , 
 client_options 
 : 
 typing 
 . 
 Optional 
 [ 
 google 
 . 
 api_core 
 . 
 client_options 
 . 
 ClientOptions 
 ] 
 = 
 None 
 )

    Create a new SubscriberClient.

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient

    google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient.__enter__

      __enter__ 
 ()

    Return self upon entering the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient. enter

    google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient.__exit__

      __exit__ 
 ( 
 exc_type 
 , 
 exc_value 
 , 
 traceback 
 )

    Raise any exception triggered within the runtime context.

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient. exit

    google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient.subscribe

      subscribe 
 ( 
 subscription 
 : 
 typing 
 . 
 Union 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 paths 
 . 
 SubscriptionPath 
 , 
 str 
 ], 
 callback 
 : 
 typing 
 . 
 Callable 
 [ 
 [ 
 google 
 . 
 cloud 
 . 
 pubsub_v1 
 . 
 subscriber 
 . 
 message 
 . 
 Message 
 ], 
 None 
 ], 
 per_partition_flow_control_settings 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 flow_control_settings 
 . 
 FlowControlSettings 
 , 
 fixed_partitions 
 : 
 typing 
 . 
 Optional 
 [ 
 typing 
 . 
 Set 
 [ 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 partition 
 . 
 Partition 
 ] 
 ] 
 = 
 None 
 , 
 ) 
 - 
> google 
 . 
 cloud 
 . 
 pubsub_v1 
 . 
 subscriber 
 . 
 futures 
 . 
 StreamingPullFuture

    This method starts a background thread to begin pulling messages from a Pub/Sub Lite subscription and scheduling them to be processed using the provided callback .

    See more: google.cloud.pubsublite.cloudpubsub.subscriber_client.SubscriberClient.subscribe

    google.cloud.pubsublite.types.CloudRegion

      CloudRegion 
 ( 
 name 
 , 
 )

    Create new instance of CloudRegion(name,).

    See more: google.cloud.pubsublite.types.CloudRegion

    google.cloud.pubsublite.types.CloudZone

      CloudZone 
 ( 
 region 
 , 
 zone_id 
 )

    Create new instance of CloudZone(region, zone_id).

    See more: google.cloud.pubsublite.types.CloudZone

    google.cloud.pubsublite.types.EventTime

      EventTime 
 ( 
 value 
 : 
 datetime 
 . 
 datetime 
 )

    Create new instance of EventTime(value,).

    See more: google.cloud.pubsublite.types.EventTime

    google.cloud.pubsublite.types.FlowControlSettings

      FlowControlSettings 
 ( 
 messages_outstanding 
 , 
 bytes_outstanding 
 )

    Create new instance of FlowControlSettings(messages_outstanding, bytes_outstanding).

    See more: google.cloud.pubsublite.types.FlowControlSettings

    google.cloud.pubsublite.types.LocationPath

      LocationPath 
 ( 
 project 
 , 
 location 
 )

    Create new instance of LocationPath(project, location).

    See more: google.cloud.pubsublite.types.LocationPath

    google.cloud.pubsublite.types.MessageMetadata

      MessageMetadata 
 ( 
 partition 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite 
 . 
 types 
 . 
 partition 
 . 
 Partition 
 , 
 cursor 
 : 
 google 
 . 
 cloud 
 . 
 pubsublite_v1 
 . 
 types 
 . 
 common 
 . 
 Cursor 
 , 
 )

    Create new instance of MessageMetadata(partition, cursor).

    See more: google.cloud.pubsublite.types.MessageMetadata

    google.cloud.pubsublite.types.Partition

      Partition 
 ( 
 value 
 , 
 )

    Create new instance of Partition(value,).

    See more: google.cloud.pubsublite.types.Partition

    google.cloud.pubsublite.types.PublishTime

      PublishTime 
 ( 
 value 
 : 
 datetime 
 . 
 datetime 
 )

    Create new instance of PublishTime(value,).

    See more: google.cloud.pubsublite.types.PublishTime

    google.cloud.pubsublite.types.ReservationPath

      ReservationPath 
 ( 
 project 
 , 
 location 
 , 
 name 
 )

    Create new instance of ReservationPath(project, location, name).

    See more: google.cloud.pubsublite.types.ReservationPath

    google.cloud.pubsublite.types.SubscriptionPath

      SubscriptionPath 
 ( 
 project 
 , 
 location 
 , 
 name 
 )

    Create new instance of SubscriptionPath(project, location, name).

    See more: google.cloud.pubsublite.types.SubscriptionPath

    google.cloud.pubsublite.types.TopicPath

      TopicPath 
 ( 
 project 
 , 
 location 
 , 
 name 
 )

    Create new instance of TopicPath(project, location, name).

    See more: google.cloud.pubsublite.types.TopicPath

    Design a Mobile Site
    View Site in Mobile | Classic
    Share by: