auditor

type CheckService interface {
	Check(ctx context.Context) ([]string, error)
}

type CheckServiceProvider interface {
	CheckService(id token.TMSID, adb *auditdb.StoreService, tdb *tokens.Service) (CheckService, error)
}

type ConfigProvider interface {
	// IsSet checks if a configuration key exists
	IsSet(key string) bool
	// UnmarshalKey unmarshals a configuration key into the provided struct
	UnmarshalKey(key string, rawVal any) error
}

type LockConfig struct {
	// MaxRetries is the maximum number of retry attempts for lock acquisition
	MaxRetries int
	// InitialBackoff is the initial backoff delay before the first retry
	InitialBackoff time.Duration
	// MaxBackoff is the maximum backoff delay between retries
	MaxBackoff time.Duration
	// BackoffMultiplier is the exponential backoff multiplier
	BackoffMultiplier float64
	// JitterFactor is the randomization factor to prevent thundering herd (0.0 to 1.0)
	JitterFactor float64
}

type LockConfigRaw struct {
	MaxRetries        int     `yaml:"maxRetries"`
	InitialBackoff    string  `yaml:"initialBackoff"`
	MaxBackoff        string  `yaml:"maxBackoff"`
	BackoffMultiplier float64 `yaml:"backoffMultiplier"`
	JitterFactor      float64 `yaml:"jitterFactor"`
}

type Metrics struct {
	// AuditDuration is a histogram of the wall-clock time for each Audit()
	// invocation (lock acquisition included), in seconds.
	AuditDuration metrics.Histogram

	// AuditLockConflicts counts calls to Audit() that failed because
	// AcquireLocks returned an error (e.g. contention or timeout).
	AuditLockConflicts metrics.Counter

	// AppendDuration is a histogram of the total wall-clock time for each
	// Append() invocation, in seconds.
	AppendDuration metrics.Histogram

	// AppendErrors counts calls to Append() that failed when writing to the
	// audit database.
	AppendErrors metrics.Counter

	// ReleasesTotal counts all calls to Release(), whether invoked explicitly
	// or via the defer inside Append().
	ReleasesTotal metrics.Counter
}

type NetworkProvider interface {
	GetNetwork(network string, channel string) (*network.Network, error)
}

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

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

type StoreServiceManager = auditdb.StoreServiceManager

type TokenManagementServiceProvider interface {
	GetManagementService(opts ...token.ServiceOption) (*token.ManagementService, error)
}

type TokensServiceManager = services.ServiceManager[*tokens.Service]

type Transaction interface {
	ID() string
	Network() string
	Channel() string
	Namespace() string
	Request() *token.Request
}

type TxStatus = auditdb.TxStatus