streams

Documentation

Index

• type Stream
  • func (s *Stream) ReceiveEvents() <-chan trace.Event
• type StreamsManager
  • func NewStreamsManager() *StreamsManager
  • func (sm *StreamsManager) Close()
  • func (sm *StreamsManager) Publish(ctx context.Context, event trace.Event)
  • func (sm *StreamsManager) Subscribe(policyMask uint64, chanSize int) *Stream
  • func (sm *StreamsManager) Unsubscribe(stream *Stream)

Types

type Stream

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

Stream is a stream of events

func (*Stream) ReceiveEvents

func (s *Stream) ReceiveEvents() <-chan trace.Event

ReceiveEvents returns a read-only channel for receiving events from the stream

type StreamsManager

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

StreamManager manages streams

func NewStreamsManager

func NewStreamsManager() *StreamsManager

NewStreamManager creates a new stream manager

func (*StreamsManager) Close

func (sm *StreamsManager) Close()

Close closes all streams

func (*StreamsManager) Publish

func (sm *StreamsManager) Publish(ctx context.Context, event trace.Event)

Publish publishes an event to all streams

func (*StreamsManager) Subscribe

func (sm *StreamsManager) Subscribe(policyMask uint64, chanSize int) *Stream

Subscribe adds a stream to the manager

func (*StreamsManager) Unsubscribe

func (sm *StreamsManager) Unsubscribe(stream *Stream)

Unsubscribe removes a stream from the manager