v1

package
v0.5.1 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2023 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_pkg_apis_proto_sourcetransform_v1_transform_proto protoreflect.FileDescriptor
View Source 
var SourceTransform_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sourcetransformer.v1.SourceTransform",
	HandlerType: (*SourceTransformServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SourceTransformFn",
			Handler:    _SourceTransform_SourceTransformFn_Handler,
		},
		{
			MethodName: "IsReady",
			Handler:    _SourceTransform_IsReady_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/apis/proto/sourcetransform/v1/transform.proto",
}

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

Functions

func RegisterSourceTransformServer 

func RegisterSourceTransformServer(s grpc.ServiceRegistrar, srv SourceTransformServer)

Types

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 SourceTransformClient 

type SourceTransformClient interface {
	// SourceTransformFn applies a function to each request element.
	// In addition to map function, SourceTransformFn also supports assigning a new event time to response.
	// SourceTransformFn can be used only at source vertex by source data transformer.
	SourceTransformFn(ctx context.Context, in *SourceTransformRequest, opts ...grpc.CallOption) (*SourceTransformResponse, error)
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
}

SourceTransformClient is the client API for SourceTransform 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 NewSourceTransformClient 

func NewSourceTransformClient(cc grpc.ClientConnInterface) SourceTransformClient

type SourceTransformRequest 

type SourceTransformRequest struct {
	Keys      []string               `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Value     []byte                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Watermark *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=watermark,proto3" json:"watermark,omitempty"`
	// contains filtered or unexported fields
}

* SourceTransformerRequest represents a request element.

func (*SourceTransformRequest) Descriptor deprecated 

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

Deprecated: Use SourceTransformRequest.ProtoReflect.Descriptor instead.

func (*SourceTransformRequest) GetEventTime 

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

func (*SourceTransformRequest) GetKeys 

func (x *SourceTransformRequest) GetKeys() []string

func (*SourceTransformRequest) GetValue 

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

func (*SourceTransformRequest) GetWatermark 

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

func (*SourceTransformRequest) ProtoMessage 

func (*SourceTransformRequest) ProtoMessage()

func (*SourceTransformRequest) ProtoReflect 

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

func (*SourceTransformRequest) Reset 

func (x *SourceTransformRequest) Reset()

func (*SourceTransformRequest) String 

func (x *SourceTransformRequest) String() string

type SourceTransformResponse 

type SourceTransformResponse struct {
	Results []*SourceTransformResponse_Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

* SourceTransformerResponse represents a response element.

func (*SourceTransformResponse) Descriptor deprecated 

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

Deprecated: Use SourceTransformResponse.ProtoReflect.Descriptor instead.

func (*SourceTransformResponse) GetResults 

func (x *SourceTransformResponse) GetResults() []*SourceTransformResponse_Result

func (*SourceTransformResponse) ProtoMessage 

func (*SourceTransformResponse) ProtoMessage()

func (*SourceTransformResponse) ProtoReflect 

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

func (*SourceTransformResponse) Reset 

func (x *SourceTransformResponse) Reset()

func (*SourceTransformResponse) String 

func (x *SourceTransformResponse) String() string

type SourceTransformResponse_Result 

type SourceTransformResponse_Result struct {
	Keys      []string               `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Value     []byte                 `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Tags      []string               `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceTransformResponse_Result) Descriptor deprecated 

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

Deprecated: Use SourceTransformResponse_Result.ProtoReflect.Descriptor instead.

func (*SourceTransformResponse_Result) GetEventTime 

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

func (*SourceTransformResponse_Result) GetKeys 

func (x *SourceTransformResponse_Result) GetKeys() []string

func (*SourceTransformResponse_Result) GetTags 

func (x *SourceTransformResponse_Result) GetTags() []string

func (*SourceTransformResponse_Result) GetValue 

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

func (*SourceTransformResponse_Result) ProtoMessage 

func (*SourceTransformResponse_Result) ProtoMessage()

func (*SourceTransformResponse_Result) ProtoReflect 

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

func (*SourceTransformResponse_Result) Reset 

func (x *SourceTransformResponse_Result) Reset()

func (*SourceTransformResponse_Result) String 

func (x *SourceTransformResponse_Result) String() string

type SourceTransformServer 

type SourceTransformServer interface {
	// SourceTransformFn applies a function to each request element.
	// In addition to map function, SourceTransformFn also supports assigning a new event time to response.
	// SourceTransformFn can be used only at source vertex by source data transformer.
	SourceTransformFn(context.Context, *SourceTransformRequest) (*SourceTransformResponse, error)
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
	// contains filtered or unexported methods
}

SourceTransformServer is the server API for SourceTransform service. All implementations must embed UnimplementedSourceTransformServer for forward compatibility

type UnimplementedSourceTransformServer 

type UnimplementedSourceTransformServer struct {
}

UnimplementedSourceTransformServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceTransformServer) IsReady 

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

func (UnimplementedSourceTransformServer) SourceTransformFn 

func (UnimplementedSourceTransformServer) SourceTransformFn(context.Context, *SourceTransformRequest) (*SourceTransformResponse, error)

type UnsafeSourceTransformServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis
Package transformermock is a generated GoMock package.
 Package transformermock 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.