- api_clients.index = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("api_clients")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ApiClientList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- api_clients.create = function(api_client, ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("api_clients")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- api_client$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ApiClient$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- url_prefix = resource$url_prefix, created_at = resource$created_at,
- updated_at = resource$updated_at, is_trusted = resource$is_trusted)
- },
-
- api_clients.update = function(api_client, uuid)
- {
- endPoint <- stringr::str_interp("api_clients/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- api_client$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ApiClient$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- url_prefix = resource$url_prefix, created_at = resource$created_at,
- updated_at = resource$updated_at, is_trusted = resource$is_trusted)
- },
-
- api_clients.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("api_clients/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ApiClient$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- url_prefix = resource$url_prefix, created_at = resource$created_at,
- updated_at = resource$updated_at, is_trusted = resource$is_trusted)
- },
-
- api_clients.list = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("api_clients")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ApiClientList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- api_clients.show = function(uuid)
- {
- endPoint <- stringr::str_interp("api_clients/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ApiClient$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- url_prefix = resource$url_prefix, created_at = resource$created_at,
- updated_at = resource$updated_at, is_trusted = resource$is_trusted)
- },
-
- api_clients.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("api_clients/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ApiClient$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- url_prefix = resource$url_prefix, created_at = resource$created_at,
- updated_at = resource$updated_at, is_trusted = resource$is_trusted)
- },
-
- container_requests.get = function(uuid)
- {
- endPoint <- stringr::str_interp("container_requests/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequest$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_at = resource$modified_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- name = resource$name, description = resource$description,
- properties = resource$properties, state = resource$state,
- requesting_container_uuid = resource$requesting_container_uuid,
- container_uuid = resource$container_uuid,
- container_count_max = resource$container_count_max,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- container_image = resource$container_image,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- priority = resource$priority, expires_at = resource$expires_at,
- filters = resource$filters, updated_at = resource$updated_at,
- container_count = resource$container_count,
- use_existing = resource$use_existing, scheduling_parameters = resource$scheduling_parameters,
- output_uuid = resource$output_uuid, log_uuid = resource$log_uuid,
- output_name = resource$output_name, output_ttl = resource$output_ttl)
- },
-
- container_requests.index = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("container_requests")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequestList$new(kind = resource$kind,
- etag = resource$etag, items = resource$items,
- next_link = resource$next_link, next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- container_requests.create = function(container_request,
- ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("container_requests")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- container_request$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequest$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_at = resource$modified_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- name = resource$name, description = resource$description,
- properties = resource$properties, state = resource$state,
- requesting_container_uuid = resource$requesting_container_uuid,
- container_uuid = resource$container_uuid,
- container_count_max = resource$container_count_max,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- container_image = resource$container_image,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- priority = resource$priority, expires_at = resource$expires_at,
- filters = resource$filters, updated_at = resource$updated_at,
- container_count = resource$container_count,
- use_existing = resource$use_existing, scheduling_parameters = resource$scheduling_parameters,
- output_uuid = resource$output_uuid, log_uuid = resource$log_uuid,
- output_name = resource$output_name, output_ttl = resource$output_ttl)
- },
-
- container_requests.update = function(container_request, uuid)
- {
- endPoint <- stringr::str_interp("container_requests/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- container_request$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequest$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_at = resource$modified_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- name = resource$name, description = resource$description,
- properties = resource$properties, state = resource$state,
- requesting_container_uuid = resource$requesting_container_uuid,
- container_uuid = resource$container_uuid,
- container_count_max = resource$container_count_max,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- container_image = resource$container_image,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- priority = resource$priority, expires_at = resource$expires_at,
- filters = resource$filters, updated_at = resource$updated_at,
- container_count = resource$container_count,
- use_existing = resource$use_existing, scheduling_parameters = resource$scheduling_parameters,
- output_uuid = resource$output_uuid, log_uuid = resource$log_uuid,
- output_name = resource$output_name, output_ttl = resource$output_ttl)
- },
-
- container_requests.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("container_requests/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequest$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_at = resource$modified_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- name = resource$name, description = resource$description,
- properties = resource$properties, state = resource$state,
- requesting_container_uuid = resource$requesting_container_uuid,
- container_uuid = resource$container_uuid,
- container_count_max = resource$container_count_max,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- container_image = resource$container_image,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- priority = resource$priority, expires_at = resource$expires_at,
- filters = resource$filters, updated_at = resource$updated_at,
- container_count = resource$container_count,
- use_existing = resource$use_existing, scheduling_parameters = resource$scheduling_parameters,
- output_uuid = resource$output_uuid, log_uuid = resource$log_uuid,
- output_name = resource$output_name, output_ttl = resource$output_ttl)
- },
-
- container_requests.list = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("container_requests")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequestList$new(kind = resource$kind,
- etag = resource$etag, items = resource$items,
- next_link = resource$next_link, next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- container_requests.show = function(uuid)
- {
- endPoint <- stringr::str_interp("container_requests/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequest$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_at = resource$modified_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- name = resource$name, description = resource$description,
- properties = resource$properties, state = resource$state,
- requesting_container_uuid = resource$requesting_container_uuid,
- container_uuid = resource$container_uuid,
- container_count_max = resource$container_count_max,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- container_image = resource$container_image,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- priority = resource$priority, expires_at = resource$expires_at,
- filters = resource$filters, updated_at = resource$updated_at,
- container_count = resource$container_count,
- use_existing = resource$use_existing, scheduling_parameters = resource$scheduling_parameters,
- output_uuid = resource$output_uuid, log_uuid = resource$log_uuid,
- output_name = resource$output_name, output_ttl = resource$output_ttl)
- },
-
- container_requests.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("container_requests/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerRequest$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_at = resource$modified_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- name = resource$name, description = resource$description,
- properties = resource$properties, state = resource$state,
- requesting_container_uuid = resource$requesting_container_uuid,
- container_uuid = resource$container_uuid,
- container_count_max = resource$container_count_max,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- container_image = resource$container_image,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- priority = resource$priority, expires_at = resource$expires_at,
- filters = resource$filters, updated_at = resource$updated_at,
- container_count = resource$container_count,
- use_existing = resource$use_existing, scheduling_parameters = resource$scheduling_parameters,
- output_uuid = resource$output_uuid, log_uuid = resource$log_uuid,
- output_name = resource$output_name, output_ttl = resource$output_ttl)
- },
-
- authorized_keys.get = function(uuid)
- {
- endPoint <- stringr::str_interp("authorized_keys/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKey$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- key_type = resource$key_type, authorized_user_uuid = resource$authorized_user_uuid,
- public_key = resource$public_key, expires_at = resource$expires_at,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- authorized_keys.index = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("authorized_keys")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKeyList$new(kind = resource$kind,
- etag = resource$etag, items = resource$items,
- next_link = resource$next_link, next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- authorized_keys.create = function(authorized_key,
- ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("authorized_keys")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- authorized_key$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKey$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- key_type = resource$key_type, authorized_user_uuid = resource$authorized_user_uuid,
- public_key = resource$public_key, expires_at = resource$expires_at,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- authorized_keys.update = function(authorized_key, uuid)
- {
- endPoint <- stringr::str_interp("authorized_keys/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- authorized_key$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKey$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- key_type = resource$key_type, authorized_user_uuid = resource$authorized_user_uuid,
- public_key = resource$public_key, expires_at = resource$expires_at,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- authorized_keys.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("authorized_keys/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKey$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- key_type = resource$key_type, authorized_user_uuid = resource$authorized_user_uuid,
- public_key = resource$public_key, expires_at = resource$expires_at,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- authorized_keys.list = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("authorized_keys")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKeyList$new(kind = resource$kind,
- etag = resource$etag, items = resource$items,
- next_link = resource$next_link, next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- authorized_keys.show = function(uuid)
- {
- endPoint <- stringr::str_interp("authorized_keys/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKey$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- key_type = resource$key_type, authorized_user_uuid = resource$authorized_user_uuid,
- public_key = resource$public_key, expires_at = resource$expires_at,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- authorized_keys.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("authorized_keys/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- AuthorizedKey$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, name = resource$name,
- key_type = resource$key_type, authorized_user_uuid = resource$authorized_user_uuid,
- public_key = resource$public_key, expires_at = resource$expires_at,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- collections.get = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.index = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact", include_trash = NULL)
- {
- endPoint <- stringr::str_interp("collections")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count,
- include_trash = include_trash)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- CollectionList$new(kind = resource$kind,
- etag = resource$etag, items = resource$items,
- next_link = resource$next_link, next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- collections.create = function(collection, ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("collections")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- collection$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.update = function(collection, uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- collection$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.provenance = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}/provenance")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.used_by = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}/used_by")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.trash = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}/trash")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.untrash = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}/untrash")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.list = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact", include_trash = NULL)
- {
- endPoint <- stringr::str_interp("collections")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count,
- include_trash = include_trash)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- CollectionList$new(kind = resource$kind,
- etag = resource$etag, items = resource$items,
- next_link = resource$next_link, next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- collections.show = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- collections.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("collections/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- collection <- Collection$new(uuid = resource$uuid,
- etag = resource$etag, owner_uuid = resource$owner_uuid,
- created_at = resource$created_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, portable_data_hash = resource$portable_data_hash,
- replication_desired = resource$replication_desired,
- replication_confirmed_at = resource$replication_confirmed_at,
- replication_confirmed = resource$replication_confirmed,
- updated_at = resource$updated_at, manifest_text = resource$manifest_text,
- name = resource$name, description = resource$description,
- properties = resource$properties, delete_at = resource$delete_at,
- file_names = resource$file_names, trash_at = resource$trash_at,
- is_trashed = resource$is_trashed)
-
- collection$setRESTService(private$REST)
- collection
- },
-
- containers.get = function(uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.index = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("containers")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- containers.create = function(container, ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("containers")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- container$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.update = function(container, uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- container$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.auth = function(uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}/auth")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.lock = function(uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}/lock")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.unlock = function(uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}/unlock")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.current = function()
- {
- endPoint <- stringr::str_interp("containers/current")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- NULL
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.list = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("containers")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- ContainerList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- containers.show = function(uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- containers.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("containers/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Container$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_at = resource$modified_at, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- state = resource$state, started_at = resource$started_at,
- finished_at = resource$finished_at, log = resource$log,
- environment = resource$environment, cwd = resource$cwd,
- command = resource$command, output_path = resource$output_path,
- mounts = resource$mounts, runtime_constraints = resource$runtime_constraints,
- output = resource$output, container_image = resource$container_image,
- progress = resource$progress, priority = resource$priority,
- updated_at = resource$updated_at, exit_code = resource$exit_code,
- auth_uuid = resource$auth_uuid, locked_by_uuid = resource$locked_by_uuid,
- scheduling_parameters = resource$scheduling_parameters)
- },
-
- humans.get = function(uuid)
- {
- endPoint <- stringr::str_interp("humans/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Human$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, properties = resource$properties,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- humans.index = function(filters = NULL, where = NULL,
- order = NULL, select = NULL, distinct = NULL,
- limit = "100", offset = "0", count = "exact")
- {
- endPoint <- stringr::str_interp("humans")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- HumanList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- humans.create = function(human, ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("humans")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- human$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Human$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, properties = resource$properties,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- humans.update = function(human, uuid)
- {
- endPoint <- stringr::str_interp("humans/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- human$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Human$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, properties = resource$properties,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- humans.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("humans/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Human$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, properties = resource$properties,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- humans.list = function(filters = NULL, where = NULL,
- order = NULL, select = NULL, distinct = NULL,
- limit = "100", offset = "0", count = "exact")
- {
- endPoint <- stringr::str_interp("humans")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- HumanList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- humans.show = function(uuid)
- {
- endPoint <- stringr::str_interp("humans/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Human$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, properties = resource$properties,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- humans.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("humans/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Human$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, properties = resource$properties,
- created_at = resource$created_at, updated_at = resource$updated_at)
- },
-
- job_tasks.get = function(uuid)
- {
- endPoint <- stringr::str_interp("job_tasks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTask$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, job_uuid = resource$job_uuid,
- sequence = resource$sequence, parameters = resource$parameters,
- output = resource$output, progress = resource$progress,
- success = resource$success, created_at = resource$created_at,
- updated_at = resource$updated_at, created_by_job_task_uuid = resource$created_by_job_task_uuid,
- qsequence = resource$qsequence, started_at = resource$started_at,
- finished_at = resource$finished_at)
- },
-
- job_tasks.index = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("job_tasks")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTaskList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- job_tasks.create = function(job_task, ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("job_tasks")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- job_task$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTask$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, job_uuid = resource$job_uuid,
- sequence = resource$sequence, parameters = resource$parameters,
- output = resource$output, progress = resource$progress,
- success = resource$success, created_at = resource$created_at,
- updated_at = resource$updated_at, created_by_job_task_uuid = resource$created_by_job_task_uuid,
- qsequence = resource$qsequence, started_at = resource$started_at,
- finished_at = resource$finished_at)
- },
-
- job_tasks.update = function(job_task, uuid)
- {
- endPoint <- stringr::str_interp("job_tasks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- job_task$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTask$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, job_uuid = resource$job_uuid,
- sequence = resource$sequence, parameters = resource$parameters,
- output = resource$output, progress = resource$progress,
- success = resource$success, created_at = resource$created_at,
- updated_at = resource$updated_at, created_by_job_task_uuid = resource$created_by_job_task_uuid,
- qsequence = resource$qsequence, started_at = resource$started_at,
- finished_at = resource$finished_at)
- },
-
- job_tasks.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("job_tasks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTask$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, job_uuid = resource$job_uuid,
- sequence = resource$sequence, parameters = resource$parameters,
- output = resource$output, progress = resource$progress,
- success = resource$success, created_at = resource$created_at,
- updated_at = resource$updated_at, created_by_job_task_uuid = resource$created_by_job_task_uuid,
- qsequence = resource$qsequence, started_at = resource$started_at,
- finished_at = resource$finished_at)
- },
-
- job_tasks.list = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("job_tasks")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTaskList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- job_tasks.show = function(uuid)
- {
- endPoint <- stringr::str_interp("job_tasks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTask$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, job_uuid = resource$job_uuid,
- sequence = resource$sequence, parameters = resource$parameters,
- output = resource$output, progress = resource$progress,
- success = resource$success, created_at = resource$created_at,
- updated_at = resource$updated_at, created_by_job_task_uuid = resource$created_by_job_task_uuid,
- qsequence = resource$qsequence, started_at = resource$started_at,
- finished_at = resource$finished_at)
- },
-
- job_tasks.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("job_tasks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobTask$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, job_uuid = resource$job_uuid,
- sequence = resource$sequence, parameters = resource$parameters,
- output = resource$output, progress = resource$progress,
- success = resource$success, created_at = resource$created_at,
- updated_at = resource$updated_at, created_by_job_task_uuid = resource$created_by_job_task_uuid,
- qsequence = resource$qsequence, started_at = resource$started_at,
- finished_at = resource$finished_at)
- },
-
- links.get = function(uuid)
- {
- endPoint <- stringr::str_interp("links/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Link$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, tail_uuid = resource$tail_uuid,
- link_class = resource$link_class, name = resource$name,
- head_uuid = resource$head_uuid, properties = resource$properties,
- updated_at = resource$updated_at)
- },
-
- links.index = function(filters = NULL, where = NULL,
- order = NULL, select = NULL, distinct = NULL,
- limit = "100", offset = "0", count = "exact")
- {
- endPoint <- stringr::str_interp("links")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- LinkList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- links.create = function(link, ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("links")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- link$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Link$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, tail_uuid = resource$tail_uuid,
- link_class = resource$link_class, name = resource$name,
- head_uuid = resource$head_uuid, properties = resource$properties,
- updated_at = resource$updated_at)
- },
-
- links.update = function(link, uuid)
- {
- endPoint <- stringr::str_interp("links/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- link$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Link$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, tail_uuid = resource$tail_uuid,
- link_class = resource$link_class, name = resource$name,
- head_uuid = resource$head_uuid, properties = resource$properties,
- updated_at = resource$updated_at)
- },
-
- links.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("links/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Link$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, tail_uuid = resource$tail_uuid,
- link_class = resource$link_class, name = resource$name,
- head_uuid = resource$head_uuid, properties = resource$properties,
- updated_at = resource$updated_at)
- },
-
- links.list = function(filters = NULL, where = NULL,
- order = NULL, select = NULL, distinct = NULL,
- limit = "100", offset = "0", count = "exact")
- {
- endPoint <- stringr::str_interp("links")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- LinkList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- links.show = function(uuid)
- {
- endPoint <- stringr::str_interp("links/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Link$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, tail_uuid = resource$tail_uuid,
- link_class = resource$link_class, name = resource$name,
- head_uuid = resource$head_uuid, properties = resource$properties,
- updated_at = resource$updated_at)
- },
-
- links.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("links/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Link$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, tail_uuid = resource$tail_uuid,
- link_class = resource$link_class, name = resource$name,
- head_uuid = resource$head_uuid, properties = resource$properties,
- updated_at = resource$updated_at)
- },
-
- links.get_permissions = function(uuid)
- {
- endPoint <- stringr::str_interp("permissions/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Link$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, created_at = resource$created_at,
- modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, tail_uuid = resource$tail_uuid,
- link_class = resource$link_class, name = resource$name,
- head_uuid = resource$head_uuid, properties = resource$properties,
- updated_at = resource$updated_at)
- },
-
- jobs.get = function(uuid)
- {
- endPoint <- stringr::str_interp("jobs/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.index = function(filters = NULL, where = NULL,
- order = NULL, select = NULL, distinct = NULL,
- limit = "100", offset = "0", count = "exact")
- {
- endPoint <- stringr::str_interp("jobs")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- jobs.create = function(job, ensure_unique_name = "false",
- find_or_create = "false", filters = NULL,
- minimum_script_version = NULL, exclude_script_versions = NULL)
- {
- endPoint <- stringr::str_interp("jobs")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name,
- find_or_create = find_or_create, filters = filters,
- minimum_script_version = minimum_script_version,
- exclude_script_versions = exclude_script_versions)
- body <- job$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.update = function(job, uuid)
- {
- endPoint <- stringr::str_interp("jobs/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- job$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("jobs/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.queue = function(filters = NULL, where = NULL,
- order = NULL, select = NULL, distinct = NULL,
- limit = "100", offset = "0", count = "exact")
- {
- endPoint <- stringr::str_interp("jobs/queue")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.queue_size = function()
- {
- endPoint <- stringr::str_interp("jobs/queue_size")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- NULL
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.cancel = function(uuid)
- {
- endPoint <- stringr::str_interp("jobs/${uuid}/cancel")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.lock = function(uuid)
- {
- endPoint <- stringr::str_interp("jobs/${uuid}/lock")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.list = function(filters = NULL, where = NULL,
- order = NULL, select = NULL, distinct = NULL,
- limit = "100", offset = "0", count = "exact")
- {
- endPoint <- stringr::str_interp("jobs")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- JobList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- jobs.show = function(uuid)
- {
- endPoint <- stringr::str_interp("jobs/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- jobs.destroy = function(uuid)
- {
- endPoint <- stringr::str_interp("jobs/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- Job$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, submit_id = resource$submit_id,
- script = resource$script, script_version = resource$script_version,
- script_parameters = resource$script_parameters,
- cancelled_by_client_uuid = resource$cancelled_by_client_uuid,
- cancelled_by_user_uuid = resource$cancelled_by_user_uuid,
- cancelled_at = resource$cancelled_at, started_at = resource$started_at,
- finished_at = resource$finished_at, running = resource$running,
- success = resource$success, output = resource$output,
- created_at = resource$created_at, updated_at = resource$updated_at,
- is_locked_by_uuid = resource$is_locked_by_uuid,
- log = resource$log, tasks_summary = resource$tasks_summary,
- runtime_constraints = resource$runtime_constraints,
- nondeterministic = resource$nondeterministic,
- repository = resource$repository, supplied_script_version = resource$supplied_script_version,
- docker_image_locator = resource$docker_image_locator,
- priority = resource$priority, description = resource$description,
- state = resource$state, arvados_sdk_version = resource$arvados_sdk_version,
- components = resource$components, script_parameters_digest = resource$script_parameters_digest)
- },
-
- keep_disks.get = function(uuid)
- {
- endPoint <- stringr::str_interp("keep_disks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- KeepDisk$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, ping_secret = resource$ping_secret,
- node_uuid = resource$node_uuid, filesystem_uuid = resource$filesystem_uuid,
- bytes_total = resource$bytes_total, bytes_free = resource$bytes_free,
- is_readable = resource$is_readable, is_writable = resource$is_writable,
- last_read_at = resource$last_read_at, last_write_at = resource$last_write_at,
- last_ping_at = resource$last_ping_at, created_at = resource$created_at,
- updated_at = resource$updated_at, keep_service_uuid = resource$keep_service_uuid)
- },
-
- keep_disks.index = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")
- {
- endPoint <- stringr::str_interp("keep_disks")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(filters = filters, where = where,
- order = order, select = select, distinct = distinct,
- limit = limit, offset = offset, count = count)
- body <- NULL
-
- response <- private$REST$http$exec("GET", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- KeepDiskList$new(kind = resource$kind, etag = resource$etag,
- items = resource$items, next_link = resource$next_link,
- next_page_token = resource$next_page_token,
- selfLink = resource$selfLink)
- },
-
- keep_disks.create = function(keep_disk, ensure_unique_name = "false")
- {
- endPoint <- stringr::str_interp("keep_disks")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(ensure_unique_name = ensure_unique_name)
- body <- keep_disk$toJSON()
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- KeepDisk$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, ping_secret = resource$ping_secret,
- node_uuid = resource$node_uuid, filesystem_uuid = resource$filesystem_uuid,
- bytes_total = resource$bytes_total, bytes_free = resource$bytes_free,
- is_readable = resource$is_readable, is_writable = resource$is_writable,
- last_read_at = resource$last_read_at, last_write_at = resource$last_write_at,
- last_ping_at = resource$last_ping_at, created_at = resource$created_at,
- updated_at = resource$updated_at, keep_service_uuid = resource$keep_service_uuid)
- },
-
- keep_disks.update = function(keep_disk, uuid)
- {
- endPoint <- stringr::str_interp("keep_disks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- keep_disk$toJSON()
-
- response <- private$REST$http$exec("PUT", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- KeepDisk$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, ping_secret = resource$ping_secret,
- node_uuid = resource$node_uuid, filesystem_uuid = resource$filesystem_uuid,
- bytes_total = resource$bytes_total, bytes_free = resource$bytes_free,
- is_readable = resource$is_readable, is_writable = resource$is_writable,
- last_read_at = resource$last_read_at, last_write_at = resource$last_write_at,
- last_ping_at = resource$last_ping_at, created_at = resource$created_at,
- updated_at = resource$updated_at, keep_service_uuid = resource$keep_service_uuid)
- },
-
- keep_disks.delete = function(uuid)
- {
- endPoint <- stringr::str_interp("keep_disks/${uuid}")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid)
- body <- NULL
-
- response <- private$REST$http$exec("DELETE", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- KeepDisk$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, ping_secret = resource$ping_secret,
- node_uuid = resource$node_uuid, filesystem_uuid = resource$filesystem_uuid,
- bytes_total = resource$bytes_total, bytes_free = resource$bytes_free,
- is_readable = resource$is_readable, is_writable = resource$is_writable,
- last_read_at = resource$last_read_at, last_write_at = resource$last_write_at,
- last_ping_at = resource$last_ping_at, created_at = resource$created_at,
- updated_at = resource$updated_at, keep_service_uuid = resource$keep_service_uuid)
- },
-
- keep_disks.ping = function(uuid = NULL, ping_secret,
- node_uuid = NULL, filesystem_uuid = NULL,
- service_host = NULL, service_port, service_ssl_flag)
- {
- endPoint <- stringr::str_interp("keep_disks/ping")
- url <- paste0(private$host, endPoint)
- headers <- list(Authorization = paste("OAuth2", private$token),
- "Content-Type" = "application/json")
- queryArgs <- list(uuid = uuid, ping_secret = ping_secret,
- node_uuid = node_uuid, filesystem_uuid = filesystem_uuid,
- service_host = service_host, service_port = service_port,
- service_ssl_flag = service_ssl_flag)
- body <- NULL
-
- response <- private$REST$http$exec("POST", url, headers, body,
- queryArgs, private$numRetries)
- resource <- private$REST$httpParser$parseJSONResponse(response)
-
- if(!is.null(resource$errors))
- stop(resource$errors)
-
- KeepDisk$new(uuid = resource$uuid, etag = resource$etag,
- owner_uuid = resource$owner_uuid, modified_by_client_uuid = resource$modified_by_client_uuid,
- modified_by_user_uuid = resource$modified_by_user_uuid,
- modified_at = resource$modified_at, ping_secret = resource$ping_secret,
- node_uuid = resource$node_uuid, filesystem_uuid = resource$filesystem_uuid,
- bytes_total = resource$bytes_total, bytes_free = resource$bytes_free,
- is_readable = resource$is_readable, is_writable = resource$is_writable,
- last_read_at = resource$last_read_at, last_write_at = resource$last_write_at,
- last_ping_at = resource$last_ping_at, created_at = resource$created_at,
- updated_at = resource$updated_at, keep_service_uuid = resource$keep_service_uuid)
- },
-
- keep_disks.list = function(filters = NULL,
- where = NULL, order = NULL, select = NULL,
- distinct = NULL, limit = "100", offset = "0",
- count = "exact")