Documentation ¶
Overview ¶
Package v1 is a generated protocol buffer package.
It is generated from these files:
v1.proto
It has these top-level messages:
PubSubPayload
Index ¶
- Constants
- Variables
- type PubSubPayload
- func (*PubSubPayload) Descriptor() ([]byte, []int)
- func (m *PubSubPayload) GetIdAttribute() string
- func (m *PubSubPayload) GetOp() PubSubPayload_Op
- func (m *PubSubPayload) GetSubscription() string
- func (m *PubSubPayload) GetTimestampAttribute() string
- func (m *PubSubPayload) GetTopic() string
- func (m *PubSubPayload) GetWithAttributes() bool
- func (*PubSubPayload) ProtoMessage()
- func (m *PubSubPayload) Reset()
- func (m *PubSubPayload) String() string
- type PubSubPayload_Op
Constants ¶
View Source
const PubSubPayloadURN = "beam:go:payload:pubsub:v1"
PubSubPayloadURN is the URN of the pubsub proto payload.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type PubSubPayload ¶
type PubSubPayload struct { Op PubSubPayload_Op `protobuf:"varint,1,opt,name=op,enum=v1.PubSubPayload_Op" json:"op,omitempty"` Topic string `protobuf:"bytes,2,opt,name=Topic" json:"Topic,omitempty"` Subscription string `protobuf:"bytes,3,opt,name=Subscription" json:"Subscription,omitempty"` IdAttribute string `protobuf:"bytes,4,opt,name=IdAttribute" json:"IdAttribute,omitempty"` TimestampAttribute string `protobuf:"bytes,5,opt,name=TimestampAttribute" json:"TimestampAttribute,omitempty"` WithAttributes bool `protobuf:"varint,6,opt,name=WithAttributes" json:"WithAttributes,omitempty"` }
func (*PubSubPayload) Descriptor ¶
func (*PubSubPayload) Descriptor() ([]byte, []int)
func (*PubSubPayload) GetIdAttribute ¶
func (m *PubSubPayload) GetIdAttribute() string
func (*PubSubPayload) GetOp ¶
func (m *PubSubPayload) GetOp() PubSubPayload_Op
func (*PubSubPayload) GetSubscription ¶
func (m *PubSubPayload) GetSubscription() string
func (*PubSubPayload) GetTimestampAttribute ¶
func (m *PubSubPayload) GetTimestampAttribute() string
func (*PubSubPayload) GetTopic ¶
func (m *PubSubPayload) GetTopic() string
func (*PubSubPayload) GetWithAttributes ¶
func (m *PubSubPayload) GetWithAttributes() bool
func (*PubSubPayload) ProtoMessage ¶
func (*PubSubPayload) ProtoMessage()
func (*PubSubPayload) Reset ¶
func (m *PubSubPayload) Reset()
func (*PubSubPayload) String ¶
func (m *PubSubPayload) String() string
type PubSubPayload_Op ¶
type PubSubPayload_Op int32
const ( PubSubPayload_INVALID PubSubPayload_Op = 0 PubSubPayload_READ PubSubPayload_Op = 1 PubSubPayload_WRITE PubSubPayload_Op = 2 )
func (PubSubPayload_Op) EnumDescriptor ¶
func (PubSubPayload_Op) EnumDescriptor() ([]byte, []int)
func (PubSubPayload_Op) String ¶
func (x PubSubPayload_Op) String() string
Click to show internal directories.
Click to hide internal directories.