storage

Documentation

Index

• Constants
• Variables
• func GetMinIOHostAndSchema(accessURL string) (scheme string, host string, err error)
• type MinIOReconciler
  • func (m *MinIOReconciler) Delete() (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) ExternalUpdate() (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) Provision() (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) ProvisionExternalStorage() (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) ProvisionInClusterSecretAsS3(minioInstamnce *minio.Tenant) (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) Reconcile() (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) Scale() (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) ScaleDown(newReplicas uint64) (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) ScaleUp(newReplicas uint64) (*lcm.CRStatus, error)
  • func (m *MinIOReconciler) Update() (*lcm.CRStatus, error)
• type Minio
• type MinioClient
  • func GetMinioClient(endpoint, accessKeyID, secretAccessKey, location string, useSSL bool) (*MinioClient, error)
  • func (m MinioClient) CreateBucket(bucket string) error
  • func (m MinioClient) IsBucketExists(bucket string) (bool, error)

Constants

const (
	GetMinIOError           = "Get minIO error"
	UpdateMinIOError        = "Update minIO error"
	CreateMinIOSecretError  = "Create minIO secret error"
	CreateMinIOServiceError = "Create service of minIO error"
	CreateMinIOIngressError = "Create ingress of minIO error"
	GetMinIOSecretError     = "Get minIO secret error"
	CreateMinIOError        = "Create minIO CR error"
	ScaleMinIOError         = "Scale minIO error"

	CreateExternalSecretError = "Create external storage secret error"
	GetExternalSecretError    = "Get external storage secret error"
	UpdateExternalSecretError = "Update external storage secret error"
	NotSupportType            = "The type of storage are not supported"
	CreateDefaultBucketError  = "Create default bucket in minIO Error"

	CreateChartMuseumStorageSecretError   = "Create chart museum storage secret err"
	GenerateChartMuseumStorageSecretError = "Generate chart museum storage secret err"
)

Define error message

const (
	DefaultExternalSecretSuffix     = "harbor-cluster-storage"
	ChartMuseumExternalSecretSuffix = "chart-museum-storage"

	DefaultCredsSecret          = "minio-creds"
	ExternalStorageSecretSuffix = "Secret"

	DefaultZone   = "zone-harbor"
	DefaultMinIO  = "minio"
	DefaultRegion = "us-east-1"
	DefaultBucket = "harbor"

	LabelOfStorageType = "storageType"
)

Variables

var (
	HarborClusterMinIOGVK = schema.GroupVersionKind{
		Group:   minio.SchemeGroupVersion.Group,
		Version: minio.SchemeGroupVersion.Version,
		Kind:    minio.MinIOCRDResourceKind,
	}
)

Functions

func GetMinIOHostAndSchema

func GetMinIOHostAndSchema(accessURL string) (scheme string, host string, err error)

Types

type MinIOReconciler

type MinIOReconciler struct {
	HarborCluster         *goharborv1.HarborCluster
	KubeClient            k8s.Client
	Ctx                   context.Context
	Log                   logr.Logger
	Scheme                *runtime.Scheme
	Recorder              record.EventRecorder
	CurrentMinIOCR        *minio.Tenant
	DesiredMinIOCR        *minio.Tenant
	CurrentExternalSecret *corev1.Secret
	DesiredExternalSecret *corev1.Secret
	MinioClient           Minio
}

func (*MinIOReconciler) Delete

func (m *MinIOReconciler) Delete() (*lcm.CRStatus, error)

func (*MinIOReconciler) ExternalUpdate

func (m *MinIOReconciler) ExternalUpdate() (*lcm.CRStatus, error)

func (*MinIOReconciler) Provision

func (m *MinIOReconciler) Provision() (*lcm.CRStatus, error)

func (*MinIOReconciler) ProvisionExternalStorage

func (m *MinIOReconciler) ProvisionExternalStorage() (*lcm.CRStatus, error)

func (*MinIOReconciler) ProvisionInClusterSecretAsS3

func (m *MinIOReconciler) ProvisionInClusterSecretAsS3(minioInstamnce *minio.Tenant) (*lcm.CRStatus, error)

func (*MinIOReconciler) Reconcile

func (m *MinIOReconciler) Reconcile() (*lcm.CRStatus, error)

Reconciler implements the reconcile logic of minIO service

func (*MinIOReconciler) Scale

func (m *MinIOReconciler) Scale() (*lcm.CRStatus, error)

func (*MinIOReconciler) ScaleDown

func (m *MinIOReconciler) ScaleDown(newReplicas uint64) (*lcm.CRStatus, error)

TODO Deprecated

func (*MinIOReconciler) ScaleUp

func (m *MinIOReconciler) ScaleUp(newReplicas uint64) (*lcm.CRStatus, error)

TODO Deprecated

func (*MinIOReconciler) Update

func (m *MinIOReconciler) Update() (*lcm.CRStatus, error)

type Minio

type Minio interface {
	IsBucketExists(bucket string) (bool, error)
	CreateBucket(bucket string) error
}

type MinioClient

type MinioClient struct {
	Client   *minv6.Client
	Location string
}

func GetMinioClient

func GetMinioClient(endpoint, accessKeyID, secretAccessKey, location string, useSSL bool) (*MinioClient, error)

func (MinioClient) CreateBucket

func (m MinioClient) CreateBucket(bucket string) error

func (MinioClient) IsBucketExists

func (m MinioClient) IsBucketExists(bucket string) (bool, error)