cluster

Documentation

Index

• Constants
• type Controller
  • func NewController(kubeClientSet kubernetes.Interface, minioClientSet clientset.Interface, ...) *Controller
  • func (c *Controller) BucketSrvHandler(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) GetenvHandler(w http.ResponseWriter, r *http.Request)
  • func (c *Controller) Start(threadiness int, stopCh <-chan struct{}) error
  • func (c *Controller) Stop()

Constants

const (

	// SuccessSynced is used as part of the Event 'reason' when a Tenant is synced
	SuccessSynced = "Synced"
	// ErrResourceExists is used as part of the Event 'reason' when a Tenant fails
	// to sync due to a StatefulSet of the same name already existing.
	ErrResourceExists = "ErrResourceExists"
	// MessageResourceExists is the message used for Events when a Tenant
	// fails to sync due to a StatefulSet already existing
	MessageResourceExists = "Resource %q already exists and is not managed by MinIO Operator"
	// MessageResourceSynced is the message used for an Event fired when a Tenant
	// is synced successfully
	MessageResourceSynced = "Tenant synced successfully"
)

const (
	StatusInitialized                   = "Initialized"
	StatusProvisioningCIService         = "Provisioning MinIO Cluster IP Service"
	StatusProvisioningHLService         = "Provisioning MinIO Headless Service"
	StatusProvisioningStatefulSet       = "Provisioning MinIO Statefulset"
	StatusProvisioningConsoleDeployment = "Provisioning Console Deployment"
	StatusProvisioningKESStatefulSet    = "Provisioning KES StatefulSet"
	StatusWaitingForReadyState          = "Waiting for Pods to be ready"
	StatusWaitingMinIOCert              = "Waiting for MinIO TLS Certificate"
	StatusWaitingMinIOClientCert        = "Waiting for MinIO TLS Client Certificate"
	StatusWaitingKESCert                = "Waiting for KES TLS Certificate"
	StatusWaitingConsoleCert            = "Waiting for Console TLS Certificate"
	StatusUpdatingMinIOVersion          = "Updating MinIO Version"
	StatusUpdatingConsoleVersion        = "Updating Console Version"
	StatusUpdatingResourceRequirements  = "Updating Resource Requirements"
	StatusUpdatingAffinity              = "Updating Pod Affinity"
	StatusNotOwned                      = "Statefulset not controlled by operator"
	StatusFailedAlreadyExists           = "Another MinIO Tenant already exists in the namespace"
	StatusInconsistentMinIOVersions     = "Different versions across MinIO Zones"
)

Standard Status messages for Tenant

Types

type Controller

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

Controller struct watches the Kubernetes API for changes to Tenant resources

func NewController

func NewController(
	kubeClientSet kubernetes.Interface,
	minioClientSet clientset.Interface,
	certClient certapi.CertificatesV1beta1Client,
	statefulSetInformer appsinformers.StatefulSetInformer,
	deploymentInformer appsinformers.DeploymentInformer,
	jobInformer batchinformers.JobInformer,
	tenantInformer informers.TenantInformer,
	serviceInformer coreinformers.ServiceInformer,
	hostsTemplate, operatorVersion string) *Controller

NewController returns a new sample controller

func (*Controller) BucketSrvHandler

func (c *Controller) BucketSrvHandler(w http.ResponseWriter, r *http.Request)

BucketSrvHandler - POST /webhook/v1/bucketsrv/{namespace}/{name}?bucket={bucket}

func (*Controller) GetenvHandler

func (c *Controller) GetenvHandler(w http.ResponseWriter, r *http.Request)

GetenvHandler - GET /webhook/v1/getenv/{namespace}/{name}?key={env}

func (*Controller) Start

func (c *Controller) Start(threadiness int, stopCh <-chan struct{}) error

Start will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.

func (*Controller) Stop

func (c *Controller) Stop()

Stop is called to shutdown the controller