in src/main/java/org/elasticsearch/repository/oss/OssRepository.java [40:64]
public OssRepository(RepositoryMetaData metadata, Environment env,
NamedXContentRegistry namedXContentRegistry, OssService ossService) {
super(metadata, env.settings(), namedXContentRegistry);
this.ossService = ossService;
String ecsRamRole = OssClientSettings.ECS_RAM_ROLE.get(metadata.settings()).toString();
if (StringUtils.isNotEmpty(ecsRamRole)) {
this.bucket = getSetting(OssClientSettings.AUTO_SNAPSHOT_BUCKET, metadata).toString();
} else {
this.bucket = getSetting(OssClientSettings.BUCKET, metadata);
}
String basePath = OssClientSettings.BASE_PATH.get(metadata.settings());
if (Strings.hasLength(basePath)) {
BlobPath path = new BlobPath();
for (String elem : basePath.split(File.separator)) {
path = path.add(elem);
}
this.basePath = path;
} else {
this.basePath = BlobPath.cleanPath();
}
this.compress = getSetting(OssClientSettings.COMPRESS, metadata);
this.chunkSize = getSetting(OssClientSettings.CHUNK_SIZE, metadata);
logger.info("Using base_path [{}], chunk_size [{}], compress [{}]",
basePath, chunkSize, compress);
}