public class WarehouseService extends AbstractService
AbstractService.OutputStreamResponseExtractormapper, restTemplate, WAIT_BEFORE_RETRY_IN_MILLIS| Constructor and Description |
|---|
WarehouseService(org.springframework.web.client.RestTemplate restTemplate)
Sets RESTful HTTP Spring template.
|
| Modifier and Type | Method and Description |
|---|---|
FutureResult<WarehouseS3Credentials> |
addS3CredentialsToWarehouse(Warehouse warehouse,
WarehouseS3Credentials s3Credentials)
add new S3 credentials to the Warehouse
|
FutureResult<WarehouseUser> |
addUserToWarehouse(Warehouse warehouse,
WarehouseUser user)
Add given user to given warehouse.
|
FutureResult<Warehouse> |
createWarehouse(Warehouse warehouse)
Create new warehouse.
|
WarehouseSchema |
getDefaultWarehouseSchema(Warehouse warehouse)
get default warehouse schema
|
Warehouse |
getWarehouseById(String id)
Get Warehouse identified by given id.
|
Warehouse |
getWarehouseByUri(String uri)
Get Warehouse identified by given uri.
|
WarehouseS3Credentials |
getWarehouseS3Credentials(Warehouse warehouse,
String region,
String accessKey)
Get S3 credentials for the Warehouse based on
region and accessKey. |
WarehouseSchema |
getWarehouseSchemaByName(Warehouse warehouse,
String name)
get warehouse schema by name
|
WarehouseSchema |
getWarehouseSchemaByUri(String uri)
get warehouse schema by uri
|
PageableList<Warehouse> |
listWarehouses()
Lists Warehouses.
|
PageableList<Warehouse> |
listWarehouses(Page startPage)
Lists Warehouses.
|
PageableList<WarehouseS3Credentials> |
listWarehouseS3Credentials(Warehouse warehouse)
List S3 credentials for the Warehouse.
|
PageableList<WarehouseSchema> |
listWarehouseSchemas(Warehouse warehouse)
list schemas for Warehouse
|
PageableList<WarehouseSchema> |
listWarehouseSchemas(Warehouse warehouse,
Page startPage)
list schemas for Warehouse
|
PageableList<WarehouseUser> |
listWarehouseUsers(Warehouse warehouse)
Lists warehouse users.
|
PageableList<WarehouseUser> |
listWarehouseUsers(Warehouse warehouse,
Page startPage)
Lists warehouse users, starting with specified page.
|
FutureResult<Void> |
removeUserFromWarehouse(WarehouseUser user)
Remove given user from warehouse instance
|
void |
removeWarehouse(Warehouse warehouse)
Delete Warehouse.
|
Warehouse |
updateWarehouse(Warehouse toUpdate)
Updates given Warehouse.
|
extractDatapublic WarehouseService(org.springframework.web.client.RestTemplate restTemplate)
restTemplate - RESTful HTTP Spring templatepublic FutureResult<Warehouse> createWarehouse(Warehouse warehouse)
warehouse - warehouse to createpublic void removeWarehouse(Warehouse warehouse)
warehouse - to deletepublic Warehouse getWarehouseByUri(String uri)
uri - warehouse uriGoodDataException - when Warehouse can't be accessedpublic Warehouse getWarehouseById(String id)
id - warehouse idGoodDataException - when Warehouse can't be accessedpublic PageableList<Warehouse> listWarehouses()
Collection.stream() to iterate
over all pages, or MultiPageList.collectAll() to load the entire list.public PageableList<Warehouse> listWarehouses(Page startPage)
listWarehouses() to get first page with default setting.startPage - page to be listedpublic PageableList<WarehouseUser> listWarehouseUsers(Warehouse warehouse)
Collection.stream() to iterate over all pages,
or MultiPageList.collectAll() to load the entire list.warehouse - warehousepublic PageableList<WarehouseUser> listWarehouseUsers(Warehouse warehouse, Page startPage)
Collection.stream() to iterate over all pages,
or MultiPageList.collectAll() to load the entire list.warehouse - warehousestartPage - page to start withpublic FutureResult<WarehouseUser> addUserToWarehouse(Warehouse warehouse, WarehouseUser user)
warehouse - warehouse the user should be added touser - user to be addedpublic FutureResult<Void> removeUserFromWarehouse(WarehouseUser user)
user - to remove from warehouseWarehouseUserNotFoundException - when user for removal can't be foundGoodDataException - any other reasonpublic Warehouse updateWarehouse(Warehouse toUpdate)
toUpdate - warehouse to be updatedGoodDataException - when update failspublic PageableList<WarehouseSchema> listWarehouseSchemas(Warehouse warehouse)
warehouse - to list schemas forpublic PageableList<WarehouseSchema> listWarehouseSchemas(Warehouse warehouse, Page startPage)
warehouse - to list schemas forstartPage - page to be listedpublic WarehouseSchema getWarehouseSchemaByName(Warehouse warehouse, String name)
warehouse - to get schema forname - of schemapublic WarehouseSchema getWarehouseSchemaByUri(String uri)
uri - of schemapublic WarehouseSchema getDefaultWarehouseSchema(Warehouse warehouse)
warehouse - to get default schema forpublic PageableList<WarehouseS3Credentials> listWarehouseS3Credentials(Warehouse warehouse)
warehouse - warehouse to get S3 credentials forpublic WarehouseS3Credentials getWarehouseS3Credentials(Warehouse warehouse, String region, String accessKey)
region and accessKey.warehouse - warehouse to get S3 credentials forWarehouseS3CredentialsNotFoundException - if no S3 credentials for the given parameters were foundpublic FutureResult<WarehouseS3Credentials> addS3CredentialsToWarehouse(Warehouse warehouse, WarehouseS3Credentials s3Credentials)
warehouse - warehouse to add credentials tos3Credentials - the credentials to storeCopyright © 2017. All rights reserved.