beam: github.com/apache/beam/sdks/go/pkg/beam/core/runtime/graphx/v1 Index | Files

package v1

import "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/graphx/v1"

Package v1 is a generated protocol buffer package.

It is generated from these files:

v1.proto

It has these top-level messages:

Type
FullType
UserFn
DynFn
Fn
WindowFn
CustomCoder
MultiEdge
InjectPayload
TransformPayload

Index

Package Files

gen.go v1.pb.go

Variables

var MultiEdge_Inbound_InputKind_name = map[int32]string{
    0:  "INVALID",
    1:  "MAIN",
    2:  "SINGLETON",
    3:  "SLICE",
    4:  "MAP",
    5:  "MULTIMAP",
    6:  "ITER",
    7:  "REITER",
}
var MultiEdge_Inbound_InputKind_value = map[string]int32{
    "INVALID":   0,
    "MAIN":      1,
    "SINGLETON": 2,
    "SLICE":     3,
    "MAP":       4,
    "MULTIMAP":  5,
    "ITER":      6,
    "REITER":    7,
}
var Type_ChanDir_name = map[int32]string{
    0:  "RECV",
    1:  "SEND",
    2:  "BOTH",
}
var Type_ChanDir_value = map[string]int32{
    "RECV": 0,
    "SEND": 1,
    "BOTH": 2,
}
var Type_Kind_name = map[int32]string{
    0:  "INVALID",
    1:  "BOOL",
    2:  "INT",
    3:  "INT8",
    4:  "INT16",
    5:  "INT32",
    6:  "INT64",
    7:  "UINT",
    8:  "UINT8",
    9:  "UINT16",
    10: "UINT32",
    11: "UINT64",
    12: "STRING",
    13: "FLOAT32",
    14: "FLOAT64",
    20: "SLICE",
    21: "STRUCT",
    22: "FUNC",
    23: "CHAN",
    24: "PTR",
    25: "SPECIAL",
    26: "EXTERNAL",
}
var Type_Kind_value = map[string]int32{
    "INVALID":  0,
    "BOOL":     1,
    "INT":      2,
    "INT8":     3,
    "INT16":    4,
    "INT32":    5,
    "INT64":    6,
    "UINT":     7,
    "UINT8":    8,
    "UINT16":   9,
    "UINT32":   10,
    "UINT64":   11,
    "STRING":   12,
    "FLOAT32":  13,
    "FLOAT64":  14,
    "SLICE":    20,
    "STRUCT":   21,
    "FUNC":     22,
    "CHAN":     23,
    "PTR":      24,
    "SPECIAL":  25,
    "EXTERNAL": 26,
}
var Type_Special_name = map[int32]string{
    0:  "ILLEGAL",
    1:  "ERROR",
    2:  "CONTEXT",
    3:  "TYPE",
    10: "EVENTTIME",
    22: "WINDOW",
    11: "KV",
    13: "COGBK",
    14: "WINDOWEDVALUE",
    15: "T",
    16: "U",
    17: "V",
    18: "W",
    19: "X",
    20: "Y",
    21: "Z",
}
var Type_Special_value = map[string]int32{
    "ILLEGAL":       0,
    "ERROR":         1,
    "CONTEXT":       2,
    "TYPE":          3,
    "EVENTTIME":     10,
    "WINDOW":        22,
    "KV":            11,
    "COGBK":         13,
    "WINDOWEDVALUE": 14,
    "T":             15,
    "U":             16,
    "V":             17,
    "W":             18,
    "X":             19,
    "Y":             20,
    "Z":             21,
}

type CustomCoder Uses

