v1

package
v2.27.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2021 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Overview

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

Constants

This section is empty.

Variables

View Source 
var MultiEdge_Inbound_InputKind_name = map[int32]string{
	0: "INVALID",
	1: "MAIN",
	2: "SINGLETON",
	3: "SLICE",
	4: "MAP",
	5: "MULTIMAP",
	6: "ITER",
	7: "REITER",
}
View Source 
var MultiEdge_Inbound_InputKind_value = map[string]int32{
	"INVALID":   0,
	"MAIN":      1,
	"SINGLETON": 2,
	"SLICE":     3,
	"MAP":       4,
	"MULTIMAP":  5,
	"ITER":      6,
	"REITER":    7,
}
View Source 
var Type_ChanDir_name = map[int32]string{
	0: "RECV",
	1: "SEND",
	2: "BOTH",
}
View Source 
var Type_ChanDir_value = map[string]int32{
	"RECV": 0,
	"SEND": 1,
	"BOTH": 2,
}
View Source 
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",
}
View Source 
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,
}
View Source 
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",
}
View Source 
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,
}

Functions

This section is empty.

Types

type CustomCoder 

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 

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

func (*CustomCoder) GetDec 

func (m *CustomCoder) GetDec() *UserFn

func (*CustomCoder) GetEnc 

func (m *CustomCoder) GetEnc() *UserFn

func (*CustomCoder) GetName 

func (m *CustomCoder) GetName() string

func (*CustomCoder) GetType 

func (m *CustomCoder) GetType() *Type

func (*CustomCoder) ProtoMessage 

func (*CustomCoder) ProtoMessage()

func (*CustomCoder) Reset 

func (m *CustomCoder) Reset()

func (*CustomCoder) String 

func (m *CustomCoder) String() string

type DynFn 

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 

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

func (*DynFn) GetData 

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

func (*DynFn) GetGen 

func (m *DynFn) GetGen() string

func (*DynFn) GetName 

func (m *DynFn) GetName() string

func (*DynFn) GetType 

func (m *DynFn) GetType() *Type

func (*DynFn) ProtoMessage 

func (*DynFn) ProtoMessage()

func (*DynFn) Reset 

func (m *DynFn) Reset()

func (*DynFn) String 

func (m *DynFn) String() string

type Fn 

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 

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

func (*Fn) GetDynfn 

func (m *Fn) GetDynfn() *DynFn

func (*Fn) GetFn 

func (m *Fn) GetFn() *UserFn

func (*Fn) GetOpt 

func (m *Fn) GetOpt() string

func (*Fn) GetType 

func (m *Fn) GetType() *Type

func (*Fn) ProtoMessage 

func (*Fn) ProtoMessage()

func (*Fn) Reset 

func (m *Fn) Reset()

func (*Fn) String 

func (m *Fn) String() string

type FullType 

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 

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

func (*FullType) GetComponents 

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

func (*FullType) GetType 

func (m *FullType) GetType() *Type

func (*FullType) ProtoMessage 

func (*FullType) ProtoMessage()

func (*FullType) Reset 

func (m *FullType) Reset()

func (*FullType) String 

func (m *FullType) String() string

type InjectPayload 

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 

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

func (*InjectPayload) GetN 

func (m *InjectPayload) GetN() int32

func (*InjectPayload) ProtoMessage 

func (*InjectPayload) ProtoMessage()

func (*InjectPayload) Reset 

func (m *InjectPayload) Reset()

func (*InjectPayload) String 

func (m *InjectPayload) String() string

type MultiEdge 

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 

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

func (*MultiEdge) GetFn 

func (m *MultiEdge) GetFn() *Fn

func (*MultiEdge) GetInbound 

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

func (*MultiEdge) GetOpcode 

func (m *MultiEdge) GetOpcode() string

func (*MultiEdge) GetOutbound 

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

func (*MultiEdge) GetWindowFn 

func (m *MultiEdge) GetWindowFn() *WindowFn

func (*MultiEdge) ProtoMessage 

func (*MultiEdge) ProtoMessage()

func (*MultiEdge) Reset 

func (m *MultiEdge) Reset()

func (*MultiEdge) String 

func (m *MultiEdge) String() string

type MultiEdge_Inbound 

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 

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

func (*MultiEdge_Inbound) GetKind 

func (m *MultiEdge_Inbound) GetKind() MultiEdge_Inbound_InputKind

func (*MultiEdge_Inbound) GetType 

func (m *MultiEdge_Inbound) GetType() *FullType

func (*MultiEdge_Inbound) ProtoMessage 

