controllers

Documentation

Index

• Variables
• type MockClient
  • func NewClient() *MockClient
  • func (c *MockClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (c *MockClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (c *MockClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (c *MockClient) Get(ctx context.Context, key types.NamespacedName, obj client.Object, ...) error
  • func (c *MockClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (c *MockClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (c *MockClient) RESTMapper() meta.RESTMapper
  • func (c *MockClient) Scheme() *runtime.Scheme
  • func (c *MockClient) Status() client.StatusWriter
  • func (c *MockClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type ServiceImportReconciler
  • func (r *ServiceImportReconciler) DeleteServiceImportOnSpoke(ctx context.Context, svcim *spokev1alpha1.WorkerServiceImport) error
  • func (a *ServiceImportReconciler) InjectClient(c client.Client) error
  • func (r *ServiceImportReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type SliceGwReconciler
  • func (r *SliceGwReconciler) InjectClient(c client.Client) error
  • func (r *SliceGwReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
• type SliceReconciler
  • func NewSliceReconciler(hubclient client.Client, mc client.Client, er *events.EventRecorder, ...) *SliceReconciler
  • func (a *SliceReconciler) InjectClient(c client.Client) error
  • func (r *SliceReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (r *SliceReconciler) UpdateSliceHealthMetrics(slice *spokev1alpha1.WorkerSliceConfig)
• type StatusClient
  • func (c *StatusClient) Create(ctx context.Context, obj1 client.Object, obj2 client.Object, ...) error
  • func (c *StatusClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (c *StatusClient) Update(ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error

Variables

var (
	ControlPlaneNamespace = "kubeslice-system"

	HubSecretSuffix      = "-kubernetes-dashboard"
	KubeSliceDashboardSA = "kubeslice-kubernetes-dashboard"
)

Types

type MockClient

type MockClient struct {
	client.Client
	mock.Mock
	StatusMock *StatusClient
}

Client is a mock for the controller-runtime dynamic client interface.

func NewClient

func NewClient() *MockClient

func (*MockClient) Create

func (c *MockClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*MockClient) Delete

func (c *MockClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*MockClient) DeleteAllOf

func (c *MockClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*MockClient) Get

func (c *MockClient) Get(ctx context.Context, key types.NamespacedName, obj client.Object, opts ...client.GetOption) error

func (*MockClient) List

func (c *MockClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*MockClient) Patch

func (c *MockClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*MockClient) RESTMapper

func (c *MockClient) RESTMapper() meta.RESTMapper

func (*MockClient) Scheme

func (c *MockClient) Scheme() *runtime.Scheme

func (*MockClient) Status

func (c *MockClient) Status() client.StatusWriter

func (*MockClient) Update

func (c *MockClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type ServiceImportReconciler

type ServiceImportReconciler struct {
	client.Client
	MeshClient    client.Client
	EventRecorder *events.EventRecorder
}

func (*ServiceImportReconciler) DeleteServiceImportOnSpoke

func (r *ServiceImportReconciler) DeleteServiceImportOnSpoke(ctx context.Context, svcim *spokev1alpha1.WorkerServiceImport) error

func (*ServiceImportReconciler) InjectClient

func (a *ServiceImportReconciler) InjectClient(c client.Client) error

func (*ServiceImportReconciler) Reconcile

func (r *ServiceImportReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

type SliceGwReconciler

type SliceGwReconciler struct {
	client.Client
	MeshClient    client.Client
	EventRecorder *events.EventRecorder
	ClusterName   string
}

func (*SliceGwReconciler) InjectClient

func (r *SliceGwReconciler) InjectClient(c client.Client) error

func (*SliceGwReconciler) Reconcile

func (r *SliceGwReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

type SliceReconciler

type SliceReconciler struct {
	client.Client
	Log               logr.Logger
	MeshClient        client.Client
	EventRecorder     *events.EventRecorder
	ReconcileInterval time.Duration
	// contains filtered or unexported fields
}

func NewSliceReconciler

func NewSliceReconciler(hubclient client.Client, mc client.Client, er *events.EventRecorder, mf metrics.MetricsFactory) *SliceReconciler

func (*SliceReconciler) InjectClient

func (a *SliceReconciler) InjectClient(c client.Client) error

func (*SliceReconciler) Reconcile

func (r *SliceReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*SliceReconciler) UpdateSliceHealthMetrics

func (r *SliceReconciler) UpdateSliceHealthMetrics(slice *spokev1alpha1.WorkerSliceConfig)

type StatusClient

type StatusClient struct {
	mock.Mock
}

func (*StatusClient) Create

func (c *StatusClient) Create(ctx context.Context, obj1 client.Object, obj2 client.Object, opts ...client.SubResourceCreateOption) error

func (*StatusClient) Patch

func (c *StatusClient) Patch(
	ctx context.Context, obj client.Object, patch client.Patch, opts ...client.SubResourcePatchOption) error

func (*StatusClient) Update

func (c *StatusClient) Update(
	ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error