groupedsinks

Documentation

Index

• type GroupedSinks
  • func NewGroupedSinks() *GroupedSinks
  • func (group *GroupedSinks) Broadcast(appId string, msg *events.Envelope)
  • func (group *GroupedSinks) BroadcastError(appId string, errorMsg *events.Envelope)
  • func (group *GroupedSinks) BroadcastMessageToFirehoses(msg *events.Envelope)
  • func (group *GroupedSinks) CloseAndDelete(sink sinks.Sink) bool
  • func (group *GroupedSinks) CloseAndDeleteFirehose(sink sinks.Sink) bool
  • func (group *GroupedSinks) ContainerMetricsFor(appId string) *containermetric.ContainerMetricSink
  • func (group *GroupedSinks) CountFor(appId string) int
  • func (group *GroupedSinks) DeleteAll()
  • func (group *GroupedSinks) DrainFor(appId, drainUrl string) sinks.Sink
  • func (group *GroupedSinks) DrainsFor(appId string) []sinks.Sink
  • func (group *GroupedSinks) DumpFor(appId string) *dump.DumpSink
  • func (group *GroupedSinks) IsFirehoseRegistered(sink sinks.Sink) bool
  • func (group *GroupedSinks) RegisterAppSink(in chan<- *events.Envelope, sink sinks.Sink) bool
  • func (group *GroupedSinks) RegisterFirehoseSink(in chan<- *events.Envelope, sink sinks.Sink) bool
  • func (group *GroupedSinks) WebsocketSinksFor(appId string) []websocket.WebsocketSink

Types

type GroupedSinks

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

func NewGroupedSinks

func NewGroupedSinks() *GroupedSinks

func (*GroupedSinks) Broadcast

func (group *GroupedSinks) Broadcast(appId string, msg *events.Envelope)

func (*GroupedSinks) BroadcastError

func (group *GroupedSinks) BroadcastError(appId string, errorMsg *events.Envelope)

func (*GroupedSinks) BroadcastMessageToFirehoses

func (group *GroupedSinks) BroadcastMessageToFirehoses(msg *events.Envelope)

func (*GroupedSinks) CloseAndDelete

func (group *GroupedSinks) CloseAndDelete(sink sinks.Sink) bool

func (*GroupedSinks) CloseAndDeleteFirehose

func (group *GroupedSinks) CloseAndDeleteFirehose(sink sinks.Sink) bool

func (*GroupedSinks) ContainerMetricsFor

func (group *GroupedSinks) ContainerMetricsFor(appId string) *containermetric.ContainerMetricSink

func (*GroupedSinks) CountFor

func (group *GroupedSinks) CountFor(appId string) int

func (*GroupedSinks) DeleteAll

func (group *GroupedSinks) DeleteAll()

func (*GroupedSinks) DrainFor

func (group *GroupedSinks) DrainFor(appId, drainUrl string) sinks.Sink

func (*GroupedSinks) DrainsFor

func (group *GroupedSinks) DrainsFor(appId string) []sinks.Sink

func (*GroupedSinks) DumpFor

func (group *GroupedSinks) DumpFor(appId string) *dump.DumpSink

func (*GroupedSinks) IsFirehoseRegistered

func (group *GroupedSinks) IsFirehoseRegistered(sink sinks.Sink) bool

func (*GroupedSinks) RegisterAppSink

func (group *GroupedSinks) RegisterAppSink(in chan<- *events.Envelope, sink sinks.Sink) bool

func (*GroupedSinks) RegisterFirehoseSink

func (group *GroupedSinks) RegisterFirehoseSink(in chan<- *events.Envelope, sink sinks.Sink) bool

func (*GroupedSinks) WebsocketSinksFor

func (group *GroupedSinks) WebsocketSinksFor(appId string) []websocket.WebsocketSink