Documentation ¶
Index ¶
- type IngestRate
- type Metrics
- func (m *Metrics) NotifyProviderErrorCleared(ctx context.Context, err error)
- func (m *Metrics) NotifyProviderErrored(ctx context.Context, err error)
- func (m *Metrics) Shutdown() error
- func (m *Metrics) Start(slowRate, nSlowest int) error
- func (m *Metrics) UpdateIngestRates(slowRates []*IngestRate, slowCount int, avg, fastest, slowest int64)
- func (m *Metrics) UpdateProviderDistanceBuckets(ctx context.Context, small, medium, large, totalDist int64)
- type SortableRates
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Metrics ¶
type Metrics struct {
// contains filtered or unexported fields
}
func (*Metrics) NotifyProviderErrorCleared ¶
func (*Metrics) NotifyProviderErrored ¶
func (*Metrics) UpdateIngestRates ¶
func (m *Metrics) UpdateIngestRates(slowRates []*IngestRate, slowCount int, avg, fastest, slowest int64)
type SortableRates ¶
type SortableRates []*IngestRate
func (SortableRates) Len ¶
func (r SortableRates) Len() int
func (SortableRates) Less ¶
func (r SortableRates) Less(i, j int) bool
func (SortableRates) Swap ¶
func (r SortableRates) Swap(i, j int)
Click to show internal directories.
Click to hide internal directories.