commonarea

package
v1.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 21, 2022 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TimestampAnnotationKey = "touch-ts"
)

Variables

View Source 
var (
	ReasonDisconnected = "Disconnected"
)

Functions

func GetSecretCACrtAndToken added in v1.8.0 

func GetSecretCACrtAndToken(secretObj *v1.Secret) ([]byte, []byte, error)

*

  • GetSecretCACrtAndToken returns the access credentials from Secret.

Types

type CommonArea 

type CommonArea interface {
	// Client grants read/write to the Namespace of the cluster that is backing this CommonArea.
	client.Client

	// GetClusterID returns the clusterID of the leader cluster.
	GetClusterID() common.ClusterID

	// GetNamespace returns the Namespace backing this CommonArea.
	GetNamespace() string
}

CommonArea is an interface that provides access to the Common Area of a ClusterSet. Common Area of a ClusterSet is a Namespace in the leader cluster.

type LabelIdentityResourceImportReconciler added in v1.9.0 

type LabelIdentityResourceImportReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

LabelIdentityResourceImportReconciler reconciles a LabelIdentity kind of ResourceImport object in the member cluster.

func NewLabelIdentityResourceImportReconciler added in v1.9.0 

func NewLabelIdentityResourceImportReconciler(client client.Client, scheme *runtime.Scheme, localClusterClient client.Client,
	localClusterID string, namespace string, remoteCommonArea RemoteCommonArea) *LabelIdentityResourceImportReconciler

func (*LabelIdentityResourceImportReconciler) Reconcile added in v1.9.0 

func (r *LabelIdentityResourceImportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*LabelIdentityResourceImportReconciler) SetupWithManager added in v1.9.0 

func (r *LabelIdentityResourceImportReconciler) SetupWithManager(mgr ctrl.Manager) error

type MockCommonArea added in v1.8.0 

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

MockCommonArea is a mock of CommonArea interface.

func NewMockCommonArea added in v1.8.0 

func NewMockCommonArea(ctrl *gomock.Controller) *MockCommonArea

NewMockCommonArea creates a new mock instance.

func (*MockCommonArea) Create added in v1.8.0 

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

Create mocks base method.

func (*MockCommonArea) Delete added in v1.8.0 

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

Delete mocks base method.

func (*MockCommonArea) DeleteAllOf added in v1.8.0 

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

DeleteAllOf mocks base method.

func (*MockCommonArea) EXPECT added in v1.8.0 

func (m *MockCommonArea) EXPECT() *MockCommonAreaMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCommonArea) Get added in v1.8.0 

func (m *MockCommonArea) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

Get mocks base method.

func (*MockCommonArea) GetClusterID added in v1.8.0 

func (m *MockCommonArea) GetClusterID() common.ClusterID

GetClusterID mocks base method.

func (*MockCommonArea) GetNamespace added in v1.8.0 

func (m *MockCommonArea) GetNamespace() string

GetNamespace mocks base method.

func (*MockCommonArea) List added in v1.8.0 

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

List mocks base method.

func (*MockCommonArea) Patch added in v1.8.0 

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

Patch mocks base method.

func (*MockCommonArea) RESTMapper added in v1.8.0 

func (m *MockCommonArea) RESTMapper() meta.RESTMapper

RESTMapper mocks base method.

func (*MockCommonArea) Scheme added in v1.8.0 

func (m *MockCommonArea) Scheme() *runtime.Scheme

Scheme mocks base method.

func (*MockCommonArea) Status added in v1.8.0 

func (m *MockCommonArea) Status() client.StatusWriter

Status mocks base method.

func (*MockCommonArea) Update added in v1.8.0 

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

Update mocks base method.

type MockCommonAreaMockRecorder added in v1.8.0 

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

MockCommonAreaMockRecorder is the mock recorder for MockCommonArea.

func (*MockCommonAreaMockRecorder) Create added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) Create(ctx, obj interface{}, opts ...interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockCommonAreaMockRecorder) Delete added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) Delete(ctx, obj interface{}, opts ...interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockCommonAreaMockRecorder) DeleteAllOf added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) DeleteAllOf(ctx, obj interface{}, opts ...interface{}) *gomock.Call

DeleteAllOf indicates an expected call of DeleteAllOf.

func (*MockCommonAreaMockRecorder) Get added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) Get(ctx, key, obj interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockCommonAreaMockRecorder) GetClusterID added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) GetClusterID() *gomock.Call

GetClusterID indicates an expected call of GetClusterID.

func (*MockCommonAreaMockRecorder) GetNamespace added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) GetNamespace() *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockCommonAreaMockRecorder) List added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) List(ctx, list interface{}, opts ...interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockCommonAreaMockRecorder) Patch added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) Patch(ctx, obj, patch interface{}, opts ...interface{}) *gomock.Call

Patch indicates an expected call of Patch.

