v1

package
v2.32.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Aug 10, 2021 License: Apache-2.0, BSD-3-Clause, MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for Type_Kind.

View Source 
var (
	Type_ChanDir_name = map[int32]string{
		0: "RECV",
		1: "SEND",
		2: "BOTH",
	}
	Type_ChanDir_value = map[string]int32{
		"RECV": 0,
		"SEND": 1,
		"BOTH": 2,
	}
)

Enum value maps for Type_ChanDir.

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

Enum value maps for Type_Special.

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",
	}
	MultiEdge_Inbound_InputKind_value = map[string]int32{
		"INVALID":   0,
		"MAIN":      1,
		"SINGLETON": 2,
		"SLICE":     3,
		"MAP":       4,
		"MULTIMAP":  5,
		"ITER":      6,
		"REITER":    7,
	}
)

Enum value maps for MultiEdge_Inbound_InputKind.

View Source 
var File_v1_proto protoreflect.FileDescriptor

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,proto3" json:"name,omitempty"`
	// (Required) Concrete type being coded.
	Type *Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// (Required) Encoding function.
	Enc *UserFn `protobuf:"bytes,3,opt,name=enc,proto3" json:"enc,omitempty"`
	// (Required) Decoding function.
	Dec *UserFn `protobuf:"bytes,4,opt,name=dec,proto3" json:"dec,omitempty"`
	// contains filtered or unexported fields
}

CustomCoder

func (*CustomCoder) Descriptor deprecated 

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

Deprecated: Use CustomCoder.ProtoReflect.Descriptor instead.

func (*CustomCoder) GetDec 

func (x *CustomCoder) GetDec() *UserFn

func (*CustomCoder) GetEnc 

func (x *CustomCoder) GetEnc() *UserFn

func (*CustomCoder) GetName 

func (x *CustomCoder) GetName() string

func (*CustomCoder) GetType 

func (x *CustomCoder) GetType() *Type

func (*CustomCoder) ProtoMessage 

func (*CustomCoder) ProtoMessage()

func (*CustomCoder) ProtoReflect 

func (x *CustomCoder) ProtoReflect() protoreflect.Message

func (*CustomCoder) Reset 

func (x *CustomCoder) Reset()

func (*CustomCoder) String 

func (x *CustomCoder) String() string

type DynFn 

type DynFn struct {

	// (Required) Name of the generated function.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// (Required) Type of the generated function.
	Type *Type `protobuf:"bytes,2,opt,name=type,proto3" 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,proto3" json:"gen,omitempty"`
	// contains filtered or unexported fields
}

DynFn represents a serialized function generator.

func (*DynFn) Descriptor deprecated 

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

Deprecated: Use DynFn.ProtoReflect.Descriptor instead.

func (*DynFn) GetData 

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

func (*DynFn) GetGen 

func (x *DynFn) GetGen() string

func (*DynFn) GetName 

func (x *DynFn) GetName() string

func (*DynFn) GetType 

func (x *DynFn) GetType() *Type

func (*DynFn) ProtoMessage 

func (*DynFn) ProtoMessage()

func (*DynFn) ProtoReflect 

func (x *DynFn) ProtoReflect() protoreflect.Message

func (*DynFn) Reset 

func (x *DynFn) Reset()

func (*DynFn) String 

func (x *DynFn) String() string

type Fn 

