Package cloud.google.com/go/eventarc/publishing/apiv1/publishingpb (v1.7.0)

Stay organized with collections Save and categorize content based on your preferences.

Variables

File_google_cloud_eventarc_publishing_v1_publisher_proto

var File_google_cloud_eventarc_publishing_v1_publisher_proto protoreflect.FileDescriptor

Functions

func RegisterPublisherServer

func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)

PublishChannelConnectionEventsRequest

type PublishChannelConnectionEventsRequest struct {

	// The channel_connection that the events are published from. For example:
	// `projects/{partner_project_id}/locations/{location}/channelConnections/{channel_connection_id}`.
	ChannelConnection string `protobuf:"bytes,1,opt,name=channel_connection,json=channelConnection,proto3" json:"channel_connection,omitempty"`
	// The CloudEvents v1.0 events to publish. No other types are allowed.
	Events []*any1.Any `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

The request message for the PublishChannelConnectionEvents method.

func (*PublishChannelConnectionEventsRequest) Descriptor

func (*PublishChannelConnectionEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use PublishChannelConnectionEventsRequest.ProtoReflect.Descriptor instead.

func (*PublishChannelConnectionEventsRequest) GetChannelConnection

func (x *PublishChannelConnectionEventsRequest) GetChannelConnection() string

func (*PublishChannelConnectionEventsRequest) GetEvents

func (*PublishChannelConnectionEventsRequest) ProtoMessage

func (*PublishChannelConnectionEventsRequest) ProtoMessage()

func (*PublishChannelConnectionEventsRequest) ProtoReflect

func (*PublishChannelConnectionEventsRequest) Reset

func (*PublishChannelConnectionEventsRequest) String

PublishChannelConnectionEventsResponse

type PublishChannelConnectionEventsResponse struct {
	// contains filtered or unexported fields
}

The response message for the PublishChannelConnectionEvents method.

func (*PublishChannelConnectionEventsResponse) Descriptor

func (*PublishChannelConnectionEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishChannelConnectionEventsResponse.ProtoReflect.Descriptor instead.

func (*PublishChannelConnectionEventsResponse) ProtoMessage

func (*PublishChannelConnectionEventsResponse) ProtoReflect

func (*PublishChannelConnectionEventsResponse) Reset

func (*PublishChannelConnectionEventsResponse) String

PublishEventsRequest

type PublishEventsRequest struct {

	// The full name of the channel to publish to. For example:
	// `projects/{project}/locations/{location}/channels/{channel-id}`.
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// The CloudEvents v1.0 events to publish. No other types are allowed.
	Events []*any1.Any `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

The request message for the PublishEvents method.

func (*PublishEventsRequest) Descriptor

func (*PublishEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use PublishEventsRequest.ProtoReflect.Descriptor instead.

func (*PublishEventsRequest) GetChannel

func (x *PublishEventsRequest) GetChannel() string

func (*PublishEventsRequest) GetEvents

func (x *PublishEventsRequest) GetEvents() []*any1.Any

func (*PublishEventsRequest) ProtoMessage

func (*PublishEventsRequest) ProtoMessage()

func (*PublishEventsRequest) ProtoReflect

func (x *PublishEventsRequest) ProtoReflect() protoreflect.Message

func (*PublishEventsRequest) Reset

func (x *PublishEventsRequest) Reset()

func (*PublishEventsRequest) String

func (x *PublishEventsRequest) String() string

PublishEventsResponse

type PublishEventsResponse struct {
	// contains filtered or unexported fields
}

The response message for the PublishEvents method.

func (*PublishEventsResponse) Descriptor

func (*PublishEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishEventsResponse.ProtoReflect.Descriptor instead.

func (*PublishEventsResponse) ProtoMessage

func (*PublishEventsResponse) ProtoMessage()

func (*PublishEventsResponse) ProtoReflect

func (x *PublishEventsResponse) ProtoReflect() protoreflect.Message

func (*PublishEventsResponse) Reset

func (x *PublishEventsResponse) Reset()

func (*PublishEventsResponse) String

func (x *PublishEventsResponse) String() string

PublisherClient

type PublisherClient interface {
	// Publish events to a ChannelConnection in a partner's project.
	PublishChannelConnectionEvents(ctx context.Context, in *PublishChannelConnectionEventsRequest, opts ...grpc.CallOption) (*PublishChannelConnectionEventsResponse, error)
	// Publish events to a subscriber's channel.
	PublishEvents(ctx context.Context, in *PublishEventsRequest, opts ...grpc.CallOption) (*PublishEventsResponse, error)
}

PublisherClient is the client API for Publisher service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPublisherClient

func NewPublisherClient(cc grpc.ClientConnInterface) PublisherClient

PublisherServer

type PublisherServer interface {
	// Publish events to a ChannelConnection in a partner's project.
	PublishChannelConnectionEvents(context.Context, *PublishChannelConnectionEventsRequest) (*PublishChannelConnectionEventsResponse, error)
	// Publish events to a subscriber's channel.
	PublishEvents(context.Context, *PublishEventsRequest) (*PublishEventsResponse, error)
}

PublisherServer is the server API for Publisher service.

UnimplementedPublisherServer

type UnimplementedPublisherServer struct {
}

UnimplementedPublisherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublisherServer) PublishChannelConnectionEvents

func (*UnimplementedPublisherServer) PublishEvents