type CustomCoder struct {
    // (Required) Name of the coder. For informational purposes only.
    Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
    // (Required) Concrete type being coded.
    Type *Type `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
    // (Required) Encoding function.
    Enc *UserFn `protobuf:"bytes,3,opt,name=enc" json:"enc,omitempty"`
    // (Required) Decoding function.
    Dec *UserFn `protobuf:"bytes,4,opt,name=dec" json:"dec,omitempty"`
}

CustomCoder

func (*CustomCoder) Descriptor Uses

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

func (*CustomCoder) GetDec Uses

func (m *CustomCoder) GetDec() *UserFn

func (*CustomCoder) GetEnc Uses

func (m *CustomCoder) GetEnc() *UserFn

func (*CustomCoder) GetName Uses

func (m *CustomCoder) GetName() string

func (*CustomCoder) GetType Uses

func (m *CustomCoder) GetType() *Type

func (*CustomCoder) ProtoMessage Uses

func (*CustomCoder) ProtoMessage()

func (*CustomCoder) Reset Uses

func (m *CustomCoder) Reset()

func (*CustomCoder) String Uses

func (m *CustomCoder) String() string

type DynFn Uses

type DynFn struct {
    // (Required) Name of the generated function.
    Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
    // (Required) Type of the generated function.
    Type *Type `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
    // (Required) Input to generator.
    Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
    // (Required) Symbol name of generator (of type []byte ->
    // []reflect.Value -> []reflect.Value).
    Gen string `protobuf:"bytes,4,opt,name=gen" json:"gen,omitempty"`
}

DynFn represents a serialized function generator.

func (*DynFn) Descriptor Uses

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

func (*DynFn) GetData Uses

func (m *DynFn) GetData() []byte

func (*DynFn) GetGen Uses

func (m *DynFn) GetGen() string

func (*DynFn) GetName Uses

func (m *DynFn) GetName() string

func (*DynFn) GetType Uses

func (m *DynFn) GetType() *Type

func (*DynFn) ProtoMessage Uses

func (*DynFn) ProtoMessage()

func (*DynFn) Reset Uses

func (m *DynFn) Reset()

func (*DynFn) String Uses

func (m *DynFn) String() string

type Fn Uses

type Fn struct {
    // (Optional) Function reference.
    Fn  *UserFn `protobuf:"bytes,1,opt,name=fn" json:"fn,omitempty"`
    // (Optional) Struct type.
    Type *Type `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
    // (Optional) JSON-serialized value, if struct.
    Opt string `protobuf:"bytes,3,opt,name=opt" json:"opt,omitempty"`
    // (Optional) Function generator, if dynamic function.
    Dynfn *DynFn `protobuf:"bytes,4,opt,name=dynfn" json:"dynfn,omitempty"`
}

Fn represents a serialized function reference or struct.

func (*Fn) Descriptor Uses

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

func (*Fn) GetDynfn Uses

func (m *Fn) GetDynfn() *DynFn

func (*Fn) GetFn Uses

func (m *Fn) GetFn() *UserFn

func (*Fn) GetOpt Uses

func (m *Fn) GetOpt() string

func (*Fn) GetType Uses

func (m *Fn) GetType() *Type

func (*Fn) ProtoMessage Uses

func (*Fn) ProtoMessage()

func (*Fn) Reset Uses

func (m *Fn) Reset()

func (*Fn) String Uses

func (m *Fn) String() string

type FullType Uses

type FullType struct {
    Type       *Type       `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
    Components []*FullType `protobuf:"bytes,2,rep,name=components" json:"components,omitempty"`
}

FullType represents a serialized typex.FullType

func (*FullType) Descriptor Uses

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

func (*FullType) GetComponents Uses

func (m *FullType) GetComponents() []*FullType

func (*FullType) GetType Uses

func (m *FullType) GetType() *Type

func (*FullType) ProtoMessage Uses

func (*FullType) ProtoMessage()

func (*FullType) Reset Uses

func (m *FullType) Reset()

func (*FullType) String Uses

func (m *FullType) String() string

type InjectPayload Uses

type InjectPayload struct {
    N int32 `protobuf:"varint,1,opt,name=n" json:"n,omitempty"`
}