type Fn struct {

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

Fn represents a serialized function reference or struct.

func (*Fn) Descriptor deprecated 

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

Deprecated: Use Fn.ProtoReflect.Descriptor instead.

func (*Fn) GetDynfn 

func (x *Fn) GetDynfn() *DynFn

func (*Fn) GetFn 

func (x *Fn) GetFn() *UserFn

func (*Fn) GetOpt 

func (x *Fn) GetOpt() string

func (*Fn) GetType 

func (x *Fn) GetType() *Type

func (*Fn) ProtoMessage 

func (*Fn) ProtoMessage()

func (*Fn) ProtoReflect 

func (x *Fn) ProtoReflect() protoreflect.Message

func (*Fn) Reset 

func (x *Fn) Reset()

func (*Fn) String 

func (x *Fn) String() string

type FullType 

type FullType struct {
	Type       *Type       `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Components []*FullType `protobuf:"bytes,2,rep,name=components,proto3" json:"components,omitempty"`
	// contains filtered or unexported fields
}

FullType represents a serialized typex.FullType

func (*FullType) Descriptor deprecated 

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

Deprecated: Use FullType.ProtoReflect.Descriptor instead.

func (*FullType) GetComponents 

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

func (*FullType) GetType 

func (x *FullType) GetType() *Type

func (*FullType) ProtoMessage 

func (*FullType) ProtoMessage()

func (*FullType) ProtoReflect 

func (x *FullType) ProtoReflect() protoreflect.Message

func (*FullType) Reset 

func (x *FullType) Reset()

func (*FullType) String 

func (x *FullType) String() string

type InjectPayload 

type InjectPayload struct {
	N int32 `protobuf:"varint,1,opt,name=n,proto3" json:"n,omitempty"`
	// contains filtered or unexported fields
}

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

func (*InjectPayload) Descriptor deprecated 

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

Deprecated: Use InjectPayload.ProtoReflect.Descriptor instead.

func (*InjectPayload) GetN 

func (x *InjectPayload) GetN() int32

func (*InjectPayload) ProtoMessage 

func (*InjectPayload) ProtoMessage()

func (*InjectPayload) ProtoReflect 

func (x *InjectPayload) ProtoReflect() protoreflect.Message

func (*InjectPayload) Reset 

func (x *InjectPayload) Reset()

func (*InjectPayload) String 

func (x *InjectPayload) String() string

type MultiEdge 

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

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

func (*MultiEdge) Descriptor deprecated 

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

Deprecated: Use MultiEdge.ProtoReflect.Descriptor instead.

func (*MultiEdge) GetFn 

func (x *MultiEdge) GetFn() *Fn

func (*MultiEdge) GetInbound 

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

func (*MultiEdge) GetOpcode 

func (x *MultiEdge) GetOpcode() string

func (*MultiEdge) GetOutbound 

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

func (*MultiEdge) GetWindowFn 

func (x *MultiEdge) GetWindowFn() *WindowFn

func (*MultiEdge) ProtoMessage 

func (*MultiEdge) ProtoMessage()

func (*MultiEdge) ProtoReflect 

func (x *MultiEdge) ProtoReflect() protoreflect.Message

func (*MultiEdge) Reset 

func (x *MultiEdge) Reset()

func (*MultiEdge) String 

func (x *MultiEdge) String() string

type MultiEdge_Inbound 

type MultiEdge_Inbound struct {
	Kind MultiEdge_Inbound_InputKind `` /* 151-byte string literal not displayed */
	Type *FullType                   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiEdge_Inbound) Descriptor deprecated 

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

Deprecated: Use MultiEdge_Inbound.ProtoReflect.Descriptor instead.

func (*MultiEdge_Inbound) GetKind 

func (x *MultiEdge_Inbound) GetKind() MultiEdge_Inbound_InputKind

func (*MultiEdge_Inbound) GetType 

func (x *MultiEdge_Inbound) GetType() *FullType

func (*MultiEdge_Inbound) ProtoMessage 

func (*MultiEdge_Inbound) ProtoMessage()

func (*MultiEdge_Inbound) ProtoReflect 

func (x *MultiEdge_Inbound) ProtoReflect() protoreflect.Message

func (*MultiEdge_Inbound) Reset 

func (x *MultiEdge_Inbound) Reset()

func (*MultiEdge_Inbound) String 

func (x *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) Descriptor 

func (MultiEdge_Inbound_InputKind) Descriptor() protoreflect.EnumDescriptor

func (MultiEdge_Inbound_InputKind) Enum 

func (x MultiEdge_Inbound_InputKind) Enum() *MultiEdge_Inbound_InputKind

func (MultiEdge_Inbound_InputKind) EnumDescriptor deprecated 

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

Deprecated: Use MultiEdge_Inbound_InputKind.Descriptor instead.

func (MultiEdge_Inbound_InputKind) Number 

func (x MultiEdge_Inbound_InputKind) Number() protoreflect.EnumNumber

func (MultiEdge_Inbound_InputKind) String 

func (x MultiEdge_Inbound_InputKind) String() string

func (MultiEdge_Inbound_InputKind) Type 

func (MultiEdge_Inbound_InputKind) Type() protoreflect.EnumType

type MultiEdge_Outbound 

type MultiEdge_Outbound struct {
	Type *FullType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiEdge_Outbound) Descriptor deprecated 

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

Deprecated: Use MultiEdge_Outbound.ProtoReflect.Descriptor instead.

func (*MultiEdge_Outbound) GetType 

func (x *MultiEdge_Outbound) GetType() *FullType

func (*MultiEdge_Outbound) ProtoMessage 

func (*MultiEdge_Outbound) ProtoMessage()

func (*MultiEdge_Outbound) ProtoReflect 

func (x *MultiEdge_Outbound) ProtoReflect() protoreflect.Message

func (*MultiEdge_Outbound) Reset 

func (x *MultiEdge_Outbound) Reset()

func (*MultiEdge_Outbound) String 

func (x *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,proto3" json:"urn,omitempty"`
	Edge   *MultiEdge     `protobuf:"bytes,2,opt,name=edge,proto3" json:"edge,omitempty"`
	Inject *InjectPayload `protobuf:"bytes,3,opt,name=inject,proto3" json:"inject,omitempty"`
	// contains filtered or unexported fields
}

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

func (*TransformPayload) Descriptor deprecated 

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

Deprecated: Use TransformPayload.ProtoReflect.Descriptor instead.

func (*TransformPayload) GetEdge 

func (x *TransformPayload) GetEdge() *MultiEdge

func (*TransformPayload) GetInject 

func (x *TransformPayload) GetInject() *InjectPayload

func (*TransformPayload) GetUrn 

func (x *TransformPayload) GetUrn() string

func (*TransformPayload) ProtoMessage 

func (*TransformPayload) ProtoMessage()

func (*TransformPayload) ProtoReflect 

func (x *TransformPayload) ProtoReflect() protoreflect.Message

func (*TransformPayload) Reset 

func (x *TransformPayload) Reset()

func (*TransformPayload) String 

func (x *TransformPayload) String() string

type Type 

type Type struct {

	// (Required) Type kind.
	Kind Type_Kind `` /* 133-byte string literal not displayed */
	// (Optional) Element type (if SLICE, PTR or CHAN)
	Element *Type `protobuf:"bytes,2,opt,name=element,proto3" json:"element,omitempty"`
	// (Optional) Fields (if STRUCT).
	Fields []*Type_StructField `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// (Optional) Parameter types (if FUNC).
	ParameterTypes []*Type `protobuf:"bytes,4,rep,name=parameter_types,json=parameterTypes,proto3" json:"parameter_types,omitempty"`
	// (Optional) Return types (if FUNC).
	ReturnTypes []*Type `protobuf:"bytes,5,rep,name=return_types,json=returnTypes,proto3" json:"return_types,omitempty"`
	// (Optional) Is variadic (if FUNC).
	IsVariadic bool `protobuf:"varint,6,opt,name=is_variadic,json=isVariadic,proto3" json:"is_variadic,omitempty"`
	// (Optional) Channel direction (if CHAN).
	ChanDir Type_ChanDir `` /* 157-byte string literal not displayed */
	// (Optional) Special type (if SPECIAL)
	Special Type_Special `` /* 142-byte string literal not displayed */
	// (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,proto3" json:"external_key,omitempty"`
	// contains filtered or unexported fields
}

Type represents a serializable reflect.Type.

func (*Type) Descriptor deprecated 

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

Deprecated: Use Type.ProtoReflect.Descriptor instead.

func (*Type) GetChanDir 

func (x *Type) GetChanDir() Type_ChanDir

func (*Type) GetElement 

func (x *Type) GetElement() *Type

func (*Type) GetExternalKey 

func (x *Type) GetExternalKey() string

func (*Type) GetFields 

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

func (*Type) GetIsVariadic 

func (x *Type) GetIsVariadic() bool

func (*Type) GetKind 

func (x *Type) GetKind() Type_Kind

func (*Type) GetParameterTypes 

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

func (*Type) GetReturnTypes 

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

func (*Type) GetSpecial 

func (x *Type) GetSpecial() Type_Special

func (*Type) ProtoMessage 

func (*Type) ProtoMessage()

func (*Type) ProtoReflect 

func (x *Type) ProtoReflect() protoreflect.Message

func (*Type) Reset 

func (x *Type) Reset()

func (*Type) String 

func (x *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) Descriptor 

func (Type_ChanDir) Descriptor() protoreflect.EnumDescriptor

func (Type_ChanDir) Enum 

func (x Type_ChanDir) Enum() *Type_ChanDir

func (Type_ChanDir) EnumDescriptor deprecated 

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

Deprecated: Use Type_ChanDir.Descriptor instead.

func (Type_ChanDir) Number 

func (x Type_ChanDir) Number() protoreflect.EnumNumber

func (Type_ChanDir) String 

func (x Type_ChanDir) String() string

func (Type_ChanDir) Type 

func (Type_ChanDir) Type() protoreflect.EnumType

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) Descriptor 

