local

Documentation

Index

• func NewClientStream(ctx context.Context, resultsChan chan record.Record, errorChan chan error) stream.ClientStream
• func NewServerStream(ctx context.Context, resultsChan chan record.Record, errorChan chan error) stream.ServerStream
• type ClientStream
  • func (s *ClientStream) Close() error
  • func (s *ClientStream) Recv() (record.Record, error)
• type ServerStream
  • func (s *ServerStream) Close() error
  • func (s *ServerStream) SendError(err error) error
  • func (s *ServerStream) SendResult(r record.Record) error

Functions

func NewClientStream

func NewClientStream(ctx context.Context, resultsChan chan record.Record, errorChan chan error) stream.ClientStream

func NewServerStream

func NewServerStream(ctx context.Context, resultsChan chan record.Record, errorChan chan error) stream.ServerStream

TODO: context

Types

type ClientStream

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

func (*ClientStream) Close

func (s *ClientStream) Close() error

func (*ClientStream) Recv

func (s *ClientStream) Recv() (record.Record, error)

type ServerStream

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

The guy that actually writes things out

func (*ServerStream) Close

func (s *ServerStream) Close() error

Close will close the server stream, disallowing all future sends

func (*ServerStream) SendError

func (s *ServerStream) SendError(err error) error

SendError will send the error err down the stream or return an error on its own

func (*ServerStream) SendResult

func (s *ServerStream) SendResult(r record.Record) error

SendResult will send the result r or return an error.