mocks

Documentation

Index

• type AppInfoRepository
  • func (air *AppInfoRepository) GetAppInfo(guid string) cloudfoundry.AppInfo
• type FirehoseClient
  • func NewFirehoseClient() *FirehoseClient
  • func (fc *FirehoseClient) Connect() (<-chan *events.Envelope, <-chan error)
  • func (fc *FirehoseClient) SendEvents(eventTypes ...events.Envelope_EventType)
• type LabelMaker
  • func (lm *LabelMaker) LogLabels(*events.Envelope) map[string]string
  • func (lm *LabelMaker) MetricLabels(*events.Envelope, bool) map[string]string
• type Log
• type LogAdapter
  • func (la *LogAdapter) Flush() error
  • func (la *LogAdapter) PostLog(log *messages.Log)
• type MetricAdapter
  • func (m *MetricAdapter) GetPostedMetrics() []*messages.Metric
  • func (m *MetricAdapter) PostMetrics(metrics []*messages.Metric)
• type MetricsBuffer
  • func (m *MetricsBuffer) IsEmpty() bool
  • func (m *MetricsBuffer) PostMetrics(metrics []*messages.Metric)
• type MockClient
  • func (mc *MockClient) CreateMetricDescriptor(request *monitoring.CreateMetricDescriptorRequest) error
  • func (mc *MockClient) ListMetricDescriptors(request *monitoring.ListMetricDescriptorsRequest) ([]*metric.MetricDescriptor, error)
  • func (mc *MockClient) Post(req *monitoring.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) Logs() []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
  • func (m *MockSerializer) GetLog(envelope *events.Envelope) *messages.Log
  • func (m *MockSerializer) GetMetrics(envelope *events.Envelope) ([]messages.Metric, error)
  • func (m *MockSerializer) IsLog(envelope *events.Envelope) bool
• type NozzleSink
  • func (s *NozzleSink) LastEnvelope() *events.Envelope
  • func (s *NozzleSink) Receive(envelope *events.Envelope)
• type TelemetrySink
  • func (ts *TelemetrySink) GetInit() []*expvar.KeyValue
  • func (ts *TelemetrySink) GetLastReport() []*expvar.KeyValue
  • func (ts *TelemetrySink) Init(val []*expvar.KeyValue)
  • func (ts *TelemetrySink) Report(val []*expvar.KeyValue)

Types

type AppInfoRepository

type AppInfoRepository struct {
	AppInfoMap map[string]cloudfoundry.AppInfo
}

func (*AppInfoRepository) GetAppInfo

func (air *AppInfoRepository) GetAppInfo(guid string) cloudfoundry.AppInfo

type FirehoseClient

type FirehoseClient struct {
	Messages chan *events.Envelope
	Errs     chan error
}

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 LabelMaker

type LabelMaker struct {
	Labels map[string]string
}

func (*LabelMaker) LogLabels

func (lm *LabelMaker) LogLabels(*events.Envelope) map[string]string

func (*LabelMaker) MetricLabels

func (lm *LabelMaker) MetricLabels(*events.Envelope, bool) map[string]string

type Log

type Log struct {
	Level  lager.LogLevel
	Action string
	Err    error
	Datas  []lager.Data
}

type LogAdapter

type LogAdapter struct {
	PostedLogs []messages.Log
}

func (*LogAdapter) Flush

func (la *LogAdapter) Flush() error

func (*LogAdapter) PostLog

func (la *LogAdapter) PostLog(log *messages.Log)

type MetricAdapter

type MetricAdapter struct {
	sync.Mutex

	PostMetricsFn    func(metrics []*messages.Metric) error
	PostMetricsCount int
	PostedMetrics    []*messages.Metric
}

func (*MetricAdapter) GetPostedMetrics

func (m *MetricAdapter) GetPostedMetrics() []*messages.Metric

func (*MetricAdapter) PostMetrics

func (m *MetricAdapter) PostMetrics(metrics []*messages.Metric)