func (Type_Kind) Descriptor() protoreflect.EnumDescriptor

func (Type_Kind) Enum 

func (x Type_Kind) Enum() *Type_Kind

func (Type_Kind) EnumDescriptor deprecated 

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

Deprecated: Use Type_Kind.Descriptor instead.

func (Type_Kind) Number 

func (x Type_Kind) Number() protoreflect.EnumNumber

func (Type_Kind) String 

func (x Type_Kind) String() string

func (Type_Kind) Type 

func (Type_Kind) Type() protoreflect.EnumType

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) Descriptor 

func (Type_Special) Descriptor() protoreflect.EnumDescriptor

func (Type_Special) Enum 

func (x Type_Special) Enum() *Type_Special

func (Type_Special) EnumDescriptor deprecated 

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

Deprecated: Use Type_Special.Descriptor instead.

func (Type_Special) Number 

func (x Type_Special) Number() protoreflect.EnumNumber

func (Type_Special) String 

func (x Type_Special) String() string

func (Type_Special) Type 

func (Type_Special) Type() protoreflect.EnumType

type Type_StructField 

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

StructField matches reflect.StructField.

func (*Type_StructField) Descriptor deprecated 

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

Deprecated: Use Type_StructField.ProtoReflect.Descriptor instead.

func (*Type_StructField) GetAnonymous 

