utils

Documentation

Index

• Constants
• Variables
• func DefaultTestSetupBuilder(testDirPathSegments ...string) *testing.ComplexEnvironmentBuilder
• type ReconcilerWithAPIServerAccess
• type TestAPIServerAccess
  • func (t *TestAPIServerAccess) GetAdminAccessClient(as *openmcpv1alpha1.APIServer, _ client.Options) (client.Client, error)
  • func (t *TestAPIServerAccess) GetAdminAccessConfig(as *openmcpv1alpha1.APIServer) (*restclient.Config, error)
  • func (t *TestAPIServerAccess) GetAdminAccessRaw(as *openmcpv1alpha1.APIServer) (string, error)
• type TestWorker
  • func NewTestWorker(crateClient, apiServerClient client.Client) *TestWorker
  • func (w *TestWorker) RegisterTask(name string, task apiserverutils.Task)
  • func (w *TestWorker) RunTasks(ctx context.Context, as *openmcpv1alpha1.APIServer) error
  • func (w *TestWorker) Start(_ context.Context, _ apiserverutils.OnExit, _ apiserverutils.OnNextInterval, ...) error
  • func (w *TestWorker) UnregisterTask(name string)

Constants

const (
	CrateCluster     = "crate"
	APIServerCluster = "apiserver"
	LaaSCoreCluster  = "laas"
	COCoreCluster    = "cloudOrchestrator"
)

Variables

var (
	Scheme *runtime.Scheme
)

Functions

func DefaultTestSetupBuilder

func DefaultTestSetupBuilder(testDirPathSegments ...string) *testing.ComplexEnvironmentBuilder

Types

type ReconcilerWithAPIServerAccess

type ReconcilerWithAPIServerAccess interface {
	SetAPIServerAccess(access apiserver.APIServerAccess)
}

type TestAPIServerAccess

type TestAPIServerAccess struct {
	APIServerAccess apiserverutils.APIServerAccessImpl
	Client          client.Client
	Error           error
}

TestAPIServerAccess is a test implementation of APIServerAccess.

func (*TestAPIServerAccess) GetAdminAccessClient

func (t *TestAPIServerAccess) GetAdminAccessClient(as *openmcpv1alpha1.APIServer, _ client.Options) (client.Client, error)

GetAdminAccessClient implements APIServerAccess.GetAdminAccessClient.

func (*TestAPIServerAccess) GetAdminAccessConfig

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

GetAdminAccessConfig implements APIServerAccess.GetAdminAccessConfig.

func (*TestAPIServerAccess) GetAdminAccessRaw

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

GetAdminAccessRaw implements APIServerAccess.GetAdminAccessRaw.

type TestWorker

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

TestWorker is a test implementation of Worker.

func NewTestWorker

func NewTestWorker(crateClient, apiServerClient client.Client) *TestWorker

NewTestWorker creates a new TestWorker.

func (*TestWorker) RegisterTask

func (w *TestWorker) RegisterTask(name string, task apiserverutils.Task)

func (*TestWorker) RunTasks

func (w *TestWorker) RunTasks(ctx context.Context, as *openmcpv1alpha1.APIServer) error

func (*TestWorker) Start

func (w *TestWorker) Start(_ context.Context, _ apiserverutils.OnExit, _ apiserverutils.OnNextInterval, _ <-chan struct{}) error

func (*TestWorker) UnregisterTask

func (w *TestWorker) UnregisterTask(name string)