scheduler

type IDLister ¶

type IDLister interface {
	ListAllIDs(ctx context.Context) ([]string, error)
}

IDLister is the scheduler's read-side dependency. Adapter above is the production wiring; tests pass an in-memory stub.

type Options ¶

type Options struct {
	Interval    time.Duration
	IterTimeout time.Duration
	Logger      *slog.Logger
	Clock       func() time.Time
}

Options configures the scheduler; all optional.

type RefreshDiscoveryScheduler ¶

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

RefreshDiscoveryScheduler runs ClusterUseCase.RefreshDiscovery on every registered cluster at a fixed interval. Phase 7 of F8 follow-up: catches node_architectures drift that would otherwise accumulate between manual Refresh Discovery clicks in the admin UI.

func NewRefreshDiscoveryScheduler(lister IDLister, runner RefreshRunner, opts Options) *RefreshDiscoveryScheduler

func (s *RefreshDiscoveryScheduler) Start(ctx context.Context)

type RefreshRunner ¶

type RefreshRunner interface {
	RefreshDiscoveryByID(ctx context.Context, id string) error
}

RefreshRunner is the subset of ClusterUseCase the scheduler calls per cluster. Mirrors `ClusterUseCase.RefreshDiscovery(ctx, id)`.

type RotationRestarter ¶

type RotationRestarter interface {
	RestartForProvider(ctx context.Context, clusterID, namespace, provider string) error
}

RotationRestarter 는 회전 성공 후 소비자 재시작을 담당한다.

type TokenRotationScheduler ¶

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

func NewTokenRotationScheduler(pool *pgxpool.Pool, secret *secrets.Router, interval, iterTimeout time.Duration, logger *slog.Logger, reissuer rotation.Reissuer) *TokenRotationScheduler

func (s *TokenRotationScheduler) Start(ctx context.Context)

func (s *TokenRotationScheduler) WithRestarter(r RotationRestarter) *TokenRotationScheduler