Files
chart/library/ix-dev/charts/minio/migrations/migrate
Stavros Kois d186c061bf minio/charts: do not add minio volumes env on distributed mode (#2387)
* minio/charts: do not add minio volumes env on distributed mode

* fix migration error
2024-04-17 14:36:16 +03:00

107 lines
3.5 KiB
Python
Executable File

#!/usr/bin/python3
import json
import os
import sys
def migrate_volume(volume):
return {
'type': 'hostPath',
'hostPathConfig': {
'hostPath': volume['hostPath']
},
} if volume.get('hostPathEnabled', False) else {
'type': 'ixVolume',
'ixVolumeConfig': {
'datasetName': volume['datasetName'],
},
}
def migrate_common_lib(values):
delete_keys = [
'dnsConfig', 'updateStrategy', 'enableResourceLimits', 'cpuLimit',
'memLimit', 'certificate', 'service', 'environmentVariables', 'minioDomain',
'accessKey', 'secretKey', 'distributedMode', 'distributedIps', 'logsearchapi',
'appVolumeMounts', 'extraAppVolumeMounts', 'postgresAppVolumeMounts', 'runAsUser', 'runAsGroup',
]
exportVol = {}
if not values['distributedMode']:
exportVol = migrate_volume(values['appVolumeMounts']['export'])
exportVol['mountPath'] = values['appVolumeMounts']['export']['mountPath']
values.update({
# Migrate Config
'minioConfig': {
'rootUser': values['accessKey'],
'rootPassword': values['secretKey'],
# We don't want to allow null value here
'domain': values.get('minioDomain', '') or '',
'extraArgs': values.get('extraArgs', []),
'additionalEnvs': values.get('environmentVariables', []),
},
# Migrate Network
'minioNetwork': {
'apiPort': values['service']['nodePort'],
'consolePort': values['service']['consolePort'],
'certificateID': values['certificate'],
},
# Migrate Resources
'resources': {
'limits': {
'cpu': values.get('cpuLimit', '4000m'),
'memory': values.get('memLimit', '8Gi'),
}
},
# Migrate DNS
'podOptions': {
'dnsConfig': {
'options': [
{'name': opt['name'], 'value': opt['value']}
for opt in values.get('dnsConfig', {}).get('options', [])
]
}
},
# Migrate Storage
'minioStorage': {
'distributedMode': values['distributedMode'],
'distributedIps': values['distributedIps'] if values['distributedMode'] else [],
'logSearchApi': values['logsearchapi']['enabled'],
'logSearchDiskCapacityGB': values['logsearchapi']['diskCapacityGB'] if values['logsearchapi']['enabled'] else 5,
'export': exportVol,
'pgData': migrate_volume(values['postgresAppVolumeMounts']['postgres-data']),
'pgBackup': migrate_volume(values['postgresAppVolumeMounts']['postgres-backup']),
'additionalStorages': [
{
'type': 'hostPath',
'hostPathConfig': {'hostPath': e['hostPath']},
'mountPath': e['mountPath'],
'readOnly': e.get('readOnly', False),
}
for e in values.get('extraAppVolumeMounts', [])
],
},
})
for k in delete_keys:
values.pop(k, None)
return values
def migrate(values):
# If this missing, we have already migrated
if not 'accessKey' in values.keys():
return values
return migrate_common_lib(values)
if __name__ == '__main__':
if len(sys.argv) != 2:
exit(1)
if os.path.exists(sys.argv[1]):
with open(sys.argv[1], 'r') as f:
print(json.dumps(migrate(json.loads(f.read()))))