fleet

Documentation

Index

• Constants
• func BuildFleetClusters(ctx context.Context, client client.Client, fleet *fleetapi.Fleet) (map[ClusterKey]*FleetCluster, error)
• func ClientForCluster(client client.Client, ns string, cluster ClusterInterface) (*kclient.Client, error)
• type ClusterInterface
• type ClusterKey
• type FleetCluster
  • func (cluster FleetCluster) GetRuntimeClient() client.Client
• type FleetManager
  • func (f *FleetManager) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (f *FleetManager) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	ClusterKind         = "Cluster"
	AttachedClusterKind = "AttachedCluster"
)

const (
	FleetFinalizer = "fleet.kurator.dev"

	RequeueAfter = 5 * time.Second
	// TODO: remove as we have `FleetNameLabel`
	FleetLabel = "fleet.kurator.dev/fleet-name"
)

const (
	MonitoringNamespace         = "monitoring"
	PrometheusThanosServiceName = "prometheus-prometheus-thanos"

	NoneClusterIP = "None"
)

const (
	AccessKey = "access-key"
	SecretKey = "secret-key"

	AWS         = "aws"
	HuaWeiCloud = "huaweicloud"
	GCP         = "gcp"
	Azure       = "azure"

	AWSObjStoreSecretNameSuffix         = "-velero-s3"
	HuaWeiCloudObjStoreSecretNameSuffix = "-velero-obs"
	GCPObjStoreSecretNameSuffix         = "-velero-gcs"
	AzureObjStoreSecretNameSuffix       = "-velero-abs"

	ObjStoreSecretNamespace = "velero"
)

const (
	FleetNameLabel  = "fleet.kurator.dev/name"
	FleetPluginName = "fleet.kurator.dev/plugin"

	ManagedByLabel        = "app.kubernetes.io/managed-by"
	ManagedByFleetManager = "fleet-manager"
)

const FleetWorkerClusterRoleBindingName = "fleet-worker"

const KarmadaCtlImage = "ghcr.io/kurator-dev/karmadactl:v0.1.0"

const ServiceAccountName = "fleet-manager-worker"

Functions

func BuildFleetClusters

func BuildFleetClusters(ctx context.Context, client client.Client, fleet *fleetapi.Fleet) (map[ClusterKey]*FleetCluster, error)

func ClientForCluster

func ClientForCluster(client client.Client, ns string, cluster ClusterInterface) (*kclient.Client, error)

Types

type ClusterInterface

type ClusterInterface interface {
	IsReady() bool
	GetObject() client.Object
	GetSecretName() string
	GetSecretKey() string
}

TODO: rename to FleetCluster?

type ClusterKey

type ClusterKey struct {
	Kind string
	Name string
}

type FleetCluster

type FleetCluster struct {
	Secret    string
	SecretKey string
	Client    *kclient.Client
}

func (FleetCluster) GetRuntimeClient

func (cluster FleetCluster) GetRuntimeClient() client.Client

type FleetManager

type FleetManager struct {
	client.Client
	Scheme    *runtime.Scheme
	Manifests fs.FS
}

FleetManager reconciles a Cluster object

func (*FleetManager) Reconcile

func (f *FleetManager) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*FleetManager) SetupWithManager

func (f *FleetManager) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.