mocks

package
v2.1.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 25, 2019 License: Apache-2.0, Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

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 

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)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.