type MetricsBuffer

type MetricsBuffer struct {
	PostedMetrics []messages.Metric
}

func (*MetricsBuffer) IsEmpty

func (m *MetricsBuffer) IsEmpty() bool

func (*MetricsBuffer) PostMetrics

func (m *MetricsBuffer) PostMetrics(metrics []*messages.Metric)

type MockClient

type MockClient struct {
	Mutex          sync.Mutex
	MetricReqs     []*monitoring.CreateTimeSeriesRequest
	TimeSeries     []*monitoring.TimeSeries
	DescriptorReqs []*monitoring.CreateMetricDescriptorRequest
	ListErr        error

	CreateMetricDescriptorFn func(req *monitoring.CreateMetricDescriptorRequest) error
	ListMetricDescriptorFn   func(request *monitoring.ListMetricDescriptorsRequest) ([]*metric.MetricDescriptor, error)
	PostFn                   func(req *monitoring.CreateTimeSeriesRequest) error
}

func (*MockClient) CreateMetricDescriptor

func (mc *MockClient) CreateMetricDescriptor(request *monitoring.CreateMetricDescriptorRequest) error

func (*MockClient) ListMetricDescriptors

func (mc *MockClient) ListMetricDescriptors(request *monitoring.ListMetricDescriptorsRequest) ([]*metric.MetricDescriptor, error)

func (*MockClient) Post

func (mc *MockClient) Post(req *monitoring.CreateTimeSeriesRequest) error

type MockLogger

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

func (*MockLogger) Debug

func (m *MockLogger) Debug(action string, data ...lager.Data)

func (*MockLogger) Error

func (m *MockLogger) Error(action string, err error, data ...lager.Data)

func (*MockLogger) Fatal

func (m *MockLogger) Fatal(action string, err error, data ...lager.Data)

func (*MockLogger) Info

func (m *MockLogger) Info(action string, data ...lager.Data)

func (*MockLogger) LastLog

func (m *MockLogger) LastLog() Log

func (*MockLogger) Logs

func (m *MockLogger) Logs() []Log

func (*MockLogger) RegisterSink

func (m *MockLogger) RegisterSink(lager.Sink)

func (*MockLogger) Session

func (m *MockLogger) Session(task string, data ...lager.Data) lager.Logger

func (*MockLogger) SessionName

func (m *MockLogger) SessionName() string

func (*MockLogger) WithData

func (m *MockLogger) WithData(lager.Data) lager.Logger

type MockSerializer

type MockSerializer struct {
	GetLogFn     func(*events.Envelope) *messages.Log
	GetMetricsFn func(*events.Envelope) ([]messages.Metric, error)
	IsLogFn      func(*events.Envelope) bool
}

func (*MockSerializer) GetLog

func (m *MockSerializer) GetLog(envelope *events.Envelope) *messages.Log

func (*MockSerializer) GetMetrics

func (m *MockSerializer) GetMetrics(envelope *events.Envelope) ([]messages.Metric, error)

func (*MockSerializer) IsLog

func (m *MockSerializer) IsLog(envelope *events.Envelope) bool

type NozzleSink

type NozzleSink struct {
	HandledEnvelopes []events.Envelope
	// contains filtered or unexported fields
}

func (*NozzleSink) LastEnvelope

func (s *NozzleSink) LastEnvelope() *events.Envelope

func (*NozzleSink) Receive

func (s *NozzleSink) Receive(envelope *events.Envelope)

type TelemetrySink

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

func (*TelemetrySink) GetInit

func (ts *TelemetrySink) GetInit() []*expvar.KeyValue

func (*TelemetrySink) GetLastReport

func (ts *TelemetrySink) GetLastReport() []*expvar.KeyValue

func (*TelemetrySink) Init

func (ts *TelemetrySink) Init(val []*expvar.KeyValue)

func (*TelemetrySink) Report

func (ts *TelemetrySink) Report(val []*expvar.KeyValue)