v1

package
v0.1008.0 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_proto_function_v1_udfunction_proto protoreflect.FileDescriptor
View Source 
var UserDefinedFunction_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "function.v1.UserDefinedFunction",
	HandlerType: (*UserDefinedFunctionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "MapFn",
			Handler:    _UserDefinedFunction_MapFn_Handler,
		},
		{
			MethodName: "MapTFn",
			Handler:    _UserDefinedFunction_MapTFn_Handler,
		},
		{
			MethodName: "IsReady",
			Handler:    _UserDefinedFunction_IsReady_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReduceFn",
			Handler:       _UserDefinedFunction_ReduceFn_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/proto/function/v1/udfunction.proto",
}

UserDefinedFunction_ServiceDesc is the grpc.ServiceDesc for UserDefinedFunction service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterUserDefinedFunctionServer 

func RegisterUserDefinedFunctionServer(s grpc.ServiceRegistrar, srv UserDefinedFunctionServer)

Types

type Datum 

type Datum struct {
	Key       string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte     `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	EventTime *EventTime `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Watermark *Watermark `protobuf:"bytes,4,opt,name=watermark,proto3" json:"watermark,omitempty"`
	// contains filtered or unexported fields
}

* Datum represents a datum element.

func (*Datum) Descriptor deprecated 

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

Deprecated: Use Datum.ProtoReflect.Descriptor instead.

func (*Datum) GetEventTime 

func (x *Datum) GetEventTime() *EventTime

func (*Datum) GetKey 

func (x *Datum) GetKey() string

func (*Datum) GetValue 

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

func (*Datum) GetWatermark 

func (x *Datum) GetWatermark() *Watermark

func (*Datum) ProtoMessage 

func (*Datum) ProtoMessage()

func (*Datum) ProtoReflect 

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

func (*Datum) Reset 

func (x *Datum) Reset()

func (*Datum) String 

func (x *Datum) String() string

type DatumList 

type DatumList struct {
	Elements []*Datum `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

* DatumList represents a list of datum elements.

func (*DatumList) Descriptor deprecated 

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

Deprecated: Use DatumList.ProtoReflect.Descriptor instead.

func (*DatumList) GetElements 

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

func (*DatumList) ProtoMessage 

func (*DatumList) ProtoMessage()

func (*DatumList) ProtoReflect 

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

func (*DatumList) Reset 

func (x *DatumList) Reset()

func (*DatumList) String 

func (x *DatumList) String() string

type EventTime 

type EventTime struct {

	// event_time is the time associated with each datum.
	EventTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// contains filtered or unexported fields
}

func (*EventTime) Descriptor deprecated 

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

Deprecated: Use EventTime.ProtoReflect.Descriptor instead.

func (*EventTime) GetEventTime 

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

func (*EventTime) ProtoMessage 

func (*EventTime) ProtoMessage()

func (*EventTime) ProtoReflect 

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

func (*EventTime) Reset 

func (x *EventTime) Reset()

func (*EventTime) String 

func (x *EventTime) String() string

type ReadyResponse 

type ReadyResponse struct {
	Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
	// contains filtered or unexported fields
}

* ReadyResponse is the health check result.

func (*ReadyResponse) Descriptor deprecated 

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

Deprecated: Use ReadyResponse.ProtoReflect.Descriptor instead.

func (*ReadyResponse) GetReady 

func (x *ReadyResponse) GetReady() bool

func (*ReadyResponse) ProtoMessage 

func (*ReadyResponse) ProtoMessage()

func (*ReadyResponse) ProtoReflect 

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

func (*ReadyResponse) Reset 

func (x *ReadyResponse) Reset()

func (*ReadyResponse) String 

func (x *ReadyResponse) String() string

type UnimplementedUserDefinedFunctionServer 

type UnimplementedUserDefinedFunctionServer struct {
}

UnimplementedUserDefinedFunctionServer must be embedded to have forward compatible implementations.

func (UnimplementedUserDefinedFunctionServer) IsReady 

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

func (UnimplementedUserDefinedFunctionServer) MapFn 

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

func (UnimplementedUserDefinedFunctionServer) MapTFn added in v0.1008.0 

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

func (UnimplementedUserDefinedFunctionServer) ReduceFn 

func (UnimplementedUserDefinedFunctionServer) ReduceFn(UserDefinedFunction_ReduceFnServer) error

type UnsafeUserDefinedFunctionServer 

type UnsafeUserDefinedFunctionServer interface {
	// contains filtered or unexported methods
}

UnsafeUserDefinedFunctionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UserDefinedFunctionServer will result in compilation errors.

type UserDefinedFunctionClient 

type UserDefinedFunctionClient interface {
	// MapFn applies a function to each datum element.
	MapFn(ctx context.Context, in *Datum, opts ...grpc.CallOption) (*DatumList, error)
	// MapTFn applies a function to each datum element.
	// In addition to map function, MapTFn also supports assigning a new event time to datum.
	// MapTFn can be used only at source vertex by source data transformer.
	MapTFn(ctx context.Context, in *Datum, opts ...grpc.CallOption) (*DatumList, error)
	// ReduceFn applies a reduce function to a datum stream.
	ReduceFn(ctx context.Context, opts ...grpc.CallOption) (UserDefinedFunction_ReduceFnClient, error)
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
}

UserDefinedFunctionClient is the client API for UserDefinedFunction service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewUserDefinedFunctionClient 

func NewUserDefinedFunctionClient(cc grpc.ClientConnInterface) UserDefinedFunctionClient

type UserDefinedFunctionServer 

type UserDefinedFunctionServer interface {
	// MapFn applies a function to each datum element.
	MapFn(context.Context, *Datum) (*DatumList, error)
	// MapTFn applies a function to each datum element.
	// In addition to map function, MapTFn also supports assigning a new event time to datum.
	// MapTFn can be used only at source vertex by source data transformer.
	MapTFn(context.Context, *Datum) (*DatumList, error)
	// ReduceFn applies a reduce function to a datum stream.
	ReduceFn(UserDefinedFunction_ReduceFnServer) error
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
	// contains filtered or unexported methods
}

UserDefinedFunctionServer is the server API for UserDefinedFunction service. All implementations must embed UnimplementedUserDefinedFunctionServer for forward compatibility

type UserDefinedFunction_ReduceFnClient 

type UserDefinedFunction_ReduceFnClient interface {
	Send(*Datum) error
	CloseAndRecv() (*DatumList, error)
	grpc.ClientStream
}

type UserDefinedFunction_ReduceFnServer 

type UserDefinedFunction_ReduceFnServer interface {
	SendAndClose(*DatumList) error
	Recv() (*Datum, error)
	grpc.ServerStream
}

type Watermark 

type Watermark struct {

	// watermark is the monotonically increasing time which denotes completeness for the given time for the given vertex.
	Watermark *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=watermark,proto3" json:"watermark,omitempty"` // future we can add LATE, ON_TIME etc.
	// contains filtered or unexported fields
}

func (*Watermark) Descriptor deprecated 

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

Deprecated: Use Watermark.ProtoReflect.Descriptor instead.

func (*Watermark) GetWatermark 

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

func (*Watermark) ProtoMessage 

func (*Watermark) ProtoMessage()

func (*Watermark) ProtoReflect 

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

func (*Watermark) Reset 

func (x *Watermark) Reset()

func (*Watermark) String 

func (x *Watermark) String() string

Source Files

View all Source files

Directories

Path Synopsis
Package funcmock is a generated GoMock package.
 Package funcmock is a generated GoMock package.

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.