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)