v1

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 8, 2024 License: Apache-2.0 Imports: 10 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	SourceTransform_SourceTransformFn_FullMethodName = "/sourcetransformer.v1.SourceTransform/SourceTransformFn"
	SourceTransform_IsReady_FullMethodName           = "/sourcetransformer.v1.SourceTransform/IsReady"
)

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: "IsReady",
			Handler:    _SourceTransform_IsReady_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SourceTransformFn",
			Handler:       _SourceTransform_SourceTransformFn_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	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 Handshake added in v0.9.0 

type Handshake struct {

	// Required field indicating the start of transmission.
	Sot bool `protobuf:"varint,1,opt,name=sot,proto3" json:"sot,omitempty"`
	// contains filtered or unexported fields
}

Handshake message between client and server to indicate the start of transmission.

func (*Handshake) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use Handshake.ProtoReflect.Descriptor instead.

func (*Handshake) GetSot added in v0.9.0 

func (x *Handshake) GetSot() bool

func (*Handshake) ProtoMessage added in v0.9.0 

func (*Handshake) ProtoMessage()

func (*Handshake) ProtoReflect added in v0.9.0 

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

func (*Handshake) Reset added in v0.9.0 

func (x *Handshake) Reset()

func (*Handshake) String added in v0.9.0 

func (x *Handshake) 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 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, opts ...grpc.CallOption) (SourceTransform_SourceTransformFnClient, 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 {
	Request   *SourceTransformRequest_Request `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Handshake *Handshake                      `protobuf:"bytes,2,opt,name=handshake,proto3,oneof" json:"handshake,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) GetHandshake added in v0.9.0 

func (x *SourceTransformRequest) GetHandshake() *Handshake

func (*SourceTransformRequest) GetRequest added in v0.9.0 

func (x *SourceTransformRequest) GetRequest() *SourceTransformRequest_Request

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 SourceTransformRequest_Request added in v0.9.0 

type SourceTransformRequest_Request 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"`
	Headers   map[string]string      `` /* 155-byte string literal not displayed */
	// This ID is used to uniquely identify a transform request
	Id string `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceTransformRequest_Request) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SourceTransformRequest_Request.ProtoReflect.Descriptor instead.

func (*SourceTransformRequest_Request) GetEventTime added in v0.9.0 

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

func (*SourceTransformRequest_Request) GetHeaders added in v0.9.0 

func (x *SourceTransformRequest_Request) GetHeaders() map[string]string

func (*SourceTransformRequest_Request) GetId added in v0.9.0 

func (x *SourceTransformRequest_Request) GetId() string

func (*SourceTransformRequest_Request) GetKeys added in v0.9.0 

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

func (*SourceTransformRequest_Request) GetValue added in v0.9.0 

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

func (*SourceTransformRequest_Request) GetWatermark added in v0.9.0 

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

func (*SourceTransformRequest_Request) ProtoMessage added in v0.9.0 

func (*SourceTransformRequest_Request) ProtoMessage()

func (*SourceTransformRequest_Request) ProtoReflect added in v0.9.0 

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

func (*SourceTransformRequest_Request) Reset added in v0.9.0 

func (x *SourceTransformRequest_Request) Reset()

func (*SourceTransformRequest_Request) String added in v0.9.0 

func (x *SourceTransformRequest_Request) String() string

type SourceTransformResponse 

type SourceTransformResponse struct {
	Results []*SourceTransformResponse_Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// This ID is used to refer the responses to the request it corresponds to.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Handshake message between client and server to indicate the start of transmission.
	Handshake *Handshake `protobuf:"bytes,3,opt,name=handshake,proto3,oneof" json:"handshake,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) GetHandshake added in v0.9.0 

func (x *SourceTransformResponse) GetHandshake() *Handshake

func (*SourceTransformResponse) GetId added in v0.9.0 

func (x *SourceTransformResponse) GetId() string

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(SourceTransform_SourceTransformFnServer) 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 SourceTransform_SourceTransformFnClient added in v0.9.0 

type SourceTransform_SourceTransformFnClient interface {
	Send(*SourceTransformRequest) error
	Recv() (*SourceTransformResponse, error)
	grpc.ClientStream
}

type SourceTransform_SourceTransformFnServer added in v0.9.0 

type SourceTransform_SourceTransformFnServer interface {
	Send(*SourceTransformResponse) error
	Recv() (*SourceTransformRequest, error)
	grpc.ServerStream
}

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(SourceTransform_SourceTransformFnServer) 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.