addons

Documentation

Index

• Constants
• func GetClientConfig(kubeConfigFile string) (*rest.Config, error)
• func GetClientFromConfig(config *rest.Config) (client.Client, error)
• func GetDeploymentsStartingWith(ctx context.Context, spokeClient client.Client, namespace string, ...) ([]string, error)
• func NewAddonAgentCommand() *cobra.Command
• func SetStatus(mmode *ramenv1alpha1.MaintenanceMode, mode ramenv1alpha1.MMode, ...)
• type AddonAgentOptions
  • func (o *AddonAgentOptions) AddFlags(cmd *cobra.Command)
  • func (o *AddonAgentOptions) RunAgent(ctx context.Context)
• type BlueSecretReconciler
  • func (r *BlueSecretReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BlueSecretReconciler) SetupWithManager(mgr ctrl.Manager) error
• type GreenSecretReconciler
  • func (r *GreenSecretReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *GreenSecretReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MaintenanceModeReconciler
  • func (r *MaintenanceModeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MaintenanceModeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MirrorPeerReconciler
  • func (r *MirrorPeerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MirrorPeerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type S3SecretReconciler
  • func (r *S3SecretReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *S3SecretReconciler) SetupWithManager(mgr ctrl.Manager) error
• type SecretExchangeHandlerInterface

Constants

const (
	RBDProvisionerTemplate        = "%s.rbd.csi.ceph.com"
	MaintenanceModeFinalizer      = "maintenance.multicluster.odf.openshift.io"
	RBDMirrorDeploymentNamePrefix = "rook-ceph-rbd-mirror"
	RookCSIEnableKey              = "CSI_ENABLE_OMAP_GENERATOR"
	RookConfigMapName             = "rook-ceph-operator-config"
	RamenLabelTemplate            = "ramendr.openshift.io/%s"
	StorageIDKey                  = "storageid"
	CephFSProvisionerTemplate     = "%s.cephfs.csi.ceph.com"
	SpokeMirrorPeerFinalizer      = "spoke.multicluster.odf.openshift.io"
)

const (
	RookType                                  = "kubernetes.io/rook"
	RookDefaultBlueSecretMatchConvergedString = "cluster-peer-token"
	DefaultExternalSecretName                 = "rook-ceph-mon"
)

const (
	ObjectBucketClaimKind     = "ObjectBucketClaim"
	S3BucketName              = "BUCKET_NAME"
	S3BucketRegion            = "BUCKET_REGION"
	S3RouteName               = "s3"
	DefaultS3EndpointProtocol = "https"
	// DefaultS3Region is used as a placeholder when region information is not provided by NooBaa
	DefaultS3Region = "noobaa"
)

Functions

func GetClientConfig

func GetClientConfig(kubeConfigFile string) (*rest.Config, error)

GetClientConfig returns the rest.Config for a kubeconfig file

func GetClientFromConfig

func GetClientFromConfig(config *rest.Config) (client.Client, error)

GetClientFromConfig returns a controller-runtime Client for a rest.Config

func GetDeploymentsStartingWith

func GetDeploymentsStartingWith(ctx context.Context, spokeClient client.Client, namespace string, prefix string) ([]string, error)

func NewAddonAgentCommand

func NewAddonAgentCommand() *cobra.Command

func SetStatus

func SetStatus(mmode *ramenv1alpha1.MaintenanceMode, mode ramenv1alpha1.MMode, state ramenv1alpha1.MModeState, err error)

Types

type AddonAgentOptions

type AddonAgentOptions struct {
	MetricsAddr          string
	EnableLeaderElection bool
	ProbeAddr            string
	HubKubeconfigFile    string
	SpokeClusterName     string
	DRMode               string
	ZapOpts              zap.Options
}

AddonAgentOptions defines the flags for agent

func (*AddonAgentOptions) AddFlags

func (o *AddonAgentOptions) AddFlags(cmd *cobra.Command)

func (*AddonAgentOptions) RunAgent

func (o *AddonAgentOptions) RunAgent(ctx context.Context)

RunAgent starts the controllers on agent to process work from hub.

type BlueSecretReconciler

type BlueSecretReconciler struct {
	Scheme           *runtime.Scheme
	HubClient        client.Client
	SpokeClient      client.Client
	SpokeClusterName string
}

BlueSecretReconciler reconciles a MirrorPeer object

func (*BlueSecretReconciler) Reconcile

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

func (*BlueSecretReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type GreenSecretReconciler

type GreenSecretReconciler struct {
	Scheme           *runtime.Scheme
	HubClient        client.Client
	SpokeClient      client.Client
	SpokeClusterName string
}

GreenSecretReconciler reconciles a MirrorPeer object

func (*GreenSecretReconciler) Reconcile

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

func (*GreenSecretReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type MaintenanceModeReconciler

type MaintenanceModeReconciler struct {
	Scheme           *runtime.Scheme
	SpokeClient      client.Client
	SpokeClusterName string
}

func (*MaintenanceModeReconciler) Reconcile

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

func (*MaintenanceModeReconciler) SetupWithManager

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

type MirrorPeerReconciler

type MirrorPeerReconciler struct {
	HubClient        client.Client
	Scheme           *runtime.Scheme
	SpokeClient      client.Client
	SpokeClusterName string
}

MirrorPeerReconciler reconciles a MirrorPeer object

func (*MirrorPeerReconciler) Reconcile

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.8.3/pkg/reconcile

func (*MirrorPeerReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type S3SecretReconciler

type S3SecretReconciler struct {
	Scheme           *runtime.Scheme
	HubClient        client.Client
	SpokeClient      client.Client
	SpokeClusterName string
}

S3SecretReconciler reconciles a MirrorPeer object

func (*S3SecretReconciler) Reconcile

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

func (*S3SecretReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type SecretExchangeHandlerInterface

type SecretExchangeHandlerInterface interface {
	// contains filtered or unexported methods
}

common func between different secret handlers