InjectPayload is the payload for the built-in Inject function.

func (*InjectPayload) Descriptor Uses

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

func (*InjectPayload) GetN Uses

func (m *InjectPayload) GetN() int32

func (*InjectPayload) ProtoMessage Uses

func (*InjectPayload) ProtoMessage()

func (*InjectPayload) Reset Uses

func (m *InjectPayload) Reset()

func (*InjectPayload) String Uses

func (m *InjectPayload) String() string

type MultiEdge Uses

type MultiEdge struct {
    Fn       *Fn                   `protobuf:"bytes,1,opt,name=fn" json:"fn,omitempty"`
    Opcode   string                `protobuf:"bytes,4,opt,name=opcode" json:"opcode,omitempty"`
    WindowFn *WindowFn             `protobuf:"bytes,5,opt,name=window_fn,json=windowFn" json:"window_fn,omitempty"`
    Inbound  []*MultiEdge_Inbound  `protobuf:"bytes,2,rep,name=inbound" json:"inbound,omitempty"`
    Outbound []*MultiEdge_Outbound `protobuf:"bytes,3,rep,name=outbound" json:"outbound,omitempty"`
}

MultiEdge represents a partly-serialized MultiEdge. It does not include node information, because runners manipulate the graph structure.

func (*MultiEdge) Descriptor Uses

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

func (*MultiEdge) GetFn Uses

func (m *MultiEdge) GetFn() *Fn

func (*MultiEdge) GetInbound Uses

func (m *MultiEdge) GetInbound() []*MultiEdge_Inbound

func (*MultiEdge) GetOpcode Uses

func (m *MultiEdge) GetOpcode() string

func (*MultiEdge) GetOutbound Uses

func (m *MultiEdge) GetOutbound() []*MultiEdge_Outbound

func (*MultiEdge) GetWindowFn Uses

func (m *MultiEdge) GetWindowFn() *WindowFn

func (*MultiEdge) ProtoMessage Uses

func (*MultiEdge) ProtoMessage()

func (*MultiEdge) Reset Uses

func (m *MultiEdge) Reset()

func (*MultiEdge) String Uses

func (m *MultiEdge) String() string

type MultiEdge_Inbound Uses

type MultiEdge_Inbound struct {
    Kind MultiEdge_Inbound_InputKind `protobuf:"varint,1,opt,name=kind,enum=v1.MultiEdge_Inbound_InputKind" json:"kind,omitempty"`
    Type *FullType                   `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
}

func (*MultiEdge_Inbound) Descriptor Uses

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

func (*MultiEdge_Inbound) GetKind Uses

func (m *MultiEdge_Inbound) GetKind() MultiEdge_Inbound_InputKind

func (*MultiEdge_Inbound) GetType Uses

func (m *MultiEdge_Inbound) GetType() *FullType

func (*MultiEdge_Inbound) ProtoMessage Uses

func (*MultiEdge_Inbound) ProtoMessage()

func (*MultiEdge_Inbound) Reset Uses

func (m *MultiEdge_Inbound) Reset()

func (*MultiEdge_Inbound) String Uses

func (m *MultiEdge_Inbound) String() string

type MultiEdge_Inbound_InputKind Uses

type MultiEdge_Inbound_InputKind int32
const (
    MultiEdge_Inbound_INVALID   MultiEdge_Inbound_InputKind = 0
    MultiEdge_Inbound_MAIN      MultiEdge_Inbound_InputKind = 1
    MultiEdge_Inbound_SINGLETON MultiEdge_Inbound_InputKind = 2
    MultiEdge_Inbound_SLICE     MultiEdge_Inbound_InputKind = 3
    MultiEdge_Inbound_MAP       MultiEdge_Inbound_InputKind = 4
    MultiEdge_Inbound_MULTIMAP  MultiEdge_Inbound_InputKind = 5
    MultiEdge_Inbound_ITER      MultiEdge_Inbound_InputKind = 6
    MultiEdge_Inbound_REITER    MultiEdge_Inbound_InputKind = 7
)

func (MultiEdge_Inbound_InputKind) EnumDescriptor Uses

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

func (MultiEdge_Inbound_InputKind) String Uses

func (x MultiEdge_Inbound_InputKind) String() string

type MultiEdge_Outbound Uses

type MultiEdge_Outbound struct {
    Type *FullType `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
}

