streams

Documentation

Index

• type ClientStreamWithContext
  • func NewClientStreamWithContext(stream grpc.ClientStream) *ClientStreamWithContext
  • func (s *ClientStreamWithContext) CloseSend() error
  • func (s *ClientStreamWithContext) Context() context.Context
  • func (s *ClientStreamWithContext) Header() (metadata.MD, error)
  • func (s *ClientStreamWithContext) RecvMsg(m interface{}) error
  • func (s *ClientStreamWithContext) SendMsg(m interface{}) error
  • func (s *ClientStreamWithContext) SetContext(ctx context.Context)
  • func (s *ClientStreamWithContext) Trailer() metadata.MD
• type ContextSetter
• type ContextStream
  • func (s *ContextStream) Context() context.Context
  • func (s *ContextStream) RecvMsg(m any) error
  • func (s *ContextStream) SendMsg(m any) error
  • func (s *ContextStream) SetContext(ctx context.Context)
• type ServerStreamWithContext
  • func NewServerStreamWithContext(stream grpc.ServerStream) *ServerStreamWithContext
  • func (s *ServerStreamWithContext) Context() context.Context
  • func (s *ServerStreamWithContext) RecvMsg(m interface{}) error
  • func (s *ServerStreamWithContext) SendHeader(md metadata.MD) error
  • func (s *ServerStreamWithContext) SendMsg(m interface{}) error
  • func (s *ServerStreamWithContext) SetContext(ctx context.Context)
  • func (s *ServerStreamWithContext) SetHeader(md metadata.MD) error
  • func (s *ServerStreamWithContext) SetTrailer(md metadata.MD)
• type Stream
• type StreamWrapper
  • func NewStreamWithContext(ctx context.Context, s Stream) StreamWrapper

Types

type ClientStreamWithContext

type ClientStreamWithContext struct {
	Stream grpc.ClientStream
	Ctx    context.Context
}

func NewClientStreamWithContext

func NewClientStreamWithContext(stream grpc.ClientStream) *ClientStreamWithContext

func (*ClientStreamWithContext) CloseSend

func (s *ClientStreamWithContext) CloseSend() error

func (*ClientStreamWithContext) Context

func (s *ClientStreamWithContext) Context() context.Context

func (*ClientStreamWithContext) Header

func (s *ClientStreamWithContext) Header() (metadata.MD, error)

func (*ClientStreamWithContext) RecvMsg

func (s *ClientStreamWithContext) RecvMsg(m interface{}) error

func (*ClientStreamWithContext) SendMsg

func (s *ClientStreamWithContext) SendMsg(m interface{}) error

func (*ClientStreamWithContext) SetContext

func (s *ClientStreamWithContext) SetContext(ctx context.Context)

func (*ClientStreamWithContext) Trailer

func (s *ClientStreamWithContext) Trailer() metadata.MD

type ContextSetter

type ContextSetter interface {
	SetContext(ctx context.Context)
}

type ContextStream

type ContextStream struct {
	// contains filtered or unexported fields
}

func (*ContextStream) Context

func (s *ContextStream) Context() context.Context

func (*ContextStream) RecvMsg

func (s *ContextStream) RecvMsg(m any) error

func (*ContextStream) SendMsg

func (s *ContextStream) SendMsg(m any) error

func (*ContextStream) SetContext

func (s *ContextStream) SetContext(ctx context.Context)

type ServerStreamWithContext

type ServerStreamWithContext struct {
	Stream grpc.ServerStream
	Ctx    context.Context
}

func NewServerStreamWithContext

func NewServerStreamWithContext(stream grpc.ServerStream) *ServerStreamWithContext

func (*ServerStreamWithContext) Context

func (s *ServerStreamWithContext) Context() context.Context

func (*ServerStreamWithContext) RecvMsg

func (s *ServerStreamWithContext) RecvMsg(m interface{}) error

func (*ServerStreamWithContext) SendHeader

func (s *ServerStreamWithContext) SendHeader(md metadata.MD) error

func (*ServerStreamWithContext) SendMsg

func (s *ServerStreamWithContext) SendMsg(m interface{}) error

func (*ServerStreamWithContext) SetContext

func (s *ServerStreamWithContext) SetContext(ctx context.Context)

func (*ServerStreamWithContext) SetHeader

func (s *ServerStreamWithContext) SetHeader(md metadata.MD) error

func (*ServerStreamWithContext) SetTrailer

func (s *ServerStreamWithContext) SetTrailer(md metadata.MD)

type Stream

type Stream interface {
	Context() context.Context
	SendMsg(m any) error
	RecvMsg(m any) error
}

type StreamWrapper

type StreamWrapper interface {
	Stream
	ContextSetter
}

func NewStreamWithContext

func NewStreamWithContext(ctx context.Context, s Stream) StreamWrapper