v1

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
  • func (PubSubPayload_Op) EnumDescriptor() ([]byte, []int)
  • func (x PubSubPayload_Op) String() string

Constants

const PubSubPayloadURN = "beam:go:payload:pubsub:v1"

PubSubPayloadURN is the URN of the pubsub proto payload.

Variables

var PubSubPayload_Op_name = map[int32]string{
	0: "INVALID",
	1: "READ",
	2: "WRITE",
}

var PubSubPayload_Op_value = map[string]int32{
	"INVALID": 0,
	"READ":    1,
	"WRITE":   2,
}

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