public CrawlingConfigWrapper(final CrawlingConfig crawlingConfig) {
        this.crawlingConfig = crawlingConfig;
    }

    @Override
    public String getId() {
        return crawlingConfig.getId();
    }

    @Override
    public String getName() {
        return crawlingConfig.getName();
    }

    @Override
    public String[] getPermissions() {

        }

        @Override
        public String getProtocol() {
            return repository.getProtocol();
        }

        @Override
        public String getId() {
            return repository.getId();
        }

        @Override
        public void setId(String id) {}

        @Override
        public ArtifactRepositoryPolicy getSnapshots() {
            return null;

        final List<ScheduledJob> scheduledJobs = new ArrayList<>();

        // Create test scheduled jobs
        ScheduledJob job1 = new ScheduledJob() {
            @Override
            public String getId() {
                return "job1";
            }

            @Override
            public String getTarget() {
                return "all";
            }

            @Override

         */
        public CharMappingItem write(final CharMappingItem oldItem) {
            try {
                if (item == null || item.getId() != oldItem.getId() || !item.isUpdated()) {
                    writer.write(oldItem.toLineString());
                    writer.write(Constants.LINE_SEPARATOR);
                    return oldItem;
                }

            return null;
        });
        kuromojiService.store(body.dictId, entity);
        return asJson(
                new ApiResult.ApiUpdateResponse().id(String.valueOf(entity.getId())).created(true).status(ApiResult.Status.OK).result());
    }

    /**
     * Updates an existing Kuromoji dictionary item.
     *
     * @param dictId the dictionary ID

            return null;
        });
        protwordsService.store(body.dictId, entity);
        return asJson(
                new ApiResult.ApiUpdateResponse().id(String.valueOf(entity.getId())).created(true).status(ApiResult.Status.OK).result());
    }

    /**
     * Update an existing protected words entry in the specified dictionary.
     *
     * @param dictId identifier of the dictionary

}

// Endpoint - any type of endpoint.
type Endpoint struct {
	*url.URL
	IsLocal bool

	PoolIdx, SetIdx, DiskIdx int
}

// Equal returns true if endpoint == ep
func (endpoint Endpoint) Equal(ep Endpoint) bool {
	if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx {
		if endpoint.Path == ep.Path && endpoint.Host == ep.Host {
			return true
		}

            if (name.startsWith(DATA_STORE.getId())) {
                return DATA_STORE;
            }
            if (name.startsWith(THEME.getId())) {
                return THEME;
            }
            if (name.startsWith(INGEST.getId())) {
                return INGEST;
            }
            if (name.startsWith(SCRIPT.getId())) {
                return SCRIPT;
            }

            return "";
        } else if (result.getEffectiveModel() != null) {
            return result.getEffectiveModel().getId();
        } else if (result.getRawModel() != null) {
            return result.getRawModel().getId();
        } else if (result.getFileModel() != null) {
            return result.getFileModel().getId();
        } else {
            return "";
        }
    }

    /**

		}

		return status, true
	}

	si := o.LocalStorageInfo(ctx, true)

	indexed := make(map[string][]madmin.Disk)
	for _, disk := range si.Disks {
		setIdx := fmt.Sprintf("%d-%d", disk.PoolIndex, disk.SetIndex)
		indexed[setIdx] = append(indexed[setIdx], disk)
	}

	for id, disks := range indexed {
		ss := madmin.SetStatus{
			ID:        id,
			SetIndex:  disks[0].SetIndex,
			PoolIndex: disks[0].PoolIndex,