session

package
v2.28.0+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: 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 (m *Entry) GetElems() *org_apache_beam_model_fn_execution_v1.Elements

func (*Entry) GetFooter 

func (m *Entry) GetFooter() *Footer

func (*Entry) GetHeader 

func (m *Entry) GetHeader() *Header

func (*Entry) GetInstReq 

func (m *Entry) GetInstReq() *org_apache_beam_model_fn_execution_v1.InstructionRequest

func (*Entry) GetInstResp 

func (m *Entry) GetInstResp() *org_apache_beam_model_fn_execution_v1.InstructionResponse

func (*Entry) GetKind 

func (m *Entry) GetKind() Kind

func (*Entry) GetLogEntries 

func (m *Entry) GetLogEntries() *org_apache_beam_model_fn_execution_v1.LogEntry_List

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.