Documentation ¶
Index ¶
- type AppInfoRepository
- type FirehoseClient
- type Heartbeater
- type LabelMaker
- type Log
- type LogAdapter
- type MetricAdapter
- type MetricsBuffer
- type MockClient
- func (mc *MockClient) CreateMetricDescriptor(request *monitoringpb.CreateMetricDescriptorRequest) error
- func (mc *MockClient) ListMetricDescriptors(request *monitoringpb.ListMetricDescriptorsRequest) ([]*metricpb.MetricDescriptor, error)
- func (mc *MockClient) Post(req *monitoringpb.CreateTimeSeriesRequest) error
- type MockLogger
- func (m *MockLogger) Debug(action string, data ...lager.Data)
- func (m *MockLogger) Error(action string, err error, data ...lager.Data)
- func (m *MockLogger) Fatal(action string, err error, data ...lager.Data)
- func (m *MockLogger) Info(action string, data ...lager.Data)
- func (m *MockLogger) LastLog() Log
- func (m *MockLogger) RegisterSink(lager.Sink)
- func (m *MockLogger) Session(task string, data ...lager.Data) lager.Logger
- func (m *MockLogger) SessionName() string
- func (m *MockLogger) WithData(lager.Data) lager.Logger
- type MockSerializer
- type Sink
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppInfoRepository ¶
type AppInfoRepository struct {
AppInfoMap map[string]cloudfoundry.AppInfo
}
func (*AppInfoRepository) GetAppInfo ¶
func (air *AppInfoRepository) GetAppInfo(guid string) cloudfoundry.AppInfo
type FirehoseClient ¶
func NewFirehoseClient ¶
func NewFirehoseClient() *FirehoseClient
func (*FirehoseClient) Connect ¶
func (fc *FirehoseClient) Connect() (<-chan *events.Envelope, <-chan error)
func (*FirehoseClient) SendEvents ¶
func (fc *FirehoseClient) SendEvents(eventTypes ...events.Envelope_EventType)
type Heartbeater ¶
type Heartbeater struct {
// contains filtered or unexported fields
}
func NewHeartbeater ¶
func NewHeartbeater() *Heartbeater
func (*Heartbeater) GetCount ¶
func (h *Heartbeater) GetCount(name string) int
func (*Heartbeater) Increment ¶
func (h *Heartbeater) Increment(name string)
func (*Heartbeater) IsRunning ¶
func (h *Heartbeater) IsRunning() bool
func (*Heartbeater) Start ¶
func (h *Heartbeater) Start()
func (*Heartbeater) Stop ¶
func (h *Heartbeater) Stop()
type LabelMaker ¶
type LogAdapter ¶
type LogAdapter struct {
PostedLogs []stackdriver.Log
}
func (*LogAdapter) Flush ¶
func (la *LogAdapter) Flush()
func (*LogAdapter) PostLog ¶
func (la *LogAdapter) PostLog(log *stackdriver.Log)
type MetricAdapter ¶
type MetricAdapter struct { PostMetricsFn func(metrics []stackdriver.Metric) error PostMetricError error PostedMetrics []stackdriver.Metric Mutex sync.Mutex }
func (*MetricAdapter) GetPostedMetrics ¶
func (m *MetricAdapter) GetPostedMetrics() []stackdriver.Metric
func (*MetricAdapter) PostMetrics ¶
func (m *MetricAdapter) PostMetrics(metrics []stackdriver.Metric) error
type MetricsBuffer ¶
type MetricsBuffer struct {
PostedMetrics []stackdriver.Metric
}
func (*MetricsBuffer) IsEmpty ¶
func (m *MetricsBuffer) IsEmpty() bool
func (*MetricsBuffer) PostMetric ¶
func (m *MetricsBuffer) PostMetric(metric *stackdriver.Metric)
type MockClient ¶
type MockClient struct { Mutex sync.Mutex MetricReqs []*monitoringpb.CreateTimeSeriesRequest DescriptorReqs []*monitoringpb.CreateMetricDescriptorRequest ListErr error CreateMetricDescriptorFn func(request *monitoringpb.CreateMetricDescriptorRequest) error }
func (*MockClient) CreateMetricDescriptor ¶
func (mc *MockClient) CreateMetricDescriptor(request *monitoringpb.CreateMetricDescriptorRequest) error
func (*MockClient) ListMetricDescriptors ¶
func (mc *MockClient) ListMetricDescriptors(request *monitoringpb.ListMetricDescriptorsRequest) ([]*metricpb.MetricDescriptor, error)
func (*MockClient) Post ¶
func (mc *MockClient) Post(req *monitoringpb.CreateTimeSeriesRequest) error
type MockLogger ¶
type MockLogger struct {
// contains filtered or unexported fields
}
func (*MockLogger) LastLog ¶
func (m *MockLogger) LastLog() Log
func (*MockLogger) RegisterSink ¶
func (m *MockLogger) RegisterSink(lager.Sink)
func (*MockLogger) SessionName ¶
func (m *MockLogger) SessionName() string
type MockSerializer ¶
type MockSerializer struct { GetLogFn func(*events.Envelope) *stackdriver.Log GetMetricsFn func(*events.Envelope) ([]stackdriver.Metric, error) IsLogFn func(*events.Envelope) bool }
func (*MockSerializer) GetLog ¶
func (m *MockSerializer) GetLog(envelope *events.Envelope) *stackdriver.Log
func (*MockSerializer) GetMetrics ¶
func (m *MockSerializer) GetMetrics(envelope *events.Envelope) ([]stackdriver.Metric, error)
Click to show internal directories.
Click to hide internal directories.