func (*MockCommonAreaMockRecorder) RESTMapper added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) RESTMapper() *gomock.Call

RESTMapper indicates an expected call of RESTMapper.

func (*MockCommonAreaMockRecorder) Scheme added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) Scheme() *gomock.Call

Scheme indicates an expected call of Scheme.

func (*MockCommonAreaMockRecorder) Status added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status.

func (*MockCommonAreaMockRecorder) Update added in v1.8.0 

func (mr *MockCommonAreaMockRecorder) Update(ctx, obj interface{}, opts ...interface{}) *gomock.Call

Update indicates an expected call of Update.

type MockRemoteCommonArea 

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

MockRemoteCommonArea is a mock of RemoteCommonArea interface.

func NewMockRemoteCommonArea 

func NewMockRemoteCommonArea(ctrl *gomock.Controller) *MockRemoteCommonArea

NewMockRemoteCommonArea creates a new mock instance.

func (*MockRemoteCommonArea) Create 

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

Create mocks base method.

func (*MockRemoteCommonArea) Delete 

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

Delete mocks base method.

func (*MockRemoteCommonArea) DeleteAllOf 

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

DeleteAllOf mocks base method.

func (*MockRemoteCommonArea) EXPECT 

func (m *MockRemoteCommonArea) EXPECT() *MockRemoteCommonAreaMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRemoteCommonArea) Get 

func (m *MockRemoteCommonArea) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

Get mocks base method.

func (*MockRemoteCommonArea) GetClusterID 

func (m *MockRemoteCommonArea) GetClusterID() common.ClusterID

GetClusterID mocks base method.

func (*MockRemoteCommonArea) GetLocalClusterID added in v1.8.0 

func (m *MockRemoteCommonArea) GetLocalClusterID() string

GetLocalClusterID mocks base method.

func (*MockRemoteCommonArea) GetNamespace 

func (m *MockRemoteCommonArea) GetNamespace() string

GetNamespace mocks base method.

func (*MockRemoteCommonArea) GetStatus 

func (m *MockRemoteCommonArea) GetStatus() []v1alpha1.ClusterCondition

GetStatus mocks base method.

func (*MockRemoteCommonArea) IsConnected 

func (m *MockRemoteCommonArea) IsConnected() bool

IsConnected mocks base method.

func (*MockRemoteCommonArea) List 

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

List mocks base method.

func (*MockRemoteCommonArea) Patch 

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

Patch mocks base method.

func (*MockRemoteCommonArea) RESTMapper 

func (m *MockRemoteCommonArea) RESTMapper() meta.RESTMapper

RESTMapper mocks base method.

func (*MockRemoteCommonArea) Scheme 

func (m *MockRemoteCommonArea) Scheme() *runtime.Scheme

Scheme mocks base method.

func (*MockRemoteCommonArea) Start 

func (m *MockRemoteCommonArea) Start() context.CancelFunc

Start mocks base method.

func (*MockRemoteCommonArea) StartWatching 

func (m *MockRemoteCommonArea) StartWatching() error

StartWatching mocks base method.

func (*MockRemoteCommonArea) Status 

func (m *MockRemoteCommonArea) Status() client.StatusWriter

Status mocks base method.

func (*MockRemoteCommonArea) Stop 

func (m *MockRemoteCommonArea) Stop()

Stop mocks base method.

func (*MockRemoteCommonArea) StopWatching 

func (m *MockRemoteCommonArea) StopWatching()

StopWatching mocks base method.

func (*MockRemoteCommonArea) Update 

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

Update mocks base method.

type MockRemoteCommonAreaMockRecorder 

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

MockRemoteCommonAreaMockRecorder is the mock recorder for MockRemoteCommonArea.

func (*MockRemoteCommonAreaMockRecorder) Create 

func (mr *MockRemoteCommonAreaMockRecorder) Create(ctx, obj interface{}, opts ...interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockRemoteCommonAreaMockRecorder) Delete 

func (mr *MockRemoteCommonAreaMockRecorder) Delete(ctx, obj interface{}, opts ...interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockRemoteCommonAreaMockRecorder) DeleteAllOf 

func (mr *MockRemoteCommonAreaMockRecorder) DeleteAllOf(ctx, obj interface{}, opts ...interface{}) *gomock.Call

DeleteAllOf indicates an expected call of DeleteAllOf.

func (*MockRemoteCommonAreaMockRecorder) Get 

func (mr *MockRemoteCommonAreaMockRecorder) Get(ctx, key, obj interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockRemoteCommonAreaMockRecorder) GetClusterID 

func (mr *MockRemoteCommonAreaMockRecorder) GetClusterID() *gomock.Call

GetClusterID indicates an expected call of GetClusterID.

func (*MockRemoteCommonAreaMockRecorder) GetLocalClusterID added in v1.8.0 

func (mr *MockRemoteCommonAreaMockRecorder) GetLocalClusterID() *gomock.Call

