workerdaemon

type ArchiveConfig struct {
	Tenant      string            `json:"tenant"`
	Stream      string            `json:"stream"`
	Directory   string            `json:"directory"`
	KeyID       string            `json:"key_id"`
	TrustedKeys map[string]string `json:"trusted_keys"`
}

type AuditConfig struct {
	Tenant string `json:"tenant"`
	Stream string `json:"stream"`
	KeyID  string `json:"key_id"`
}

type Config struct {
	ProjectionCleanup      *ProjectionCleanupConfig     `json:"projection_cleanup,omitempty"`
	OrphanCleanup          *workers.OrphanCleanupConfig `json:"orphan_cleanup,omitempty"`
	Telemetry              *runtimeconfig.Telemetry     `json:"telemetry,omitempty"`
	OpenFGATraceContext    bool                         `json:"openfga_trace_context,omitempty"`
	Extraction             *ExtractionConfig            `json:"extraction"`
	Refresh                *RefreshConfig               `json:"refresh"`
	Archive                *ArchiveConfig               `json:"archive"`
	Audit                  AuditConfig                  `json:"audit"`
	Mode                   string                       `json:"mode"`
	Principal              string                       `json:"principal"`
	Projection             runtimeconfig.LexicalRoute   `json:"projection"`
	OpenFGAURL             string                       `json:"openfga_url"`
	OpenFGAStore           string                       `json:"openfga_store"`
	OpenFGAModel           string                       `json:"openfga_model"`
	MaxConnections         int32                        `json:"max_connections"`
	MaxAttempts            int                          `json:"max_attempts"`
	LeaseSeconds           int                          `json:"lease_seconds"`
	PollMilliseconds       int                          `json:"poll_milliseconds"`
	MinBackoffMilliseconds int                          `json:"min_backoff_milliseconds"`
	MaxBackoffSeconds      int                          `json:"max_backoff_seconds"`
	DeliveryTimeoutSeconds int                          `json:"delivery_timeout_seconds"`
}

type ExtractionConfig struct {
	Tenant     string                              `json:"tenant"`
	Stream     string                              `json:"stream"`
	Scheduling *runtimeconfig.ExtractionScheduling `json:"scheduling"`
	Gateways   []ExtractionGateway                 `json:"gateways"`
}

type ExtractionGateway struct {
	PropagateTraceContext  bool   `json:"propagate_trace_context,omitempty"`
	ProfileID              string `json:"profile_id"`
	URL                    string `json:"url"`
	TokenEnv               string `json:"token_env,omitempty"`
	RootCAFile             string `json:"root_ca_file,omitempty"`
	AllowPlaintextLoopback bool   `json:"allow_plaintext_loopback,omitempty"`
}

type OrphanTicker interface {
	Tick(context.Context) (workers.OrphanCleanupResult, error)
}

type Processor interface {
	ProcessOne(context.Context) (bool, error)
}

type ProjectionCleanupConfig struct {
	workers.ProjectionCleanupConfig
	Destinations []runtimeconfig.CleanupRoute `json:"destinations"`
}

type ProjectionCleanupTicker interface {
	Tick(context.Context) (workers.ProjectionCleanupResult, error)
}

type RefreshBinding struct {
	Scope     string `json:"scope"`
	ProfileID string `json:"profile_id"`
}

type RefreshConfig struct {
	RedactionPolicyVersions []string                  `json:"redaction_policy_versions,omitempty"`
	SweepIntervalMinutes    int                       `json:"sweep_interval_minutes,omitempty"`
	Tenant                  string                    `json:"tenant"`
	Stream                  string                    `json:"stream"`
	Purpose                 string                    `json:"purpose"`
	Bindings                []RefreshBinding          `json:"bindings"`
	Profiles                []model.ExtractionProfile `json:"profiles"`
	MaxConcurrentPerTenant  int                       `json:"max_concurrent_per_tenant"`
	DailyTokenBudget        int64                     `json:"daily_token_budget"`
	CostUnit                string                    `json:"cost_unit"`
	DailyCostBudgetUnits    int64                     `json:"daily_cost_budget_units"`
}

type SweepTicker interface {
	Tick(context.Context, time.Time) ([]model.CommitResult, error)
}