cluster

Documentation

Index

• Constants
• Variables
• func MinIOControllerRateLimiter() queue.RateLimiter
• 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"
	StatusProvisioningLogPGStatefulSet       = "Provisioning Postgres server for Log Search feature"
	StatusProvisioningLogSearchAPIDeployment = "Provisioning Log Search API server for Log Search feature"
	StatusProvisioningPrometheusStatefulSet  = "Provisioning Prometheus server for Prometheus metrics feature"
	StatusWaitingForReadyState               = "Waiting for Pods to be ready"
	StatusWaitingForLogSearchReadyState      = "Waiting for Log Search 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"
	StatusUpdatingConsole                    = "Updating Console"
	StatusUpdatingLogPGStatefulSet           = "Updating Postgres server for Log Search feature"
	StatusUpdatingLogSearchAPIServer         = "Updating Log Search API server"
	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 Pools"
)

Standard Status messages for Tenant

Variables

var ErrLogSearchNotReady = fmt.Errorf("Log Search is not ready")

ErrLogSearchNotReady is the error returned when Log Search is not Ready

var ErrMinIONotReady = fmt.Errorf("MinIO is not ready")

ErrMinIONotReady is the error returned when MinIO is not Ready

Functions

func MinIOControllerRateLimiter

func MinIOControllerRateLimiter() queue.RateLimiter

MinIOControllerRateLimiter is a no-arg constructor for a default rate limiter for a workqueue for our controller. both overall and per-item rate limiting. The overall is a token bucket and the per-item is exponential

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