pubsubv1

Documentation

Index

• Variables
• type MessagePublishedData
  • func (x *MessagePublishedData) ClearMessage()
  • func (x *MessagePublishedData) GetMessage() *PubsubMessage
  • func (x *MessagePublishedData) GetSubscription() string
  • func (x *MessagePublishedData) HasMessage() bool
  • func (*MessagePublishedData) ProtoMessage()
  • func (x *MessagePublishedData) ProtoReflect() protoreflect.Message
  • func (x *MessagePublishedData) Reset()
  • func (x *MessagePublishedData) SetMessage(v *PubsubMessage)
  • func (x *MessagePublishedData) SetSubscription(v string)
  • func (x *MessagePublishedData) String() string
• type MessagePublishedData_builder
  • func (b0 MessagePublishedData_builder) Build() *MessagePublishedData
• type MessagePublishedEvent
  • func (x *MessagePublishedEvent) ClearData()
  • func (x *MessagePublishedEvent) GetData() *MessagePublishedData
  • func (x *MessagePublishedEvent) HasData() bool
  • func (*MessagePublishedEvent) ProtoMessage()
  • func (x *MessagePublishedEvent) ProtoReflect() protoreflect.Message
  • func (x *MessagePublishedEvent) Reset()
  • func (x *MessagePublishedEvent) SetData(v *MessagePublishedData)
  • func (x *MessagePublishedEvent) String() string
• type MessagePublishedEvent_builder
  • func (b0 MessagePublishedEvent_builder) Build() *MessagePublishedEvent
• type PubsubMessage
  • func (x *PubsubMessage) ClearPublishTime()
  • func (x *PubsubMessage) GetAttributes() map[string]string
  • func (x *PubsubMessage) GetData() []byte
  • func (x *PubsubMessage) GetMessageId() string
  • func (x *PubsubMessage) GetOrderingKey() string
  • func (x *PubsubMessage) GetPublishTime() *timestamppb.Timestamp
  • func (x *PubsubMessage) HasPublishTime() bool
  • func (*PubsubMessage) ProtoMessage()
  • func (x *PubsubMessage) ProtoReflect() protoreflect.Message
  • func (x *PubsubMessage) Reset()
  • func (x *PubsubMessage) SetAttributes(v map[string]string)
  • func (x *PubsubMessage) SetData(v []byte)
  • func (x *PubsubMessage) SetMessageId(v string)
  • func (x *PubsubMessage) SetOrderingKey(v string)
  • func (x *PubsubMessage) SetPublishTime(v *timestamppb.Timestamp)
  • func (x *PubsubMessage) String() string
• type PubsubMessage_builder
  • func (b0 PubsubMessage_builder) Build() *PubsubMessage

Variables

var File_google_events_cloud_pubsub_v1_data_proto protoreflect.FileDescriptor

var File_google_events_cloud_pubsub_v1_events_proto protoreflect.FileDescriptor

Types

type MessagePublishedData

type MessagePublishedData struct {

	// The message that was published.
	Message *PubsubMessage `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The resource name of the subscription for which this event was
	// generated. The format of the value is
	// `projects/{project-id}/subscriptions/{subscription-id}`.
	Subscription string `protobuf:"bytes,2,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// contains filtered or unexported fields
}

The event data when a message is published to a topic.

func (*MessagePublishedData) ClearMessage

func (x *MessagePublishedData) ClearMessage()

func (*MessagePublishedData) GetMessage

func (x *MessagePublishedData) GetMessage() *PubsubMessage

func (*MessagePublishedData) GetSubscription

func (x *MessagePublishedData) GetSubscription() string

func (*MessagePublishedData) HasMessage

func (x *MessagePublishedData) HasMessage() bool

func (*MessagePublishedData) ProtoMessage

func (*MessagePublishedData) ProtoMessage()

func (*MessagePublishedData) ProtoReflect

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

func (*MessagePublishedData) Reset

func (x *MessagePublishedData) Reset()

func (*MessagePublishedData) SetMessage

func (x *MessagePublishedData) SetMessage(v *PubsubMessage)

func (*MessagePublishedData) SetSubscription

func (x *MessagePublishedData) SetSubscription(v string)

func (*MessagePublishedData) String

func (x *MessagePublishedData) String() string

type MessagePublishedData_builder

type MessagePublishedData_builder struct {

	// The message that was published.
	Message *PubsubMessage
	// The resource name of the subscription for which this event was
	// generated. The format of the value is
	// `projects/{project-id}/subscriptions/{subscription-id}`.
	Subscription string
	// contains filtered or unexported fields
}

