apiserver

Mar 19, 2025

Changes in this version

+ type APIServerAccess interface

+ GetAdminAccessClient func(as *openmcpv1alpha1.APIServer, options client.Options) (client.Client, error)

+ GetAdminAccessConfig func(as *openmcpv1alpha1.APIServer) (*restclient.Config, error)

+ GetAdminAccessRaw func(as *openmcpv1alpha1.APIServer) (string, error)

+ type APIServerAccessImpl struct

+ NewClient client.NewClientFunc

+ func (a *APIServerAccessImpl) GetAdminAccessClient(apiServer *openmcpv1alpha1.APIServer, options client.Options) (client.Client, error)

+ func (a *APIServerAccessImpl) GetAdminAccessConfig(apiServer *openmcpv1alpha1.APIServer) (*restclient.Config, error)

+ func (a *APIServerAccessImpl) GetAdminAccessRaw(apiServer *openmcpv1alpha1.APIServer) (string, error)

+ type OnExit chan bool

+ type OnNextInterval chan bool

+ type Options struct

+ Interval *time.Duration

+ MaxWorkers *int

+ NewClient client.NewClientFunc

+ func (o *Options) SetDefaultsIfNotSet()

+ type Task func(context.Context, *openmcpv1alpha1.APIServer, client.Client, client.Client) error

+ type Worker interface

+ RegisterTask func(name string, task Task)

+ Start func(ctx context.Context, onExit OnExit, onNextInterval OnNextInterval, ...) error

+ UnregisterTask func(name string)

+ func NewWorker(crateClient client.Client, options *Options) (Worker, error)

+ type WorkerImpl struct

+ NewClient client.NewClientFunc

+ func (w *WorkerImpl) RegisterTask(name string, task Task)

+ func (w *WorkerImpl) Start(ctx context.Context, onExit OnExit, onNextInterval OnNextInterval, ...) error

+ func (w *WorkerImpl) UnregisterTask(name string)