Documentation
¶
Index ¶
- type SinkManager
- func (sinkManager *SinkManager) Emit() instrumentation.Context
- func (sinkManager *SinkManager) LatestContainerMetrics(appId string) []*events.Envelope
- func (sinkManager *SinkManager) RecentLogsFor(appId string) []*events.Envelope
- func (sinkManager *SinkManager) RegisterFirehoseSink(sink sinks.Sink) bool
- func (sinkManager *SinkManager) RegisterSink(sink sinks.Sink) bool
- func (sinkManager *SinkManager) SendSyslogErrorToLoggregator(errorMsg string, appId string, sinkUrl string)
- func (sinkManager *SinkManager) SendTo(appId string, receivedMessage *events.Envelope)
- func (sinkManager *SinkManager) SinkDropUpdateChannel() chan<- int64
- func (sinkManager *SinkManager) Start(newAppServiceChan, deletedAppServiceChan <-chan appservice.AppService)
- func (sinkManager *SinkManager) Stop()
- func (sinkManager *SinkManager) UnregisterFirehoseSink(sink sinks.Sink)
- func (sinkManager *SinkManager) UnregisterSink(sink sinks.Sink)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SinkManager ¶
type SinkManager struct {
// contains filtered or unexported fields
}
func New ¶
func New(maxRetainedLogMessages uint32, skipCertVerify bool, blackListManager *blacklist.URLBlacklistManager, logger *gosteno.Logger, dropsondeOrigin string, sinkTimeout, metricTTL time.Duration) *SinkManager
func (*SinkManager) Emit ¶
func (sinkManager *SinkManager) Emit() instrumentation.Context
func (*SinkManager) LatestContainerMetrics ¶
func (sinkManager *SinkManager) LatestContainerMetrics(appId string) []*events.Envelope
func (*SinkManager) RecentLogsFor ¶
func (sinkManager *SinkManager) RecentLogsFor(appId string) []*events.Envelope
func (*SinkManager) RegisterFirehoseSink ¶
func (sinkManager *SinkManager) RegisterFirehoseSink(sink sinks.Sink) bool
func (*SinkManager) RegisterSink ¶
func (sinkManager *SinkManager) RegisterSink(sink sinks.Sink) bool
func (*SinkManager) SendSyslogErrorToLoggregator ¶
func (sinkManager *SinkManager) SendSyslogErrorToLoggregator(errorMsg string, appId string, sinkUrl string)
func (*SinkManager) SendTo ¶
func (sinkManager *SinkManager) SendTo(appId string, receivedMessage *events.Envelope)
func (*SinkManager) SinkDropUpdateChannel ¶
func (sinkManager *SinkManager) SinkDropUpdateChannel() chan<- int64
func (*SinkManager) Start ¶
func (sinkManager *SinkManager) Start(newAppServiceChan, deletedAppServiceChan <-chan appservice.AppService)
func (*SinkManager) Stop ¶
func (sinkManager *SinkManager) Stop()
func (*SinkManager) UnregisterFirehoseSink ¶
func (sinkManager *SinkManager) UnregisterFirehoseSink(sink sinks.Sink)
func (*SinkManager) UnregisterSink ¶
func (sinkManager *SinkManager) UnregisterSink(sink sinks.Sink)
Source Files
Click to show internal directories.
Click to hide internal directories.