Versions in this module Expand all Collapse all v0 v0.2.1 Apr 7, 2025 v0.2.0 Mar 26, 2025 Changes in this version + const EndpointStreamsCall v0.1.0 Feb 24, 2025 Changes in this version + const HandlerStreams + const Streams_Call_FullMethodName + var File_echo_proto protoreflect.FileDescriptor + var Streams_ServiceDesc = grpc.ServiceDesc + func RegisterStreamsHandler(handler StreamsHandler) server.RegistrationFunc + type CallRequest struct + Name string + Sleep uint64 + func (*CallRequest) Descriptor() ([]byte, []int) + func (*CallRequest) ProtoMessage() + func (x *CallRequest) GetName() string + func (x *CallRequest) GetSleep() uint64 + func (x *CallRequest) ProtoReflect() protoreflect.Message + func (x *CallRequest) Reset() + func (x *CallRequest) String() string + type CallResponse struct + Msg string + Payload []byte + func (*CallResponse) Descriptor() ([]byte, []int) + func (*CallResponse) ProtoMessage() + func (x *CallResponse) GetMsg() string + func (x *CallResponse) GetPayload() []byte + func (x *CallResponse) ProtoReflect() protoreflect.Message + func (x *CallResponse) Reset() + func (x *CallResponse) String() string + type StreamsClient struct + func NewStreamsClient(client client.Client) *StreamsClient + func (c *StreamsClient) Call(ctx context.Context, service string, req *CallRequest, ...) (*CallResponse, error) + type StreamsHandler interface + Call func(ctx context.Context, req *CallRequest) (*CallResponse, error) + type StreamsServer interface + Call func(context.Context, *CallRequest) (*CallResponse, error) + type UnimplementedStreamsServer struct + func (UnimplementedStreamsServer) Call(context.Context, *CallRequest) (*CallResponse, error) + type UnsafeStreamsServer interface
Go to main page