Packages

c

com.google.pubsub.v1

SubscriberClient

abstract class SubscriberClient extends SubscriberClientPowerApi with Subscriber with AkkaGrpcClient

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SubscriberClient
  2. AkkaGrpcClient
  3. Subscriber
  4. SubscriberClientPowerApi
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SubscriberClient()

Type Members

  1. type Serializers = Subscriber.Serializers
    Attributes
    protected
    Definition Classes
    Subscriber

Abstract Value Members

  1. abstract def acknowledge(in: AcknowledgeRequest): CompletionStage[Empty]
    Definition Classes
    Subscriber
  2. abstract def close(): CompletionStage[Done]
    Definition Classes
    AkkaGrpcClient
  3. abstract def closed(): CompletionStage[Done]
    Definition Classes
    AkkaGrpcClient
  4. abstract def createSnapshot(in: CreateSnapshotRequest): CompletionStage[Snapshot]
    Definition Classes
    Subscriber
  5. abstract def createSubscription(in: Subscription): CompletionStage[Subscription]
    Definition Classes
    Subscriber
  6. abstract def deleteSnapshot(in: DeleteSnapshotRequest): CompletionStage[Empty]
    Definition Classes
    Subscriber
  7. abstract def deleteSubscription(in: DeleteSubscriptionRequest): CompletionStage[Empty]
    Definition Classes
    Subscriber
  8. abstract def getSubscription(in: GetSubscriptionRequest): CompletionStage[Subscription]
    Definition Classes
    Subscriber
  9. abstract def listSnapshots(in: ListSnapshotsRequest): CompletionStage[ListSnapshotsResponse]
    Definition Classes
    Subscriber
  10. abstract def listSubscriptions(in: ListSubscriptionsRequest): CompletionStage[ListSubscriptionsResponse]
    Definition Classes
    Subscriber
  11. abstract def modifyAckDeadline(in: ModifyAckDeadlineRequest): CompletionStage[Empty]
    Definition Classes
    Subscriber
  12. abstract def modifyPushConfig(in: ModifyPushConfigRequest): CompletionStage[Empty]
    Definition Classes
    Subscriber
  13. abstract def pull(in: PullRequest): CompletionStage[PullResponse]
    Definition Classes
    Subscriber
  14. abstract def seek(in: SeekRequest): CompletionStage[SeekResponse]
    Definition Classes
    Subscriber
  15. abstract def streamingPull(in: Source[StreamingPullRequest, NotUsed]): Source[StreamingPullResponse, NotUsed]
    Definition Classes
    Subscriber
  16. abstract def updateSnapshot(in: UpdateSnapshotRequest): CompletionStage[Snapshot]
    Definition Classes
    Subscriber
  17. abstract def updateSubscription(in: UpdateSubscriptionRequest): CompletionStage[Subscription]
    Definition Classes
    Subscriber

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def acknowledge(): SingleResponseRequestBuilder[AcknowledgeRequest, Empty]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer acknowledge(com.google.pubsub.v1.AcknowledgeRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  7. def createSnapshot(): SingleResponseRequestBuilder[CreateSnapshotRequest, Snapshot]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer createSnapshot(com.google.pubsub.v1.CreateSnapshotRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  8. def createSubscription(): SingleResponseRequestBuilder[Subscription, Subscription]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer createSubscription(com.google.pubsub.v1.Subscription) if possible.

    Definition Classes
    SubscriberClientPowerApi
  9. def deleteSnapshot(): SingleResponseRequestBuilder[DeleteSnapshotRequest, Empty]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer deleteSnapshot(com.google.pubsub.v1.DeleteSnapshotRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  10. def deleteSubscription(): SingleResponseRequestBuilder[DeleteSubscriptionRequest, Empty]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer deleteSubscription(com.google.pubsub.v1.DeleteSubscriptionRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def getSubscription(): SingleResponseRequestBuilder[GetSubscriptionRequest, Subscription]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer getSubscription(com.google.pubsub.v1.GetSubscriptionRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. def listSnapshots(): SingleResponseRequestBuilder[ListSnapshotsRequest, ListSnapshotsResponse]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer listSnapshots(com.google.pubsub.v1.ListSnapshotsRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  19. def listSubscriptions(): SingleResponseRequestBuilder[ListSubscriptionsRequest, ListSubscriptionsResponse]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer listSubscriptions(com.google.pubsub.v1.ListSubscriptionsRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  20. def modifyAckDeadline(): SingleResponseRequestBuilder[ModifyAckDeadlineRequest, Empty]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer modifyAckDeadline(com.google.pubsub.v1.ModifyAckDeadlineRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  21. def modifyPushConfig(): SingleResponseRequestBuilder[ModifyPushConfigRequest, Empty]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer modifyPushConfig(com.google.pubsub.v1.ModifyPushConfigRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  22. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. def pull(): SingleResponseRequestBuilder[PullRequest, PullResponse]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer pull(com.google.pubsub.v1.PullRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  26. def seek(): SingleResponseRequestBuilder[SeekRequest, SeekResponse]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer seek(com.google.pubsub.v1.SeekRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  27. def streamingPull(): StreamResponseRequestBuilder[Source[StreamingPullRequest, NotUsed], StreamingPullResponse]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer streamingPull(com.google.pubsub.v1.StreamingPullRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  28. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  29. def toString(): String
    Definition Classes
    AnyRef → Any
  30. def updateSnapshot(): SingleResponseRequestBuilder[UpdateSnapshotRequest, Snapshot]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer updateSnapshot(com.google.pubsub.v1.UpdateSnapshotRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  31. def updateSubscription(): SingleResponseRequestBuilder[UpdateSubscriptionRequest, Subscription]

    Lower level "lifted" version of the method, giving access to request metadata etc.

    Lower level "lifted" version of the method, giving access to request metadata etc. prefer updateSubscription(com.google.pubsub.v1.UpdateSubscriptionRequest) if possible.

    Definition Classes
    SubscriberClientPowerApi
  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AkkaGrpcClient

Inherited from Subscriber

Inherited from SubscriberClientPowerApi

Inherited from AnyRef

Inherited from Any

Ungrouped