testing

Documentation

Index

• type ErrorSender
  • func (e *ErrorSender) Send(d []*wireformat.MetricBatch) (*wireformat.Response, error)
• type MockSender
  • func (m *MockSender) IgnoreBatches(batches ...*state.MetricBatch)
  • func (m *MockSender) Send(d []*wireformat.MetricBatch) (*wireformat.Response, error)

Types

type ErrorSender

type ErrorSender struct {
	Err error
}

ErrorSender implements the metric sender interface and is used to return errors during testing

func (*ErrorSender) Send

func (e *ErrorSender) Send(d []*wireformat.MetricBatch) (*wireformat.Response, error)

Send implements the Send interface returning errors specified in the ErrorSender.

type MockSender

type MockSender struct {
	UnackedBatches map[string]struct{}
	Data           [][]*wireformat.MetricBatch
}

MockSender implements the metric sender interface.

func (*MockSender) IgnoreBatches

func (m *MockSender) IgnoreBatches(batches ...*state.MetricBatch)

func (*MockSender) Send

func (m *MockSender) Send(d []*wireformat.MetricBatch) (*wireformat.Response, error)

Send implements the Send interface.