handler

Documentation

Index

• type Stream
  • func NewStream() (*Stream, error)
  • func (s *Stream) Create(ctx context.Context, req *pb.CreateRequest, resp *pb.CreateResponse) error
  • func (s *Stream) Publish(ctx context.Context, stream pb.Stream_PublishStream) error
  • func (s *Stream) Stop() error
  • func (s *Stream) Subscribe(ctx context.Context, req *pb.SubscribeRequest, ...) error

Types

type Stream

type Stream struct {
	// Mux maps streams to data dispatchers
	Mux *mux.Mux
	// contains filtered or unexported fields
}

Stream is a data stream

func NewStream

func NewStream() (*Stream, error)

func (*Stream) Create

func (s *Stream) Create(ctx context.Context, req *pb.CreateRequest, resp *pb.CreateResponse) error

Create creates new data stream. It creates new stream dispatcher. It returns error if the requested stream id has already been registered.

func (*Stream) Publish

func (s *Stream) Publish(ctx context.Context, stream pb.Stream_PublishStream) error

Publish publishes data on stream

func (*Stream) Stop

func (s *Stream) Stop() error

func (*Stream) Subscribe

func (s *Stream) Subscribe(ctx context.Context, req *pb.SubscribeRequest, stream pb.Stream_SubscribeStream) error