Versions in this module Expand all Collapse all v0 v0.8.1 Aug 29, 2024 v0.8.0 Aug 19, 2024 Changes in this version + var BatchMap_ServiceDesc = grpc.ServiceDesc + var File_pkg_apis_proto_batchmap_v1_batchmap_proto protoreflect.FileDescriptor + func RegisterBatchMapServer(s grpc.ServiceRegistrar, srv BatchMapServer) + type BatchMapClient interface + BatchMapFn func(ctx context.Context, opts ...grpc.CallOption) (BatchMap_BatchMapFnClient, error) + IsReady func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error) + func NewBatchMapClient(cc grpc.ClientConnInterface) BatchMapClient + type BatchMapRequest struct + EventTime *timestamppb.Timestamp + Headers map[string]string + Id string + Keys []string + Value []byte + Watermark *timestamppb.Timestamp + func (*BatchMapRequest) Descriptor() ([]byte, []int) + func (*BatchMapRequest) ProtoMessage() + func (x *BatchMapRequest) GetEventTime() *timestamppb.Timestamp + func (x *BatchMapRequest) GetHeaders() map[string]string + func (x *BatchMapRequest) GetId() string + func (x *BatchMapRequest) GetKeys() []string + func (x *BatchMapRequest) GetValue() []byte + func (x *BatchMapRequest) GetWatermark() *timestamppb.Timestamp + func (x *BatchMapRequest) ProtoReflect() protoreflect.Message + func (x *BatchMapRequest) Reset() + func (x *BatchMapRequest) String() string + type BatchMapResponse struct + Id string + Results []*BatchMapResponse_Result + func (*BatchMapResponse) Descriptor() ([]byte, []int) + func (*BatchMapResponse) ProtoMessage() + func (x *BatchMapResponse) GetId() string + func (x *BatchMapResponse) GetResults() []*BatchMapResponse_Result + func (x *BatchMapResponse) ProtoReflect() protoreflect.Message + func (x *BatchMapResponse) Reset() + func (x *BatchMapResponse) String() string + type BatchMapResponse_Result struct + Keys []string + Tags []string + Value []byte + func (*BatchMapResponse_Result) Descriptor() ([]byte, []int) + func (*BatchMapResponse_Result) ProtoMessage() + func (x *BatchMapResponse_Result) GetKeys() []string + func (x *BatchMapResponse_Result) GetTags() []string + func (x *BatchMapResponse_Result) GetValue() []byte + func (x *BatchMapResponse_Result) ProtoReflect() protoreflect.Message + func (x *BatchMapResponse_Result) Reset() + func (x *BatchMapResponse_Result) String() string + type BatchMapServer interface + BatchMapFn func(BatchMap_BatchMapFnServer) error + IsReady func(context.Context, *emptypb.Empty) (*ReadyResponse, error) + type BatchMap_BatchMapFnClient interface + Recv func() (*BatchMapResponse, error) + Send func(*BatchMapRequest) error + type BatchMap_BatchMapFnServer interface + Recv func() (*BatchMapRequest, error) + Send func(*BatchMapResponse) error + 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 UnimplementedBatchMapServer struct + func (UnimplementedBatchMapServer) BatchMapFn(BatchMap_BatchMapFnServer) error + func (UnimplementedBatchMapServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error) + type UnsafeBatchMapServer interface
Go to main page