Documentation
¶
Overview ¶
Package deploymentattempts backfills canonical deployment attempts and continuously repairs the activation crash window.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
func DefaultConfig ¶
func DefaultConfig() Config
type Controller ¶
type Controller struct {
Log *slog.Logger
Store entity.Store
Tracker *deploylifecycle.Tracker
Config Config
// contains filtered or unexported fields
}
func New ¶
func New(log *slog.Logger, store entity.Store, eac *entityserver_v1alpha.EntityAccessClient) *Controller
func (*Controller) Ready ¶
func (c *Controller) Ready() <-chan struct{}
Ready closes after the first complete migration and reconciliation sweep with no skipped records. Consumers that expose canonical deployment data may wait on it without making the controller's ongoing repair loop part of their own lifecycle.
func (*Controller) SetProgressReporter ¶
func (c *Controller) SetProgressReporter(report func(Progress))
SetProgressReporter attaches runtime diagnostics before Start is called.
func (*Controller) Start ¶
func (c *Controller) Start(ctx context.Context)
func (*Controller) Step ¶
func (c *Controller) Step(ctx context.Context) error
Step processes one bounded page. It is public so tests and operators can drive convergence without waiting for the loop.
func (*Controller) Stop ¶
func (c *Controller) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.