Versions in this module Expand all Collapse all v0 v0.12.1 Jan 3, 2025 v0.12.0 Dec 10, 2024 Changes in this version + const StreamingBidirectional + const StreamingClient + const StreamingNone + const StreamingServer + const StreamingUnary + func WithStreamArgsContext(ctx context.Context, args StreamArgs) context.Context + type BidiStreamingClient interface + Recv func(ctx context.Context) (*Res, error) + Send func(ctx context.Context, req *Req) error + type BidiStreamingHandler func(ctx context.Context, stream BidiStreamingServer[Req, Res]) error + type BidiStreamingServer interface + Recv func(ctx context.Context) (*Req, error) + Send func(ctx context.Context, res *Res) error + type ClientProvider interface + NewStream func(ctx context.Context, ri rpcinfo.RPCInfo) (ClientStream, error) + type ClientStream interface + CloseSend func(ctx context.Context) error + type ClientStreamMetadata interface + Header func() (Header, error) + Trailer func() (Trailer, error) + type ClientStreamingClient interface + CloseAndRecv func(ctx context.Context) (*Res, error) + Send func(ctx context.Context, req *Req) error + type ClientStreamingHandler func(ctx context.Context, stream ClientStreamingServer[Req, Res]) (*Res, error) + type ClientStreamingServer interface + Recv func(ctx context.Context) (*Req, error) + type EventHandler func(ctx context.Context, evt stats.Event, err error) + type GenericClientStream struct + func NewGenericClientStream[Req, Res any](cs ClientStream) *GenericClientStream[Req, Res] + func (x *GenericClientStream[Req, Res]) CloseAndRecv(ctx context.Context) (*Res, error) + func (x *GenericClientStream[Req, Res]) Recv(ctx context.Context) (m *Res, err error) + func (x *GenericClientStream[Req, Res]) RecvMsg(ctx context.Context, m any) (err error) + func (x *GenericClientStream[Req, Res]) Send(ctx context.Context, m *Req) error + func (x *GenericClientStream[Req, Res]) SendMsg(ctx context.Context, m any) error + func (x *GenericClientStream[Req, Res]) SetStreamRecvMiddleware(e StreamRecvMiddleware) + func (x *GenericClientStream[Req, Res]) SetStreamSendMiddleware(e StreamSendMiddleware) + type GenericServerStream struct + func NewGenericServerStream[Req, Res any](ss ServerStream) *GenericServerStream[Req, Res] + func (x *GenericServerStream[Req, Res]) Recv(ctx context.Context) (m *Req, err error) + func (x *GenericServerStream[Req, Res]) RecvMsg(ctx context.Context, m any) (err error) + func (x *GenericServerStream[Req, Res]) Send(ctx context.Context, m *Res) error + func (x *GenericServerStream[Req, Res]) SendAndClose(ctx context.Context, m *Res) error + func (x *GenericServerStream[Req, Res]) SendMsg(ctx context.Context, m any) error + func (x *GenericServerStream[Req, Res]) SetStreamRecvMiddleware(e StreamRecvMiddleware) + func (x *GenericServerStream[Req, Res]) SetStreamSendMiddleware(e StreamSendMiddleware) + type Header map[string]string + type MutableStreamArgs interface + SetStream func(st Stream) + SetStreamMiddleware func(mw StreamMiddleware) + SetStreamRecvMiddleware func(mw StreamRecvMiddleware) + SetStreamSendMiddleware func(mw StreamSendMiddleware) + func AsMutableStreamArgs(args StreamArgs) MutableStreamArgs + type ServerProvider interface + Available func(ctx context.Context, conn net.Conn) bool + OnActive func(ctx context.Context, conn net.Conn) (context.Context, error) + OnInactive func(ctx context.Context, conn net.Conn) (context.Context, error) + OnStream func(ctx context.Context, conn net.Conn) (context.Context, ServerStream, error) + OnStreamFinish func(ctx context.Context, ss ServerStream, err error) (context.Context, error) + type ServerStream interface + type ServerStreamMetadata interface + SendHeader func(hd Header) error + SetHeader func(hd Header) error + SetTrailer func(hd Trailer) error + type ServerStreamingClient interface + Recv func(ctx context.Context) (*Res, error) + type ServerStreamingHandler func(ctx context.Context, req *Req, stream ServerStreamingServer[Res]) error + type ServerStreamingServer interface + Send func(ctx context.Context, res *Res) error + type Stream interface + RecvMsg func(ctx context.Context, m any) error + SendMsg func(ctx context.Context, m any) error + func AsStream(args interface{}) (Stream, error) + type StreamArgs interface + Stream func() Stream + func GetStreamArgsFromContext(ctx context.Context) (args StreamArgs) + func NewStreamArgs(stream Stream) StreamArgs + type StreamEndpoint func(ctx context.Context, streamArgs StreamArgs, reqArgs StreamReqArgs, ...) (err error) + type StreamMiddleware func(next StreamEndpoint) StreamEndpoint + func StreamMiddlewareChain(mws ...StreamMiddleware) StreamMiddleware + type StreamMiddlewaresArgs interface + Middlewares func() (StreamMiddleware, StreamRecvMiddleware, StreamSendMiddleware) + type StreamRecvEndpoint func(ctx context.Context, stream Stream, res any) (err error) + type StreamRecvMiddleware func(next StreamRecvEndpoint) StreamRecvEndpoint + func NewStreamRecvStatMiddleware(traceCtx context.Context, ehandler EventHandler) StreamRecvMiddleware + func StreamRecvMiddlewareChain(mws ...StreamRecvMiddleware) StreamRecvMiddleware + type StreamReqArgs interface + Req func() any + SetReq func(req any) + func NewStreamReqArgs(req any) StreamReqArgs + type StreamResArgs interface + Res func() any + SetRes func(res any) + func NewStreamResArgs(res any) StreamResArgs + type StreamSendEndpoint func(ctx context.Context, stream Stream, req any) (err error) + type StreamSendMiddleware func(next StreamSendEndpoint) StreamSendEndpoint + func NewStreamSendStatMiddleware(traceCtx context.Context, ehandler EventHandler) StreamSendMiddleware + func StreamSendMiddlewareChain(mws ...StreamSendMiddleware) StreamSendMiddleware + type StreamingMode = serviceinfo.StreamingMode + type Trailer map[string]string + type UnaryHandler func(ctx context.Context, req *Req) (*Res, error)
Go to main page