func (x *Type_StructField) GetAnonymous() bool

func (*Type_StructField) GetIndex 

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

func (*Type_StructField) GetName 

func (x *Type_StructField) GetName() string

func (*Type_StructField) GetOffset 

func (x *Type_StructField) GetOffset() int64

func (*Type_StructField) GetPkgPath 

func (x *Type_StructField) GetPkgPath() string

func (*Type_StructField) GetTag 

func (x *Type_StructField) GetTag() string

func (*Type_StructField) GetType 

func (x *Type_StructField) GetType() *Type

func (*Type_StructField) ProtoMessage 

func (*Type_StructField) ProtoMessage()

func (*Type_StructField) ProtoReflect 

func (x *Type_StructField) ProtoReflect() protoreflect.Message

func (*Type_StructField) Reset 

func (x *Type_StructField) Reset()

func (*Type_StructField) String 

func (x *Type_StructField) String() string

type UserFn 

type UserFn struct {

	// (Required) Symbol name of function.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// (Required) Function type.
	Type *Type `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use UserFn.ProtoReflect.Descriptor instead.

func (*UserFn) GetName 

func (x *UserFn) GetName() string

func (*UserFn) GetType 

func (x *UserFn) GetType() *Type

func (*UserFn) ProtoMessage 

func (*UserFn) ProtoMessage()

func (*UserFn) ProtoReflect 

func (x *UserFn) ProtoReflect() protoreflect.Message

func (*UserFn) Reset 

func (x *UserFn) Reset()

func (*UserFn) String 

func (x *UserFn) String() string

type WindowFn 

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

WindowFn represents a window fn.

func (*WindowFn) Descriptor deprecated 

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

Deprecated: Use WindowFn.ProtoReflect.Descriptor instead.

func (*WindowFn) GetGapMs 

func (x *WindowFn) GetGapMs() int64

func (*WindowFn) GetKind 

func (x *WindowFn) GetKind() string

func (*WindowFn) GetPeriodMs 

func (x *WindowFn) GetPeriodMs() int64

func (*WindowFn) GetSizeMs 

func (x *WindowFn) GetSizeMs() int64

func (*WindowFn) ProtoMessage 

func (*WindowFn) ProtoMessage()

func (*WindowFn) ProtoReflect 

func (x *WindowFn) ProtoReflect() protoreflect.Message

func (*WindowFn) Reset 

func (x *WindowFn) Reset()

func (*WindowFn) String 

func (x *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.