drpcstream

README

package drpcstream

import "storj.io/drpc/drpcstream"

package drpcstream sends protobufs using the dprc wire protocol.

Usage

type Stream

type Stream struct {
}

func New

func New(ctx context.Context, sid uint64, wr *drpcwire.Writer) *Stream

func (*Stream) CancelContext

func (s *Stream) CancelContext()

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) CloseQueue

func (s *Stream) CloseQueue()

func (*Stream) CloseSend

func (s *Stream) CloseSend() error

func (*Stream) Context

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

func (*Stream) DoneSig

func (s *Stream) DoneSig() *drpcsignal.Signal

func (*Stream) ID

func (s *Stream) ID() uint64

func (*Stream) MsgRecv

func (s *Stream) MsgRecv(msg drpc.Message) error

func (*Stream) MsgSend

func (s *Stream) MsgSend(msg drpc.Message) error

func (*Stream) Queue

func (s *Stream) Queue() chan drpcwire.Packet

func (*Stream) QueueClosed

func (s *Stream) QueueClosed() bool

func (*Stream) RawFlush

func (s *Stream) RawFlush() (err error)

func (*Stream) RawRecv

func (s *Stream) RawRecv() ([]byte, error)

func (*Stream) RawWrite

func (s *Stream) RawWrite(kind drpcwire.Kind, data []byte) error

func (*Stream) RemoteErrSig

func (s *Stream) RemoteErrSig() *drpcsignal.Signal

func (*Stream) SendCancel

func (s *Stream) SendCancel() error

func (*Stream) SendError

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

func (*Stream) SendSig

func (s *Stream) SendSig() *drpcsignal.Signal

Documentation

Overview

package drpcstream sends protobufs using the dprc wire protocol.

Index

• type Stream
  • func New(ctx context.Context, sid uint64, wr *drpcwire.Writer) *Stream
  • func (s *Stream) CancelContext()
  • func (s *Stream) Close() error
  • func (s *Stream) CloseQueue()
  • func (s *Stream) CloseSend() error
  • func (s *Stream) Context() context.Context
  • func (s *Stream) DoneSig() *drpcsignal.Signal
  • func (s *Stream) ID() uint64
  • func (s *Stream) MsgRecv(msg drpc.Message) error
  • func (s *Stream) MsgSend(msg drpc.Message) error
  • func (s *Stream) Queue() chan drpcwire.Packet
  • func (s *Stream) QueueClosed() bool
  • func (s *Stream) RawFlush() (err error)
  • func (s *Stream) RawRecv() ([]byte, error)
  • func (s *Stream) RawWrite(kind drpcwire.Kind, data []byte) error
  • func (s *Stream) RemoteErrSig() *drpcsignal.Signal
  • func (s *Stream) SendCancel() error
  • func (s *Stream) SendError(err error) error
  • func (s *Stream) SendSig() *drpcsignal.Signal

Types

type Stream

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

func New

func New(ctx context.Context, sid uint64, wr *drpcwire.Writer) *Stream

func (*Stream) CancelContext

func (s *Stream) CancelContext()

func (*Stream) Close

func (s *Stream) Close() error

func (*Stream) CloseQueue

func (s *Stream) CloseQueue()

func (*Stream) CloseSend

func (s *Stream) CloseSend() error

func (*Stream) Context

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

func (*Stream) DoneSig

func (s *Stream) DoneSig() *drpcsignal.Signal

func (*Stream) ID

func (s *Stream) ID() uint64

func (*Stream) MsgRecv

func (s *Stream) MsgRecv(msg drpc.Message) error

func (*Stream) MsgSend

func (s *Stream) MsgSend(msg drpc.Message) error

func (*Stream) Queue

func (s *Stream) Queue() chan drpcwire.Packet

func (*Stream) QueueClosed

func (s *Stream) QueueClosed() bool

func (*Stream) RawFlush

func (s *Stream) RawFlush() (err error)

func (*Stream) RawRecv

func (s *Stream) RawRecv() ([]byte, error)

func (*Stream) RawWrite

func (s *Stream) RawWrite(kind drpcwire.Kind, data []byte) error

func (*Stream) RemoteErrSig

func (s *Stream) RemoteErrSig() *drpcsignal.Signal

func (*Stream) SendCancel

func (s *Stream) SendCancel() error

func (*Stream) SendError

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

func (*Stream) SendSig

func (s *Stream) SendSig() *drpcsignal.Signal