All URIs are relative to https://pipes.turbot.com/api/v0
Method | HTTP request | Description |
---|---|---|
Command | Post /user/{user_handle}/workspace/{workspace_handle}/process/{process_id}/command | Run user workspace process command |
Get | Get /user/{user_handle}/workspace/{workspace_handle}/process/{process_id} | Get user workspace process |
List | Get /user/{user_handle}/workspace/{workspace_handle}/process | List user workspace processes |
Log | Get /user/{user_handle}/workspace/{workspace_handle}/process/{process_id}/log/{log_file}.{content_type} | List user workspace process logs |
WorkspaceProcessCommandResponse Command(ctx, userHandle, workspaceHandle, processId).Request(request).Execute()
Run user workspace process command
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
userHandle := "userHandle_example" // string | The handle of the user where we want to run the workspace process command.
workspaceHandle := "workspaceHandle_example" // string | The handle of the workspace where the process command will be executed.
processId := "processId_example" // string | The id of the process where the command will be executed against.
request := *openapiclient.NewWorkspaceProcessCommandRequest(openapiclient.WorkspaceProcessCommandAction("terminate")) // WorkspaceProcessCommandRequest | The request body for the workspace process command.
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.UserWorkspaceProcesses.Command(context.Background(), userHandle, workspaceHandle, processId).Request(request).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `UserWorkspaceProcesses.Command``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `Command`: WorkspaceProcessCommandResponse
fmt.Fprintf(os.Stdout, "Response from `UserWorkspaceProcesses.Command`: %v\n", resp)
}
Name | Type | Description | Notes |
---|---|---|---|
ctx | context.Context | context for authentication, logging, cancellation, deadlines, tracing, etc. | |
userHandle | string | The handle of the user where we want to run the workspace process command. | |
workspaceHandle | string | The handle of the workspace where the process command will be executed. | |
processId | string | The id of the process where the command will be executed against. |
Other parameters are passed through a pointer to a apiCommandRequest struct via the builder pattern
Name | Type | Description | Notes |
---|
request | WorkspaceProcessCommandRequest | The request body for the workspace process command. |
WorkspaceProcessCommandResponse
No authorization required
- Content-Type: application/json
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
SpProcess Get(ctx, userHandle, workspaceHandle, processId).Execute()
Get user workspace process
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
userHandle := "userHandle_example" // string | The handle of the user where the workspace exist.
workspaceHandle := "workspaceHandle_example" // string | The handle of the workspace whose process needs to be fetched.
processId := "processId_example" // string | The id of the process to be fetched.
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.UserWorkspaceProcesses.Get(context.Background(), userHandle, workspaceHandle, processId).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `UserWorkspaceProcesses.Get``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `Get`: SpProcess
fmt.Fprintf(os.Stdout, "Response from `UserWorkspaceProcesses.Get`: %v\n", resp)
}
Name | Type | Description | Notes |
---|---|---|---|
ctx | context.Context | context for authentication, logging, cancellation, deadlines, tracing, etc. | |
userHandle | string | The handle of the user where the workspace exist. | |
workspaceHandle | string | The handle of the workspace whose process needs to be fetched. | |
processId | string | The id of the process to be fetched. |
Other parameters are passed through a pointer to a apiGetRequest struct via the builder pattern
Name | Type | Description | Notes |
---|
No authorization required
- Content-Type: Not defined
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
ListProcessesResponse List(ctx, userHandle, workspaceHandle).Where(where).Limit(limit).NextToken(nextToken).Execute()
List user workspace processes
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
userHandle := "userHandle_example" // string | The handle of the user for which you want to start listing processes.
workspaceHandle := "workspaceHandle_example" // string | The handle of the workspace where you want to list the processes.
where := "where_example" // string | The SQL where filter you wish to apply to this request. The filter will be parsed and sanitised and checked against the supported columns for this API. (optional)
limit := int32(56) // int32 | The max number of items to fetch per page of data, subject to a min and max of 1 and 100 respectively. If not specified will default to 25. (optional) (default to 25)
nextToken := "nextToken_example" // string | When list results are truncated, next_token will be returned, which is a cursor to fetch the next page of data. Pass next_token to the subsequent list request to fetch the next page of data. (optional)
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.UserWorkspaceProcesses.List(context.Background(), userHandle, workspaceHandle).Where(where).Limit(limit).NextToken(nextToken).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `UserWorkspaceProcesses.List``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `List`: ListProcessesResponse
fmt.Fprintf(os.Stdout, "Response from `UserWorkspaceProcesses.List`: %v\n", resp)
}
Name | Type | Description | Notes |
---|---|---|---|
ctx | context.Context | context for authentication, logging, cancellation, deadlines, tracing, etc. | |
userHandle | string | The handle of the user for which you want to start listing processes. | |
workspaceHandle | string | The handle of the workspace where you want to list the processes. |
Other parameters are passed through a pointer to a apiListRequest struct via the builder pattern
Name | Type | Description | Notes |
---|
where | string | The SQL where filter you wish to apply to this request. The filter will be parsed and sanitised and checked against the supported columns for this API. | limit | int32 | The max number of items to fetch per page of data, subject to a min and max of 1 and 100 respectively. If not specified will default to 25. | [default to 25] nextToken | string | When list results are truncated, next_token will be returned, which is a cursor to fetch the next page of data. Pass next_token to the subsequent list request to fetch the next page of data. |
No authorization required
- Content-Type: Not defined
- Accept: application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]
string Log(ctx, userHandle, workspaceHandle, processId, logFile, contentType).Execute()
List user workspace process logs
package main
import (
"context"
"fmt"
"os"
openapiclient "./openapi"
)
func main() {
userHandle := "userHandle_example" // string | The handle of the user where the workspace exist.
workspaceHandle := "workspaceHandle_example" // string | The handle of the workspace where you want to list the process logs.
processId := "processId_example" // string | The id of the process where you want to list the process logs.
logFile := "logFile_example" // string | The process logs file to be fetched.
contentType := "contentType_example" // string | The required content type of the process logs.
configuration := openapiclient.NewConfiguration()
api_client := openapiclient.NewAPIClient(configuration)
resp, r, err := api_client.UserWorkspaceProcesses.Log(context.Background(), userHandle, workspaceHandle, processId, logFile, contentType).Execute()
if err != nil {
fmt.Fprintf(os.Stderr, "Error when calling `UserWorkspaceProcesses.Log``: %v\n", err)
fmt.Fprintf(os.Stderr, "Full HTTP response: %v\n", r)
}
// response from `Log`: string
fmt.Fprintf(os.Stdout, "Response from `UserWorkspaceProcesses.Log`: %v\n", resp)
}
Name | Type | Description | Notes |
---|---|---|---|
ctx | context.Context | context for authentication, logging, cancellation, deadlines, tracing, etc. | |
userHandle | string | The handle of the user where the workspace exist. | |
workspaceHandle | string | The handle of the workspace where you want to list the process logs. | |
processId | string | The id of the process where you want to list the process logs. | |
logFile | string | The process logs file to be fetched. | |
contentType | string | The required content type of the process logs. |
Other parameters are passed through a pointer to a apiLogRequest struct via the builder pattern
Name | Type | Description | Notes |
---|
string
No authorization required
- Content-Type: Not defined
- Accept: application/jsonlines+json, application/json
[Back to top] [Back to API list] [Back to Model list] [Back to README]