consul

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

type AllowlistUpdaterConfig struct {
	// Logger is used for logging the operation of the allowlist updater.
	Logger *slog.Logger

	// Allowlist is the allowlist to update.
	Allowlist *ratelimit.DynamicAllowlist

	// ConsulURL is the URL from which to update Allowlist.
	ConsulURL *url.URL

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

	// Metrics is used to collect allowlist statistics.
	Metrics Metrics

	// Timeout is the timeout for Consul queries.
	Timeout time.Duration
}

type EmptyMetrics struct{}

type Metrics interface {
	// SetSize sets the number of received subnets.
	SetSize(ctx context.Context, n int)

	// SetStatus sets the status and time of the allowlist refresh attempt.
	SetStatus(ctx context.Context, err error)
}