Documentation ¶
Index ¶
- Variables
- func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)
- type PublishChannelConnectionEventsRequest
- func (*PublishChannelConnectionEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishChannelConnectionEventsRequest) GetChannelConnection() string
- func (x *PublishChannelConnectionEventsRequest) GetEvents() []*anypb.Any
- func (x *PublishChannelConnectionEventsRequest) GetTextEvents() []string
- func (*PublishChannelConnectionEventsRequest) ProtoMessage()
- func (x *PublishChannelConnectionEventsRequest) ProtoReflect() protoreflect.Message
- func (x *PublishChannelConnectionEventsRequest) Reset()
- func (x *PublishChannelConnectionEventsRequest) String() string
- type PublishChannelConnectionEventsResponse
- func (*PublishChannelConnectionEventsResponse) Descriptor() ([]byte, []int)deprecated
- func (*PublishChannelConnectionEventsResponse) ProtoMessage()
- func (x *PublishChannelConnectionEventsResponse) ProtoReflect() protoreflect.Message
- func (x *PublishChannelConnectionEventsResponse) Reset()
- func (x *PublishChannelConnectionEventsResponse) String() string
- type PublishEventsRequest
- func (*PublishEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishEventsRequest) GetChannel() string
- func (x *PublishEventsRequest) GetEvents() []*anypb.Any
- func (x *PublishEventsRequest) GetTextEvents() []string
- func (*PublishEventsRequest) ProtoMessage()
- func (x *PublishEventsRequest) ProtoReflect() protoreflect.Message
- func (x *PublishEventsRequest) Reset()
- func (x *PublishEventsRequest) String() string
- type PublishEventsResponse
- type PublisherClient
- type PublisherServer
- type UnimplementedPublisherServer
Constants ¶
This section is empty.
Variables ¶
var File_google_cloud_eventarc_publishing_v1_publisher_proto protoreflect.FileDescriptor
Functions ¶
func RegisterPublisherServer ¶
func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)
Types ¶
type 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
deprecated
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 ¶ added in v1.9.0
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
type PublishChannelConnectionEventsResponse ¶
type PublishChannelConnectionEventsResponse struct {
// contains filtered or unexported fields
}
The response message for the PublishChannelConnectionEvents method.
func (*PublishChannelConnectionEventsResponse) Descriptor
deprecated
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
type 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
deprecated
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 ¶ added in v1.9.0
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
type PublishEventsResponse ¶
type PublishEventsResponse struct {
// contains filtered or unexported fields
}
The response message for the PublishEvents method.
func (*PublishEventsResponse) Descriptor
deprecated
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
type 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
type 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.
type 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)