func (MessagePublishedData_builder) Build

func (b0 MessagePublishedData_builder) Build() *MessagePublishedData

type MessagePublishedEvent

type MessagePublishedEvent struct {

	// The data associated with the event.
	Data *MessagePublishedData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a PubSub message is published for a topic.

func (*MessagePublishedEvent) ClearData

func (x *MessagePublishedEvent) ClearData()

func (*MessagePublishedEvent) GetData

func (x *MessagePublishedEvent) GetData() *MessagePublishedData

func (*MessagePublishedEvent) HasData

func (x *MessagePublishedEvent) HasData() bool

func (*MessagePublishedEvent) ProtoMessage

func (*MessagePublishedEvent) ProtoMessage()

func (*MessagePublishedEvent) ProtoReflect

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

func (*MessagePublishedEvent) Reset

func (x *MessagePublishedEvent) Reset()

func (*MessagePublishedEvent) SetData

func (x *MessagePublishedEvent) SetData(v *MessagePublishedData)

func (*MessagePublishedEvent) String

func (x *MessagePublishedEvent) String() string

type MessagePublishedEvent_builder

type MessagePublishedEvent_builder struct {

	// The data associated with the event.
	Data *MessagePublishedData
	// contains filtered or unexported fields
}

func (MessagePublishedEvent_builder) Build

func (b0 MessagePublishedEvent_builder) Build() *MessagePublishedEvent

type PubsubMessage

type PubsubMessage struct {

	// The binary data in the message.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Attributes for this message.
	Attributes map[string]string `` /* 147-byte string literal not displayed */
	// ID of this message, assigned by the server when the message is published.
	// Guaranteed to be unique within the topic.
	MessageId string `protobuf:"bytes,3,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// The time at which the message was published, populated by the server when
	// it receives the `Publish` call.
	PublishTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=publish_time,json=publishTime,proto3" json:"publish_time,omitempty"`
	// If non-empty, identifies related messages for which publish order should be
	// respected.
	OrderingKey string `protobuf:"bytes,5,opt,name=ordering_key,json=orderingKey,proto3" json:"ordering_key,omitempty"`
	// contains filtered or unexported fields
}

A message published to a topic.

func (*PubsubMessage) ClearPublishTime

func (x *PubsubMessage) ClearPublishTime()

func (*PubsubMessage) GetAttributes

func (x *PubsubMessage) GetAttributes() map[string]string

func (*PubsubMessage) GetData

func (x *PubsubMessage) GetData() []byte

func (*PubsubMessage) GetMessageId

func (x *PubsubMessage) GetMessageId() string

func (*PubsubMessage) GetOrderingKey

func (x *PubsubMessage) GetOrderingKey() string

func (*PubsubMessage) GetPublishTime

func (x *PubsubMessage) GetPublishTime() *timestamppb.Timestamp

func (*PubsubMessage) HasPublishTime

func (x *PubsubMessage) HasPublishTime() bool

func (*PubsubMessage) ProtoMessage

func (*PubsubMessage) ProtoMessage()

func (*PubsubMessage) ProtoReflect

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

func (*PubsubMessage) Reset

func (x *PubsubMessage) Reset()

func (*PubsubMessage) SetAttributes

func (x *PubsubMessage) SetAttributes(v map[string]string)

func (*PubsubMessage) SetData

func (x *PubsubMessage) SetData(v []byte)

func (*PubsubMessage) SetMessageId

func (x *PubsubMessage) SetMessageId(v string)

func (*PubsubMessage) SetOrderingKey

func (x *PubsubMessage) SetOrderingKey(v string)

func (*PubsubMessage) SetPublishTime

func (x *PubsubMessage) SetPublishTime(v *timestamppb.Timestamp)

func (*PubsubMessage) String

func (x *PubsubMessage) String() string

type PubsubMessage_builder

type PubsubMessage_builder struct {

	// The binary data in the message.
	Data []byte
	// Attributes for this message.
	Attributes map[string]string
	// ID of this message, assigned by the server when the message is published.
	// Guaranteed to be unique within the topic.
	MessageId string
	// The time at which the message was published, populated by the server when
	// it receives the `Publish` call.
	PublishTime *timestamppb.Timestamp
	// If non-empty, identifies related messages for which publish order should be
	// respected.
	OrderingKey string
	// contains filtered or unexported fields
}

func (PubsubMessage_builder) Build

func (b0 PubsubMessage_builder) Build() *PubsubMessage