apiserver

type APIServerAccess interface {
	// GetAdminAccessClient returns the admin access kubeconfig for the given APIServer.
	GetAdminAccessClient(as *openmcpv1alpha1.APIServer, options client.Options) (client.Client, error)
	// GetAdminAccessConfig returns the admin access kubeconfig for the given APIServer.
	GetAdminAccessConfig(as *openmcpv1alpha1.APIServer) (*restclient.Config, error)
	// GetAdminAccessRaw returns the admin access kubeconfig for the given APIServer.
	GetAdminAccessRaw(as *openmcpv1alpha1.APIServer) (string, error)
}

type APIServerAccessImpl struct {
	NewClient client.NewClientFunc
}

type OnExit chan bool

type OnNextInterval chan bool

type Options struct {
	// MaxWorkers is the maximum number of workers that can be executed concurrently
	MaxWorkers *int
	// Interval is the time between each execution of the tasks
	Interval *time.Duration
	// NewClient is the function to create a new client for the APIServer
	NewClient client.NewClientFunc
}

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

type Worker interface {
	// RegisterTask registers a new task with the given name
	// The name must be unique
	RegisterTask(name string, task Task)
	// UnregisterTask removes the task with the given name
	UnregisterTask(name string)
	// Start starts the worker
	// This function will not block.
	// The worker will be stopped when the context is canceled
	// The OnExit channel will be used to signal when the worker is stopped (when not nil)
	// The OnNextInterval channel will be used to signal when the next interval is executed (when not nil)
	Start(ctx context.Context, onExit OnExit, onNextInterval OnNextInterval, waitFor <-chan struct{}) error
}

type WorkerImpl struct {
	NewClient client.NewClientFunc
	// contains filtered or unexported fields
}