GetLocalClusterID indicates an expected call of GetLocalClusterID.

func (*MockRemoteCommonAreaMockRecorder) GetNamespace 

func (mr *MockRemoteCommonAreaMockRecorder) GetNamespace() *gomock.Call

GetNamespace indicates an expected call of GetNamespace.

func (*MockRemoteCommonAreaMockRecorder) GetStatus 

func (mr *MockRemoteCommonAreaMockRecorder) GetStatus() *gomock.Call

GetStatus indicates an expected call of GetStatus.

func (*MockRemoteCommonAreaMockRecorder) IsConnected 

func (mr *MockRemoteCommonAreaMockRecorder) IsConnected() *gomock.Call

IsConnected indicates an expected call of IsConnected.

func (*MockRemoteCommonAreaMockRecorder) List 

func (mr *MockRemoteCommonAreaMockRecorder) List(ctx, list interface{}, opts ...interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockRemoteCommonAreaMockRecorder) Patch 

func (mr *MockRemoteCommonAreaMockRecorder) Patch(ctx, obj, patch interface{}, opts ...interface{}) *gomock.Call

Patch indicates an expected call of Patch.

func (*MockRemoteCommonAreaMockRecorder) RESTMapper 

func (mr *MockRemoteCommonAreaMockRecorder) RESTMapper() *gomock.Call

RESTMapper indicates an expected call of RESTMapper.

func (*MockRemoteCommonAreaMockRecorder) Scheme 

func (mr *MockRemoteCommonAreaMockRecorder) Scheme() *gomock.Call

Scheme indicates an expected call of Scheme.

func (*MockRemoteCommonAreaMockRecorder) Start 

func (mr *MockRemoteCommonAreaMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockRemoteCommonAreaMockRecorder) StartWatching 

func (mr *MockRemoteCommonAreaMockRecorder) StartWatching() *gomock.Call

StartWatching indicates an expected call of StartWatching.

func (*MockRemoteCommonAreaMockRecorder) Status 

func (mr *MockRemoteCommonAreaMockRecorder) Status() *gomock.Call

Status indicates an expected call of Status.

func (*MockRemoteCommonAreaMockRecorder) Stop 

func (mr *MockRemoteCommonAreaMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockRemoteCommonAreaMockRecorder) StopWatching 

func (mr *MockRemoteCommonAreaMockRecorder) StopWatching() *gomock.Call

StopWatching indicates an expected call of StopWatching.

func (*MockRemoteCommonAreaMockRecorder) Update 

func (mr *MockRemoteCommonAreaMockRecorder) Update(ctx, obj interface{}, opts ...interface{}) *gomock.Call

Update indicates an expected call of Update.

type RemoteCommonArea 

type RemoteCommonArea interface {
	CommonArea

	Start() context.CancelFunc

	Stop()

	// IsConnected returns whether the RemoteCommonArea is accessible or not.
	IsConnected() bool

	// StartWatching sets up a Manager to reconcile resource crud operations from CommonArea of RemoteCommonArea.
	StartWatching() error

	// StopWatching stops the Manager so the crud operations in RemoteCommonArea no longer invoke the reconcilers.
	StopWatching()

	GetStatus() []multiclusterv1alpha1.ClusterCondition

	GetLocalClusterID() string
}

RemoteCommonArea is an abstraction to connect to CommonArea of the leader cluster.

func NewFakeRemoteCommonArea 

func NewFakeRemoteCommonArea(fakeClient client.Client, clusterID string, localClusterID string, namespace string) RemoteCommonArea

NewFakeRemoteCommonArea creates a new fakeRemoteCommonArea for unit test purpose only

func NewRemoteCommonArea 

func NewRemoteCommonArea(clusterID common.ClusterID, clusterSetID common.ClusterSetID, localClusterID common.ClusterSetID, url string, secret *v1.Secret,
	scheme *runtime.Scheme, localClusterClient client.Client, clusterSetNamespace string, localNamespace string) (RemoteCommonArea, error)

NewRemoteCommonArea returns a RemoteCommonArea instance which will use access credentials from the Secret to connect to the leader cluster's CommonArea.

type ResourceImportReconciler 

type ResourceImportReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ResourceImportReconciler reconciles a ResourceImport object in the member cluster.

func NewResourceImportReconciler 

func NewResourceImportReconciler(client client.Client, scheme *runtime.Scheme, localClusterClient client.Client,
	localClusterID string, namespace string, remoteCommonArea RemoteCommonArea) *ResourceImportReconciler

func (*ResourceImportReconciler) Reconcile 

func (r *ResourceImportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile will attempt to ensure that the imported Resource is installed in local cluster as per the ResourceImport object.

func (*ResourceImportReconciler) SetupWithManager 

func (r *ResourceImportReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the ClusterManager which will set up controllers for resources that need to be monitored in the remoteCommonArea.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.