v1

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
}

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
}

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
}

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
}

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

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
}

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
}

type MultiEdge_Inbound_InputKind int32

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

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
}

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 Type_ChanDir int32

type Type_Kind int32

type Type_Special int32

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
}

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
}

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
}