beam: github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/session Index | Files

package session

import "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/harness/session"

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

Package Files

session.pb.go

Variables

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

type Entry Uses

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 Uses

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

func (*Entry) GetElems Uses

func (m *Entry) GetElems() *org_apache_beam_model_fn_execution_v1.Elements

func (*Entry) GetFooter Uses

func (m *Entry) GetFooter() *Footer

func (*Entry) GetHeader Uses

func (m *Entry) GetHeader() *Header

func (*Entry) GetInstReq Uses

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

func (*Entry) GetInstResp Uses

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

func (*Entry) GetKind Uses

func (m *Entry) GetKind() Kind

func (*Entry) GetLogEntries Uses

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

func (*Entry) GetMsg Uses

func (m *Entry) GetMsg() isEntry_Msg

func (*Entry) GetTimestamp Uses

func (m *Entry) GetTimestamp() int64

func (*Entry) ProtoMessage Uses

func (*Entry) ProtoMessage()

func (*Entry) Reset Uses

func (m *Entry) Reset()

func (*Entry) String Uses

func (m *Entry) String() string

func (*Entry) XXX_OneofFuncs Uses

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 Uses

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 Uses

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

func (*EntryHeader) GetKind Uses

func (m *EntryHeader) GetKind() Kind

func (*EntryHeader) GetLen Uses

func (m *EntryHeader) GetLen() int64

func (*EntryHeader) ProtoMessage Uses

func (*EntryHeader) ProtoMessage()

func (*EntryHeader) Reset Uses

func (m *EntryHeader) Reset()

func (*EntryHeader) String Uses

func (m *EntryHeader) String() string

type Entry_Elems Uses

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

type Entry_Footer Uses

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

type Entry_Header Uses

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

type Entry_InstReq Uses

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 Uses

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 Uses

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 Uses

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

func (*Footer) ProtoMessage Uses

func (*Footer) ProtoMessage()

func (*Footer) Reset Uses

func (m *Footer) Reset()

func (*Footer) String Uses

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 Uses

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

func (*Header) GetMaxMsgLen Uses

func (m *Header) GetMaxMsgLen() int64

func (*Header) GetSdkVersion Uses

func (m *Header) GetSdkVersion() string

func (*Header) GetVersion Uses

func (m *Header) GetVersion() string

func (*Header) ProtoMessage Uses

func (*Header) ProtoMessage()

func (*Header) Reset Uses

func (m *Header) Reset()

func (*Header) String Uses

func (m *Header) String() string

type Kind Uses

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 Uses

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

func (Kind) String Uses

func (x Kind) String() string

Package session imports 4 packages (graph) and is imported by 2 packages. Updated 2018-07-25. Refresh now. Tools for package owners.