func (*MultiEdge_Outbound) Descriptor Uses

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

func (*MultiEdge_Outbound) GetType Uses

func (m *MultiEdge_Outbound) GetType() *FullType

func (*MultiEdge_Outbound) ProtoMessage Uses

func (*MultiEdge_Outbound) ProtoMessage()

func (*MultiEdge_Outbound) Reset Uses

func (m *MultiEdge_Outbound) Reset()

func (*MultiEdge_Outbound) String Uses

func (m *MultiEdge_Outbound) String() string

type TransformPayload Uses

type TransformPayload struct {
    // urn is included here. It is also present in the model pipeline, but
    // not when submitting through Dataflow yet.
    Urn    string         `protobuf:"bytes,1,opt,name=urn" json:"urn,omitempty"`
    Edge   *MultiEdge     `protobuf:"bytes,2,opt,name=edge" json:"edge,omitempty"`
    Inject *InjectPayload `protobuf:"bytes,3,opt,name=inject" json:"inject,omitempty"`
}

TransformPayload represents the full payload for transforms, both user defined and built-in.

func (*TransformPayload) Descriptor Uses

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

func (*TransformPayload) GetEdge Uses

func (m *TransformPayload) GetEdge() *MultiEdge

func (*TransformPayload) GetInject Uses

func (m *TransformPayload) GetInject() *InjectPayload

func (*TransformPayload) GetUrn Uses

func (m *TransformPayload) GetUrn() string

func (*TransformPayload) ProtoMessage Uses

func (*TransformPayload) ProtoMessage()

func (*TransformPayload) Reset Uses

func (m *TransformPayload) Reset()

func (*TransformPayload) String Uses

func (m *TransformPayload) String() string

type Type Uses

type Type struct {
    // (Required) Type kind.
    Kind Type_Kind `protobuf:"varint,1,opt,name=kind,enum=v1.Type_Kind" json:"kind,omitempty"`
    // (Optional) Element type (if SLICE, PTR or CHAN)
    Element *Type `protobuf:"bytes,2,opt,name=element" json:"element,omitempty"`
    // (Optional) Fields (if STRUCT).
    Fields []*Type_StructField `protobuf:"bytes,3,rep,name=fields" json:"fields,omitempty"`
    // (Optional) Parameter types (if FUNC).
    ParameterTypes []*Type `protobuf:"bytes,4,rep,name=parameter_types,json=parameterTypes" json:"parameter_types,omitempty"`
    // (Optional) Return types (if FUNC).
    ReturnTypes []*Type `protobuf:"bytes,5,rep,name=return_types,json=returnTypes" json:"return_types,omitempty"`
    // (Optional) Is variadic (if FUNC).
    IsVariadic bool `protobuf:"varint,6,opt,name=is_variadic,json=isVariadic" json:"is_variadic,omitempty"`
    // (Optional) Channel direction (if CHAN).
    ChanDir Type_ChanDir `protobuf:"varint,7,opt,name=chan_dir,json=chanDir,enum=v1.Type_ChanDir" json:"chan_dir,omitempty"`
    // (Optional) Special type (if SPECIAL)
    Special Type_Special `protobuf:"varint,8,opt,name=special,enum=v1.Type_Special" json:"special,omitempty"`
    // (Optional) Key for external types.
    // External types are types that are not directly serialized using
    // the types above, but rather indirectly serialized.  The wire format
    // holds a lookup key into a registry to reify the types in a worker from a
    // registry. The main usage of external serialization is to preserve
    // methods attached to types.
    ExternalKey string `protobuf:"bytes,9,opt,name=external_key,json=externalKey" json:"external_key,omitempty"`
}

