cluster

Documentation

Index

• Constants
• func ClusterClientset(config *rest.Config) (*kubeclient.Clientset, error)
• func ClusterServiceAccountName(joiningClusterName, hostClusterName string) string
• func HostClientset(config *rest.Config) (*kubeclient.Clientset, error)
• func IsPrimaryCluster(obj, clusterObj pkgruntime.Object) bool
• func MetaAccessor(obj pkgruntime.Object) metav1.Object
• func NewClusterController(k8sClient kubernetes.Interface, ksClient kubesphere.Interface, ...) *clusterController
• type ValidatingHandler
  • func (h *ValidatingHandler) Handle(ctx context.Context, req admission.Request) admission.Response
  • func (h *ValidatingHandler) InjectDecoder(d *admission.Decoder) error

Constants

const (
	NotificationCleanup = "notification.kubesphere.io/cleanup"
)

Functions

func ClusterClientset

func ClusterClientset(config *rest.Config) (*kubeclient.Clientset, error)

ClusterClientset provides a kubernetes API compliant clientset to communicate with the joining cluster's kubernetes API server.

func ClusterServiceAccountName

func ClusterServiceAccountName(joiningClusterName, hostClusterName string) string

ClusterServiceAccountName returns the name of a service account whose credentials are used by the host cluster to access the client cluster.

func HostClientset

func HostClientset(config *rest.Config) (*kubeclient.Clientset, error)

HostClientset provides a kubernetes API compliant clientset to communicate with the host cluster's kubernetes API server.

func IsPrimaryCluster

func IsPrimaryCluster(obj, clusterObj pkgruntime.Object) bool

IsPrimaryCluster checks if the caller is working with objects for the primary cluster by checking if the UIDs match for both ObjectMetas passed in. TODO (font): Need to revisit this when cluster ID is available.

func MetaAccessor

func MetaAccessor(obj pkgruntime.Object) metav1.Object

func NewClusterController

func NewClusterController(
	k8sClient kubernetes.Interface,
	ksClient kubesphere.Interface,
	config *rest.Config,
	clusterInformer clusterinformer.ClusterInformer,
	userLister iamv1alpha2listers.UserLister,
	resyncPeriod time.Duration,
	hostClusterName string,
) *clusterController

Types

type ValidatingHandler

type ValidatingHandler struct {
	Client client.Client
	// contains filtered or unexported fields
}

func (*ValidatingHandler) Handle

func (h *ValidatingHandler) Handle(ctx context.Context, req admission.Request) admission.Response

Handle handles admission requests.

func (*ValidatingHandler) InjectDecoder

func (h *ValidatingHandler) InjectDecoder(d *admission.Decoder) error

InjectDecoder injects the decoder into a ValidatingHandler.