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 Heartbeater
  • func NewHeartbeater() *Heartbeater
  • func (h *Heartbeater) GetCount(name string) int
  • func (h *Heartbeater) Increment(name string)
  • func (h *Heartbeater) IsRunning() bool
  • func (h *Heartbeater) Start()
  • func (h *Heartbeater) Stop()
• type LabelMaker
  • func (lm *LabelMaker) Build(*events.Envelope) map[string]string
• type Log
• type LogAdapter
  • func (la *LogAdapter) Flush()
  • func (la *LogAdapter) PostLog(log *stackdriver.Log)
• type MetricAdapter
  • func (m *MetricAdapter) GetPostedMetrics() []stackdriver.Metric
  • func (m *MetricAdapter) PostMetrics(metrics []stackdriver.Metric) error
• type MetricsBuffer
  • func (m *MetricsBuffer) IsEmpty() bool
  • func (m *MetricsBuffer) PostMetric(metric *stackdriver.Metric)
• 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
  • func (m *MockSerializer) GetLog(envelope *events.Envelope) *stackdriver.Log
  • func (m *MockSerializer) GetMetrics(envelope *events.Envelope) ([]stackdriver.Metric, error)
  • func (m *MockSerializer) IsLog(envelope *events.Envelope) bool
• type Sink
  • func (s *Sink) LastEnvelope() *events.Envelope
  • func (s *Sink) Receive(envelope *events.Envelope) error

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 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 LabelMaker struct {
	Labels map[string]string
}

func (*LabelMaker) Build

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

type Log

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

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) 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) 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) *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)

func (*MockSerializer) IsLog

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

type Sink

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

func (*Sink) LastEnvelope

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

func (*Sink) Receive

func (s *Sink) Receive(envelope *events.Envelope) error