sinkmanager

Documentation

Index

• type SinkManager
  • func New(maxRetainedLogMessages uint32, skipCertVerify bool, ...) *SinkManager
  • func (sm *SinkManager) IsFirehoseRegistered(sink sinks.Sink) bool
  • func (sm *SinkManager) LatestContainerMetrics(appId string) []*events.Envelope
  • func (sm *SinkManager) RecentLogsFor(appId string) []*events.Envelope
  • func (sm *SinkManager) RegisterFirehoseSink(sink sinks.Sink) bool
  • func (sm *SinkManager) RegisterSink(sink sinks.Sink) bool
  • func (sm *SinkManager) SendSyslogErrorToLoggregator(errorMsg string, appId string)
  • func (sm *SinkManager) SendTo(appID string, msg *events.Envelope)
  • func (sm *SinkManager) Start(newAppServiceChan, deletedAppServiceChan <-chan appservice.AppService)
  • func (sm *SinkManager) Stop()
  • func (sm *SinkManager) UnregisterFirehoseSink(sink sinks.Sink)
  • func (sm *SinkManager) UnregisterSink(sink sinks.Sink)

Types

type SinkManager

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

func New

func New(
	maxRetainedLogMessages uint32,
	skipCertVerify bool,
	blackListManager *blacklist.URLBlacklistManager,
	messageDrainBufferSize uint,
	dropsondeOrigin string,
	sinkTimeout,
	sinkIOTimeout,
	metricTTL,
	dialTimeout time.Duration,
) *SinkManager

func (*SinkManager) IsFirehoseRegistered

func (sm *SinkManager) IsFirehoseRegistered(sink sinks.Sink) bool

func (*SinkManager) LatestContainerMetrics

func (sm *SinkManager) LatestContainerMetrics(appId string) []*events.Envelope

func (*SinkManager) RecentLogsFor

func (sm *SinkManager) RecentLogsFor(appId string) []*events.Envelope

func (*SinkManager) RegisterFirehoseSink

func (sm *SinkManager) RegisterFirehoseSink(sink sinks.Sink) bool

func (*SinkManager) RegisterSink

func (sm *SinkManager) RegisterSink(sink sinks.Sink) bool

func (*SinkManager) SendSyslogErrorToLoggregator

func (sm *SinkManager) SendSyslogErrorToLoggregator(errorMsg string, appId string)

func (*SinkManager) SendTo

func (sm *SinkManager) SendTo(appID string, msg *events.Envelope)

func (*SinkManager) Start

func (sm *SinkManager) Start(newAppServiceChan, deletedAppServiceChan <-chan appservice.AppService)

func (*SinkManager) Stop

func (sm *SinkManager) Stop()

func (*SinkManager) UnregisterFirehoseSink

func (sm *SinkManager) UnregisterFirehoseSink(sink sinks.Sink)

func (*SinkManager) UnregisterSink

func (sm *SinkManager) UnregisterSink(sink sinks.Sink)