collector

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

type Diagnostic struct {
	Self      domain.NodeIdentity `json:"self"`
	OS        string              `json:"os"`
	PeerCount int                 `json:"peerCount"`
}

type DiagnosticSource interface {
	Diagnostic(context.Context) (Diagnostic, error)
}

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

type HTTPStatusError struct {
	StatusCode int
	Status     string
	Message    string
}

type Options struct {
	SampleInterval    time.Duration
	HeartbeatInterval time.Duration
	RetryMin          time.Duration
	RetryMax          time.Duration
	SummaryInterval   time.Duration
	ReporterInstance  string
	Now               func() time.Time
	Jitter            func() float64
	Wait              func(context.Context, time.Duration) error
	Logger            *slog.Logger
}

type PeerSnapshot struct {
	Identity domain.NodeIdentity
	RxBytes  int64
	TxBytes  int64
	Path     domain.PathObservation
}

type Reporter interface {
	Send(context.Context, domain.ReportEnvelope) (domain.ReportReceipt, error)
}

type Snapshot struct {
	CollectedAt time.Time
	Observer    domain.NodeIdentity
	Peers       []PeerSnapshot
}

type Source interface {
	Snapshot(context.Context) (Snapshot, error)
}