billstat

type EmptyMetrics struct{}

type EmptyRecorder struct{}

type Metrics interface {
	// SetRecordCount sets the total number of records stored.
	SetRecordCount(ctx context.Context, count int)

	// HandleUploadDuration handles the upload duration of billing statistics.
	HandleUploadDuration(ctx context.Context, dur float64, err error)
}

type Record struct {
	// Time is the time of the most recent query from the device.
	Time time.Time

	// Country is the detected country of the client's IP address, if any.
	Country geoip.Country

	// ASN is the detected ASN of the client's IP address, if any.
	ASN geoip.ASN

	// Queries is the total number of Queries the device has performed since the
	// most recent sync.  This value is an int32 to be in sync with the business
	// logic backend which uses this type.  Change it if it is changed there.
	// Queries must not be negative.
	Queries int32

	// Proto is the DNS protocol of the most recent query from the device.
	Proto agd.Protocol
}

type Recorder interface {
	Record(
		ctx context.Context,
		id agd.DeviceID,
		ctry geoip.Country,
		asn geoip.ASN,
		start time.Time,
		proto agd.Protocol,
	)
}

type Records = map[agd.DeviceID]*Record

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

type RuntimeRecorderConfig struct {
	// Logger is used for logging the operation of the recorder.
	Logger *slog.Logger

	// ErrColl is used to collect errors during refreshes.
	ErrColl errcoll.Interface

	// Uploader is used to upload the billing statistics records to.
	Uploader Uploader

	// Metrics is used for the collection of the billing statistics.
	Metrics Metrics
}

type Uploader interface {
	Upload(ctx context.Context, records Records) (err error)
}