firehose_group

Documentation

Index

• func NewFirehoseGroup(logger *gosteno.Logger) *firehoseGroup
• type FirehoseGroup

Functions

func NewFirehoseGroup

func NewFirehoseGroup(logger *gosteno.Logger) *firehoseGroup

Types

type FirehoseGroup

type FirehoseGroup interface {
	AddSink(sink sinks.Sink, in chan<- *events.Envelope) bool
	RemoveSink(fsink sinks.Sink) bool
	RemoveAllSinks()
	IsEmpty() bool
	BroadcastMessage(msg *events.Envelope)
}