streams

Documentation

Index

• Variables
• type Stream
  • func (s *Stream) Close()
  • func (s *Stream) Done() <-chan struct{}
  • func (s *Stream) Write(m protocol.EncodeDecoder)
• type Streams
  • func New(e *environment.Environment) *Streams
  • func (ss *Streams) DeleteStreamByID(id uint64)
  • func (ss *Streams) GetStreamByID(id uint64) (*Stream, error)
  • func (ss *Streams) RegisterOperations(operations map[protocol.OpCode]func(w, r protocol.EncodeDecoder))
  • func (ss *Streams) Shutdown(ctx context.Context) error

Variables

var ErrStreamNotFound = errors.New("stream could not be found")

Types

type Stream

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

Stream provides a bidirectional communication channel between Olric nodes and clients. It can also be used for node-to-node communication.

func (*Stream) Close

func (s *Stream) Close()

Close calls s.cancel and stops all background goroutines.

func (*Stream) Done

func (s *Stream) Done() <-chan struct{}

func (*Stream) Write

func (s *Stream) Write(m protocol.EncodeDecoder)

type Streams

type Streams struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Streams maps StreamIDs to Stream

func New

func New(e *environment.Environment) *Streams

func (*Streams) DeleteStreamByID

func (ss *Streams) DeleteStreamByID(id uint64)

func (*Streams) GetStreamByID

func (ss *Streams) GetStreamByID(id uint64) (*Stream, error)

func (*Streams) RegisterOperations

func (ss *Streams) RegisterOperations(operations map[protocol.OpCode]func(w, r protocol.EncodeDecoder))

func (*Streams) Shutdown

func (ss *Streams) Shutdown(ctx context.Context) error