Class PublisherGrpc.PublisherFutureStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<PublisherGrpc.PublisherFutureStub>
com.google.cloud.eventarc.publishing.v1.PublisherGrpc.PublisherFutureStub
- Enclosing class:
- PublisherGrpc
public static final class PublisherGrpc.PublisherFutureStub
extends io.grpc.stub.AbstractFutureStub<PublisherGrpc.PublisherFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Publisher.
Eventarc processes events generated by an event provider and delivers them to a subscriber. An event provider is a software-as-a-service (SaaS) system or product that can generate and deliver events through Eventarc. A third-party event provider is an event provider from outside of Google. A partner is a third-party event provider that is integrated with Eventarc. A subscriber is a Google Cloud customer interested in receiving events. Channel is a first-class Eventarc resource that is created and managed by the subscriber in their Google Cloud project. A Channel represents a subscriber's intent to receive events from an event provider. A Channel is associated with exactly one event provider. ChannelConnection is a first-class Eventarc resource that is created and managed by the partner in their Google Cloud project. A ChannelConnection represents a connection between a partner and a subscriber's Channel. A ChannelConnection has a one-to-one mapping with a Channel. Bus is a first-class Eventarc resource that is created and managed in a Google Cloud project. A Bus provides a discoverable endpoint for events and is a router that receives all events published by event providers and delivers them to zero or more subscribers. Publisher allows an event provider to publish events to Eventarc.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub
io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>> -
Method Summary
Modifier and TypeMethodDescriptionprotected PublisherGrpc.PublisherFutureStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) com.google.common.util.concurrent.ListenableFuture<PublishResponse>publish(PublishRequest request) Publish events to a message bus.com.google.common.util.concurrent.ListenableFuture<PublishChannelConnectionEventsResponse>Publish events to a ChannelConnection in a partner's project.com.google.common.util.concurrent.ListenableFuture<PublishEventsResponse>publishEvents(PublishEventsRequest request) Publish events to a subscriber's channel.Methods inherited from class io.grpc.stub.AbstractFutureStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
protected PublisherGrpc.PublisherFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
buildin classio.grpc.stub.AbstractStub<PublisherGrpc.PublisherFutureStub>
-
publishChannelConnectionEvents
public com.google.common.util.concurrent.ListenableFuture<PublishChannelConnectionEventsResponse> publishChannelConnectionEvents(PublishChannelConnectionEventsRequest request) Publish events to a ChannelConnection in a partner's project.
-
publishEvents
public com.google.common.util.concurrent.ListenableFuture<PublishEventsResponse> publishEvents(PublishEventsRequest request) Publish events to a subscriber's channel.
-
publish
public com.google.common.util.concurrent.ListenableFuture<PublishResponse> publish(PublishRequest request) Publish events to a message bus.
-