Versions in this module Expand all Collapse all v0 v0.3.0 Mar 26, 2025 Changes in this version + const EndpointStreamsAuthorizedCall + const EndpointStreamsCall + const HandlerStreams + const Streams_AuthorizedCall_FullMethodName + const Streams_Call_FullMethodName + var File_echo_echo_proto protoreflect.FileDescriptor + var Streams_ServiceDesc = grpc.ServiceDesc + func RegisterStreamsHandler(handler any) server.RegistrationFunc + type CallRequest struct + Name string + func (*CallRequest) Descriptor() ([]byte, []int) + func (*CallRequest) ProtoMessage() + func (x *CallRequest) GetName() string + 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 DRPCStreamsDescription struct + func (DRPCStreamsDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool) + func (DRPCStreamsDescription) NumMethods() int + type DRPCStreamsServer interface + AuthorizedCall func(context.Context, *CallRequest) (*CallResponse, error) + Call func(context.Context, *CallRequest) (*CallResponse, error) + type DRPCStreamsUnimplementedServer struct + func (s *DRPCStreamsUnimplementedServer) AuthorizedCall(context.Context, *CallRequest) (*CallResponse, error) + func (s *DRPCStreamsUnimplementedServer) Call(context.Context, *CallRequest) (*CallResponse, error) + type DRPCStreams_AuthorizedCallStream interface + SendAndClose func(*CallResponse) error + type DRPCStreams_CallStream interface + SendAndClose func(*CallResponse) error + type StreamsClient struct + func NewStreamsClient(client client.Client) *StreamsClient + func (c *StreamsClient) AuthorizedCall(ctx context.Context, service string, req *CallRequest, ...) (*CallResponse, error) + func (c *StreamsClient) Call(ctx context.Context, service string, req *CallRequest, ...) (*CallResponse, error) + type StreamsHandler interface + AuthorizedCall func(ctx context.Context, req *CallRequest) (*CallResponse, error) + Call func(ctx context.Context, req *CallRequest) (*CallResponse, error) + type StreamsServer interface + AuthorizedCall func(context.Context, *CallRequest) (*CallResponse, error) + Call func(context.Context, *CallRequest) (*CallResponse, error) + type UnimplementedStreamsServer struct + func (UnimplementedStreamsServer) AuthorizedCall(context.Context, *CallRequest) (*CallResponse, error) + func (UnimplementedStreamsServer) Call(context.Context, *CallRequest) (*CallResponse, error) + type UnsafeStreamsServer interface
Go to main page