Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

streamx

package

Go to main page

Versions in this module

v0

v0.12.4

Apr 8, 2025

v0.12.3

Feb 27, 2025

v0.12.2

Feb 18, 2025

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)