Class PublisherGrpc.PublisherStub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractAsyncStub<PublisherGrpc.PublisherStub>
com.google.cloud.eventarc.publishing.v1.PublisherGrpc.PublisherStub
- Enclosing class:
- PublisherGrpc
public static final class PublisherGrpc.PublisherStub
extends io.grpc.stub.AbstractAsyncStub<PublisherGrpc.PublisherStub>
A stub to allow clients to do asynchronous 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.PublisherStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions) voidpublish(PublishRequest request, io.grpc.stub.StreamObserver<PublishResponse> responseObserver) Publish events to a message bus.voidpublishChannelConnectionEvents(PublishChannelConnectionEventsRequest request, io.grpc.stub.StreamObserver<PublishChannelConnectionEventsResponse> responseObserver) Publish events to a ChannelConnection in a partner's project.voidpublishEvents(PublishEventsRequest request, io.grpc.stub.StreamObserver<PublishEventsResponse> responseObserver) Publish events to a subscriber's channel.Methods inherited from class io.grpc.stub.AbstractAsyncStub
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.PublisherStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
buildin classio.grpc.stub.AbstractStub<PublisherGrpc.PublisherStub>
-
publishChannelConnectionEvents
public void publishChannelConnectionEvents(PublishChannelConnectionEventsRequest request, io.grpc.stub.StreamObserver<PublishChannelConnectionEventsResponse> responseObserver) Publish events to a ChannelConnection in a partner's project.
-
publishEvents
public void publishEvents(PublishEventsRequest request, io.grpc.stub.StreamObserver<PublishEventsResponse> responseObserver) Publish events to a subscriber's channel.
-
publish
public void publish(PublishRequest request, io.grpc.stub.StreamObserver<PublishResponse> responseObserver) Publish events to a message bus.
-