dynconfig

type Config struct {
	RDB          rueidis.Client
	Prefix       string
	PollInterval time.Duration // Default: 10s.
	Logger       gochainedlog.Logger
}

type HandlerOverride struct {
	Concurrency int           `json:"concurrency,omitempty"`
	Timeout     time.Duration `json:"timeout,omitempty"`
	MaxAttempts int           `json:"max_attempts,omitempty"`
}

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

type Snapshot struct {
	// Global settings.
	MaxConcurrency        int           `json:"max_concurrency,omitempty"`
	SchedulerTickInterval time.Duration `json:"scheduler_tick_interval,omitempty"`

	// Per-handler overrides (keyed by task type).
	Handlers map[string]HandlerOverride `json:"handlers,omitempty"`
}