Compare commits

...

2 Commits

Author SHA1 Message Date
Minio Trusted
c0bf9c5da8 update version to v0.3.8 2020-08-05 12:38:13 -07:00
Daniel Valdivia
16a6524b11 Pass Annotations to PVC (#233) 2020-08-05 12:35:41 -07:00
3 changed files with 30 additions and 22 deletions

View File

@@ -15,7 +15,7 @@ spec:
serviceAccountName: console-sa serviceAccountName: console-sa
containers: containers:
- name: console - name: console
image: minio/console:v0.3.7 image: minio/console:v0.3.8
imagePullPolicy: "IfNotPresent" imagePullPolicy: "IfNotPresent"
args: args:
- server - server

View File

@@ -15,7 +15,7 @@ spec:
serviceAccountName: console-sa serviceAccountName: console-sa
containers: containers:
- name: console - name: console
image: minio/console:v0.3.7 image: minio/console:v0.3.8
imagePullPolicy: "IfNotPresent" imagePullPolicy: "IfNotPresent"
env: env:
- name: CONSOLE_OPERATOR_MODE - name: CONSOLE_OPERATOR_MODE

View File

@@ -798,7 +798,7 @@ func getTenantCreatedResponse(session *models.Principal, params admin_api.Create
return nil, err return nil, err
} }
const consoleVersion = "minio/console:v0.3.7" const consoleVersion = "minio/console:v0.3.8"
minInst.Spec.Console = &operator.ConsoleConfiguration{ minInst.Spec.Console = &operator.ConsoleConfiguration{
Replicas: 2, Replicas: 2,
Image: consoleVersion, Image: consoleVersion,
@@ -815,9 +815,18 @@ func getTenantCreatedResponse(session *models.Principal, params admin_api.Create
if tenantReq.ServiceName != "" { if tenantReq.ServiceName != "" {
minInst.Spec.ServiceName = tenantReq.ServiceName minInst.Spec.ServiceName = tenantReq.ServiceName
} }
// add annotations
var annotations map[string]string
if len(tenantReq.Annotations) > 0 {
if minInst.Spec.Metadata == nil {
minInst.Spec.Metadata = &metav1.ObjectMeta{}
}
annotations = tenantReq.Annotations
minInst.Spec.Metadata.Annotations = annotations
}
// set the zones if they are provided // set the zones if they are provided
for _, zone := range tenantReq.Zones { for _, zone := range tenantReq.Zones {
zone, err := parseTenantZoneRequest(zone) zone, err := parseTenantZoneRequest(zone, annotations)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -828,13 +837,6 @@ func getTenantCreatedResponse(session *models.Principal, params admin_api.Create
if tenantReq.MounthPath != "" { if tenantReq.MounthPath != "" {
minInst.Spec.Mountpath = tenantReq.MounthPath minInst.Spec.Mountpath = tenantReq.MounthPath
} }
// add annotations
if len(tenantReq.Annotations) > 0 {
if minInst.Spec.Metadata == nil {
minInst.Spec.Metadata = &metav1.ObjectMeta{}
}
minInst.Spec.Metadata.Annotations = tenantReq.Annotations
}
if err := setImageRegistry(ctx, tenantReq.ImageRegistry, clientset.CoreV1(), ns); err != nil { if err := setImageRegistry(ctx, tenantReq.ImageRegistry, clientset.CoreV1(), ns); err != nil {
log.Println("error setting image registry secret:", err) log.Println("error setting image registry secret:", err)
@@ -1002,7 +1004,7 @@ func addTenantZone(ctx context.Context, operatorClient OperatorClient, params ad
} }
zoneParams := params.Body zoneParams := params.Body
zone, err := parseTenantZoneRequest(zoneParams) zone, err := parseTenantZoneRequest(zoneParams, tenant.ObjectMeta.Annotations)
if err != nil { if err != nil {
return err return err
} }
@@ -1101,7 +1103,7 @@ func getTenantUsageResponse(session *models.Principal, params admin_api.GetTenan
// parseTenantZoneRequest parse zone request and returns the equivalent // parseTenantZoneRequest parse zone request and returns the equivalent
// operator.Zone object // operator.Zone object
func parseTenantZoneRequest(zoneParams *models.Zone) (*operator.Zone, error) { func parseTenantZoneRequest(zoneParams *models.Zone, annotations map[string]string) (*operator.Zone, error) {
if zoneParams.VolumeConfiguration == nil { if zoneParams.VolumeConfiguration == nil {
return nil, errors.New("a volume configuration must be specified") return nil, errors.New("a volume configuration must be specified")
} }
@@ -1241,16 +1243,22 @@ func parseTenantZoneRequest(zoneParams *models.Zone) (*operator.Zone, error) {
tolerations = append(tolerations, toleration) tolerations = append(tolerations, toleration)
} }
zone := &operator.Zone{ // Pass annotations to the volume
Name: zoneParams.Name, vct := &corev1.PersistentVolumeClaim{
Servers: int32(*zoneParams.Servers), ObjectMeta: metav1.ObjectMeta{
VolumesPerServer: *zoneParams.VolumesPerServer, Name: "data",
VolumeClaimTemplate: &corev1.PersistentVolumeClaim{
ObjectMeta: metav1.ObjectMeta{
Name: "data",
},
Spec: volTemp,
}, },
Spec: volTemp,
}
if len(annotations) > 0 {
vct.ObjectMeta.Annotations = annotations
}
zone := &operator.Zone{
Name: zoneParams.Name,
Servers: int32(*zoneParams.Servers),
VolumesPerServer: *zoneParams.VolumesPerServer,
VolumeClaimTemplate: vct,
Resources: corev1.ResourceRequirements{ Resources: corev1.ResourceRequirements{
Requests: resourcesRequests, Requests: resourcesRequests,
Limits: resourcesLimits, Limits: resourcesLimits,