v1

package
v2.28.0-RC1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 13, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

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

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

PubSubPayloadURN is the URN of the pubsub proto payload.

Variables

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL