Versions in this module Expand all Collapse all v0 v0.9.0 Nov 8, 2024 Changes in this version + const Map_IsReady_FullMethodName + const Map_MapFn_FullMethodName + type Handshake struct + Sot bool + func (*Handshake) Descriptor() ([]byte, []int) + func (*Handshake) ProtoMessage() + func (x *Handshake) GetSot() bool + func (x *Handshake) ProtoReflect() protoreflect.Message + func (x *Handshake) Reset() + func (x *Handshake) String() string type MapRequest + Handshake *Handshake + Id string + Request *MapRequest_Request + Status *TransmissionStatus + func (x *MapRequest) GetHandshake() *Handshake + func (x *MapRequest) GetId() string + func (x *MapRequest) GetRequest() *MapRequest_Request + func (x *MapRequest) GetStatus() *TransmissionStatus + type MapRequest_Request struct + EventTime *timestamppb.Timestamp + Headers map[string]string + Keys []string + Value []byte + Watermark *timestamppb.Timestamp + func (*MapRequest_Request) Descriptor() ([]byte, []int) + func (*MapRequest_Request) ProtoMessage() + func (x *MapRequest_Request) GetEventTime() *timestamppb.Timestamp + func (x *MapRequest_Request) GetHeaders() map[string]string + func (x *MapRequest_Request) GetKeys() []string + func (x *MapRequest_Request) GetValue() []byte + func (x *MapRequest_Request) GetWatermark() *timestamppb.Timestamp + func (x *MapRequest_Request) ProtoReflect() protoreflect.Message + func (x *MapRequest_Request) Reset() + func (x *MapRequest_Request) String() string type MapResponse + Handshake *Handshake + Id string + Status *TransmissionStatus + func (x *MapResponse) GetHandshake() *Handshake + func (x *MapResponse) GetId() string + func (x *MapResponse) GetStatus() *TransmissionStatus + type Map_MapFnClient interface + Recv func() (*MapResponse, error) + Send func(*MapRequest) error + type Map_MapFnServer interface + Recv func() (*MapRequest, error) + Send func(*MapResponse) error + type TransmissionStatus struct + Eot bool + func (*TransmissionStatus) Descriptor() ([]byte, []int) + func (*TransmissionStatus) ProtoMessage() + func (x *TransmissionStatus) GetEot() bool + func (x *TransmissionStatus) ProtoReflect() protoreflect.Message + func (x *TransmissionStatus) Reset() + func (x *TransmissionStatus) String() string v0.8.1 Aug 29, 2024 v0.8.0 Aug 19, 2024 v0.7.0 Apr 23, 2024 Changes in this version type MapRequest + Headers map[string]string + func (x *MapRequest) GetHeaders() map[string]string v0.7.0-rc2 Apr 18, 2024 v0.7.0-rc1 Mar 25, 2024 v0.6.0 Dec 15, 2023 v0.5.2 Oct 13, 2023 v0.5.1 Oct 2, 2023 v0.5.0 Aug 29, 2023 Changes in this version + var File_pkg_apis_proto_map_v1_map_proto protoreflect.FileDescriptor + var Map_ServiceDesc = grpc.ServiceDesc + func RegisterMapServer(s grpc.ServiceRegistrar, srv MapServer) + type MapClient interface + IsReady func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error) + MapFn func(ctx context.Context, in *MapRequest, opts ...grpc.CallOption) (*MapResponse, error) + func NewMapClient(cc grpc.ClientConnInterface) MapClient + type MapRequest struct + EventTime *timestamppb.Timestamp + Keys []string + Value []byte + Watermark *timestamppb.Timestamp + func (*MapRequest) Descriptor() ([]byte, []int) + func (*MapRequest) ProtoMessage() + func (x *MapRequest) GetEventTime() *timestamppb.Timestamp + func (x *MapRequest) GetKeys() []string + func (x *MapRequest) GetValue() []byte + func (x *MapRequest) GetWatermark() *timestamppb.Timestamp + func (x *MapRequest) ProtoReflect() protoreflect.Message + func (x *MapRequest) Reset() + func (x *MapRequest) String() string + type MapResponse struct + Results []*MapResponse_Result + func (*MapResponse) Descriptor() ([]byte, []int) + func (*MapResponse) ProtoMessage() + func (x *MapResponse) GetResults() []*MapResponse_Result + func (x *MapResponse) ProtoReflect() protoreflect.Message + func (x *MapResponse) Reset() + func (x *MapResponse) String() string + type MapResponse_Result struct + Keys []string + Tags []string + Value []byte + func (*MapResponse_Result) Descriptor() ([]byte, []int) + func (*MapResponse_Result) ProtoMessage() + func (x *MapResponse_Result) GetKeys() []string + func (x *MapResponse_Result) GetTags() []string + func (x *MapResponse_Result) GetValue() []byte + func (x *MapResponse_Result) ProtoReflect() protoreflect.Message + func (x *MapResponse_Result) Reset() + func (x *MapResponse_Result) String() string + type MapServer interface + IsReady func(context.Context, *emptypb.Empty) (*ReadyResponse, error) + MapFn func(context.Context, *MapRequest) (*MapResponse, 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 UnimplementedMapServer struct + func (UnimplementedMapServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error) + func (UnimplementedMapServer) MapFn(context.Context, *MapRequest) (*MapResponse, error) + type UnsafeMapServer interface
Go to main page