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

Version latest

• 1.13.5 (latest)
• 1.13.4

Note: To get more information about this package, such as access to older versions, view this package on pkg.go.dev.

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.
	// If this field is set, then the `text_events` fields must not be set.
	Events []*anypb.Any `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// The text representation of events to publish.
	// CloudEvent v1.0 in JSON format is the only allowed type. Refer to
	// https://github.com/cloudevents/spec/blob/v1.0.2/cloudevents/formats/json-format.md
	// for specification.
	// If this field is set, then the `events` fields must not be set.
	TextEvents []string `protobuf:"bytes,3,rep,name=text_events,json=textEvents,proto3" json:"text_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 (x *PublishChannelConnectionEventsRequest) GetEvents() []*anypb.Any

func (*PublishChannelConnectionEventsRequest) GetTextEvents

func (x *PublishChannelConnectionEventsRequest) GetTextEvents() []string

func (*PublishChannelConnectionEventsRequest) ProtoMessage

func (*PublishChannelConnectionEventsRequest) ProtoMessage()

func (*PublishChannelConnectionEventsRequest) ProtoReflect

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

func (*PublishChannelConnectionEventsRequest) Reset

func (x *PublishChannelConnectionEventsRequest) Reset()

func (*PublishChannelConnectionEventsRequest) String

func (x *PublishChannelConnectionEventsRequest) String() 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) ProtoMessage()

func (*PublishChannelConnectionEventsResponse) ProtoReflect

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

func (*PublishChannelConnectionEventsResponse) Reset

func (x *PublishChannelConnectionEventsResponse) Reset()

func (*PublishChannelConnectionEventsResponse) String

func (x *PublishChannelConnectionEventsResponse) String() 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.
	// If this field is set, then the `text_events` fields must not be set.
	Events []*anypb.Any `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// The text representation of events to publish.
	// CloudEvent v1.0 in JSON format is the only allowed type. Refer to
	// https://github.com/cloudevents/spec/blob/v1.0.2/cloudevents/formats/json-format.md
	// for specification.
	// If this field is set, then the `events` fields must not be set.
	TextEvents []string `protobuf:"bytes,3,rep,name=text_events,json=textEvents,proto3" json:"text_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() []*anypb.Any

func (*PublishEventsRequest) GetTextEvents

func (x *PublishEventsRequest) GetTextEvents() []string

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) PublishChannelConnectionEvents(context.Context, *PublishChannelConnectionEventsRequest) (*PublishChannelConnectionEventsResponse, error)

func (*UnimplementedPublisherServer) PublishEvents

func (*UnimplementedPublisherServer) PublishEvents(context.Context, *PublishEventsRequest) (*PublishEventsResponse, error)