bootstrap

type BootstrapServiceSpec struct {
	Name     string                 `db:"name"     json:"name"`
	Kind     provider.WorkloadKind  `db:"kind"     json:"kind,omitempty"`     // default deployment
	Replicas int                    `db:"replicas" json:"replicas,omitempty"` // default 1
	Services []provider.ServiceSpec `db:"services" json:"services"`
	Labels   map[string]string      `db:"labels"   json:"labels,omitempty"`
}

type BootstrapWorkload struct {
	ctrlplane.Entity

	DatacenterID id.ID                  `db:"datacenter_id" json:"datacenter_id"`
	Name         string                 `db:"name"          json:"name"`
	Kind         provider.WorkloadKind  `db:"kind"          json:"kind"`
	Services     []provider.ServiceSpec `db:"services"      json:"services"`
	State        State                  `db:"state"         json:"state"`
	ProviderRef  string                 `db:"provider_ref"  json:"provider_ref,omitempty"`
	ServiceRefs  map[string]string      `db:"service_refs"  json:"service_refs,omitempty"`
	LastError    string                 `db:"last_error"    json:"last_error,omitempty"`
	Attempts     int                    `db:"attempts"      json:"attempts"`
	Labels       map[string]string      `db:"labels"        json:"labels,omitempty"`
}

type DatacenterInfo struct {
	ID           id.ID
	ProviderName string
	Region       string
	Zone         string
	Labels       map[string]string
}

type Hook interface {
	// Name returns a stable identifier for this hook. Used for
	// logging, audit events, and to dedupe re-registrations of
	// the same hook (Register replaces, never duplicates).
	Name() string

	// Services returns the bootstrap specs this hook contributes
	// for the given datacenter. Returning nil or empty means the
	// hook has nothing to contribute for this datacenter.
	//
	// An error from Services is logged and the hook is treated as
	// having contributed nothing for this tick — a broken hook
	// does not block other hooks or wipe the desired set.
	Services(ctx context.Context, dc DatacenterInfo) ([]BootstrapServiceSpec, error)
}

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

type Service interface {
	// Reconcile drives one datacenter's bootstrap state forward by
	// one step. Idempotent: safe to call repeatedly. The caller
	// supplies:
	//
	//   - dc: the datacenter projection used to address the
	//     provider and (via DatacenterInfo) feed registered hooks.
	//   - declared: the operator-declared spec list from the
	//     datacenter row. May be nil for datacenters that rely
	//     entirely on hooks.
	//
	// Reconcile reads the registered hook set, unions hook-
	// contributed specs with `declared`, dedupes by Spec.Name
	// (declared wins on conflict), then diffs against the current
	// row set and walks each delta toward the desired state.
	Reconcile(ctx context.Context, dc DatacenterInfo, declared []BootstrapServiceSpec) error

	// ListByDatacenter returns the bootstrap workloads attached to
	// a datacenter. Read-only.
	ListByDatacenter(ctx context.Context, datacenterID id.ID) ([]*BootstrapWorkload, error)

	// Get returns a single bootstrap workload by ID. Read-only.
	Get(ctx context.Context, bootstrapID id.ID) (*BootstrapWorkload, error)
}

type State string

type Store interface {
	// InsertBootstrap persists a new bootstrap workload row.
	InsertBootstrap(ctx context.Context, bw *BootstrapWorkload) error

	// GetBootstrap returns a bootstrap workload by ID.
	GetBootstrap(ctx context.Context, bootstrapID id.ID) (*BootstrapWorkload, error)

	// GetBootstrapByName returns the row whose (DatacenterID, Name)
	// pair matches. Used by the reconciler to match desired specs
	// against current rows.
	GetBootstrapByName(ctx context.Context, datacenterID id.ID, name string) (*BootstrapWorkload, error)

	// ListBootstraps returns every bootstrap workload attached to
	// the given datacenter. Read path for the reconciler and the
	// dashboard panel.
	ListBootstraps(ctx context.Context, datacenterID id.ID) ([]*BootstrapWorkload, error)

	// UpdateBootstrap persists changes to an existing row.
	UpdateBootstrap(ctx context.Context, bw *BootstrapWorkload) error

	// DeleteBootstrap removes a row. Called by the reconciler after
	// Deprovision returns successfully on a retiring workload.
	DeleteBootstrap(ctx context.Context, bootstrapID id.ID) error
}