Documentation
¶
Index ¶
- Variables
- type 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
- type SliceReconciler
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ControlPlaneNamespace = "kubeslice-system" HubSecretSuffix = "-kubernetes-dashboard" KubeSliceDashboardSA = "kubeslice-kubernetes-dashboard" )
Functions ¶
This section is empty.
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
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
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) UpdateSliceHealthMetrics ¶
func (r *SliceReconciler) UpdateSliceHealthMetrics(slice *spokev1alpha1.WorkerSliceConfig)
type StatusClient ¶
func (*StatusClient) Create ¶ added in v1.3.0
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
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.