telemetry

README

telemetry

measures and compares indexer and provider metrics

Documentation

Index

• Variables
• type Rate
• type Telemetry
  • func New(adDepthLimit int64, updateIn, updateTo time.Duration, pc *pcache.ProviderCache, ...) (*Telemetry, error)
  • func (tel *Telemetry) Close()
  • func (tel *Telemetry) GetProvider(ctx context.Context, providerID peer.ID, w io.Writer) bool
  • func (tel *Telemetry) ListProviders(ctx context.Context, w io.Writer)

Variables

var (
	// Release is the release version tag value, e.g. "v1.2.3"
	Release string
	// Revision is the git commit hash.
	Revision string
	// Version is the full version string: Release-Revision.
	Version string
	// Modified indicates if the source tree had local modifications.
	Modified bool
)

Types

type Rate

type Rate struct {
	Count   uint64
	Elapsed time.Duration
	Samples int
}

type Telemetry

type Telemetry struct {
	// contains filtered or unexported fields
}

func New

func New(adDepthLimit int64, updateIn, updateTo time.Duration, pc *pcache.ProviderCache, met *metrics.Metrics, indexerAdminURLs []string, slowRate, nSlowest int, topic string) (*Telemetry, error)

func (*Telemetry) Close

func (tel *Telemetry) Close()

func (*Telemetry) GetProvider

func (tel *Telemetry) GetProvider(ctx context.Context, providerID peer.ID, w io.Writer) bool

func (*Telemetry) ListProviders

func (tel *Telemetry) ListProviders(ctx context.Context, w io.Writer)