Type represents a serializable reflect.Type.

func (*Type) Descriptor Uses

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

func (*Type) GetChanDir Uses

func (m *Type) GetChanDir() Type_ChanDir

func (*Type) GetElement Uses

func (m *Type) GetElement() *Type

func (*Type) GetExternalKey Uses

func (m *Type) GetExternalKey() string

func (*Type) GetFields Uses

func (m *Type) GetFields() []*Type_StructField

func (*Type) GetIsVariadic Uses

func (m *Type) GetIsVariadic() bool

func (*Type) GetKind Uses

func (m *Type) GetKind() Type_Kind

func (*Type) GetParameterTypes Uses

func (m *Type) GetParameterTypes() []*Type

func (*Type) GetReturnTypes Uses

func (m *Type) GetReturnTypes() []*Type

func (*Type) GetSpecial Uses

func (m *Type) GetSpecial() Type_Special

func (*Type) ProtoMessage Uses

func (*Type) ProtoMessage()

func (*Type) Reset Uses

func (m *Type) Reset()

func (*Type) String Uses

func (m *Type) String() string

type Type_ChanDir Uses

type Type_ChanDir int32

ChanDir matches reflect.ChanDir.

const (
    Type_RECV Type_ChanDir = 0
    Type_SEND Type_ChanDir = 1
    Type_BOTH Type_ChanDir = 2
)

func (Type_ChanDir) EnumDescriptor Uses

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

func (Type_ChanDir) String Uses

func (x Type_ChanDir) String() string

type Type_Kind Uses

type Type_Kind int32

Kind is mostly identical to reflect.TypeKind, expect we handle certain types specially, such as "error".

const (
    Type_INVALID Type_Kind = 0
    // Primitive.
    Type_BOOL    Type_Kind = 1
    Type_INT     Type_Kind = 2
    Type_INT8    Type_Kind = 3
    Type_INT16   Type_Kind = 4
    Type_INT32   Type_Kind = 5
    Type_INT64   Type_Kind = 6
    Type_UINT    Type_Kind = 7
    Type_UINT8   Type_Kind = 8
    Type_UINT16  Type_Kind = 9
    Type_UINT32  Type_Kind = 10
    Type_UINT64  Type_Kind = 11
    Type_STRING  Type_Kind = 12
    Type_FLOAT32 Type_Kind = 13
    Type_FLOAT64 Type_Kind = 14
    // Non-primitive types.
    Type_SLICE    Type_Kind = 20
    Type_STRUCT   Type_Kind = 21
    Type_FUNC     Type_Kind = 22
    Type_CHAN     Type_Kind = 23
    Type_PTR      Type_Kind = 24
    Type_SPECIAL  Type_Kind = 25
    Type_EXTERNAL Type_Kind = 26
)

func (Type_Kind) EnumDescriptor Uses

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

func (Type_Kind) String Uses

func (x Type_Kind) String() string

type Type_Special Uses

type Type_Special int32
const (
    Type_ILLEGAL Type_Special = 0
    // Go
    Type_ERROR   Type_Special = 1
    Type_CONTEXT Type_Special = 2
    Type_TYPE    Type_Special = 3
    // Beam
    Type_EVENTTIME     Type_Special = 10
    Type_WINDOW        Type_Special = 22
    Type_KV            Type_Special = 11
    Type_COGBK         Type_Special = 13
    Type_WINDOWEDVALUE Type_Special = 14
    Type_T             Type_Special = 15
    Type_U             Type_Special = 16
    Type_V             Type_Special = 17
    Type_W             Type_Special = 18
    Type_X             Type_Special = 19
    Type_Y             Type_Special = 20
    Type_Z             Type_Special = 21
)

