Versions in this module Expand all Collapse all v1 v1.0.0 Apr 26, 2019 Changes in this version + const ClusterVersionInvalid + func NewResourceBuilder(config, burstConfig *rest.Config, ...) payload.ResourceBuilder + type ConfigSyncWorker interface + Start func(ctx context.Context, maxWorkers int) + StatusCh func() <-chan SyncWorkerStatus + Update func(generation int64, desired configv1.Update, ...) *SyncWorkerStatus + func NewSyncWorker(retriever PayloadRetriever, builder payload.ResourceBuilder, ...) ConfigSyncWorker + type Operator struct + func New(nodename string, namespace, name string, releaseImage string, ...) *Operator + func (optr *Operator) InitializeFromPayload() error + func (optr *Operator) Run(ctx context.Context, workers int) + func (optr *Operator) SetSyncWorkerForTesting(worker ConfigSyncWorker) + type PayloadRetriever interface + RetrievePayload func(ctx context.Context, desired configv1.Update) (string, error) + type StatusReporter interface + Report func(status SyncWorkerStatus) + type SyncWork struct + Attempt int + Completed int + Desired configv1.Update + Generation int64 + Overrides []configv1.ComponentOverride + State payload.State + func (w SyncWork) Empty() bool + type SyncWorker struct + func (w *SyncWorker) Desired() configv1.Update + func (w *SyncWorker) Start(ctx context.Context, maxWorkers int) + func (w *SyncWorker) Status() *SyncWorkerStatus + func (w *SyncWorker) StatusCh() <-chan SyncWorkerStatus + func (w *SyncWorker) Update(generation int64, desired configv1.Update, ...) *SyncWorkerStatus + type SyncWorkerStatus struct + Actual configv1.Update + Completed int + Failure error + Fraction float32 + Generation int64 + Initial bool + LastProgress time.Time + Reconciling bool + Step string + VersionHash string + func (w SyncWorkerStatus) DeepCopy() *SyncWorkerStatus Incompatible versions in this module v3.11.0+incompatible Sep 5, 2018
Go to main page