v1

Apr 12, 2023

Changes in this version

+ type DatumRequest struct

+ EventTime *EventTime

+ Keys []string

+ Metadata *Metadata

+ Value []byte

+ Watermark *Watermark

+ func (*DatumRequest) Descriptor() ([]byte, []int)

+ func (*DatumRequest) ProtoMessage()

+ func (x *DatumRequest) GetEventTime() *EventTime

+ func (x *DatumRequest) GetKeys() []string

+ func (x *DatumRequest) GetMetadata() *Metadata

+ func (x *DatumRequest) GetValue() []byte

+ func (x *DatumRequest) GetWatermark() *Watermark

+ func (x *DatumRequest) ProtoReflect() protoreflect.Message

+ func (x *DatumRequest) Reset()

+ func (x *DatumRequest) String() string

+ type DatumResponse struct

+ EventTime *EventTime

+ Keys []string

+ Tags []string

+ Value []byte

+ Watermark *Watermark

+ func (*DatumResponse) Descriptor() ([]byte, []int)

+ func (*DatumResponse) ProtoMessage()

+ func (x *DatumResponse) GetEventTime() *EventTime

+ func (x *DatumResponse) GetKeys() []string

+ func (x *DatumResponse) GetTags() []string

+ func (x *DatumResponse) GetValue() []byte

+ func (x *DatumResponse) GetWatermark() *Watermark

+ func (x *DatumResponse) ProtoReflect() protoreflect.Message

+ func (x *DatumResponse) Reset()

+ func (x *DatumResponse) String() string

+ type DatumResponseList struct

+ Elements []*DatumResponse

+ func (*DatumResponseList) Descriptor() ([]byte, []int)

+ func (*DatumResponseList) ProtoMessage()

+ func (x *DatumResponseList) GetElements() []*DatumResponse

+ func (x *DatumResponseList) ProtoReflect() protoreflect.Message

+ func (x *DatumResponseList) Reset()

+ func (x *DatumResponseList) String() string

Apr 6, 2023

retracted

Changes in this version

type Datum

+ Metadata *Metadata

+ func (x *Datum) GetMetadata() *Metadata

+ type Metadata struct

+ Id string

+ NumDelivered uint64

+ func (*Metadata) Descriptor() ([]byte, []int)

+ func (*Metadata) ProtoMessage()

+ func (x *Metadata) GetId() string

+ func (x *Metadata) GetNumDelivered() uint64

+ func (x *Metadata) ProtoReflect() protoreflect.Message

+ func (x *Metadata) Reset()

+ func (x *Metadata) String() string

Apr 5, 2023

Changes in this version

type Datum

+ Keys []string

+ func (x *Datum) GetKeys() []string

Feb 16, 2023

Changes in this version

type UserDefinedFunction_ReduceFnClient

+ Recv func() (*DatumList, error)

type UserDefinedFunction_ReduceFnServer

+ Send func(*DatumList) error

Jan 20, 2023

Changes in this version

type UnimplementedUserDefinedFunctionServer

+ func (UnimplementedUserDefinedFunctionServer) MapTFn(context.Context, *Datum) (*DatumList, error)

type UserDefinedFunctionClient

+ MapTFn func(ctx context.Context, in *Datum, opts ...grpc.CallOption) (*DatumList, error)

type UserDefinedFunctionServer

+ MapTFn func(context.Context, *Datum) (*DatumList, error)

Sep 1, 2022

Changes in this version

+ var File_pkg_apis_proto_function_v1_udfunction_proto protoreflect.FileDescriptor

+ var UserDefinedFunction_ServiceDesc = grpc.ServiceDesc

+ func RegisterUserDefinedFunctionServer(s grpc.ServiceRegistrar, srv UserDefinedFunctionServer)

+ type Datum struct

+ EventTime *EventTime

+ Key string

+ Value []byte

+ Watermark *Watermark

+ func (*Datum) Descriptor() ([]byte, []int)

+ func (*Datum) ProtoMessage()

+ func (x *Datum) GetEventTime() *EventTime

+ func (x *Datum) GetKey() string

+ func (x *Datum) GetValue() []byte

+ func (x *Datum) GetWatermark() *Watermark

+ func (x *Datum) ProtoReflect() protoreflect.Message

+ func (x *Datum) Reset()

+ func (x *Datum) String() string

+ type DatumList struct

+ Elements []*Datum

+ func (*DatumList) Descriptor() ([]byte, []int)

+ func (*DatumList) ProtoMessage()

+ func (x *DatumList) GetElements() []*Datum

+ func (x *DatumList) ProtoReflect() protoreflect.Message

+ func (x *DatumList) Reset()

+ func (x *DatumList) String() string

+ type EventTime struct

+ EventTime *timestamppb.Timestamp

+ func (*EventTime) Descriptor() ([]byte, []int)

+ func (*EventTime) ProtoMessage()

+ func (x *EventTime) GetEventTime() *timestamppb.Timestamp

+ func (x *EventTime) ProtoReflect() protoreflect.Message

+ func (x *EventTime) Reset()

+ func (x *EventTime) String() string

+ type ReadyResponse struct

+ Ready bool

+ func (*ReadyResponse) Descriptor() ([]byte, []int)

+ func (*ReadyResponse) ProtoMessage()

+ func (x *ReadyResponse) GetReady() bool

+ func (x *ReadyResponse) ProtoReflect() protoreflect.Message

+ func (x *ReadyResponse) Reset()

+ func (x *ReadyResponse) String() string

+ type UnimplementedUserDefinedFunctionServer struct

+ func (UnimplementedUserDefinedFunctionServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)

+ func (UnimplementedUserDefinedFunctionServer) MapFn(context.Context, *Datum) (*DatumList, error)

+ func (UnimplementedUserDefinedFunctionServer) ReduceFn(UserDefinedFunction_ReduceFnServer) error

+ type UnsafeUserDefinedFunctionServer interface

+ type UserDefinedFunctionClient interface

+ IsReady func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)

+ MapFn func(ctx context.Context, in *Datum, opts ...grpc.CallOption) (*DatumList, error)

+ ReduceFn func(ctx context.Context, opts ...grpc.CallOption) (UserDefinedFunction_ReduceFnClient, error)

+ func NewUserDefinedFunctionClient(cc grpc.ClientConnInterface) UserDefinedFunctionClient

+ type UserDefinedFunctionServer interface

+ IsReady func(context.Context, *emptypb.Empty) (*ReadyResponse, error)

+ MapFn func(context.Context, *Datum) (*DatumList, error)

+ ReduceFn func(UserDefinedFunction_ReduceFnServer) error

+ type UserDefinedFunction_ReduceFnClient interface

+ CloseAndRecv func() (*DatumList, error)

+ Send func(*Datum) error

+ type UserDefinedFunction_ReduceFnServer interface

+ Recv func() (*Datum, error)

+ SendAndClose func(*DatumList) error

+ type Watermark struct

+ Watermark *timestamppb.Timestamp

+ func (*Watermark) Descriptor() ([]byte, []int)

+ func (*Watermark) ProtoMessage()

+ func (x *Watermark) GetWatermark() *timestamppb.Timestamp

+ func (x *Watermark) ProtoReflect() protoreflect.Message

+ func (x *Watermark) Reset()

+ func (x *Watermark) String() string