v1

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BatchMap_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "batchmap.v1.BatchMap",
	HandlerType: (*BatchMapServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsReady",
			Handler:    _BatchMap_IsReady_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BatchMapFn",
			Handler:       _BatchMap_BatchMapFn_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/apis/proto/batchmap/v1/batchmap.proto",
}

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

View Source 
var File_pkg_apis_proto_batchmap_v1_batchmap_proto protoreflect.FileDescriptor

Functions

func RegisterBatchMapServer 

func RegisterBatchMapServer(s grpc.ServiceRegistrar, srv BatchMapServer)

Types

type BatchMapClient 

type BatchMapClient interface {
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error)
	// BatchMapFn is a bi-directional streaming rpc which applies a
	// map function on each BatchMapRequest element of the stream and then streams
	// back BatchMapResponse elements.
	BatchMapFn(ctx context.Context, opts ...grpc.CallOption) (BatchMap_BatchMapFnClient, error)
}

BatchMapClient is the client API for BatchMap 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 NewBatchMapClient 

func NewBatchMapClient(cc grpc.ClientConnInterface) BatchMapClient

type BatchMapRequest 

type BatchMapRequest 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 uniquely identify a map request
	Id string `protobuf:"bytes,6,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

* BatchMapRequest represents a request element.

func (*BatchMapRequest) Descriptor deprecated 

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

Deprecated: Use BatchMapRequest.ProtoReflect.Descriptor instead.

func (*BatchMapRequest) GetEventTime 

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

func (*BatchMapRequest) GetHeaders 

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

func (*BatchMapRequest) GetId 

func (x *BatchMapRequest) GetId() string

func (*BatchMapRequest) GetKeys 

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

func (*BatchMapRequest) GetValue 

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

func (*BatchMapRequest) GetWatermark 

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

func (*BatchMapRequest) ProtoMessage 

func (*BatchMapRequest) ProtoMessage()

func (*BatchMapRequest) ProtoReflect 

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

func (*BatchMapRequest) Reset 

func (x *BatchMapRequest) Reset()

func (*BatchMapRequest) String 

func (x *BatchMapRequest) String() string

type BatchMapResponse 

type BatchMapResponse struct {
	Results []*BatchMapResponse_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"`
	// contains filtered or unexported fields
}

* BatchMapResponse represents a response element.

func (*BatchMapResponse) Descriptor deprecated 

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

Deprecated: Use BatchMapResponse.ProtoReflect.Descriptor instead.

func (*BatchMapResponse) GetId 

func (x *BatchMapResponse) GetId() string

func (*BatchMapResponse) GetResults 

func (x *BatchMapResponse) GetResults() []*BatchMapResponse_Result

func (*BatchMapResponse) ProtoMessage 

func (*BatchMapResponse) ProtoMessage()

func (*BatchMapResponse) ProtoReflect 

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

func (*BatchMapResponse) Reset 

func (x *BatchMapResponse) Reset()

func (*BatchMapResponse) String 

func (x *BatchMapResponse) String() string

type BatchMapResponse_Result 

type BatchMapResponse_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"`
	Tags  []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchMapResponse_Result) Descriptor deprecated 

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

Deprecated: Use BatchMapResponse_Result.ProtoReflect.Descriptor instead.

func (*BatchMapResponse_Result) GetKeys 

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

func (*BatchMapResponse_Result) GetTags 

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

func (*BatchMapResponse_Result) GetValue 

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

func (*BatchMapResponse_Result) ProtoMessage 

func (*BatchMapResponse_Result) ProtoMessage()

func (*BatchMapResponse_Result) ProtoReflect 

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

func (*BatchMapResponse_Result) Reset 

func (x *BatchMapResponse_Result) Reset()

func (*BatchMapResponse_Result) String 

func (x *BatchMapResponse_Result) String() string

type BatchMapServer 

type BatchMapServer interface {
	// IsReady is the heartbeat endpoint for gRPC.
	IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
	// BatchMapFn is a bi-directional streaming rpc which applies a
	// map function on each BatchMapRequest element of the stream and then streams
	// back BatchMapResponse elements.
	BatchMapFn(BatchMap_BatchMapFnServer) error
	// contains filtered or unexported methods
}

BatchMapServer is the server API for BatchMap service. All implementations must embed UnimplementedBatchMapServer for forward compatibility

type BatchMap_BatchMapFnClient 

type BatchMap_BatchMapFnClient interface {
	Send(*BatchMapRequest) error
	Recv() (*BatchMapResponse, error)
	grpc.ClientStream
}

type BatchMap_BatchMapFnServer 

type BatchMap_BatchMapFnServer interface {
	Send(*BatchMapResponse) error
	Recv() (*BatchMapRequest, error)
	grpc.ServerStream
}

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 UnimplementedBatchMapServer 

type UnimplementedBatchMapServer struct {
}

UnimplementedBatchMapServer must be embedded to have forward compatible implementations.

func (UnimplementedBatchMapServer) BatchMapFn 

func (UnimplementedBatchMapServer) BatchMapFn(BatchMap_BatchMapFnServer) error

func (UnimplementedBatchMapServer) IsReady 

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

type UnsafeBatchMapServer 

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

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

Source Files

View all Source files

Directories

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