beam: github.com/apache/beam/sdks/go/pkg/beam/io/pubsubio/v1 Index | Files

package v1

import "github.com/apache/beam/sdks/go/pkg/beam/io/pubsubio/v1"

Package v1 is a generated protocol buffer package.

It is generated from these files: 

v1.proto

It has these top-level messages: 

PubSubPayload

Index

Package Files

gen.go v1.pb.go

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,
}

type PubSubPayload Uses

❖
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 Uses

❖
func (*PubSubPayload) Descriptor() ([]byte, []int)

func (*PubSubPayload) GetIdAttribute Uses

❖
func (m *PubSubPayload) GetIdAttribute() string

func (*PubSubPayload) GetOp Uses

❖
func (m *PubSubPayload) GetOp() PubSubPayload_Op

func (*PubSubPayload) GetSubscription Uses

❖
func (m *PubSubPayload) GetSubscription() string

func (*PubSubPayload) GetTimestampAttribute Uses

❖
func (m *PubSubPayload) GetTimestampAttribute() string

func (*PubSubPayload) GetTopic Uses

❖
func (m *PubSubPayload) GetTopic() string

func (*PubSubPayload) GetWithAttributes Uses

❖
func (m *PubSubPayload) GetWithAttributes() bool

func (*PubSubPayload) ProtoMessage Uses

❖
func (*PubSubPayload) ProtoMessage()

func (*PubSubPayload) Reset Uses

❖
func (m *PubSubPayload) Reset()

func (*PubSubPayload) String Uses

❖
func (m *PubSubPayload) String() string

type PubSubPayload_Op Uses

❖
type PubSubPayload_Op int32
❖
const (
    PubSubPayload_INVALID PubSubPayload_Op = 0
    PubSubPayload_READ    PubSubPayload_Op = 1
    PubSubPayload_WRITE   PubSubPayload_Op = 2
)

func (PubSubPayload_Op) EnumDescriptor Uses

❖
func (PubSubPayload_Op) EnumDescriptor() ([]byte, []int)

func (PubSubPayload_Op) String Uses

❖
func (x PubSubPayload_Op) String() string

Package v1 imports 3 packages (graph) and is imported by 2 packages. Updated 2018-04-24. Refresh now. Tools for package owners.