mock

Documentation

Index

• type Exporter
  • func (e Exporter) Scrape() (string, error)
• type LagWaiter
  • func (w LagWaiter) Wait(now, then time.Time, f int, srcId string) (int64, time.Duration)
• type MetricFactory
  • func (f MetricFactory) Make(domain string, args blip.CollectorFactoryArgs) (blip.Collector, error)
• type MetricsCollector
  • func (c MetricsCollector) Collect(ctx context.Context, levelName string) ([]blip.MetricValue, error)
  • func (c MetricsCollector) Domain() string
  • func (c MetricsCollector) Help() blip.CollectorHelp
  • func (c MetricsCollector) Prepare(ctx context.Context, plan blip.Plan) (func(), error)
• type Monitor
  • func (m Monitor) DB() *sql.DB
  • func (m Monitor) MonitorId() string
• type RDSClient
  • func (r RDSClient) DescribeDBInstances(context.Context, *rds.DescribeDBInstancesInput, ...func(*rds.Options)) (*rds.DescribeDBInstancesOutput, error)
• type RDSClientFactory
  • func (f RDSClientFactory) Make(ba blip.AWS) (blipAWS.RDSClient, error)
• type Sink
  • func (s Sink) Name() string
  • func (s Sink) Send(ctx context.Context, m *blip.Metrics) error
• type Tr
  • func (tr *Tr) Translate(domain, metric string) string
• type Transport
  • func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)

Types

type Exporter

type Exporter struct {
	ScrapeFunc func() (string, error)
}

func (Exporter) Scrape

func (e Exporter) Scrape() (string, error)

type LagWaiter

type LagWaiter struct {
	WaitFunc func(now, then time.Time, f int, srcId string) (int64, time.Duration)
}

func (LagWaiter) Wait

func (w LagWaiter) Wait(now, then time.Time, f int, srcId string) (int64, time.Duration)

type MetricFactory

type MetricFactory struct {
	MakeFunc func(domain string, args blip.CollectorFactoryArgs) (blip.Collector, error)
}

func (MetricFactory) Make

func (f MetricFactory) Make(domain string, args blip.CollectorFactoryArgs) (blip.Collector, error)

type MetricsCollector

type MetricsCollector struct {
	PrepareFunc func(ctx context.Context, plan blip.Plan) (func(), error)
	CollectFunc func(ctx context.Context, levelName string) ([]blip.MetricValue, error)
}

func (MetricsCollector) Collect

func (c MetricsCollector) Collect(ctx context.Context, levelName string) ([]blip.MetricValue, error)

func (MetricsCollector) Domain

func (c MetricsCollector) Domain() string

func (MetricsCollector) Help

func (c MetricsCollector) Help() blip.CollectorHelp

func (MetricsCollector) Prepare

func (c MetricsCollector) Prepare(ctx context.Context, plan blip.Plan) (func(), error)

type Monitor

type Monitor struct {
	MonitorIdFunc func() string
	DBFunc        func() *sql.DB
}

func (Monitor) DB

func (m Monitor) DB() *sql.DB

func (Monitor) MonitorId

func (m Monitor) MonitorId() string

type RDSClient

type RDSClient struct {
	Out   rds.DescribeDBInstancesOutput
	Error error
}

func (RDSClient) DescribeDBInstances

func (r RDSClient) DescribeDBInstances(context.Context, *rds.DescribeDBInstancesInput, ...func(*rds.Options)) (*rds.DescribeDBInstancesOutput, error)

type RDSClientFactory

type RDSClientFactory struct {
	MakeFunc func(blip.AWS) (blipAWS.RDSClient, error)
}

func (RDSClientFactory) Make

func (f RDSClientFactory) Make(ba blip.AWS) (blipAWS.RDSClient, error)

type Sink

type Sink struct {
	SendFunc func(ctx context.Context, m *blip.Metrics) error
}

func (Sink) Name

func (s Sink) Name() string

func (Sink) Send

func (s Sink) Send(ctx context.Context, m *blip.Metrics) error

type Tr

type Tr struct {
	TranslateFunc func(domain, metric string) string
}

func (*Tr) Translate

func (tr *Tr) Translate(domain, metric string) string

type Transport

type Transport struct {
	RoundTripFunc func(*http.Request) (*http.Response, error)
}

A mock of http.Transport.

func (*Transport) RoundTrip

func (t *Transport) RoundTrip(req *http.Request) (*http.Response, error)