Versions in this module Expand all Collapse all v1 v1.0.1 Nov 28, 2023 Changes in this version + const CSRNameSuffix + const CfgFile + const CfgPath + const ConsoleAdminPolicyName + const ConsoleName + const ConsolePort + const ConsoleServicePortName + const ConsoleServiceTLSPortName + const ConsoleTLSPort + const ConsoleTenantLabel + const DefaultImagePullPolicy + const DefaultKESImage + const DefaultKESReplicas + const DefaultMinIOImage + const DefaultMinIOUpdateURL + const DefaultMonitoringInterval + const DefaultPodManagementPolicy + const DefaultPrometheusNamespace + const DefaultUpdateStrategy + const KESConfigMountPath + const KESContainerName + const KESHLSvcNameSuffix + const KESInstanceLabel + const KESMinIOKey + const KESName + const KESPort + const KESServicePortName + const MinIOBrowserRedirectURL + const MinIOCRDResourceKind + const MinIOCertPath + const MinIODomain + const MinIOHLSvcNameSuffix + const MinIOPort + const MinIOPortLoadBalancerSVC + const MinIOPrometheusPathCluster + const MinIOPrometheusScrapeInterval + const MinIOSFTPPort + const MinIOServerName + const MinIOServerURL + const MinIOServiceHTTPPortName + const MinIOServiceHTTPSPortName + const MinIOServiceSFTPPortName + const MinIOTLSPortLoadBalancerSVC + const MinIOVolumeMountPath + const MinIOVolumeName + const MinIOVolumeSubPath + const PoolLabel + const PrometheusAddlScrapeConfigKey + const PrometheusAddlScrapeConfigSecret + const PrometheusName + const PrometheusNamespace + const Revision + const StatefulSetLegacyPrefix + const StatefulSetPrefix + const TenantConfigurationSecretSuffix + const TenantLabel + const TmpPath + const Version + const ZoneLabel + var AddToScheme = SchemeBuilder.AddToScheme + var DefaultEllipticCurve = elliptic.P256() + var DefaultOrgName = []string + var DefaultQueryInterval = time.Second * 5 + var DefaultQueryTimeout = time.Minute * 20 + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + var TLSSecretSuffix = "-tls" + func CompactJSONString(jsonObject string) (string, error) + func ExtractTar(filesToExtract []string, basePath, tarFileName string) error + func GenerateCredentials() (accessKey, secretKey string, err error) + func GenerateTenantConfigurationFile(configuration map[string]string) string + func GetClusterDomain() string + func GetMonitoringInterval() int + func GetNSFromFile() string + func GetOpenshiftCSRSignerCAFromFile() []byte + func GetOpenshiftServiceCAFromFile() []byte + func GetPodCAFromFile() []byte + func GetPrivateKeyFilePath(serviceName string) string + func GetPrometheusName() string + func GetPrometheusNamespace() string + func GetPublicCertFilePath(serviceName string) string + func GetTenantKesImage() string + func GetTenantMinIOImage() string + func IsContainersEnvUpdated(existingContainers, expectedContainers []corev1.Container) bool + func IsEnvUpdated(old, new map[string]string) bool + func Kind(kind string) schema.GroupKind + func MergeMaps(a, b map[string]string) map[string]string + func MustGetSystemCertPool() *x509.CertPool + func ParseRawConfiguration(configuration []byte) (config map[string][]byte) + func ReleaseTagToReleaseTime(releaseTag string) (releaseTime time.Time, err error) + func Resource(resource string) schema.GroupResource + func ToMap(envs []corev1.EnvVar) map[string]string + type AuditConfig struct + DiskCapacityGB *int + func (in *AuditConfig) DeepCopy() *AuditConfig + func (in *AuditConfig) DeepCopyInto(out *AuditConfig) + type Bucket struct + Name string + ObjectLocking bool + Region string + func (in *Bucket) DeepCopy() *Bucket + func (in *Bucket) DeepCopyInto(out *Bucket) + type CertificateConfig struct + CommonName string + DNSNames []string + OrganizationName []string + func (in *CertificateConfig) DeepCopy() *CertificateConfig + func (in *CertificateConfig) DeepCopyInto(out *CertificateConfig) + type CertificateStatus struct + AutoCertEnabled *bool + CustomCertificates *CustomCertificates + func (in *CertificateStatus) DeepCopy() *CertificateStatus + func (in *CertificateStatus) DeepCopyInto(out *CertificateStatus) + type CustomCertificateConfig struct + CertName string + Domains []string + ExpiresIn string + Expiry string + SerialNo string + func (in *CustomCertificateConfig) DeepCopy() *CustomCertificateConfig + func (in *CustomCertificateConfig) DeepCopyInto(out *CustomCertificateConfig) + type CustomCertificates struct + Client []*CustomCertificateConfig + Minio []*CustomCertificateConfig + MinioCAs []*CustomCertificateConfig + func (in *CustomCertificates) DeepCopy() *CustomCertificates + func (in *CustomCertificates) DeepCopyInto(out *CustomCertificates) + type ExposeServices struct + Console bool + MinIO bool + func (in *ExposeServices) DeepCopy() *ExposeServices + func (in *ExposeServices) DeepCopyInto(out *ExposeServices) + type Features struct + BucketDNS bool + Domains *TenantDomains + EnableSFTP *bool + func (in *Features) DeepCopy() *Features + func (in *Features) DeepCopyInto(out *Features) + type HealthStatus string + const HealthStatusGreen + const HealthStatusRed + const HealthStatusYellow + type KESConfig struct + Affinity *corev1.Affinity + Annotations map[string]string + ClientCertSecret *LocalCertificateReference + Configuration *corev1.LocalObjectReference + Env []corev1.EnvVar + ExternalCertSecret *LocalCertificateReference + GCPCredentialSecretName string + GCPWorkloadIdentityPool string + Image string + ImagePullPolicy corev1.PullPolicy + KeyName string + Labels map[string]string + NodeSelector map[string]string + Replicas int32 + Resources corev1.ResourceRequirements + SecurityContext *corev1.PodSecurityContext + ServiceAccountName string + Tolerations []corev1.Toleration + TopologySpreadConstraints []corev1.TopologySpreadConstraint + func (c *KESConfig) EqualImage(currentImage string) bool + func (in *KESConfig) DeepCopy() *KESConfig + func (in *KESConfig) DeepCopyInto(out *KESConfig) + type LocalCertificateReference struct + Name string + Type string + func (in *LocalCertificateReference) DeepCopy() *LocalCertificateReference + func (in *LocalCertificateReference) DeepCopyInto(out *LocalCertificateReference) + type Logging struct + Anonymous bool + JSON bool + Quiet bool + func (in *Logging) DeepCopy() *Logging + func (in *Logging) DeepCopyInto(out *Logging) + type Pool struct + Affinity *corev1.Affinity + Annotations map[string]string + ContainerSecurityContext *corev1.SecurityContext + Labels map[string]string + Name string + NodeSelector map[string]string + ReclaimStorage *bool + Resources corev1.ResourceRequirements + RuntimeClassName *string + SecurityContext *corev1.PodSecurityContext + Servers int32 + Tolerations []corev1.Toleration + TopologySpreadConstraints []corev1.TopologySpreadConstraint + VolumeClaimTemplate *corev1.PersistentVolumeClaim + VolumesPerServer int32 + func (in *Pool) DeepCopy() *Pool + func (in *Pool) DeepCopyInto(out *Pool) + func (z *Pool) Validate(zi int) error + type PoolState string + const PoolCreated + const PoolInitialized + const PoolNotCreated + type PoolStatus struct + LegacySecurityContext bool + SSName string + State PoolState + func (in *PoolStatus) DeepCopy() *PoolStatus + func (in *PoolStatus) DeepCopyInto(out *PoolStatus) + type ServiceMetadata struct + ConsoleServiceAnnotations map[string]string + ConsoleServiceLabels map[string]string + MinIOServiceAnnotations map[string]string + MinIOServiceLabels map[string]string + func (in *ServiceMetadata) DeepCopy() *ServiceMetadata + func (in *ServiceMetadata) DeepCopyInto(out *ServiceMetadata) + type SideCars struct + Containers []corev1.Container + Resources *corev1.ResourceRequirements + VolumeClaimTemplates []corev1.PersistentVolumeClaim + Volumes []corev1.Volume + func (in *SideCars) DeepCopy() *SideCars + func (in *SideCars) DeepCopyInto(out *SideCars) + type Tenant struct + Scheduler TenantScheduler + Spec TenantSpec + Status TenantStatus + func (*Tenant) Hub() + func (in *Tenant) DeepCopy() *Tenant + func (in *Tenant) DeepCopyInto(out *Tenant) + func (in *Tenant) DeepCopyObject() runtime.Object + func (t *Tenant) AllMinIOHosts() []string + func (t *Tenant) AutoCert() bool + func (t *Tenant) BucketDNS() bool + func (t *Tenant) ConfigurationSecretName() string + func (t *Tenant) ConsoleCIServiceName() string + func (t *Tenant) ConsoleCSRName() string + func (t *Tenant) ConsoleCommonName() string + func (t *Tenant) ConsoleDeploymentName() string + func (t *Tenant) ConsolePodLabels() map[string]string + func (t *Tenant) ConsoleServerHost() string + func (t *Tenant) ConsoleTLSSecretName() string + func (t *Tenant) ConsoleVolMountName() string + func (t *Tenant) CreateBuckets(minioClient *minio.Client, buckets ...Bucket) (created bool, err error) + func (t *Tenant) CreateUsers(madmClnt *madmin.AdminClient, userCredentialSecrets []*corev1.Secret, ...) error + func (t *Tenant) EnsureDefaults() *Tenant + func (t *Tenant) ExternalCaCerts() bool + func (t *Tenant) ExternalCert() bool + func (t *Tenant) ExternalClientCert() bool + func (t *Tenant) ExternalClientCerts() bool + func (t *Tenant) GenBearerToken(accessKey, secretKey string) string + func (t *Tenant) GetBindingName() string + func (t *Tenant) GetDomainHosts() []string + func (t *Tenant) GetEnvVars() (env []corev1.EnvVar) + func (t *Tenant) GetKESEnvVars() (env []corev1.EnvVar) + func (t *Tenant) GetRoleName() string + func (t *Tenant) GetTenantServiceURL() (svcURL string) + func (t *Tenant) HasCertConfig() bool + func (t *Tenant) HasConfigurationSecret() bool + func (t *Tenant) HasConsoleDomains() bool + func (t *Tenant) HasCredsSecret() bool + func (t *Tenant) HasEnv(envName string) bool + func (t *Tenant) HasGCPCredentialSecretForKES() bool + func (t *Tenant) HasGCPWorkloadIdentityPoolForKES() bool + func (t *Tenant) HasKESEnabled() bool + func (t *Tenant) HasMinIODomains() bool + func (t *Tenant) HasPrometheusOperatorEnabled() bool + func (t *Tenant) KESCSRName() string + func (t *Tenant) KESClientCert() bool + func (t *Tenant) KESExternalCert() bool + func (t *Tenant) KESHLServiceName() string + func (t *Tenant) KESHosts() []string + func (t *Tenant) KESJobName() string + func (t *Tenant) KESPodLabels() map[string]string + func (t *Tenant) KESReplicas() int32 + func (t *Tenant) KESServiceEndpoint() string + func (t *Tenant) KESServiceHost() string + func (t *Tenant) KESStatefulSetName() string + func (t *Tenant) KESTLSSecretName() string + func (t *Tenant) KESVolMountName() string + func (t *Tenant) KESWildCardName() string + func (t *Tenant) LegacyStatefulsetName(pool *Pool) string + func (t *Tenant) MinIOBucketBaseDomain() string + func (t *Tenant) MinIOBucketBaseWildcardDomain() string + func (t *Tenant) MinIOCIServiceName() string + func (t *Tenant) MinIOCSRName() string + func (t *Tenant) MinIOClientCSRName() string + func (t *Tenant) MinIOClientTLSSecretName() string + func (t *Tenant) MinIOEndpoints(hostsTemplate string) (endpoints []string) + func (t *Tenant) MinIOFQDNServiceName() string + func (t *Tenant) MinIOFQDNServiceNameAndNamespace() string + func (t *Tenant) MinIOFQDNShortServiceName() string + func (t *Tenant) MinIOHLPodAddress(podName string) string + func (t *Tenant) MinIOHLPodHostname(podName string) string + func (t *Tenant) MinIOHLServiceName() string + func (t *Tenant) MinIOHeadlessServiceHost() string + func (t *Tenant) MinIOHealthCheck(tr *http.Transport) bool + func (t *Tenant) MinIOHosts() (hosts []string) + func (t *Tenant) MinIOPodLabels() map[string]string + func (t *Tenant) MinIOServerEndpoint() string + func (t *Tenant) MinIOServerHostAddress() string + func (t *Tenant) MinIOStatefulSetNameForPool(z *Pool) string + func (t *Tenant) MinIOTLSSecretName() string + func (t *Tenant) MinIOWildCardName() string + func (t *Tenant) NewMinIOAdmin(minioSecret map[string][]byte, tr *http.Transport) (*madmin.AdminClient, error) + func (t *Tenant) NewMinIOAdminForAddress(address string, minioSecret map[string][]byte, tr *http.Transport) (*madmin.AdminClient, error) + func (t *Tenant) NewMinIOUser(minioSecret map[string][]byte, tr *http.Transport) (*minio.Client, error) + func (t *Tenant) NewMinIOUserForAddress(address string, minioSecret map[string][]byte, tr *http.Transport) (*minio.Client, error) + func (t *Tenant) ObjectRef() corev1.ObjectReference + func (t *Tenant) OwnerRef() []metav1.OwnerReference + func (t *Tenant) PoolStatefulsetName(pool *Pool) string + func (t *Tenant) PrometheusConfigJobName() string + func (t *Tenant) PrometheusConfigMapName() string + func (t *Tenant) PrometheusOperatorAddlConfigJobName() string + func (t *Tenant) TLS() bool + func (t *Tenant) TemplatedMinIOHosts(hostsTemplate string) (hosts []string) + func (t *Tenant) UpdateURL(ltag string, overrideURL string) (string, error) + func (t *Tenant) Validate() error + func (t *Tenant) ValidateDomains() error + func (t *Tenant) VolumePathForPool(pool *Pool) string + type TenantDomains struct + Console string + Minio []string + func (in *TenantDomains) DeepCopy() *TenantDomains + func (in *TenantDomains) DeepCopyInto(out *TenantDomains) + type TenantList struct + Items []Tenant + func (in *TenantList) DeepCopy() *TenantList + func (in *TenantList) DeepCopyInto(out *TenantList) + func (in *TenantList) DeepCopyObject() runtime.Object + type TenantScheduler struct + Name string + func (in *TenantScheduler) DeepCopy() *TenantScheduler + func (in *TenantScheduler) DeepCopyInto(out *TenantScheduler) + type TenantSpec struct + AdditionalVolumeMounts []corev1.VolumeMount + AdditionalVolumes []corev1.Volume + Buckets []Bucket + CertConfig *CertificateConfig + Configuration *corev1.LocalObjectReference + CredsSecret *corev1.LocalObjectReference + Env []corev1.EnvVar + ExposeServices *ExposeServices + ExternalCaCertSecret []*LocalCertificateReference + ExternalCertSecret []*LocalCertificateReference + ExternalClientCertSecret *LocalCertificateReference + ExternalClientCertSecrets []*LocalCertificateReference + Features *Features + Image string + ImagePullPolicy corev1.PullPolicy + ImagePullSecret corev1.LocalObjectReference + InitContainers []corev1.Container + KES *KESConfig + Liveness *corev1.Probe + Logging *Logging + Mountpath string + PodManagementPolicy appsv1.PodManagementPolicyType + Pools []Pool + PriorityClassName string + PrometheusOperator bool + Readiness *corev1.Probe + RequestAutoCert *bool + ServiceAccountName string + ServiceMetadata *ServiceMetadata + SideCars *SideCars + Startup *corev1.Probe + Subpath string + Users []*corev1.LocalObjectReference + func (in *TenantSpec) DeepCopy() *TenantSpec + func (in *TenantSpec) DeepCopyInto(out *TenantSpec) + type TenantStatus struct + AvailableReplicas int32 + Certificates CertificateStatus + CurrentState string + DrivesHealing int32 + DrivesOffline int32 + DrivesOnline int32 + HealthMessage string + HealthStatus HealthStatus + Pools []PoolStatus + ProvisionedBuckets bool + ProvisionedUsers bool + Revision int32 + SyncVersion string + Usage TenantUsage + WaitingOnReady *metav1.Time + WriteQuorum int32 + func (in *TenantStatus) DeepCopy() *TenantStatus + func (in *TenantStatus) DeepCopyInto(out *TenantStatus) + type TenantUsage struct + Capacity int64 + RawCapacity int64 + RawUsage int64 + Tiers []TierUsage + Usage int64 + func (in *TenantUsage) DeepCopy() *TenantUsage + func (in *TenantUsage) DeepCopyInto(out *TenantUsage) + type TierUsage struct + Name string + TotalSize int64 + Type string + func (in *TierUsage) DeepCopy() *TierUsage + func (in *TierUsage) DeepCopyInto(out *TierUsage)