func (Type_Special) EnumDescriptor Uses

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

func (Type_Special) String Uses

func (x Type_Special) String() string

type Type_StructField Uses

type Type_StructField struct {
    Name      string  `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
    PkgPath   string  `protobuf:"bytes,2,opt,name=pkg_path,json=pkgPath" json:"pkg_path,omitempty"`
    Type      *Type   `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
    Tag       string  `protobuf:"bytes,4,opt,name=tag" json:"tag,omitempty"`
    Offset    int64   `protobuf:"varint,5,opt,name=offset" json:"offset,omitempty"`
    Index     []int32 `protobuf:"varint,6,rep,packed,name=index" json:"index,omitempty"`
    Anonymous bool    `protobuf:"varint,7,opt,name=anonymous" json:"anonymous,omitempty"`
}

StructField matches reflect.StructField.

func (*Type_StructField) Descriptor Uses

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

func (*Type_StructField) GetAnonymous Uses

func (m *Type_StructField) GetAnonymous() bool

func (*Type_StructField) GetIndex Uses

func (m *Type_StructField) GetIndex() []int32

func (*Type_StructField) GetName Uses

func (m *Type_StructField) GetName() string

func (*Type_StructField) GetOffset Uses

func (m *Type_StructField) GetOffset() int64

func (*Type_StructField) GetPkgPath Uses

func (m *Type_StructField) GetPkgPath() string

func (*Type_StructField) GetTag Uses

func (m *Type_StructField) GetTag() string

func (*Type_StructField) GetType Uses

func (m *Type_StructField) GetType() *Type

func (*Type_StructField) ProtoMessage Uses

func (*Type_StructField) ProtoMessage()

func (*Type_StructField) Reset Uses

func (m *Type_StructField) Reset()

func (*Type_StructField) String Uses

func (m *Type_StructField) String() string

type UserFn Uses

type UserFn struct {
    // (Required) Symbol name of function.
    Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
    // (Required) Function type.
    Type *Type `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
}

UserFn represents a serialized function reference. The implementation is notably not serialized and must be present (and somehow discoverable from the symbol name) on the decoding side.

func (*UserFn) Descriptor Uses

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

func (*UserFn) GetName Uses

func (m *UserFn) GetName() string

func (*UserFn) GetType Uses

func (m *UserFn) GetType() *Type

func (*UserFn) ProtoMessage Uses

func (*UserFn) ProtoMessage()

func (*UserFn) Reset Uses

func (m *UserFn) Reset()

func (*UserFn) String Uses

func (m *UserFn) String() string

type WindowFn Uses

type WindowFn struct {
    Kind     string `protobuf:"bytes,1,opt,name=kind" json:"kind,omitempty"`
    SizeMs   int64  `protobuf:"varint,2,opt,name=size_ms,json=sizeMs" json:"size_ms,omitempty"`
    PeriodMs int64  `protobuf:"varint,3,opt,name=period_ms,json=periodMs" json:"period_ms,omitempty"`
    GapMs    int64  `protobuf:"varint,4,opt,name=gap_ms,json=gapMs" json:"gap_ms,omitempty"`
}

WindowFn represents a window fn.

func (*WindowFn) Descriptor Uses

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

func (*WindowFn) GetGapMs Uses

func (m *WindowFn) GetGapMs() int64

func (*WindowFn) GetKind Uses

func (m *WindowFn) GetKind() string

func (*WindowFn) GetPeriodMs Uses

func (m *WindowFn) GetPeriodMs() int64

func (*WindowFn) GetSizeMs Uses

func (m *WindowFn) GetSizeMs() int64

func (*WindowFn) ProtoMessage Uses

func (*WindowFn) ProtoMessage()

func (*WindowFn) Reset Uses

func (m *WindowFn) Reset()

func (*WindowFn) String Uses

func (m *WindowFn) String() string

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