Documentation ¶
Index ¶
- Variables
- func RegisterMapStreamServer(s grpc.ServiceRegistrar, srv MapStreamServer)
- type MapStreamClient
- type MapStreamRequest
- func (*MapStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MapStreamRequest) GetEventTime() *timestamppb.Timestamp
- func (x *MapStreamRequest) GetHeaders() map[string]string
- func (x *MapStreamRequest) GetKeys() []string
- func (x *MapStreamRequest) GetValue() []byte
- func (x *MapStreamRequest) GetWatermark() *timestamppb.Timestamp
- func (*MapStreamRequest) ProtoMessage()
- func (x *MapStreamRequest) ProtoReflect() protoreflect.Message
- func (x *MapStreamRequest) Reset()
- func (x *MapStreamRequest) String() string
- type MapStreamResponse
- func (*MapStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MapStreamResponse) GetResult() *MapStreamResponse_Result
- func (*MapStreamResponse) ProtoMessage()
- func (x *MapStreamResponse) ProtoReflect() protoreflect.Message
- func (x *MapStreamResponse) Reset()
- func (x *MapStreamResponse) String() string
- type MapStreamResponse_Result
- func (*MapStreamResponse_Result) Descriptor() ([]byte, []int)deprecated
- func (x *MapStreamResponse_Result) GetKeys() []string
- func (x *MapStreamResponse_Result) GetTags() []string
- func (x *MapStreamResponse_Result) GetValue() []byte
- func (*MapStreamResponse_Result) ProtoMessage()
- func (x *MapStreamResponse_Result) ProtoReflect() protoreflect.Message
- func (x *MapStreamResponse_Result) Reset()
- func (x *MapStreamResponse_Result) String() string
- type MapStreamServer
- type MapStream_MapStreamFnClient
- type MapStream_MapStreamFnServer
- type ReadyResponse
- type UnimplementedMapStreamServer
- type UnsafeMapStreamServer
Constants ¶
This section is empty.
Variables ¶
var File_pkg_apis_proto_mapstream_v1_mapstream_proto protoreflect.FileDescriptor
var MapStream_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mapstream.v1.MapStream", HandlerType: (*MapStreamServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "IsReady", Handler: _MapStream_IsReady_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "MapStreamFn", Handler: _MapStream_MapStreamFn_Handler, ServerStreams: true, }, }, Metadata: "pkg/apis/proto/mapstream/v1/mapstream.proto", }
MapStream_ServiceDesc is the grpc.ServiceDesc for MapStream service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMapStreamServer ¶
func RegisterMapStreamServer(s grpc.ServiceRegistrar, srv MapStreamServer)
Types ¶
type MapStreamClient ¶
type MapStreamClient interface { // MapStreamFn applies a function to each request element and returns a stream. MapStreamFn(ctx context.Context, in *MapStreamRequest, opts ...grpc.CallOption) (MapStream_MapStreamFnClient, error) // IsReady is the heartbeat endpoint for gRPC. IsReady(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ReadyResponse, error) }
MapStreamClient is the client API for MapStream 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 NewMapStreamClient ¶
func NewMapStreamClient(cc grpc.ClientConnInterface) MapStreamClient
type MapStreamRequest ¶
type MapStreamRequest 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 */ // contains filtered or unexported fields }
* MapStreamRequest represents a request element.
func (*MapStreamRequest) Descriptor
deprecated
func (*MapStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use MapStreamRequest.ProtoReflect.Descriptor instead.
func (*MapStreamRequest) GetEventTime ¶
func (x *MapStreamRequest) GetEventTime() *timestamppb.Timestamp
func (*MapStreamRequest) GetHeaders ¶ added in v0.7.0
func (x *MapStreamRequest) GetHeaders() map[string]string
func (*MapStreamRequest) GetKeys ¶
func (x *MapStreamRequest) GetKeys() []string
func (*MapStreamRequest) GetValue ¶
func (x *MapStreamRequest) GetValue() []byte
func (*MapStreamRequest) GetWatermark ¶
func (x *MapStreamRequest) GetWatermark() *timestamppb.Timestamp
func (*MapStreamRequest) ProtoMessage ¶
func (*MapStreamRequest) ProtoMessage()
func (*MapStreamRequest) ProtoReflect ¶
func (x *MapStreamRequest) ProtoReflect() protoreflect.Message
func (*MapStreamRequest) Reset ¶
func (x *MapStreamRequest) Reset()
func (*MapStreamRequest) String ¶
func (x *MapStreamRequest) String() string
type MapStreamResponse ¶
type MapStreamResponse struct { Result *MapStreamResponse_Result `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
* MapStreamResponse represents a response element.
func (*MapStreamResponse) Descriptor
deprecated
func (*MapStreamResponse) Descriptor() ([]byte, []int)
Deprecated: Use MapStreamResponse.ProtoReflect.Descriptor instead.
func (*MapStreamResponse) GetResult ¶
func (x *MapStreamResponse) GetResult() *MapStreamResponse_Result
func (*MapStreamResponse) ProtoMessage ¶
func (*MapStreamResponse) ProtoMessage()
func (*MapStreamResponse) ProtoReflect ¶
func (x *MapStreamResponse) ProtoReflect() protoreflect.Message
func (*MapStreamResponse) Reset ¶
func (x *MapStreamResponse) Reset()
func (*MapStreamResponse) String ¶
func (x *MapStreamResponse) String() string
type MapStreamResponse_Result ¶
type MapStreamResponse_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 (*MapStreamResponse_Result) Descriptor
deprecated
func (*MapStreamResponse_Result) Descriptor() ([]byte, []int)
Deprecated: Use MapStreamResponse_Result.ProtoReflect.Descriptor instead.
func (*MapStreamResponse_Result) GetKeys ¶
func (x *MapStreamResponse_Result) GetKeys() []string
func (*MapStreamResponse_Result) GetTags ¶
func (x *MapStreamResponse_Result) GetTags() []string
func (*MapStreamResponse_Result) GetValue ¶
func (x *MapStreamResponse_Result) GetValue() []byte
func (*MapStreamResponse_Result) ProtoMessage ¶
func (*MapStreamResponse_Result) ProtoMessage()
func (*MapStreamResponse_Result) ProtoReflect ¶
func (x *MapStreamResponse_Result) ProtoReflect() protoreflect.Message
func (*MapStreamResponse_Result) Reset ¶
func (x *MapStreamResponse_Result) Reset()
func (*MapStreamResponse_Result) String ¶
func (x *MapStreamResponse_Result) String() string
type MapStreamServer ¶
type MapStreamServer interface { // MapStreamFn applies a function to each request element and returns a stream. MapStreamFn(*MapStreamRequest, MapStream_MapStreamFnServer) error // IsReady is the heartbeat endpoint for gRPC. IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error) // contains filtered or unexported methods }
MapStreamServer is the server API for MapStream service. All implementations must embed UnimplementedMapStreamServer for forward compatibility
type MapStream_MapStreamFnClient ¶
type MapStream_MapStreamFnClient interface { Recv() (*MapStreamResponse, error) grpc.ClientStream }
type MapStream_MapStreamFnServer ¶
type MapStream_MapStreamFnServer interface { Send(*MapStreamResponse) 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 UnimplementedMapStreamServer ¶
type UnimplementedMapStreamServer struct { }
UnimplementedMapStreamServer must be embedded to have forward compatible implementations.
func (UnimplementedMapStreamServer) IsReady ¶
func (UnimplementedMapStreamServer) IsReady(context.Context, *emptypb.Empty) (*ReadyResponse, error)
func (UnimplementedMapStreamServer) MapStreamFn ¶
func (UnimplementedMapStreamServer) MapStreamFn(*MapStreamRequest, MapStream_MapStreamFnServer) error
type UnsafeMapStreamServer ¶
type UnsafeMapStreamServer interface {
// contains filtered or unexported methods
}
UnsafeMapStreamServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MapStreamServer will result in compilation errors.
Directories ¶
Path | Synopsis |
---|---|
Package mapstreammock is a generated GoMock package.
|
Package mapstreammock is a generated GoMock package. |