session

package
Version: v2.25.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Oct 20, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package session is a generated protocol buffer package.

It is generated from these files:

session.proto

It has these top-level messages:

Header
Footer
EntryHeader
Entry

Index

Constants

This section is empty.

Variables

View Source
var Kind_name = map[int32]string{
	0: "INVALID",
	1: "INSTRUCTION_REQUEST",
	2: "INSTRUCTION_RESPONSE",
	3: "DATA_RECEIVED",
	4: "DATA_SENT",
	5: "LOG_ENTRIES",
	6: "HEADER",
	7: "FOOTER",
}
View Source
var Kind_value = map[string]int32{
	"INVALID":              0,
	"INSTRUCTION_REQUEST":  1,
	"INSTRUCTION_RESPONSE": 2,
	"DATA_RECEIVED":        3,
	"DATA_SENT":            4,
	"LOG_ENTRIES":          5,
	"HEADER":               6,
	"FOOTER":               7,
}

Functions

This section is empty.

Types

type Entry

type Entry struct {
	Kind Kind `protobuf:"varint,1,opt,name=kind,enum=session.Kind" json:"kind,omitempty"`
	// Types that are valid to be assigned to Msg:
	//	*Entry_InstReq
	//	*Entry_InstResp
	//	*Entry_Elems
	//	*Entry_LogEntries
	//	*Entry_Header
	//	*Entry_Footer
	Msg       isEntry_Msg `protobuf_oneof:"msg"`
	Timestamp int64       `protobuf:"varint,2,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*Entry) Descriptor

func (*Entry) Descriptor() ([]byte, []int)

func (*Entry) GetElems

func (*Entry) GetFooter

func (m *Entry) GetFooter() *Footer

func (*Entry) GetHeader

func (m *Entry) GetHeader() *Header

func (*Entry) GetInstReq

func (*Entry) GetInstResp

func (*Entry) GetKind

func (m *Entry) GetKind() Kind

func (*Entry) GetLogEntries

func (*Entry) GetMsg

func (m *Entry) GetMsg() isEntry_Msg

func (*Entry) GetTimestamp

func (m *Entry) GetTimestamp() int64

func (*Entry) ProtoMessage

func (*Entry) ProtoMessage()

func (*Entry) Reset

func (m *Entry) Reset()

func (*Entry) String

func (m *Entry) String() string

func (*Entry) XXX_OneofFuncs

func (*Entry) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type EntryHeader

type EntryHeader struct {
	Len  int64 `protobuf:"varint,1,opt,name=len" json:"len,omitempty"`
	Kind Kind  `protobuf:"varint,2,opt,name=kind,enum=session.Kind" json:"kind,omitempty"`
}

func (*EntryHeader) Descriptor

func (*EntryHeader) Descriptor() ([]byte, []int)

func (*EntryHeader) GetKind

func (m *EntryHeader) GetKind() Kind

func (*EntryHeader) GetLen

func (m *EntryHeader) GetLen() int64

func (*EntryHeader) ProtoMessage

func (*EntryHeader) ProtoMessage()

func (*EntryHeader) Reset

func (m *EntryHeader) Reset()

func (*EntryHeader) String

func (m *EntryHeader) String() string

type Entry_Elems

type Entry_Elems struct {
	Elems *org_apache_beam_model_fn_execution_v1.Elements `protobuf:"bytes,1002,opt,name=elems,oneof"`
}

type Entry_Footer

type Entry_Footer struct {
	Footer *Footer `protobuf:"bytes,1005,opt,name=footer,oneof"`
}

type Entry_Header

type Entry_Header struct {
	Header *Header `protobuf:"bytes,1004,opt,name=header,oneof"`
}

type Entry_InstReq

type Entry_InstReq struct {
	InstReq *org_apache_beam_model_fn_execution_v1.InstructionRequest `protobuf:"bytes,1000,opt,name=inst_req,json=instReq,oneof"`
}

type Entry_InstResp

type Entry_InstResp struct {
	InstResp *org_apache_beam_model_fn_execution_v1.InstructionResponse `protobuf:"bytes,1001,opt,name=inst_resp,json=instResp,oneof"`
}

type Entry_LogEntries

type Entry_LogEntries struct {
	LogEntries *org_apache_beam_model_fn_execution_v1.LogEntry_List `protobuf:"bytes,1003,opt,name=log_entries,json=logEntries,oneof"`
}
type Footer struct {
}

func (*Footer) Descriptor

func (*Footer) Descriptor() ([]byte, []int)

func (*Footer) ProtoMessage

func (*Footer) ProtoMessage()

func (*Footer) Reset

func (m *Footer) Reset()

func (*Footer) String

func (m *Footer) String() string
type Header struct {
	Version    string `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	SdkVersion string `protobuf:"bytes,2,opt,name=sdk_version,json=sdkVersion" json:"sdk_version,omitempty"`
	MaxMsgLen  int64  `protobuf:"varint,3,opt,name=max_msg_len,json=maxMsgLen" json:"max_msg_len,omitempty"`
}

func (*Header) Descriptor

func (*Header) Descriptor() ([]byte, []int)

func (*Header) GetMaxMsgLen

func (m *Header) GetMaxMsgLen() int64

func (*Header) GetSdkVersion

func (m *Header) GetSdkVersion() string

func (*Header) GetVersion

func (m *Header) GetVersion() string

func (*Header) ProtoMessage

func (*Header) ProtoMessage()

func (*Header) Reset

func (m *Header) Reset()

func (*Header) String

func (m *Header) String() string

type Kind

type Kind int32
const (
	Kind_INVALID              Kind = 0
	Kind_INSTRUCTION_REQUEST  Kind = 1
	Kind_INSTRUCTION_RESPONSE Kind = 2
	Kind_DATA_RECEIVED        Kind = 3
	Kind_DATA_SENT            Kind = 4
	Kind_LOG_ENTRIES          Kind = 5
	Kind_HEADER               Kind = 6
	Kind_FOOTER               Kind = 7
)

func (Kind) EnumDescriptor

func (Kind) EnumDescriptor() ([]byte, []int)

func (Kind) String

func (x Kind) String() string

Source Files

Jump to

Keyboard shortcuts

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