testm3server

Documentation

Index

• type FakeM3Server
  • func NewFakeM3Server(t *testing.T, wg *lib.WaitAtLeast, countBatches bool, countMetrics bool, ...) *FakeM3Server
  • func (f *FakeM3Server) Close() error
  • func (f *FakeM3Server) Serve()
• type FakeM3Service
  • func NewFakeM3Service(wg *lib.WaitAtLeast, countBatches bool, countMetrics bool) *FakeM3Service
  • func (m *FakeM3Service) EmitMetricBatch(batch *m3.MetricBatch) (err error)
  • func (m *FakeM3Service) GetBatches() []*m3.MetricBatch
  • func (m *FakeM3Service) GetMetrics() map[string]*m3.Metric

Types

type FakeM3Server

type FakeM3Server struct {
	Service *FakeM3Service
	Addr    string
	// contains filtered or unexported fields
}

FakeM3Server represents an M3 UDP server

func NewFakeM3Server

func NewFakeM3Server(
	t *testing.T,
	wg *lib.WaitAtLeast,
	countBatches bool,
	countMetrics bool,
	protocol metrics.Protocol,
) *FakeM3Server

NewFakeM3Server creates server, pass it a wait group Which can be used to wait for receival of messages

func (*FakeM3Server) Close

func (f *FakeM3Server) Close() error

Close closes the UDP server

func (*FakeM3Server) Serve

func (f *FakeM3Server) Serve()

Serve will handle incoming UDP connections, currently only reads one packet

type FakeM3Service

type FakeM3Service struct {
	MaxMetrics int
	// contains filtered or unexported fields
}

FakeM3Service tracks the metrics the server has received

func NewFakeM3Service

func NewFakeM3Service(
	wg *lib.WaitAtLeast,
	countBatches bool,
	countMetrics bool,
) *FakeM3Service

NewFakeM3Service creates an M3Service

func (*FakeM3Service) EmitMetricBatch

func (m *FakeM3Service) EmitMetricBatch(batch *m3.MetricBatch) (err error)

EmitMetricBatch is called by thrift message processor

func (*FakeM3Service) GetBatches

func (m *FakeM3Service) GetBatches() []*m3.MetricBatch

GetBatches gets the batches

func (*FakeM3Service) GetMetrics

func (m *FakeM3Service) GetMetrics() map[string]*m3.Metric

GetMetrics gets the individual metrics