func (*MultiEdge_Inbound) ProtoMessage()

func (*MultiEdge_Inbound) Reset 

func (m *MultiEdge_Inbound) Reset()

func (*MultiEdge_Inbound) String 

func (m *MultiEdge_Inbound) String() string

type MultiEdge_Inbound_InputKind 

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 

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

func (MultiEdge_Inbound_InputKind) String 

func (x MultiEdge_Inbound_InputKind) String() string

type MultiEdge_Outbound 

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

func (*MultiEdge_Outbound) Descriptor 

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

func (*MultiEdge_Outbound) GetType 

func (m *MultiEdge_Outbound) GetType() *FullType

func (*MultiEdge_Outbound) ProtoMessage 

func (*MultiEdge_Outbound) ProtoMessage()

func (*MultiEdge_Outbound) Reset 

func (m *MultiEdge_Outbound) Reset()

func (*MultiEdge_Outbound) String 

func (m *MultiEdge_Outbound) String() string

type TransformPayload 

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 

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

func (*TransformPayload) GetEdge 

func (m *TransformPayload) GetEdge() *MultiEdge

func (*TransformPayload) GetInject 

func (m *TransformPayload) GetInject() *InjectPayload

func (*TransformPayload) GetUrn 

func (m *TransformPayload) GetUrn() string

func (*TransformPayload) ProtoMessage 

func (*TransformPayload) ProtoMessage()

func (*TransformPayload) Reset 

func (m *TransformPayload) Reset()

func (*TransformPayload) String 

func (m *TransformPayload) String() string

type Type 

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 

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

func (*Type) GetChanDir 

func (m *Type) GetChanDir() Type_ChanDir

func (*Type) GetElement 

func (m *Type) GetElement() *Type

func (*Type) GetExternalKey 

func (m *Type) GetExternalKey() string

func (*Type) GetFields 

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

func (*Type) GetIsVariadic 

func (m *Type) GetIsVariadic() bool

func (*Type) GetKind 

func (m *Type) GetKind() Type_Kind

func (*Type) GetParameterTypes 

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

func (*Type) GetReturnTypes 

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

func (*Type) GetSpecial 

func (m *Type) GetSpecial() Type_Special

func (*Type) ProtoMessage 

func (*Type) ProtoMessage()

func (*Type) Reset 

func (m *Type) Reset()

func (*Type) String 

func (m *Type) String() string

type Type_ChanDir 

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 

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

func (Type_ChanDir) String 

func (x Type_ChanDir) String() string

type Type_Kind 

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 

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

func (Type_Kind) String 

func (x Type_Kind) String() string

type Type_Special 

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 

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

func (Type_Special) String 

func (x Type_Special) String() string

type Type_StructField 

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 

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

func (*Type_StructField) GetAnonymous 

func (m *Type_StructField) GetAnonymous() bool

func (*Type_StructField) GetIndex 

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

func (*Type_StructField) GetName 

func (m *Type_StructField) GetName() string

func (*Type_StructField) GetOffset 

func (m *Type_StructField) GetOffset() int64

func (*Type_StructField) GetPkgPath 

func (m *Type_StructField) GetPkgPath() string

func (*Type_StructField) GetTag 

func (m *Type_StructField) GetTag() string

func (*Type_StructField) GetType 

func (m *Type_StructField) GetType() *Type

func (*Type_StructField) ProtoMessage 

func (*Type_StructField) ProtoMessage()

func (*Type_StructField) Reset 

func (m *Type_StructField) Reset()

func (*Type_StructField) String 

func (m *Type_StructField) String() string

type UserFn 

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 

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

func (*UserFn) GetName 

func (m *UserFn) GetName() string

func (*UserFn) GetType 

func (m *UserFn) GetType() *Type

func (*UserFn) ProtoMessage 

func (*UserFn) ProtoMessage()

func (*UserFn) Reset 

func (m *UserFn) Reset()

func (*UserFn) String 

func (m *UserFn) String() string

type WindowFn 

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 

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

func (*WindowFn) GetGapMs 

func (m *WindowFn) GetGapMs() int64

func (*WindowFn) GetKind 

func (m *WindowFn) GetKind() string

func (*WindowFn) GetPeriodMs 

func (m *WindowFn) GetPeriodMs() int64

func (*WindowFn) GetSizeMs 

func (m *WindowFn) GetSizeMs() int64

func (*WindowFn) ProtoMessage 

func (*WindowFn) ProtoMessage()

func (*WindowFn) Reset 

func (m *WindowFn) Reset()

func (*WindowFn) String 

func (m *WindowFn) 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.