Documentation ¶ Index ¶ type LogStream func New(bufferSize int, bufferConstructor func(int) logbuffer.LogBuffer) *LogStream func (e *LogStream) AddTopic(topic string, signal chan struct{}) func (e *LogStream) DeQueue(topic string) (log.Log, error) func (e *LogStream) EnQueue(topic string, value log.Log) error func (e *LogStream) RemoveTopic(topic string) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type LogStream ¶ type LogStream struct { // contains filtered or unexported fields } func New ¶ func New(bufferSize int, bufferConstructor func(int) logbuffer.LogBuffer) *LogStream func (*LogStream) AddTopic ¶ func (e *LogStream) AddTopic(topic string, signal chan struct{}) func (*LogStream) DeQueue ¶ func (e *LogStream) DeQueue(topic string) (log.Log, error) func (*LogStream) EnQueue ¶ func (e *LogStream) EnQueue(topic string, value log.Log) error func (*LogStream) RemoveTopic ¶ func (e *LogStream) RemoveTopic(topic string) Source Files ¶ View all Source files logstream.go Directories ¶ Show internal Expand all Path Synopsis globalque Click to show internal directories. Click to hide internal directories.