scheduler

type Interval interface {
	FromNowWhenNext(policy types.PluginPolicy) (time.Time, error)
}

type NilService struct{}

type PolicyFetcher interface {
	GetPluginPolicy(ctx context.Context, id uuid.UUID) (*types.PluginPolicy, error)
}

type Scheduler struct {
	PolicyID      uuid.UUID `json:"policy_id"`
	NextExecution time.Time `json:"next_execution"`
}

type Service interface {
	Create(ctx context.Context, policy types.PluginPolicy) error
	Update(ctx context.Context, oldPolicy, newPolicy types.PluginPolicy) error
	Delete(ctx context.Context, policyID uuid.UUID) error
}

type Storage interface {
	Tx() storage.Tx
	GetByPolicy(ctx context.Context, policyID uuid.UUID) (Scheduler, error)
	Create(ctx context.Context, policyID uuid.UUID, next time.Time) error
	Delete(ctx context.Context, policyID uuid.UUID) error
	GetPending(ctx context.Context) ([]Scheduler, error)
	SetNext(ctx context.Context, policyID uuid.UUID, next time.Time) error
}

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