sdk

Documentation

Overview

Package sdk provides primitives to interact with the openapi HTTP API.

Code generated by github.com/deepmap/oapi-codegen/v2 version v2.1.0 DO NOT EDIT.

Index

• func NewAttachTaskExecutionRequest(server string, namespaceId string, pipelineId string, runId uint64, ...) (*http.Request, error)
• func NewCancelRunRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)
• func NewCancelTaskExecutionRequest(server string, namespaceId string, pipelineId string, runId uint64, ...) (*http.Request, error)
• func NewCreateBootstrapTokenRequest(server string) (*http.Request, error)
• func NewCreateNamespaceRequest(server string, body CreateNamespaceJSONRequestBody) (*http.Request, error)
• func NewCreateNamespaceRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewCreateSubscriptionRequest(server string, namespaceId string, pipelineId string, ...) (*http.Request, error)
• func NewCreateSubscriptionRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, ...) (*http.Request, error)
• func NewCreateTokenRequest(server string, body CreateTokenJSONRequestBody) (*http.Request, error)
• func NewCreateTokenRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewDeleteConfigRequest(server string, namespaceId string, pipelineId string, version int64) (*http.Request, error)
• func NewDeleteEventRequest(server string, eventId string) (*http.Request, error)
• func NewDeleteGlobalSecretRequest(server string, key string) (*http.Request, error)
• func NewDeleteLogsRequest(server string, namespaceId string, pipelineId string, runId uint64, ...) (*http.Request, error)
• func NewDeleteNamespaceRequest(server string, namespaceId string) (*http.Request, error)
• func NewDeletePipelineObjectRequest(server string, namespaceId string, pipelineId string, key string) (*http.Request, error)
• func NewDeletePipelineRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)
• func NewDeletePipelineSecretRequest(server string, namespaceId string, pipelineId string, key string) (*http.Request, error)
• func NewDeleteRunObjectRequest(server string, namespaceId string, pipelineId string, runId uint64, key string) (*http.Request, error)
• func NewDeleteSubscriptionRequest(server string, namespaceId string, pipelineId string, extensionId string, ...) (*http.Request, error)
• func NewDeleteTokenRequest(server string, id string) (*http.Request, error)
• func NewDeployConfigRequest(server string, namespaceId string, pipelineId string, version int64) (*http.Request, error)
• func NewGetConfigRequest(server string, namespaceId string, pipelineId string, version int64) (*http.Request, error)
• func NewGetDeploymentRequest(server string, namespaceId string, pipelineId string, deploymentId uint64) (*http.Request, error)
• func NewGetEventRequest(server string, eventId string) (*http.Request, error)
• func NewGetExtensionLogsRequest(server string, extensionId string) (*http.Request, error)
• func NewGetExtensionRequest(server string, extensionId string) (*http.Request, error)
• func NewGetGlobalSecretRequest(server string, key string, params *GetGlobalSecretParams) (*http.Request, error)
• func NewGetLogsRequest(server string, namespaceId string, pipelineId string, runId uint64, ...) (*http.Request, error)
• func NewGetMetadataRequest(server string) (*http.Request, error)
• func NewGetNamespaceRequest(server string, namespaceId string) (*http.Request, error)
• func NewGetPipelineObjectRequest(server string, namespaceId string, pipelineId string, key string) (*http.Request, error)
• func NewGetPipelineRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)
• func NewGetPipelineSecretRequest(server string, namespaceId string, pipelineId string, key string, ...) (*http.Request, error)
• func NewGetRunObjectRequest(server string, namespaceId string, pipelineId string, runId uint64, key string) (*http.Request, error)
• func NewGetRunRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)
• func NewGetSubscriptionRequest(server string, namespaceId string, pipelineId string, extensionId string, ...) (*http.Request, error)
• func NewGetTaskExecutionRequest(server string, namespaceId string, pipelineId string, runId uint64, ...) (*http.Request, error)
• func NewGetTokenByIdRequest(server string, id string) (*http.Request, error)
• func NewInstallExtensionRequest(server string, body InstallExtensionJSONRequestBody) (*http.Request, error)
• func NewInstallExtensionRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewListConfigsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)
• func NewListDeploymentsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)
• func NewListExtensionsRequest(server string) (*http.Request, error)
• func NewListGlobalSecretsRequest(server string) (*http.Request, error)
• func NewListNamespacesRequest(server string) (*http.Request, error)
• func NewListPipelineObjectsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)
• func NewListPipelineSecretsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)
• func NewListPipelinesRequest(server string, namespaceId string) (*http.Request, error)
• func NewListRunObjectsRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)
• func NewListRunsRequest(server string, namespaceId string, pipelineId string, params *ListRunsParams) (*http.Request, error)
• func NewListSubscriptionsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)
• func NewListTaskExecutionsRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)
• func NewListTokensRequest(server string) (*http.Request, error)
• func NewPutGlobalSecretRequest(server string, body PutGlobalSecretJSONRequestBody) (*http.Request, error)
• func NewPutGlobalSecretRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
• func NewPutPipelineObjectRequest(server string, namespaceId string, pipelineId string, ...) (*http.Request, error)
• func NewPutPipelineObjectRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, ...) (*http.Request, error)
• func NewPutPipelineSecretRequest(server string, namespaceId string, pipelineId string, ...) (*http.Request, error)
• func NewPutPipelineSecretRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, ...) (*http.Request, error)
• func NewPutRunObjectRequest(server string, namespaceId string, pipelineId string, runId uint64, ...) (*http.Request, error)
• func NewPutRunObjectRequestWithBody(server string, namespaceId string, pipelineId string, runId uint64, ...) (*http.Request, error)
• func NewRegisterConfigRequest(server string, namespaceId string, pipelineId string, ...) (*http.Request, error)
• func NewRegisterConfigRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, ...) (*http.Request, error)
• func NewStartRunRequest(server string, namespaceId string, pipelineId string, ...) (*http.Request, error)
• func NewStartRunRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, ...) (*http.Request, error)
• func NewStreamEventsRequest(server string, params *StreamEventsParams) (*http.Request, error)
• func NewUninstallExtensionRequest(server string, extensionId string) (*http.Request, error)
• func NewUpdateExtensionRequest(server string, extensionId string, body UpdateExtensionJSONRequestBody) (*http.Request, error)
• func NewUpdateExtensionRequestWithBody(server string, extensionId string, contentType string, body io.Reader) (*http.Request, error)
• func NewUpdateNamespaceRequest(server string, namespaceId string, body UpdateNamespaceJSONRequestBody) (*http.Request, error)
• func NewUpdateNamespaceRequestWithBody(server string, namespaceId string, contentType string, body io.Reader) (*http.Request, error)
• func NewUpdatePipelineRequest(server string, namespaceId string, pipelineId string, ...) (*http.Request, error)
• func NewUpdatePipelineRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, ...) (*http.Request, error)
• func NewUpdateSubscriptionRequest(server string, namespaceId string, pipelineId string, extensionId string, ...) (*http.Request, error)
• func NewUpdateSubscriptionRequestWithBody(server string, namespaceId string, pipelineId string, extensionId string, ...) (*http.Request, error)
• func NewUpdateTokenRequest(server string, id string, body UpdateTokenJSONRequestBody) (*http.Request, error)
• func NewUpdateTokenRequestWithBody(server string, id string, contentType string, body io.Reader) (*http.Request, error)
• func NewWhoamiRequest(server string) (*http.Request, error)
• type AttachTaskExecutionParams
• type AttachTaskExecutionResp
  • func ParseAttachTaskExecutionResp(rsp *http.Response) (*AttachTaskExecutionResp, error)
  • func (r AttachTaskExecutionResp) Status() string
  • func (r AttachTaskExecutionResp) StatusCode() int
• type CancelRunResp
  • func ParseCancelRunResp(rsp *http.Response) (*CancelRunResp, error)
  • func (r CancelRunResp) Status() string
  • func (r CancelRunResp) StatusCode() int
• type CancelTaskExecutionParams
• type CancelTaskExecutionResp
  • func ParseCancelTaskExecutionResp(rsp *http.Response) (*CancelTaskExecutionResp, error)
  • func (r CancelTaskExecutionResp) Status() string
  • func (r CancelTaskExecutionResp) StatusCode() int
• type Client
  • func NewClient(server string, opts ...ClientOption) (*Client, error)
  • func NewClientWithHeaders(host, token string, apiVersion GoferAPIVersion) (*Client, error)
  • func (c *Client) AttachTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) CancelRun(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) CancelTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) CreateBootstrapToken(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) CreateNamespace(ctx context.Context, body CreateNamespaceJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) CreateNamespaceWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) CreateSubscription(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) CreateSubscriptionWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*http.Response, error)
  • func (c *Client) CreateToken(ctx context.Context, body CreateTokenJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) CreateTokenWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) DeleteConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, ...) (*http.Response, error)
  • func (c *Client) DeleteEvent(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DeleteGlobalSecret(ctx context.Context, key string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DeleteLogs(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) DeleteNamespace(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DeletePipeline(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) DeletePipelineObject(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*http.Response, error)
  • func (c *Client) DeletePipelineSecret(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*http.Response, error)
  • func (c *Client) DeleteRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) DeleteSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*http.Response, error)
  • func (c *Client) DeleteToken(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) DeployConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, ...) (*http.Response, error)
  • func (c *Client) GetConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, ...) (*http.Response, error)
  • func (c *Client) GetDeployment(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) GetEvent(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) GetExtension(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) GetExtensionLogs(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) GetGlobalSecret(ctx context.Context, key string, params *GetGlobalSecretParams, ...) (*http.Response, error)
  • func (c *Client) GetLogs(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) GetMetadata(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) GetNamespace(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) GetPipeline(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) GetPipelineObject(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*http.Response, error)
  • func (c *Client) GetPipelineSecret(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*http.Response, error)
  • func (c *Client) GetRun(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) GetRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) GetSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*http.Response, error)
  • func (c *Client) GetTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) GetTokenById(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) InstallExtension(ctx context.Context, body InstallExtensionJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) InstallExtensionWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) ListConfigs(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) ListDeployments(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) ListExtensions(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) ListGlobalSecrets(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) ListNamespaces(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) ListPipelineObjects(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) ListPipelineSecrets(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) ListPipelines(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) ListRunObjects(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) ListRuns(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) ListSubscriptions(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) ListTaskExecutions(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) ListTokens(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) PutGlobalSecret(ctx context.Context, body PutGlobalSecretJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) PutGlobalSecretWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) PutPipelineObject(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) PutPipelineObjectWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*http.Response, error)
  • func (c *Client) PutPipelineSecret(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) PutPipelineSecretWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*http.Response, error)
  • func (c *Client) PutRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) PutRunObjectWithBody(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*http.Response, error)
  • func (c *Client) RegisterConfig(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) RegisterConfigWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*http.Response, error)
  • func (c *Client) StartRun(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) StartRunWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*http.Response, error)
  • func (c *Client) StreamEvents(ctx context.Context, params *StreamEventsParams, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) UninstallExtension(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)
  • func (c *Client) UpdateExtension(ctx context.Context, extensionId string, body UpdateExtensionJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) UpdateExtensionWithBody(ctx context.Context, extensionId string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) UpdateNamespace(ctx context.Context, namespaceId string, body UpdateNamespaceJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) UpdateNamespaceWithBody(ctx context.Context, namespaceId string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) UpdatePipeline(ctx context.Context, namespaceId string, pipelineId string, ...) (*http.Response, error)
  • func (c *Client) UpdatePipelineWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*http.Response, error)
  • func (c *Client) UpdateSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*http.Response, error)
  • func (c *Client) UpdateSubscriptionWithBody(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*http.Response, error)
  • func (c *Client) UpdateToken(ctx context.Context, id string, body UpdateTokenJSONRequestBody, ...) (*http.Response, error)
  • func (c *Client) UpdateTokenWithBody(ctx context.Context, id string, contentType string, body io.Reader, ...) (*http.Response, error)
  • func (c *Client) Whoami(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
• type ClientInterface
• type ClientOption
  • func WithBaseURL(baseURL string) ClientOption
  • func WithHTTPClient(doer HttpRequestDoer) ClientOption
  • func WithRequestEditorFn(fn RequestEditorFn) ClientOption
• type ClientWithResponses
  • func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)
  • func (c *ClientWithResponses) AttachTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*AttachTaskExecutionResp, error)
  • func (c *ClientWithResponses) CancelRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*CancelRunResp, error)
  • func (c *ClientWithResponses) CancelTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*CancelTaskExecutionResp, error)
  • func (c *ClientWithResponses) CreateBootstrapTokenWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*CreateBootstrapTokenResp, error)
  • func (c *ClientWithResponses) CreateNamespaceWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateNamespaceResp, error)
  • func (c *ClientWithResponses) CreateNamespaceWithResponse(ctx context.Context, body CreateNamespaceJSONRequestBody, ...) (*CreateNamespaceResp, error)
  • func (c *ClientWithResponses) CreateSubscriptionWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*CreateSubscriptionResp, error)
  • func (c *ClientWithResponses) CreateSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*CreateSubscriptionResp, error)
  • func (c *ClientWithResponses) CreateTokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateTokenResp, error)
  • func (c *ClientWithResponses) CreateTokenWithResponse(ctx context.Context, body CreateTokenJSONRequestBody, ...) (*CreateTokenResp, error)
  • func (c *ClientWithResponses) DeleteConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, ...) (*DeleteConfigResp, error)
  • func (c *ClientWithResponses) DeleteEventWithResponse(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*DeleteEventResp, error)
  • func (c *ClientWithResponses) DeleteGlobalSecretWithResponse(ctx context.Context, key string, reqEditors ...RequestEditorFn) (*DeleteGlobalSecretResp, error)
  • func (c *ClientWithResponses) DeleteLogsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*DeleteLogsResp, error)
  • func (c *ClientWithResponses) DeleteNamespaceWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*DeleteNamespaceResp, error)
  • func (c *ClientWithResponses) DeletePipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*DeletePipelineObjectResp, error)
  • func (c *ClientWithResponses) DeletePipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*DeletePipelineSecretResp, error)
  • func (c *ClientWithResponses) DeletePipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*DeletePipelineResp, error)
  • func (c *ClientWithResponses) DeleteRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*DeleteRunObjectResp, error)
  • func (c *ClientWithResponses) DeleteSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*DeleteSubscriptionResp, error)
  • func (c *ClientWithResponses) DeleteTokenWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*DeleteTokenResp, error)
  • func (c *ClientWithResponses) DeployConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, ...) (*DeployConfigResp, error)
  • func (c *ClientWithResponses) GetConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, ...) (*GetConfigResp, error)
  • func (c *ClientWithResponses) GetDeploymentWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*GetDeploymentResp, error)
  • func (c *ClientWithResponses) GetEventWithResponse(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*GetEventResp, error)
  • func (c *ClientWithResponses) GetExtensionLogsWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*GetExtensionLogsResp, error)
  • func (c *ClientWithResponses) GetExtensionWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*GetExtensionResp, error)
  • func (c *ClientWithResponses) GetGlobalSecretWithResponse(ctx context.Context, key string, params *GetGlobalSecretParams, ...) (*GetGlobalSecretResp, error)
  • func (c *ClientWithResponses) GetLogsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*GetLogsResp, error)
  • func (c *ClientWithResponses) GetMetadataWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMetadataResp, error)
  • func (c *ClientWithResponses) GetNamespaceWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*GetNamespaceResp, error)
  • func (c *ClientWithResponses) GetPipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*GetPipelineObjectResp, error)
  • func (c *ClientWithResponses) GetPipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, ...) (*GetPipelineSecretResp, error)
  • func (c *ClientWithResponses) GetPipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*GetPipelineResp, error)
  • func (c *ClientWithResponses) GetRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*GetRunObjectResp, error)
  • func (c *ClientWithResponses) GetRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*GetRunResp, error)
  • func (c *ClientWithResponses) GetSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*GetSubscriptionResp, error)
  • func (c *ClientWithResponses) GetTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*GetTaskExecutionResp, error)
  • func (c *ClientWithResponses) GetTokenByIdWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*GetTokenByIdResp, error)
  • func (c *ClientWithResponses) InstallExtensionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*InstallExtensionResp, error)
  • func (c *ClientWithResponses) InstallExtensionWithResponse(ctx context.Context, body InstallExtensionJSONRequestBody, ...) (*InstallExtensionResp, error)
  • func (c *ClientWithResponses) ListConfigsWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*ListConfigsResp, error)
  • func (c *ClientWithResponses) ListDeploymentsWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*ListDeploymentsResp, error)
  • func (c *ClientWithResponses) ListExtensionsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListExtensionsResp, error)
  • func (c *ClientWithResponses) ListGlobalSecretsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListGlobalSecretsResp, error)
  • func (c *ClientWithResponses) ListNamespacesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListNamespacesResp, error)
  • func (c *ClientWithResponses) ListPipelineObjectsWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*ListPipelineObjectsResp, error)
  • func (c *ClientWithResponses) ListPipelineSecretsWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*ListPipelineSecretsResp, error)
  • func (c *ClientWithResponses) ListPipelinesWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*ListPipelinesResp, error)
  • func (c *ClientWithResponses) ListRunObjectsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*ListRunObjectsResp, error)
  • func (c *ClientWithResponses) ListRunsWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*ListRunsResp, error)
  • func (c *ClientWithResponses) ListSubscriptionsWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*ListSubscriptionsResp, error)
  • func (c *ClientWithResponses) ListTaskExecutionsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*ListTaskExecutionsResp, error)
  • func (c *ClientWithResponses) ListTokensWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListTokensResp, error)
  • func (c *ClientWithResponses) PutGlobalSecretWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*PutGlobalSecretResp, error)
  • func (c *ClientWithResponses) PutGlobalSecretWithResponse(ctx context.Context, body PutGlobalSecretJSONRequestBody, ...) (*PutGlobalSecretResp, error)
  • func (c *ClientWithResponses) PutPipelineObjectWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*PutPipelineObjectResp, error)
  • func (c *ClientWithResponses) PutPipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*PutPipelineObjectResp, error)
  • func (c *ClientWithResponses) PutPipelineSecretWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*PutPipelineSecretResp, error)
  • func (c *ClientWithResponses) PutPipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*PutPipelineSecretResp, error)
  • func (c *ClientWithResponses) PutRunObjectWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*PutRunObjectResp, error)
  • func (c *ClientWithResponses) PutRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, ...) (*PutRunObjectResp, error)
  • func (c *ClientWithResponses) RegisterConfigWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*RegisterConfigResp, error)
  • func (c *ClientWithResponses) RegisterConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*RegisterConfigResp, error)
  • func (c *ClientWithResponses) StartRunWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*StartRunResp, error)
  • func (c *ClientWithResponses) StartRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*StartRunResp, error)
  • func (c *ClientWithResponses) StreamEventsWithResponse(ctx context.Context, params *StreamEventsParams, reqEditors ...RequestEditorFn) (*StreamEventsResp, error)
  • func (c *ClientWithResponses) UninstallExtensionWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*UninstallExtensionResp, error)
  • func (c *ClientWithResponses) UpdateExtensionWithBodyWithResponse(ctx context.Context, extensionId string, contentType string, body io.Reader, ...) (*UpdateExtensionResp, error)
  • func (c *ClientWithResponses) UpdateExtensionWithResponse(ctx context.Context, extensionId string, body UpdateExtensionJSONRequestBody, ...) (*UpdateExtensionResp, error)
  • func (c *ClientWithResponses) UpdateNamespaceWithBodyWithResponse(ctx context.Context, namespaceId string, contentType string, body io.Reader, ...) (*UpdateNamespaceResp, error)
  • func (c *ClientWithResponses) UpdateNamespaceWithResponse(ctx context.Context, namespaceId string, body UpdateNamespaceJSONRequestBody, ...) (*UpdateNamespaceResp, error)
  • func (c *ClientWithResponses) UpdatePipelineWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, ...) (*UpdatePipelineResp, error)
  • func (c *ClientWithResponses) UpdatePipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, ...) (*UpdatePipelineResp, error)
  • func (c *ClientWithResponses) UpdateSubscriptionWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*UpdateSubscriptionResp, error)
  • func (c *ClientWithResponses) UpdateSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, ...) (*UpdateSubscriptionResp, error)
  • func (c *ClientWithResponses) UpdateTokenWithBodyWithResponse(ctx context.Context, id string, contentType string, body io.Reader, ...) (*UpdateTokenResp, error)
  • func (c *ClientWithResponses) UpdateTokenWithResponse(ctx context.Context, id string, body UpdateTokenJSONRequestBody, ...) (*UpdateTokenResp, error)
  • func (c *ClientWithResponses) WhoamiWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*WhoamiResp, error)
• type ClientWithResponsesInterface
• type Config
• type ConfigState
  • func (t ConfigState) AsConfigState0() (ConfigState0, error)
  • func (t ConfigState) AsConfigState1() (ConfigState1, error)
  • func (t ConfigState) AsConfigState2() (ConfigState2, error)
  • func (t ConfigState) AsConfigState3() (ConfigState3, error)
  • func (t *ConfigState) FromConfigState0(v ConfigState0) error
  • func (t *ConfigState) FromConfigState1(v ConfigState1) error
  • func (t *ConfigState) FromConfigState2(v ConfigState2) error
  • func (t *ConfigState) FromConfigState3(v ConfigState3) error
  • func (t ConfigState) MarshalJSON() ([]byte, error)
  • func (t *ConfigState) MergeConfigState0(v ConfigState0) error
  • func (t *ConfigState) MergeConfigState1(v ConfigState1) error
  • func (t *ConfigState) MergeConfigState2(v ConfigState2) error
  • func (t *ConfigState) MergeConfigState3(v ConfigState3) error
  • func (t *ConfigState) UnmarshalJSON(b []byte) error
• type ConfigState0
• type ConfigState1
• type ConfigState2
• type ConfigState3
• type CreateBootstrapTokenResp
  • func ParseCreateBootstrapTokenResp(rsp *http.Response) (*CreateBootstrapTokenResp, error)
  • func (r CreateBootstrapTokenResp) Status() string
  • func (r CreateBootstrapTokenResp) StatusCode() int
• type CreateNamespaceJSONRequestBody
• type CreateNamespaceRequest
• type CreateNamespaceResp
  • func ParseCreateNamespaceResp(rsp *http.Response) (*CreateNamespaceResp, error)
  • func (r CreateNamespaceResp) Status() string
  • func (r CreateNamespaceResp) StatusCode() int
• type CreateNamespaceResponse
• type CreateSubscriptionJSONRequestBody
• type CreateSubscriptionRequest
• type CreateSubscriptionResp
  • func ParseCreateSubscriptionResp(rsp *http.Response) (*CreateSubscriptionResp, error)
  • func (r CreateSubscriptionResp) Status() string
  • func (r CreateSubscriptionResp) StatusCode() int
• type CreateSubscriptionResponse
• type CreateTokenJSONRequestBody
• type CreateTokenRequest
• type CreateTokenResp
  • func ParseCreateTokenResp(rsp *http.Response) (*CreateTokenResp, error)
  • func (r CreateTokenResp) Status() string
  • func (r CreateTokenResp) StatusCode() int
• type CreateTokenResponse
• type DeleteConfigResp
  • func ParseDeleteConfigResp(rsp *http.Response) (*DeleteConfigResp, error)
  • func (r DeleteConfigResp) Status() string
  • func (r DeleteConfigResp) StatusCode() int
• type DeleteEventResp
  • func ParseDeleteEventResp(rsp *http.Response) (*DeleteEventResp, error)
  • func (r DeleteEventResp) Status() string
  • func (r DeleteEventResp) StatusCode() int
• type DeleteGlobalSecretResp
  • func ParseDeleteGlobalSecretResp(rsp *http.Response) (*DeleteGlobalSecretResp, error)
  • func (r DeleteGlobalSecretResp) Status() string
  • func (r DeleteGlobalSecretResp) StatusCode() int
• type DeleteLogsResp
  • func ParseDeleteLogsResp(rsp *http.Response) (*DeleteLogsResp, error)
  • func (r DeleteLogsResp) Status() string
  • func (r DeleteLogsResp) StatusCode() int
• type DeleteNamespaceResp
  • func ParseDeleteNamespaceResp(rsp *http.Response) (*DeleteNamespaceResp, error)
  • func (r DeleteNamespaceResp) Status() string
  • func (r DeleteNamespaceResp) StatusCode() int
• type DeletePipelineObjectResp
  • func ParseDeletePipelineObjectResp(rsp *http.Response) (*DeletePipelineObjectResp, error)
  • func (r DeletePipelineObjectResp) Status() string
  • func (r DeletePipelineObjectResp) StatusCode() int
• type DeletePipelineResp
  • func ParseDeletePipelineResp(rsp *http.Response) (*DeletePipelineResp, error)
  • func (r DeletePipelineResp) Status() string
  • func (r DeletePipelineResp) StatusCode() int
• type DeletePipelineSecretResp
  • func ParseDeletePipelineSecretResp(rsp *http.Response) (*DeletePipelineSecretResp, error)
  • func (r DeletePipelineSecretResp) Status() string
  • func (r DeletePipelineSecretResp) StatusCode() int
• type DeleteRunObjectResp
  • func ParseDeleteRunObjectResp(rsp *http.Response) (*DeleteRunObjectResp, error)
  • func (r DeleteRunObjectResp) Status() string
  • func (r DeleteRunObjectResp) StatusCode() int
• type DeleteSubscriptionResp
  • func ParseDeleteSubscriptionResp(rsp *http.Response) (*DeleteSubscriptionResp, error)
  • func (r DeleteSubscriptionResp) Status() string
  • func (r DeleteSubscriptionResp) StatusCode() int
• type DeleteTokenResp
  • func ParseDeleteTokenResp(rsp *http.Response) (*DeleteTokenResp, error)
  • func (r DeleteTokenResp) Status() string
  • func (r DeleteTokenResp) StatusCode() int
• type DeployConfigResp
  • func ParseDeployConfigResp(rsp *http.Response) (*DeployConfigResp, error)
  • func (r DeployConfigResp) Status() string
  • func (r DeployConfigResp) StatusCode() int
• type DeployPipelineConfigResponse
• type Deployment
• type DeploymentState
  • func (t DeploymentState) AsDeploymentState0() (DeploymentState0, error)
  • func (t DeploymentState) AsDeploymentState1() (DeploymentState1, error)
  • func (t *DeploymentState) FromDeploymentState0(v DeploymentState0) error
  • func (t *DeploymentState) FromDeploymentState1(v DeploymentState1) error
  • func (t DeploymentState) MarshalJSON() ([]byte, error)
  • func (t *DeploymentState) MergeDeploymentState0(v DeploymentState0) error
  • func (t *DeploymentState) MergeDeploymentState1(v DeploymentState1) error
  • func (t *DeploymentState) UnmarshalJSON(b []byte) error
• type DeploymentState0
• type DeploymentState1
• type DeploymentStatus
  • func (t DeploymentStatus) AsDeploymentStatus0() (DeploymentStatus0, error)
  • func (t DeploymentStatus) AsDeploymentStatus1() (DeploymentStatus1, error)
  • func (t DeploymentStatus) AsDeploymentStatus2() (DeploymentStatus2, error)
  • func (t *DeploymentStatus) FromDeploymentStatus0(v DeploymentStatus0) error
  • func (t *DeploymentStatus) FromDeploymentStatus1(v DeploymentStatus1) error
  • func (t *DeploymentStatus) FromDeploymentStatus2(v DeploymentStatus2) error
  • func (t DeploymentStatus) MarshalJSON() ([]byte, error)
  • func (t *DeploymentStatus) MergeDeploymentStatus0(v DeploymentStatus0) error
  • func (t *DeploymentStatus) MergeDeploymentStatus1(v DeploymentStatus1) error
  • func (t *DeploymentStatus) MergeDeploymentStatus2(v DeploymentStatus2) error
  • func (t *DeploymentStatus) UnmarshalJSON(b []byte) error
• type DeploymentStatus0
• type DeploymentStatus1
• type DeploymentStatus2
• type DeploymentStatusReason
• type DeploymentStatusReasonType
• type Documentation
• type Error
• type Event
• type Extension
• type ExtensionState
  • func (t ExtensionState) AsExtensionState0() (ExtensionState0, error)
  • func (t ExtensionState) AsExtensionState1() (ExtensionState1, error)
  • func (t ExtensionState) AsExtensionState2() (ExtensionState2, error)
  • func (t ExtensionState) AsExtensionState3() (ExtensionState3, error)
  • func (t *ExtensionState) FromExtensionState0(v ExtensionState0) error
  • func (t *ExtensionState) FromExtensionState1(v ExtensionState1) error
  • func (t *ExtensionState) FromExtensionState2(v ExtensionState2) error
  • func (t *ExtensionState) FromExtensionState3(v ExtensionState3) error
  • func (t ExtensionState) MarshalJSON() ([]byte, error)
  • func (t *ExtensionState) MergeExtensionState0(v ExtensionState0) error
  • func (t *ExtensionState) MergeExtensionState1(v ExtensionState1) error
  • func (t *ExtensionState) MergeExtensionState2(v ExtensionState2) error
  • func (t *ExtensionState) MergeExtensionState3(v ExtensionState3) error
  • func (t *ExtensionState) UnmarshalJSON(b []byte) error
• type ExtensionState0
• type ExtensionState1
• type ExtensionState2
• type ExtensionState3
• type ExtensionStatus
  • func (t ExtensionStatus) AsExtensionStatus0() (ExtensionStatus0, error)
  • func (t ExtensionStatus) AsExtensionStatus1() (ExtensionStatus1, error)
  • func (t ExtensionStatus) AsExtensionStatus2() (ExtensionStatus2, error)
  • func (t *ExtensionStatus) FromExtensionStatus0(v ExtensionStatus0) error
  • func (t *ExtensionStatus) FromExtensionStatus1(v ExtensionStatus1) error
  • func (t *ExtensionStatus) FromExtensionStatus2(v ExtensionStatus2) error
  • func (t ExtensionStatus) MarshalJSON() ([]byte, error)
  • func (t *ExtensionStatus) MergeExtensionStatus0(v ExtensionStatus0) error
  • func (t *ExtensionStatus) MergeExtensionStatus1(v ExtensionStatus1) error
  • func (t *ExtensionStatus) MergeExtensionStatus2(v ExtensionStatus2) error
  • func (t *ExtensionStatus) UnmarshalJSON(b []byte) error
• type ExtensionStatus0
• type ExtensionStatus1
• type ExtensionStatus2
• type GetConfigResp
  • func ParseGetConfigResp(rsp *http.Response) (*GetConfigResp, error)
  • func (r GetConfigResp) Status() string
  • func (r GetConfigResp) StatusCode() int
• type GetDeploymentResp
  • func ParseGetDeploymentResp(rsp *http.Response) (*GetDeploymentResp, error)
  • func (r GetDeploymentResp) Status() string
  • func (r GetDeploymentResp) StatusCode() int
• type GetDeploymentResponse
• type GetEventResp
  • func ParseGetEventResp(rsp *http.Response) (*GetEventResp, error)
  • func (r GetEventResp) Status() string
  • func (r GetEventResp) StatusCode() int
• type GetEventResponse
• type GetExtensionLogsResp
  • func ParseGetExtensionLogsResp(rsp *http.Response) (*GetExtensionLogsResp, error)
  • func (r GetExtensionLogsResp) Status() string
  • func (r GetExtensionLogsResp) StatusCode() int
• type GetExtensionResp
  • func ParseGetExtensionResp(rsp *http.Response) (*GetExtensionResp, error)
  • func (r GetExtensionResp) Status() string
  • func (r GetExtensionResp) StatusCode() int
• type GetExtensionResponse
• type GetGlobalSecretParams
• type GetGlobalSecretResp
  • func ParseGetGlobalSecretResp(rsp *http.Response) (*GetGlobalSecretResp, error)
  • func (r GetGlobalSecretResp) Status() string
  • func (r GetGlobalSecretResp) StatusCode() int
• type GetGlobalSecretResponse
• type GetLogsResp
  • func ParseGetLogsResp(rsp *http.Response) (*GetLogsResp, error)
  • func (r GetLogsResp) Status() string
  • func (r GetLogsResp) StatusCode() int
• type GetMetadataResp
  • func ParseGetMetadataResp(rsp *http.Response) (*GetMetadataResp, error)
  • func (r GetMetadataResp) Status() string
  • func (r GetMetadataResp) StatusCode() int
• type GetNamespaceResp
  • func ParseGetNamespaceResp(rsp *http.Response) (*GetNamespaceResp, error)
  • func (r GetNamespaceResp) Status() string
  • func (r GetNamespaceResp) StatusCode() int
• type GetNamespaceResponse
• type GetPipelineConfigResponse
• type GetPipelineObjectResp
  • func ParseGetPipelineObjectResp(rsp *http.Response) (*GetPipelineObjectResp, error)
  • func (r GetPipelineObjectResp) Status() string
  • func (r GetPipelineObjectResp) StatusCode() int
• type GetPipelineObjectResponse
• type GetPipelineResp
  • func ParseGetPipelineResp(rsp *http.Response) (*GetPipelineResp, error)
  • func (r GetPipelineResp) Status() string
  • func (r GetPipelineResp) StatusCode() int
• type GetPipelineResponse
• type GetPipelineSecretParams
• type GetPipelineSecretResp
  • func ParseGetPipelineSecretResp(rsp *http.Response) (*GetPipelineSecretResp, error)
  • func (r GetPipelineSecretResp) Status() string
  • func (r GetPipelineSecretResp) StatusCode() int
• type GetPipelineSecretResponse
• type GetRunObjectResp
  • func ParseGetRunObjectResp(rsp *http.Response) (*GetRunObjectResp, error)
  • func (r GetRunObjectResp) Status() string
  • func (r GetRunObjectResp) StatusCode() int
• type GetRunObjectResponse
• type GetRunResp
  • func ParseGetRunResp(rsp *http.Response) (*GetRunResp, error)
  • func (r GetRunResp) Status() string
  • func (r GetRunResp) StatusCode() int
• type GetRunResponse
• type GetSubscriptionResp
  • func ParseGetSubscriptionResp(rsp *http.Response) (*GetSubscriptionResp, error)
  • func (r GetSubscriptionResp) Status() string
  • func (r GetSubscriptionResp) StatusCode() int
• type GetSubscriptionResponse
• type GetSystemMetadataResponse
• type GetTaskExecutionResp
  • func ParseGetTaskExecutionResp(rsp *http.Response) (*GetTaskExecutionResp, error)
  • func (r GetTaskExecutionResp) Status() string
  • func (r GetTaskExecutionResp) StatusCode() int
• type GetTaskExecutionResponse
• type GetTokenByIDResponse
• type GetTokenByIdResp
  • func ParseGetTokenByIdResp(rsp *http.Response) (*GetTokenByIdResp, error)
  • func (r GetTokenByIdResp) Status() string
  • func (r GetTokenByIdResp) StatusCode() int
• type GoferAPIVersion
• type HttpRequestDoer
• type Initiator
• type InitiatorType
• type InstallExtensionJSONRequestBody
• type InstallExtensionRequest
• type InstallExtensionResp
  • func ParseInstallExtensionResp(rsp *http.Response) (*InstallExtensionResp, error)
  • func (r InstallExtensionResp) Status() string
  • func (r InstallExtensionResp) StatusCode() int
• type InstallExtensionResponse
• type Kind
  • func (t Kind) AsKind0() (Kind0, error)
  • func (t Kind) AsKind1() (Kind1, error)
  • func (t Kind) AsKind10() (Kind10, error)
  • func (t Kind) AsKind11() (Kind11, error)
  • func (t Kind) AsKind12() (Kind12, error)
  • func (t Kind) AsKind13() (Kind13, error)
  • func (t Kind) AsKind14() (Kind14, error)
  • func (t Kind) AsKind15() (Kind15, error)
  • func (t Kind) AsKind16() (Kind16, error)
  • func (t Kind) AsKind17() (Kind17, error)
  • func (t Kind) AsKind18() (Kind18, error)
  • func (t Kind) AsKind19() (Kind19, error)
  • func (t Kind) AsKind2() (Kind2, error)
  • func (t Kind) AsKind3() (Kind3, error)
  • func (t Kind) AsKind4() (Kind4, error)
  • func (t Kind) AsKind5() (Kind5, error)
  • func (t Kind) AsKind6() (Kind6, error)
  • func (t Kind) AsKind7() (Kind7, error)
  • func (t Kind) AsKind8() (Kind8, error)
  • func (t Kind) AsKind9() (Kind9, error)
  • func (t *Kind) FromKind0(v Kind0) error
  • func (t *Kind) FromKind1(v Kind1) error
  • func (t *Kind) FromKind10(v Kind10) error
  • func (t *Kind) FromKind11(v Kind11) error
  • func (t *Kind) FromKind12(v Kind12) error
  • func (t *Kind) FromKind13(v Kind13) error
  • func (t *Kind) FromKind14(v Kind14) error
  • func (t *Kind) FromKind15(v Kind15) error
  • func (t *Kind) FromKind16(v Kind16) error
  • func (t *Kind) FromKind17(v Kind17) error
  • func (t *Kind) FromKind18(v Kind18) error
  • func (t *Kind) FromKind19(v Kind19) error
  • func (t *Kind) FromKind2(v Kind2) error
  • func (t *Kind) FromKind3(v Kind3) error
  • func (t *Kind) FromKind4(v Kind4) error
  • func (t *Kind) FromKind5(v Kind5) error
  • func (t *Kind) FromKind6(v Kind6) error
  • func (t *Kind) FromKind7(v Kind7) error
  • func (t *Kind) FromKind8(v Kind8) error
  • func (t *Kind) FromKind9(v Kind9) error
  • func (t Kind) MarshalJSON() ([]byte, error)
  • func (t *Kind) MergeKind0(v Kind0) error
  • func (t *Kind) MergeKind1(v Kind1) error
  • func (t *Kind) MergeKind10(v Kind10) error
  • func (t *Kind) MergeKind11(v Kind11) error
  • func (t *Kind) MergeKind12(v Kind12) error
  • func (t *Kind) MergeKind13(v Kind13) error
  • func (t *Kind) MergeKind14(v Kind14) error
  • func (t *Kind) MergeKind15(v Kind15) error
  • func (t *Kind) MergeKind16(v Kind16) error
  • func (t *Kind) MergeKind17(v Kind17) error
  • func (t *Kind) MergeKind18(v Kind18) error
  • func (t *Kind) MergeKind19(v Kind19) error
  • func (t *Kind) MergeKind2(v Kind2) error
  • func (t *Kind) MergeKind3(v Kind3) error
  • func (t *Kind) MergeKind4(v Kind4) error
  • func (t *Kind) MergeKind5(v Kind5) error
  • func (t *Kind) MergeKind6(v Kind6) error
  • func (t *Kind) MergeKind7(v Kind7) error
  • func (t *Kind) MergeKind8(v Kind8) error
  • func (t *Kind) MergeKind9(v Kind9) error
  • func (t *Kind) UnmarshalJSON(b []byte) error
• type Kind0
• type Kind1
• type Kind10
• type Kind11
• type Kind12
• type Kind13
• type Kind14
• type Kind15
• type Kind16
• type Kind17
• type Kind18
• type Kind19
• type Kind2
• type Kind3
• type Kind4
• type Kind5
• type Kind6
• type Kind7
• type Kind8
• type Kind9
• type ListConfigsResp
  • func ParseListConfigsResp(rsp *http.Response) (*ListConfigsResp, error)
  • func (r ListConfigsResp) Status() string
  • func (r ListConfigsResp) StatusCode() int
• type ListDeploymentsResp
  • func ParseListDeploymentsResp(rsp *http.Response) (*ListDeploymentsResp, error)
  • func (r ListDeploymentsResp) Status() string
  • func (r ListDeploymentsResp) StatusCode() int
• type ListDeploymentsResponse
• type ListExtensionsResp
  • func ParseListExtensionsResp(rsp *http.Response) (*ListExtensionsResp, error)
  • func (r ListExtensionsResp) Status() string
  • func (r ListExtensionsResp) StatusCode() int
• type ListExtensionsResponse
• type ListGlobalSecretsResp
  • func ParseListGlobalSecretsResp(rsp *http.Response) (*ListGlobalSecretsResp, error)
  • func (r ListGlobalSecretsResp) Status() string
  • func (r ListGlobalSecretsResp) StatusCode() int
• type ListGlobalSecretsResponse
• type ListNamespacesResp
  • func ParseListNamespacesResp(rsp *http.Response) (*ListNamespacesResp, error)
  • func (r ListNamespacesResp) Status() string
  • func (r ListNamespacesResp) StatusCode() int
• type ListNamespacesResponse
• type ListPipelineConfigsResponse
• type ListPipelineObjectsResp
  • func ParseListPipelineObjectsResp(rsp *http.Response) (*ListPipelineObjectsResp, error)
  • func (r ListPipelineObjectsResp) Status() string
  • func (r ListPipelineObjectsResp) StatusCode() int
• type ListPipelineObjectsResponse
• type ListPipelineSecretsResp
  • func ParseListPipelineSecretsResp(rsp *http.Response) (*ListPipelineSecretsResp, error)
  • func (r ListPipelineSecretsResp) Status() string
  • func (r ListPipelineSecretsResp) StatusCode() int
• type ListPipelineSecretsResponse
• type ListPipelinesResp
  • func ParseListPipelinesResp(rsp *http.Response) (*ListPipelinesResp, error)
  • func (r ListPipelinesResp) Status() string
  • func (r ListPipelinesResp) StatusCode() int
• type ListPipelinesResponse
• type ListRunObjectsResp
  • func ParseListRunObjectsResp(rsp *http.Response) (*ListRunObjectsResp, error)
  • func (r ListRunObjectsResp) Status() string
  • func (r ListRunObjectsResp) StatusCode() int
• type ListRunObjectsResponse
• type ListRunsParams
• type ListRunsResp
  • func ParseListRunsResp(rsp *http.Response) (*ListRunsResp, error)
  • func (r ListRunsResp) Status() string
  • func (r ListRunsResp) StatusCode() int
• type ListRunsResponse
• type ListSubscriptionsResp
  • func ParseListSubscriptionsResp(rsp *http.Response) (*ListSubscriptionsResp, error)
  • func (r ListSubscriptionsResp) Status() string
  • func (r ListSubscriptionsResp) StatusCode() int
• type ListSubscriptionsResponse
• type ListTaskExecutionsResp
  • func ParseListTaskExecutionsResp(rsp *http.Response) (*ListTaskExecutionsResp, error)
  • func (r ListTaskExecutionsResp) Status() string
  • func (r ListTaskExecutionsResp) StatusCode() int
• type ListTaskExecutionsResponse
• type ListTokensResp
  • func ParseListTokensResp(rsp *http.Response) (*ListTokensResp, error)
  • func (r ListTokensResp) Status() string
  • func (r ListTokensResp) StatusCode() int
• type ListTokensResponse
• type Metadata
• type Namespace
• type Object
• type Parameter
• type Pipeline
• type Pipeline2
• type PipelineState
• type PutGlobalSecretJSONRequestBody
• type PutGlobalSecretRequest
• type PutGlobalSecretResp
  • func ParsePutGlobalSecretResp(rsp *http.Response) (*PutGlobalSecretResp, error)
  • func (r PutGlobalSecretResp) Status() string
  • func (r PutGlobalSecretResp) StatusCode() int
• type PutGlobalSecretResponse
• type PutPipelineObjectJSONRequestBody
• type PutPipelineObjectRequest
• type PutPipelineObjectResp
  • func ParsePutPipelineObjectResp(rsp *http.Response) (*PutPipelineObjectResp, error)
  • func (r PutPipelineObjectResp) Status() string
  • func (r PutPipelineObjectResp) StatusCode() int
• type PutPipelineObjectResponse
• type PutPipelineSecretJSONRequestBody
• type PutPipelineSecretRequest
• type PutPipelineSecretResp
  • func ParsePutPipelineSecretResp(rsp *http.Response) (*PutPipelineSecretResp, error)
  • func (r PutPipelineSecretResp) Status() string
  • func (r PutPipelineSecretResp) StatusCode() int
• type PutPipelineSecretResponse
• type PutRunObjectJSONRequestBody
• type PutRunObjectRequest
• type PutRunObjectResp
  • func ParsePutRunObjectResp(rsp *http.Response) (*PutRunObjectResp, error)
  • func (r PutRunObjectResp) Status() string
  • func (r PutRunObjectResp) StatusCode() int
• type PutRunObjectResponse
• type RegisterConfigJSONRequestBody
• type RegisterConfigResp
  • func ParseRegisterConfigResp(rsp *http.Response) (*RegisterConfigResp, error)
  • func (r RegisterConfigResp) Status() string
  • func (r RegisterConfigResp) StatusCode() int
• type RegisterPipelineConfigRequest
• type RegisterPipelineConfigResponse
• type Registration
• type RegistryAuth
• type RegistryAuth2
• type RequestEditorFn
• type RequiredParentStatus
• type RequiredParentStatus2
• type Run
• type RunState
  • func (t RunState) AsRunState0() (RunState0, error)
  • func (t RunState) AsRunState1() (RunState1, error)
  • func (t RunState) AsRunState2() (RunState2, error)
  • func (t RunState) AsRunState3() (RunState3, error)
  • func (t *RunState) FromRunState0(v RunState0) error
  • func (t *RunState) FromRunState1(v RunState1) error
  • func (t *RunState) FromRunState2(v RunState2) error
  • func (t *RunState) FromRunState3(v RunState3) error
  • func (t RunState) MarshalJSON() ([]byte, error)
  • func (t *RunState) MergeRunState0(v RunState0) error
  • func (t *RunState) MergeRunState1(v RunState1) error
  • func (t *RunState) MergeRunState2(v RunState2) error
  • func (t *RunState) MergeRunState3(v RunState3) error
  • func (t *RunState) UnmarshalJSON(b []byte) error
• type RunState0
• type RunState1
• type RunState2
• type RunState3
• type RunStatus
  • func (t RunStatus) AsRunStatus0() (RunStatus0, error)
  • func (t RunStatus) AsRunStatus1() (RunStatus1, error)
  • func (t RunStatus) AsRunStatus2() (RunStatus2, error)
  • func (t RunStatus) AsRunStatus3() (RunStatus3, error)
  • func (t *RunStatus) FromRunStatus0(v RunStatus0) error
  • func (t *RunStatus) FromRunStatus1(v RunStatus1) error
  • func (t *RunStatus) FromRunStatus2(v RunStatus2) error
  • func (t *RunStatus) FromRunStatus3(v RunStatus3) error
  • func (t RunStatus) MarshalJSON() ([]byte, error)
  • func (t *RunStatus) MergeRunStatus0(v RunStatus0) error
  • func (t *RunStatus) MergeRunStatus1(v RunStatus1) error
  • func (t *RunStatus) MergeRunStatus2(v RunStatus2) error
  • func (t *RunStatus) MergeRunStatus3(v RunStatus3) error
  • func (t *RunStatus) UnmarshalJSON(b []byte) error
• type RunStatus0
• type RunStatus1
• type RunStatus2
• type RunStatus3
• type RunStatusReason
• type RunStatusReasonType
  • func (t RunStatusReasonType) AsRunStatusReasonType0() (RunStatusReasonType0, error)
  • func (t RunStatusReasonType) AsRunStatusReasonType1() (RunStatusReasonType1, error)
  • func (t RunStatusReasonType) AsRunStatusReasonType2() (RunStatusReasonType2, error)
  • func (t RunStatusReasonType) AsRunStatusReasonType3() (RunStatusReasonType3, error)
  • func (t RunStatusReasonType) AsRunStatusReasonType4() (RunStatusReasonType4, error)
  • func (t RunStatusReasonType) AsRunStatusReasonType5() (RunStatusReasonType5, error)
  • func (t *RunStatusReasonType) FromRunStatusReasonType0(v RunStatusReasonType0) error
  • func (t *RunStatusReasonType) FromRunStatusReasonType1(v RunStatusReasonType1) error
  • func (t *RunStatusReasonType) FromRunStatusReasonType2(v RunStatusReasonType2) error
  • func (t *RunStatusReasonType) FromRunStatusReasonType3(v RunStatusReasonType3) error
  • func (t *RunStatusReasonType) FromRunStatusReasonType4(v RunStatusReasonType4) error
  • func (t *RunStatusReasonType) FromRunStatusReasonType5(v RunStatusReasonType5) error
  • func (t RunStatusReasonType) MarshalJSON() ([]byte, error)
  • func (t *RunStatusReasonType) MergeRunStatusReasonType0(v RunStatusReasonType0) error
  • func (t *RunStatusReasonType) MergeRunStatusReasonType1(v RunStatusReasonType1) error
  • func (t *RunStatusReasonType) MergeRunStatusReasonType2(v RunStatusReasonType2) error
  • func (t *RunStatusReasonType) MergeRunStatusReasonType3(v RunStatusReasonType3) error
  • func (t *RunStatusReasonType) MergeRunStatusReasonType4(v RunStatusReasonType4) error
  • func (t *RunStatusReasonType) MergeRunStatusReasonType5(v RunStatusReasonType5) error
  • func (t *RunStatusReasonType) UnmarshalJSON(b []byte) error
• type RunStatusReasonType0
• type RunStatusReasonType1
• type RunStatusReasonType2
• type RunStatusReasonType3
• type RunStatusReasonType4
• type RunStatusReasonType5
• type Secret
• type StartRunJSONRequestBody
• type StartRunRequest
• type StartRunResp
  • func ParseStartRunResp(rsp *http.Response) (*StartRunResp, error)
  • func (r StartRunResp) Status() string
  • func (r StartRunResp) StatusCode() int
• type StartRunResponse
• type StreamEventsParams
• type StreamEventsResp
  • func ParseStreamEventsResp(rsp *http.Response) (*StreamEventsResp, error)
  • func (r StreamEventsResp) Status() string
  • func (r StreamEventsResp) StatusCode() int
• type Subscription
• type SubscriptionStatus
• type SubscriptionStatusReason
• type SubscriptionStatusReasonType
• type Task
• type Task2
• type TaskExecution
• type TaskExecutionState
  • func (t TaskExecutionState) AsTaskExecutionState0() (TaskExecutionState0, error)
  • func (t TaskExecutionState) AsTaskExecutionState1() (TaskExecutionState1, error)
  • func (t TaskExecutionState) AsTaskExecutionState2() (TaskExecutionState2, error)
  • func (t TaskExecutionState) AsTaskExecutionState3() (TaskExecutionState3, error)
  • func (t TaskExecutionState) AsTaskExecutionState4() (TaskExecutionState4, error)
  • func (t *TaskExecutionState) FromTaskExecutionState0(v TaskExecutionState0) error
  • func (t *TaskExecutionState) FromTaskExecutionState1(v TaskExecutionState1) error
  • func (t *TaskExecutionState) FromTaskExecutionState2(v TaskExecutionState2) error
  • func (t *TaskExecutionState) FromTaskExecutionState3(v TaskExecutionState3) error
  • func (t *TaskExecutionState) FromTaskExecutionState4(v TaskExecutionState4) error
  • func (t TaskExecutionState) MarshalJSON() ([]byte, error)
  • func (t *TaskExecutionState) MergeTaskExecutionState0(v TaskExecutionState0) error
  • func (t *TaskExecutionState) MergeTaskExecutionState1(v TaskExecutionState1) error
  • func (t *TaskExecutionState) MergeTaskExecutionState2(v TaskExecutionState2) error
  • func (t *TaskExecutionState) MergeTaskExecutionState3(v TaskExecutionState3) error
  • func (t *TaskExecutionState) MergeTaskExecutionState4(v TaskExecutionState4) error
  • func (t *TaskExecutionState) UnmarshalJSON(b []byte) error
• type TaskExecutionState0
• type TaskExecutionState1
• type TaskExecutionState2
• type TaskExecutionState3
• type TaskExecutionState4
• type TaskExecutionStatus
  • func (t TaskExecutionStatus) AsTaskExecutionStatus0() (TaskExecutionStatus0, error)
  • func (t TaskExecutionStatus) AsTaskExecutionStatus1() (TaskExecutionStatus1, error)
  • func (t TaskExecutionStatus) AsTaskExecutionStatus2() (TaskExecutionStatus2, error)
  • func (t TaskExecutionStatus) AsTaskExecutionStatus3() (TaskExecutionStatus3, error)
  • func (t TaskExecutionStatus) AsTaskExecutionStatus4() (TaskExecutionStatus4, error)
  • func (t *TaskExecutionStatus) FromTaskExecutionStatus0(v TaskExecutionStatus0) error
  • func (t *TaskExecutionStatus) FromTaskExecutionStatus1(v TaskExecutionStatus1) error
  • func (t *TaskExecutionStatus) FromTaskExecutionStatus2(v TaskExecutionStatus2) error
  • func (t *TaskExecutionStatus) FromTaskExecutionStatus3(v TaskExecutionStatus3) error
  • func (t *TaskExecutionStatus) FromTaskExecutionStatus4(v TaskExecutionStatus4) error
  • func (t TaskExecutionStatus) MarshalJSON() ([]byte, error)
  • func (t *TaskExecutionStatus) MergeTaskExecutionStatus0(v TaskExecutionStatus0) error
  • func (t *TaskExecutionStatus) MergeTaskExecutionStatus1(v TaskExecutionStatus1) error
  • func (t *TaskExecutionStatus) MergeTaskExecutionStatus2(v TaskExecutionStatus2) error
  • func (t *TaskExecutionStatus) MergeTaskExecutionStatus3(v TaskExecutionStatus3) error
  • func (t *TaskExecutionStatus) MergeTaskExecutionStatus4(v TaskExecutionStatus4) error
  • func (t *TaskExecutionStatus) UnmarshalJSON(b []byte) error
• type TaskExecutionStatus0
• type TaskExecutionStatus1
• type TaskExecutionStatus2
• type TaskExecutionStatus3
• type TaskExecutionStatus4
• type TaskExecutionStatusReason
• type TaskExecutionStatusReasonType
  • func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType0() (TaskExecutionStatusReasonType0, error)
  • func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType1() (TaskExecutionStatusReasonType1, error)
  • func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType2() (TaskExecutionStatusReasonType2, error)
  • func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType3() (TaskExecutionStatusReasonType3, error)
  • func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType4() (TaskExecutionStatusReasonType4, error)
  • func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType5() (TaskExecutionStatusReasonType5, error)
  • func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType0(v TaskExecutionStatusReasonType0) error
  • func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType1(v TaskExecutionStatusReasonType1) error
  • func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType2(v TaskExecutionStatusReasonType2) error
  • func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType3(v TaskExecutionStatusReasonType3) error
  • func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType4(v TaskExecutionStatusReasonType4) error
  • func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType5(v TaskExecutionStatusReasonType5) error
  • func (t TaskExecutionStatusReasonType) MarshalJSON() ([]byte, error)
  • func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType0(v TaskExecutionStatusReasonType0) error
  • func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType1(v TaskExecutionStatusReasonType1) error
  • func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType2(v TaskExecutionStatusReasonType2) error
  • func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType3(v TaskExecutionStatusReasonType3) error
  • func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType4(v TaskExecutionStatusReasonType4) error
  • func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType5(v TaskExecutionStatusReasonType5) error
  • func (t *TaskExecutionStatusReasonType) UnmarshalJSON(b []byte) error
• type TaskExecutionStatusReasonType0
• type TaskExecutionStatusReasonType1
• type TaskExecutionStatusReasonType2
• type TaskExecutionStatusReasonType3
• type TaskExecutionStatusReasonType4
• type TaskExecutionStatusReasonType5
• type Token
• type TokenType
  • func (t TokenType) AsTokenType0() (TokenType0, error)
  • func (t TokenType) AsTokenType1() (TokenType1, error)
  • func (t TokenType) AsTokenType2() (TokenType2, error)
  • func (t TokenType) AsTokenType3() (TokenType3, error)
  • func (t *TokenType) FromTokenType0(v TokenType0) error
  • func (t *TokenType) FromTokenType1(v TokenType1) error
  • func (t *TokenType) FromTokenType2(v TokenType2) error
  • func (t *TokenType) FromTokenType3(v TokenType3) error
  • func (t TokenType) MarshalJSON() ([]byte, error)
  • func (t *TokenType) MergeTokenType0(v TokenType0) error
  • func (t *TokenType) MergeTokenType1(v TokenType1) error
  • func (t *TokenType) MergeTokenType2(v TokenType2) error
  • func (t *TokenType) MergeTokenType3(v TokenType3) error
  • func (t *TokenType) UnmarshalJSON(b []byte) error
• type TokenType0
• type TokenType1
• type TokenType2
• type TokenType3
• type UninstallExtensionResp
  • func ParseUninstallExtensionResp(rsp *http.Response) (*UninstallExtensionResp, error)
  • func (r UninstallExtensionResp) Status() string
  • func (r UninstallExtensionResp) StatusCode() int
• type UpdateExtensionJSONRequestBody
• type UpdateExtensionRequest
• type UpdateExtensionResp
  • func ParseUpdateExtensionResp(rsp *http.Response) (*UpdateExtensionResp, error)
  • func (r UpdateExtensionResp) Status() string
  • func (r UpdateExtensionResp) StatusCode() int
• type UpdateNamespaceJSONRequestBody
• type UpdateNamespaceRequest
• type UpdateNamespaceResp
  • func ParseUpdateNamespaceResp(rsp *http.Response) (*UpdateNamespaceResp, error)
  • func (r UpdateNamespaceResp) Status() string
  • func (r UpdateNamespaceResp) StatusCode() int
• type UpdateNamespaceResponse
• type UpdatePipelineJSONRequestBody
• type UpdatePipelineRequest
• type UpdatePipelineResp
  • func ParseUpdatePipelineResp(rsp *http.Response) (*UpdatePipelineResp, error)
  • func (r UpdatePipelineResp) Status() string
  • func (r UpdatePipelineResp) StatusCode() int
• type UpdateSubscriptionJSONRequestBody
• type UpdateSubscriptionRequest
• type UpdateSubscriptionResp
  • func ParseUpdateSubscriptionResp(rsp *http.Response) (*UpdateSubscriptionResp, error)
  • func (r UpdateSubscriptionResp) Status() string
  • func (r UpdateSubscriptionResp) StatusCode() int
• type UpdateSubscriptionStatus
• type UpdateTokenJSONRequestBody
• type UpdateTokenRequest
• type UpdateTokenResp
  • func ParseUpdateTokenResp(rsp *http.Response) (*UpdateTokenResp, error)
  • func (r UpdateTokenResp) Status() string
  • func (r UpdateTokenResp) StatusCode() int
• type Variable
• type VariableSource
  • func (t VariableSource) AsVariableSource0() (VariableSource0, error)
  • func (t VariableSource) AsVariableSource1() (VariableSource1, error)
  • func (t VariableSource) AsVariableSource2() (VariableSource2, error)
  • func (t VariableSource) AsVariableSource3() (VariableSource3, error)
  • func (t VariableSource) AsVariableSource4() (VariableSource4, error)
  • func (t *VariableSource) FromVariableSource0(v VariableSource0) error
  • func (t *VariableSource) FromVariableSource1(v VariableSource1) error
  • func (t *VariableSource) FromVariableSource2(v VariableSource2) error
  • func (t *VariableSource) FromVariableSource3(v VariableSource3) error
  • func (t *VariableSource) FromVariableSource4(v VariableSource4) error
  • func (t VariableSource) MarshalJSON() ([]byte, error)
  • func (t *VariableSource) MergeVariableSource0(v VariableSource0) error
  • func (t *VariableSource) MergeVariableSource1(v VariableSource1) error
  • func (t *VariableSource) MergeVariableSource2(v VariableSource2) error
  • func (t *VariableSource) MergeVariableSource3(v VariableSource3) error
  • func (t *VariableSource) MergeVariableSource4(v VariableSource4) error
  • func (t *VariableSource) UnmarshalJSON(b []byte) error
• type VariableSource0
• type VariableSource1
• type VariableSource2
• type VariableSource3
• type VariableSource4
• type WhoAmIResponse
• type WhoamiResp
  • func ParseWhoamiResp(rsp *http.Response) (*WhoamiResp, error)
  • func (r WhoamiResp) Status() string
  • func (r WhoamiResp) StatusCode() int

Functions

func NewAttachTaskExecutionRequest

func NewAttachTaskExecutionRequest(server string, namespaceId string, pipelineId string, runId uint64, taskId string, params *AttachTaskExecutionParams) (*http.Request, error)

NewAttachTaskExecutionRequest generates requests for AttachTaskExecution

func NewCancelRunRequest

func NewCancelRunRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)

NewCancelRunRequest generates requests for CancelRun

func NewCancelTaskExecutionRequest

func NewCancelTaskExecutionRequest(server string, namespaceId string, pipelineId string, runId uint64, taskId string, params *CancelTaskExecutionParams) (*http.Request, error)

NewCancelTaskExecutionRequest generates requests for CancelTaskExecution

func NewCreateBootstrapTokenRequest

func NewCreateBootstrapTokenRequest(server string) (*http.Request, error)

NewCreateBootstrapTokenRequest generates requests for CreateBootstrapToken

func NewCreateNamespaceRequest

func NewCreateNamespaceRequest(server string, body CreateNamespaceJSONRequestBody) (*http.Request, error)

NewCreateNamespaceRequest calls the generic CreateNamespace builder with application/json body

func NewCreateNamespaceRequestWithBody

func NewCreateNamespaceRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewCreateNamespaceRequestWithBody generates requests for CreateNamespace with any type of body

func NewCreateSubscriptionRequest

func NewCreateSubscriptionRequest(server string, namespaceId string, pipelineId string, body CreateSubscriptionJSONRequestBody) (*http.Request, error)

NewCreateSubscriptionRequest calls the generic CreateSubscription builder with application/json body

func NewCreateSubscriptionRequestWithBody

func NewCreateSubscriptionRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, body io.Reader) (*http.Request, error)

NewCreateSubscriptionRequestWithBody generates requests for CreateSubscription with any type of body

func NewCreateTokenRequest

func NewCreateTokenRequest(server string, body CreateTokenJSONRequestBody) (*http.Request, error)

NewCreateTokenRequest calls the generic CreateToken builder with application/json body

func NewCreateTokenRequestWithBody

func NewCreateTokenRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewCreateTokenRequestWithBody generates requests for CreateToken with any type of body

func NewDeleteConfigRequest

func NewDeleteConfigRequest(server string, namespaceId string, pipelineId string, version int64) (*http.Request, error)

NewDeleteConfigRequest generates requests for DeleteConfig

func NewDeleteEventRequest

func NewDeleteEventRequest(server string, eventId string) (*http.Request, error)

NewDeleteEventRequest generates requests for DeleteEvent

func NewDeleteGlobalSecretRequest

func NewDeleteGlobalSecretRequest(server string, key string) (*http.Request, error)

NewDeleteGlobalSecretRequest generates requests for DeleteGlobalSecret

func NewDeleteLogsRequest

func NewDeleteLogsRequest(server string, namespaceId string, pipelineId string, runId uint64, taskId string) (*http.Request, error)

NewDeleteLogsRequest generates requests for DeleteLogs

func NewDeleteNamespaceRequest

func NewDeleteNamespaceRequest(server string, namespaceId string) (*http.Request, error)

NewDeleteNamespaceRequest generates requests for DeleteNamespace

func NewDeletePipelineObjectRequest

func NewDeletePipelineObjectRequest(server string, namespaceId string, pipelineId string, key string) (*http.Request, error)

NewDeletePipelineObjectRequest generates requests for DeletePipelineObject

func NewDeletePipelineRequest

func NewDeletePipelineRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)

NewDeletePipelineRequest generates requests for DeletePipeline

func NewDeletePipelineSecretRequest

func NewDeletePipelineSecretRequest(server string, namespaceId string, pipelineId string, key string) (*http.Request, error)

NewDeletePipelineSecretRequest generates requests for DeletePipelineSecret

func NewDeleteRunObjectRequest

func NewDeleteRunObjectRequest(server string, namespaceId string, pipelineId string, runId uint64, key string) (*http.Request, error)

NewDeleteRunObjectRequest generates requests for DeleteRunObject

func NewDeleteSubscriptionRequest

func NewDeleteSubscriptionRequest(server string, namespaceId string, pipelineId string, extensionId string, subscriptionId string) (*http.Request, error)

NewDeleteSubscriptionRequest generates requests for DeleteSubscription

func NewDeleteTokenRequest

func NewDeleteTokenRequest(server string, id string) (*http.Request, error)

NewDeleteTokenRequest generates requests for DeleteToken

func NewDeployConfigRequest

func NewDeployConfigRequest(server string, namespaceId string, pipelineId string, version int64) (*http.Request, error)

NewDeployConfigRequest generates requests for DeployConfig

func NewGetConfigRequest

func NewGetConfigRequest(server string, namespaceId string, pipelineId string, version int64) (*http.Request, error)

NewGetConfigRequest generates requests for GetConfig

func NewGetDeploymentRequest

func NewGetDeploymentRequest(server string, namespaceId string, pipelineId string, deploymentId uint64) (*http.Request, error)

NewGetDeploymentRequest generates requests for GetDeployment

func NewGetEventRequest

func NewGetEventRequest(server string, eventId string) (*http.Request, error)

NewGetEventRequest generates requests for GetEvent

func NewGetExtensionLogsRequest

func NewGetExtensionLogsRequest(server string, extensionId string) (*http.Request, error)

NewGetExtensionLogsRequest generates requests for GetExtensionLogs

func NewGetExtensionRequest

func NewGetExtensionRequest(server string, extensionId string) (*http.Request, error)

NewGetExtensionRequest generates requests for GetExtension

func NewGetGlobalSecretRequest

func NewGetGlobalSecretRequest(server string, key string, params *GetGlobalSecretParams) (*http.Request, error)

NewGetGlobalSecretRequest generates requests for GetGlobalSecret

func NewGetLogsRequest

func NewGetLogsRequest(server string, namespaceId string, pipelineId string, runId uint64, taskId string) (*http.Request, error)

NewGetLogsRequest generates requests for GetLogs

func NewGetMetadataRequest

func NewGetMetadataRequest(server string) (*http.Request, error)

NewGetMetadataRequest generates requests for GetMetadata

func NewGetNamespaceRequest

func NewGetNamespaceRequest(server string, namespaceId string) (*http.Request, error)

NewGetNamespaceRequest generates requests for GetNamespace

func NewGetPipelineObjectRequest

func NewGetPipelineObjectRequest(server string, namespaceId string, pipelineId string, key string) (*http.Request, error)

NewGetPipelineObjectRequest generates requests for GetPipelineObject

func NewGetPipelineRequest

func NewGetPipelineRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)

NewGetPipelineRequest generates requests for GetPipeline

func NewGetPipelineSecretRequest

func NewGetPipelineSecretRequest(server string, namespaceId string, pipelineId string, key string, params *GetPipelineSecretParams) (*http.Request, error)

NewGetPipelineSecretRequest generates requests for GetPipelineSecret

func NewGetRunObjectRequest

func NewGetRunObjectRequest(server string, namespaceId string, pipelineId string, runId uint64, key string) (*http.Request, error)

NewGetRunObjectRequest generates requests for GetRunObject

func NewGetRunRequest

func NewGetRunRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)

NewGetRunRequest generates requests for GetRun

func NewGetSubscriptionRequest

func NewGetSubscriptionRequest(server string, namespaceId string, pipelineId string, extensionId string, subscriptionId string) (*http.Request, error)

NewGetSubscriptionRequest generates requests for GetSubscription

func NewGetTaskExecutionRequest

func NewGetTaskExecutionRequest(server string, namespaceId string, pipelineId string, runId uint64, taskId string) (*http.Request, error)

NewGetTaskExecutionRequest generates requests for GetTaskExecution

func NewGetTokenByIdRequest

func NewGetTokenByIdRequest(server string, id string) (*http.Request, error)

NewGetTokenByIdRequest generates requests for GetTokenById

func NewInstallExtensionRequest

func NewInstallExtensionRequest(server string, body InstallExtensionJSONRequestBody) (*http.Request, error)

NewInstallExtensionRequest calls the generic InstallExtension builder with application/json body

func NewInstallExtensionRequestWithBody

func NewInstallExtensionRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewInstallExtensionRequestWithBody generates requests for InstallExtension with any type of body

func NewListConfigsRequest

func NewListConfigsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)

NewListConfigsRequest generates requests for ListConfigs

func NewListDeploymentsRequest

func NewListDeploymentsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)

NewListDeploymentsRequest generates requests for ListDeployments

func NewListExtensionsRequest

func NewListExtensionsRequest(server string) (*http.Request, error)

NewListExtensionsRequest generates requests for ListExtensions

func NewListGlobalSecretsRequest

func NewListGlobalSecretsRequest(server string) (*http.Request, error)

NewListGlobalSecretsRequest generates requests for ListGlobalSecrets

func NewListNamespacesRequest

func NewListNamespacesRequest(server string) (*http.Request, error)

NewListNamespacesRequest generates requests for ListNamespaces

func NewListPipelineObjectsRequest

func NewListPipelineObjectsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)

NewListPipelineObjectsRequest generates requests for ListPipelineObjects

func NewListPipelineSecretsRequest

func NewListPipelineSecretsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)

NewListPipelineSecretsRequest generates requests for ListPipelineSecrets

func NewListPipelinesRequest

func NewListPipelinesRequest(server string, namespaceId string) (*http.Request, error)

NewListPipelinesRequest generates requests for ListPipelines

func NewListRunObjectsRequest

func NewListRunObjectsRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)

NewListRunObjectsRequest generates requests for ListRunObjects

func NewListRunsRequest

func NewListRunsRequest(server string, namespaceId string, pipelineId string, params *ListRunsParams) (*http.Request, error)

NewListRunsRequest generates requests for ListRuns

func NewListSubscriptionsRequest

func NewListSubscriptionsRequest(server string, namespaceId string, pipelineId string) (*http.Request, error)

NewListSubscriptionsRequest generates requests for ListSubscriptions

func NewListTaskExecutionsRequest

func NewListTaskExecutionsRequest(server string, namespaceId string, pipelineId string, runId uint64) (*http.Request, error)

NewListTaskExecutionsRequest generates requests for ListTaskExecutions

func NewListTokensRequest

func NewListTokensRequest(server string) (*http.Request, error)

NewListTokensRequest generates requests for ListTokens

func NewPutGlobalSecretRequest

func NewPutGlobalSecretRequest(server string, body PutGlobalSecretJSONRequestBody) (*http.Request, error)

NewPutGlobalSecretRequest calls the generic PutGlobalSecret builder with application/json body

func NewPutGlobalSecretRequestWithBody

func NewPutGlobalSecretRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

NewPutGlobalSecretRequestWithBody generates requests for PutGlobalSecret with any type of body

func NewPutPipelineObjectRequest

func NewPutPipelineObjectRequest(server string, namespaceId string, pipelineId string, body PutPipelineObjectJSONRequestBody) (*http.Request, error)

NewPutPipelineObjectRequest calls the generic PutPipelineObject builder with application/json body

func NewPutPipelineObjectRequestWithBody

func NewPutPipelineObjectRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, body io.Reader) (*http.Request, error)

NewPutPipelineObjectRequestWithBody generates requests for PutPipelineObject with any type of body

func NewPutPipelineSecretRequest

func NewPutPipelineSecretRequest(server string, namespaceId string, pipelineId string, body PutPipelineSecretJSONRequestBody) (*http.Request, error)

NewPutPipelineSecretRequest calls the generic PutPipelineSecret builder with application/json body

func NewPutPipelineSecretRequestWithBody

func NewPutPipelineSecretRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, body io.Reader) (*http.Request, error)

NewPutPipelineSecretRequestWithBody generates requests for PutPipelineSecret with any type of body

func NewPutRunObjectRequest

func NewPutRunObjectRequest(server string, namespaceId string, pipelineId string, runId uint64, body PutRunObjectJSONRequestBody) (*http.Request, error)

NewPutRunObjectRequest calls the generic PutRunObject builder with application/json body

func NewPutRunObjectRequestWithBody

func NewPutRunObjectRequestWithBody(server string, namespaceId string, pipelineId string, runId uint64, contentType string, body io.Reader) (*http.Request, error)

NewPutRunObjectRequestWithBody generates requests for PutRunObject with any type of body

func NewRegisterConfigRequest

func NewRegisterConfigRequest(server string, namespaceId string, pipelineId string, body RegisterConfigJSONRequestBody) (*http.Request, error)

NewRegisterConfigRequest calls the generic RegisterConfig builder with application/json body

func NewRegisterConfigRequestWithBody

func NewRegisterConfigRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, body io.Reader) (*http.Request, error)

NewRegisterConfigRequestWithBody generates requests for RegisterConfig with any type of body

func NewStartRunRequest

func NewStartRunRequest(server string, namespaceId string, pipelineId string, body StartRunJSONRequestBody) (*http.Request, error)

NewStartRunRequest calls the generic StartRun builder with application/json body

func NewStartRunRequestWithBody

func NewStartRunRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, body io.Reader) (*http.Request, error)

NewStartRunRequestWithBody generates requests for StartRun with any type of body

func NewStreamEventsRequest

func NewStreamEventsRequest(server string, params *StreamEventsParams) (*http.Request, error)

NewStreamEventsRequest generates requests for StreamEvents

func NewUninstallExtensionRequest

func NewUninstallExtensionRequest(server string, extensionId string) (*http.Request, error)

NewUninstallExtensionRequest generates requests for UninstallExtension

func NewUpdateExtensionRequest

func NewUpdateExtensionRequest(server string, extensionId string, body UpdateExtensionJSONRequestBody) (*http.Request, error)

NewUpdateExtensionRequest calls the generic UpdateExtension builder with application/json body

func NewUpdateExtensionRequestWithBody

func NewUpdateExtensionRequestWithBody(server string, extensionId string, contentType string, body io.Reader) (*http.Request, error)

NewUpdateExtensionRequestWithBody generates requests for UpdateExtension with any type of body

func NewUpdateNamespaceRequest

func NewUpdateNamespaceRequest(server string, namespaceId string, body UpdateNamespaceJSONRequestBody) (*http.Request, error)

NewUpdateNamespaceRequest calls the generic UpdateNamespace builder with application/json body

func NewUpdateNamespaceRequestWithBody

func NewUpdateNamespaceRequestWithBody(server string, namespaceId string, contentType string, body io.Reader) (*http.Request, error)

NewUpdateNamespaceRequestWithBody generates requests for UpdateNamespace with any type of body

func NewUpdatePipelineRequest

func NewUpdatePipelineRequest(server string, namespaceId string, pipelineId string, body UpdatePipelineJSONRequestBody) (*http.Request, error)

NewUpdatePipelineRequest calls the generic UpdatePipeline builder with application/json body

func NewUpdatePipelineRequestWithBody

func NewUpdatePipelineRequestWithBody(server string, namespaceId string, pipelineId string, contentType string, body io.Reader) (*http.Request, error)

NewUpdatePipelineRequestWithBody generates requests for UpdatePipeline with any type of body

func NewUpdateSubscriptionRequest

func NewUpdateSubscriptionRequest(server string, namespaceId string, pipelineId string, extensionId string, subscriptionId string, body UpdateSubscriptionJSONRequestBody) (*http.Request, error)

NewUpdateSubscriptionRequest calls the generic UpdateSubscription builder with application/json body

func NewUpdateSubscriptionRequestWithBody

func NewUpdateSubscriptionRequestWithBody(server string, namespaceId string, pipelineId string, extensionId string, subscriptionId string, contentType string, body io.Reader) (*http.Request, error)

NewUpdateSubscriptionRequestWithBody generates requests for UpdateSubscription with any type of body

func NewUpdateTokenRequest

func NewUpdateTokenRequest(server string, id string, body UpdateTokenJSONRequestBody) (*http.Request, error)

NewUpdateTokenRequest calls the generic UpdateToken builder with application/json body

func NewUpdateTokenRequestWithBody

func NewUpdateTokenRequestWithBody(server string, id string, contentType string, body io.Reader) (*http.Request, error)

NewUpdateTokenRequestWithBody generates requests for UpdateToken with any type of body

func NewWhoamiRequest

func NewWhoamiRequest(server string) (*http.Request, error)

NewWhoamiRequest generates requests for Whoami

Types

type AttachTaskExecutionParams

type AttachTaskExecutionParams struct {
	Command string `form:"command" json:"command"`
}

AttachTaskExecutionParams defines parameters for AttachTaskExecution.

type AttachTaskExecutionResp

type AttachTaskExecutionResp struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseAttachTaskExecutionResp

func ParseAttachTaskExecutionResp(rsp *http.Response) (*AttachTaskExecutionResp, error)

ParseAttachTaskExecutionResp parses an HTTP response from a AttachTaskExecutionWithResponse call

func (AttachTaskExecutionResp) Status

func (r AttachTaskExecutionResp) Status() string

Status returns HTTPResponse.Status

func (AttachTaskExecutionResp) StatusCode

func (r AttachTaskExecutionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CancelRunResp

type CancelRunResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseCancelRunResp

func ParseCancelRunResp(rsp *http.Response) (*CancelRunResp, error)

ParseCancelRunResp parses an HTTP response from a CancelRunWithResponse call

func (CancelRunResp) Status

func (r CancelRunResp) Status() string

Status returns HTTPResponse.Status

func (CancelRunResp) StatusCode

func (r CancelRunResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CancelTaskExecutionParams

type CancelTaskExecutionParams struct {
	// WaitFor Period of time to wait the task before forcing it to cancel. 0 means send SIGKILL instantly.
	WaitFor uint64 `form:"wait_for" json:"wait_for"`
}

CancelTaskExecutionParams defines parameters for CancelTaskExecution.

type CancelTaskExecutionResp

type CancelTaskExecutionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseCancelTaskExecutionResp

func ParseCancelTaskExecutionResp(rsp *http.Response) (*CancelTaskExecutionResp, error)

ParseCancelTaskExecutionResp parses an HTTP response from a CancelTaskExecutionWithResponse call

func (CancelTaskExecutionResp) Status

func (r CancelTaskExecutionResp) Status() string

Status returns HTTPResponse.Status

func (CancelTaskExecutionResp) StatusCode

func (r CancelTaskExecutionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type Client

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

Client which conforms to the OpenAPI3 specification for this service.

func NewClient

func NewClient(server string, opts ...ClientOption) (*Client, error)

Creates a new Client, with reasonable defaults

func NewClientWithHeaders

func NewClientWithHeaders(host, token string, apiVersion GoferAPIVersion) (*Client, error)

Creates a new client for the main Gofer API with all the required headers.

func (*Client) AttachTaskExecution

func (c *Client) AttachTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *AttachTaskExecutionParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CancelRun

func (c *Client) CancelRun(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CancelTaskExecution

func (c *Client) CancelTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *CancelTaskExecutionParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateBootstrapToken

func (c *Client) CreateBootstrapToken(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateNamespace

func (c *Client) CreateNamespace(ctx context.Context, body CreateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateNamespaceWithBody

func (c *Client) CreateNamespaceWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateSubscription

func (c *Client) CreateSubscription(ctx context.Context, namespaceId string, pipelineId string, body CreateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateSubscriptionWithBody

func (c *Client) CreateSubscriptionWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateToken

func (c *Client) CreateToken(ctx context.Context, body CreateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CreateTokenWithBody

func (c *Client) CreateTokenWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteConfig

func (c *Client) DeleteConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteEvent

func (c *Client) DeleteEvent(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteGlobalSecret

func (c *Client) DeleteGlobalSecret(ctx context.Context, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteLogs

func (c *Client) DeleteLogs(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteNamespace

func (c *Client) DeleteNamespace(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeletePipeline

func (c *Client) DeletePipeline(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeletePipelineObject

func (c *Client) DeletePipelineObject(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeletePipelineSecret

func (c *Client) DeletePipelineSecret(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteRunObject

func (c *Client) DeleteRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteSubscription

func (c *Client) DeleteSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeleteToken

func (c *Client) DeleteToken(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) DeployConfig

func (c *Client) DeployConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetConfig

func (c *Client) GetConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetDeployment

func (c *Client) GetDeployment(ctx context.Context, namespaceId string, pipelineId string, deploymentId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetEvent

func (c *Client) GetEvent(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetExtension

func (c *Client) GetExtension(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetExtensionLogs

func (c *Client) GetExtensionLogs(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetGlobalSecret

func (c *Client) GetGlobalSecret(ctx context.Context, key string, params *GetGlobalSecretParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetLogs

func (c *Client) GetLogs(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetMetadata

func (c *Client) GetMetadata(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetNamespace

func (c *Client) GetNamespace(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetPipeline

func (c *Client) GetPipeline(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetPipelineObject

func (c *Client) GetPipelineObject(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetPipelineSecret

func (c *Client) GetPipelineSecret(ctx context.Context, namespaceId string, pipelineId string, key string, params *GetPipelineSecretParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetRun

func (c *Client) GetRun(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetRunObject

func (c *Client) GetRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetSubscription

func (c *Client) GetSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetTaskExecution

func (c *Client) GetTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetTokenById

func (c *Client) GetTokenById(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) InstallExtension

func (c *Client) InstallExtension(ctx context.Context, body InstallExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) InstallExtensionWithBody

func (c *Client) InstallExtensionWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListConfigs

func (c *Client) ListConfigs(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListDeployments

func (c *Client) ListDeployments(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListExtensions

func (c *Client) ListExtensions(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListGlobalSecrets

func (c *Client) ListGlobalSecrets(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListNamespaces

func (c *Client) ListNamespaces(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListPipelineObjects

func (c *Client) ListPipelineObjects(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListPipelineSecrets

func (c *Client) ListPipelineSecrets(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListPipelines

func (c *Client) ListPipelines(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListRunObjects

func (c *Client) ListRunObjects(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListRuns

func (c *Client) ListRuns(ctx context.Context, namespaceId string, pipelineId string, params *ListRunsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListSubscriptions

func (c *Client) ListSubscriptions(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListTaskExecutions

func (c *Client) ListTaskExecutions(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListTokens

func (c *Client) ListTokens(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutGlobalSecret

func (c *Client) PutGlobalSecret(ctx context.Context, body PutGlobalSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutGlobalSecretWithBody

func (c *Client) PutGlobalSecretWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutPipelineObject

func (c *Client) PutPipelineObject(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutPipelineObjectWithBody

func (c *Client) PutPipelineObjectWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutPipelineSecret

func (c *Client) PutPipelineSecret(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutPipelineSecretWithBody

func (c *Client) PutPipelineSecretWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutRunObject

func (c *Client) PutRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, body PutRunObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutRunObjectWithBody

func (c *Client) PutRunObjectWithBody(ctx context.Context, namespaceId string, pipelineId string, runId uint64, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RegisterConfig

func (c *Client) RegisterConfig(ctx context.Context, namespaceId string, pipelineId string, body RegisterConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RegisterConfigWithBody

func (c *Client) RegisterConfigWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) StartRun

func (c *Client) StartRun(ctx context.Context, namespaceId string, pipelineId string, body StartRunJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) StartRunWithBody

func (c *Client) StartRunWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) StreamEvents

func (c *Client) StreamEvents(ctx context.Context, params *StreamEventsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UninstallExtension

func (c *Client) UninstallExtension(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateExtension

func (c *Client) UpdateExtension(ctx context.Context, extensionId string, body UpdateExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateExtensionWithBody

func (c *Client) UpdateExtensionWithBody(ctx context.Context, extensionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateNamespace

func (c *Client) UpdateNamespace(ctx context.Context, namespaceId string, body UpdateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateNamespaceWithBody

func (c *Client) UpdateNamespaceWithBody(ctx context.Context, namespaceId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdatePipeline

func (c *Client) UpdatePipeline(ctx context.Context, namespaceId string, pipelineId string, body UpdatePipelineJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdatePipelineWithBody

func (c *Client) UpdatePipelineWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateSubscription

func (c *Client) UpdateSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, body UpdateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateSubscriptionWithBody

func (c *Client) UpdateSubscriptionWithBody(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateToken

func (c *Client) UpdateToken(ctx context.Context, id string, body UpdateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpdateTokenWithBody

func (c *Client) UpdateTokenWithBody(ctx context.Context, id string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) Whoami

func (c *Client) Whoami(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

type ClientInterface

type ClientInterface interface {
	// StreamEvents request
	StreamEvents(ctx context.Context, params *StreamEventsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteEvent request
	DeleteEvent(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetEvent request
	GetEvent(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListExtensions request
	ListExtensions(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// InstallExtensionWithBody request with any body
	InstallExtensionWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	InstallExtension(ctx context.Context, body InstallExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UninstallExtension request
	UninstallExtension(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetExtension request
	GetExtension(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateExtensionWithBody request with any body
	UpdateExtensionWithBody(ctx context.Context, extensionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateExtension(ctx context.Context, extensionId string, body UpdateExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetExtensionLogs request
	GetExtensionLogs(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListNamespaces request
	ListNamespaces(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateNamespaceWithBody request with any body
	CreateNamespaceWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CreateNamespace(ctx context.Context, body CreateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteNamespace request
	DeleteNamespace(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetNamespace request
	GetNamespace(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateNamespaceWithBody request with any body
	UpdateNamespaceWithBody(ctx context.Context, namespaceId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateNamespace(ctx context.Context, namespaceId string, body UpdateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListPipelines request
	ListPipelines(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeletePipeline request
	DeletePipeline(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetPipeline request
	GetPipeline(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdatePipelineWithBody request with any body
	UpdatePipelineWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdatePipeline(ctx context.Context, namespaceId string, pipelineId string, body UpdatePipelineJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListConfigs request
	ListConfigs(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RegisterConfigWithBody request with any body
	RegisterConfigWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	RegisterConfig(ctx context.Context, namespaceId string, pipelineId string, body RegisterConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteConfig request
	DeleteConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetConfig request
	GetConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeployConfig request
	DeployConfig(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListDeployments request
	ListDeployments(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetDeployment request
	GetDeployment(ctx context.Context, namespaceId string, pipelineId string, deploymentId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListPipelineObjects request
	ListPipelineObjects(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutPipelineObjectWithBody request with any body
	PutPipelineObjectWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutPipelineObject(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeletePipelineObject request
	DeletePipelineObject(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetPipelineObject request
	GetPipelineObject(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListRuns request
	ListRuns(ctx context.Context, namespaceId string, pipelineId string, params *ListRunsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// StartRunWithBody request with any body
	StartRunWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	StartRun(ctx context.Context, namespaceId string, pipelineId string, body StartRunJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CancelRun request
	CancelRun(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetRun request
	GetRun(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListRunObjects request
	ListRunObjects(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutRunObjectWithBody request with any body
	PutRunObjectWithBody(ctx context.Context, namespaceId string, pipelineId string, runId uint64, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, body PutRunObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteRunObject request
	DeleteRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetRunObject request
	GetRunObject(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListTaskExecutions request
	ListTaskExecutions(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CancelTaskExecution request
	CancelTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *CancelTaskExecutionParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetTaskExecution request
	GetTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AttachTaskExecution request
	AttachTaskExecution(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *AttachTaskExecutionParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteLogs request
	DeleteLogs(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetLogs request
	GetLogs(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListPipelineSecrets request
	ListPipelineSecrets(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutPipelineSecretWithBody request with any body
	PutPipelineSecretWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutPipelineSecret(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeletePipelineSecret request
	DeletePipelineSecret(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetPipelineSecret request
	GetPipelineSecret(ctx context.Context, namespaceId string, pipelineId string, key string, params *GetPipelineSecretParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListSubscriptions request
	ListSubscriptions(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateSubscriptionWithBody request with any body
	CreateSubscriptionWithBody(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CreateSubscription(ctx context.Context, namespaceId string, pipelineId string, body CreateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteSubscription request
	DeleteSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetSubscription request
	GetSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateSubscriptionWithBody request with any body
	UpdateSubscriptionWithBody(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateSubscription(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, body UpdateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListGlobalSecrets request
	ListGlobalSecrets(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutGlobalSecretWithBody request with any body
	PutGlobalSecretWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutGlobalSecret(ctx context.Context, body PutGlobalSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteGlobalSecret request
	DeleteGlobalSecret(ctx context.Context, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetGlobalSecret request
	GetGlobalSecret(ctx context.Context, key string, params *GetGlobalSecretParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetMetadata request
	GetMetadata(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListTokens request
	ListTokens(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateTokenWithBody request with any body
	CreateTokenWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CreateToken(ctx context.Context, body CreateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CreateBootstrapToken request
	CreateBootstrapToken(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// Whoami request
	Whoami(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// DeleteToken request
	DeleteToken(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetTokenById request
	GetTokenById(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpdateTokenWithBody request with any body
	UpdateTokenWithBody(ctx context.Context, id string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpdateToken(ctx context.Context, id string, body UpdateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
}

The interface specification for the client above.

type ClientOption

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient

func WithHTTPClient(doer HttpRequestDoer) ClientOption

WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.

func WithRequestEditorFn

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

type ClientWithResponses

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func NewClientWithResponses

func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling

func (*ClientWithResponses) AttachTaskExecutionWithResponse

func (c *ClientWithResponses) AttachTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *AttachTaskExecutionParams, reqEditors ...RequestEditorFn) (*AttachTaskExecutionResp, error)

AttachTaskExecutionWithResponse request returning *AttachTaskExecutionResp

func (*ClientWithResponses) CancelRunWithResponse

func (c *ClientWithResponses) CancelRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*CancelRunResp, error)

CancelRunWithResponse request returning *CancelRunResp

func (*ClientWithResponses) CancelTaskExecutionWithResponse

func (c *ClientWithResponses) CancelTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *CancelTaskExecutionParams, reqEditors ...RequestEditorFn) (*CancelTaskExecutionResp, error)

CancelTaskExecutionWithResponse request returning *CancelTaskExecutionResp

func (*ClientWithResponses) CreateBootstrapTokenWithResponse

func (c *ClientWithResponses) CreateBootstrapTokenWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*CreateBootstrapTokenResp, error)

CreateBootstrapTokenWithResponse request returning *CreateBootstrapTokenResp

func (*ClientWithResponses) CreateNamespaceWithBodyWithResponse

func (c *ClientWithResponses) CreateNamespaceWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateNamespaceResp, error)

CreateNamespaceWithBodyWithResponse request with arbitrary body returning *CreateNamespaceResp

func (*ClientWithResponses) CreateNamespaceWithResponse

func (c *ClientWithResponses) CreateNamespaceWithResponse(ctx context.Context, body CreateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateNamespaceResp, error)

func (*ClientWithResponses) CreateSubscriptionWithBodyWithResponse

func (c *ClientWithResponses) CreateSubscriptionWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateSubscriptionResp, error)

CreateSubscriptionWithBodyWithResponse request with arbitrary body returning *CreateSubscriptionResp

func (*ClientWithResponses) CreateSubscriptionWithResponse

func (c *ClientWithResponses) CreateSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, body CreateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateSubscriptionResp, error)

func (*ClientWithResponses) CreateTokenWithBodyWithResponse

func (c *ClientWithResponses) CreateTokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateTokenResp, error)

CreateTokenWithBodyWithResponse request with arbitrary body returning *CreateTokenResp

func (*ClientWithResponses) CreateTokenWithResponse

func (c *ClientWithResponses) CreateTokenWithResponse(ctx context.Context, body CreateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateTokenResp, error)

func (*ClientWithResponses) DeleteConfigWithResponse

func (c *ClientWithResponses) DeleteConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*DeleteConfigResp, error)

DeleteConfigWithResponse request returning *DeleteConfigResp

func (*ClientWithResponses) DeleteEventWithResponse

func (c *ClientWithResponses) DeleteEventWithResponse(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*DeleteEventResp, error)

DeleteEventWithResponse request returning *DeleteEventResp

func (*ClientWithResponses) DeleteGlobalSecretWithResponse

func (c *ClientWithResponses) DeleteGlobalSecretWithResponse(ctx context.Context, key string, reqEditors ...RequestEditorFn) (*DeleteGlobalSecretResp, error)

DeleteGlobalSecretWithResponse request returning *DeleteGlobalSecretResp

func (*ClientWithResponses) DeleteLogsWithResponse

func (c *ClientWithResponses) DeleteLogsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*DeleteLogsResp, error)

DeleteLogsWithResponse request returning *DeleteLogsResp

func (*ClientWithResponses) DeleteNamespaceWithResponse

func (c *ClientWithResponses) DeleteNamespaceWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*DeleteNamespaceResp, error)

DeleteNamespaceWithResponse request returning *DeleteNamespaceResp

func (*ClientWithResponses) DeletePipelineObjectWithResponse

func (c *ClientWithResponses) DeletePipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*DeletePipelineObjectResp, error)

DeletePipelineObjectWithResponse request returning *DeletePipelineObjectResp

func (*ClientWithResponses) DeletePipelineSecretWithResponse

func (c *ClientWithResponses) DeletePipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*DeletePipelineSecretResp, error)

DeletePipelineSecretWithResponse request returning *DeletePipelineSecretResp

func (*ClientWithResponses) DeletePipelineWithResponse

func (c *ClientWithResponses) DeletePipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*DeletePipelineResp, error)

DeletePipelineWithResponse request returning *DeletePipelineResp

func (*ClientWithResponses) DeleteRunObjectWithResponse

func (c *ClientWithResponses) DeleteRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*DeleteRunObjectResp, error)

DeleteRunObjectWithResponse request returning *DeleteRunObjectResp

func (*ClientWithResponses) DeleteSubscriptionWithResponse

func (c *ClientWithResponses) DeleteSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*DeleteSubscriptionResp, error)

DeleteSubscriptionWithResponse request returning *DeleteSubscriptionResp

func (*ClientWithResponses) DeleteTokenWithResponse

func (c *ClientWithResponses) DeleteTokenWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*DeleteTokenResp, error)

DeleteTokenWithResponse request returning *DeleteTokenResp

func (*ClientWithResponses) DeployConfigWithResponse

func (c *ClientWithResponses) DeployConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*DeployConfigResp, error)

DeployConfigWithResponse request returning *DeployConfigResp

func (*ClientWithResponses) GetConfigWithResponse

func (c *ClientWithResponses) GetConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*GetConfigResp, error)

GetConfigWithResponse request returning *GetConfigResp

func (*ClientWithResponses) GetDeploymentWithResponse

func (c *ClientWithResponses) GetDeploymentWithResponse(ctx context.Context, namespaceId string, pipelineId string, deploymentId uint64, reqEditors ...RequestEditorFn) (*GetDeploymentResp, error)

GetDeploymentWithResponse request returning *GetDeploymentResp

func (*ClientWithResponses) GetEventWithResponse

func (c *ClientWithResponses) GetEventWithResponse(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*GetEventResp, error)

GetEventWithResponse request returning *GetEventResp

func (*ClientWithResponses) GetExtensionLogsWithResponse

func (c *ClientWithResponses) GetExtensionLogsWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*GetExtensionLogsResp, error)

GetExtensionLogsWithResponse request returning *GetExtensionLogsResp

func (*ClientWithResponses) GetExtensionWithResponse

func (c *ClientWithResponses) GetExtensionWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*GetExtensionResp, error)

GetExtensionWithResponse request returning *GetExtensionResp

func (*ClientWithResponses) GetGlobalSecretWithResponse

func (c *ClientWithResponses) GetGlobalSecretWithResponse(ctx context.Context, key string, params *GetGlobalSecretParams, reqEditors ...RequestEditorFn) (*GetGlobalSecretResp, error)

GetGlobalSecretWithResponse request returning *GetGlobalSecretResp

func (*ClientWithResponses) GetLogsWithResponse

func (c *ClientWithResponses) GetLogsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*GetLogsResp, error)

GetLogsWithResponse request returning *GetLogsResp

func (*ClientWithResponses) GetMetadataWithResponse

func (c *ClientWithResponses) GetMetadataWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMetadataResp, error)

GetMetadataWithResponse request returning *GetMetadataResp

func (*ClientWithResponses) GetNamespaceWithResponse

func (c *ClientWithResponses) GetNamespaceWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*GetNamespaceResp, error)

GetNamespaceWithResponse request returning *GetNamespaceResp

func (*ClientWithResponses) GetPipelineObjectWithResponse

func (c *ClientWithResponses) GetPipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*GetPipelineObjectResp, error)

GetPipelineObjectWithResponse request returning *GetPipelineObjectResp

func (*ClientWithResponses) GetPipelineSecretWithResponse

func (c *ClientWithResponses) GetPipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, params *GetPipelineSecretParams, reqEditors ...RequestEditorFn) (*GetPipelineSecretResp, error)

GetPipelineSecretWithResponse request returning *GetPipelineSecretResp

func (*ClientWithResponses) GetPipelineWithResponse

func (c *ClientWithResponses) GetPipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*GetPipelineResp, error)

GetPipelineWithResponse request returning *GetPipelineResp

func (*ClientWithResponses) GetRunObjectWithResponse

func (c *ClientWithResponses) GetRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*GetRunObjectResp, error)

GetRunObjectWithResponse request returning *GetRunObjectResp

func (*ClientWithResponses) GetRunWithResponse

func (c *ClientWithResponses) GetRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*GetRunResp, error)

GetRunWithResponse request returning *GetRunResp

func (*ClientWithResponses) GetSubscriptionWithResponse

func (c *ClientWithResponses) GetSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*GetSubscriptionResp, error)

GetSubscriptionWithResponse request returning *GetSubscriptionResp

func (*ClientWithResponses) GetTaskExecutionWithResponse

func (c *ClientWithResponses) GetTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*GetTaskExecutionResp, error)

GetTaskExecutionWithResponse request returning *GetTaskExecutionResp

func (*ClientWithResponses) GetTokenByIdWithResponse

func (c *ClientWithResponses) GetTokenByIdWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*GetTokenByIdResp, error)

GetTokenByIdWithResponse request returning *GetTokenByIdResp

func (*ClientWithResponses) InstallExtensionWithBodyWithResponse

func (c *ClientWithResponses) InstallExtensionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*InstallExtensionResp, error)

InstallExtensionWithBodyWithResponse request with arbitrary body returning *InstallExtensionResp

func (*ClientWithResponses) InstallExtensionWithResponse

func (c *ClientWithResponses) InstallExtensionWithResponse(ctx context.Context, body InstallExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*InstallExtensionResp, error)

func (*ClientWithResponses) ListConfigsWithResponse

func (c *ClientWithResponses) ListConfigsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListConfigsResp, error)

ListConfigsWithResponse request returning *ListConfigsResp

func (*ClientWithResponses) ListDeploymentsWithResponse

func (c *ClientWithResponses) ListDeploymentsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListDeploymentsResp, error)

ListDeploymentsWithResponse request returning *ListDeploymentsResp

func (*ClientWithResponses) ListExtensionsWithResponse

func (c *ClientWithResponses) ListExtensionsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListExtensionsResp, error)

ListExtensionsWithResponse request returning *ListExtensionsResp

func (*ClientWithResponses) ListGlobalSecretsWithResponse

func (c *ClientWithResponses) ListGlobalSecretsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListGlobalSecretsResp, error)

ListGlobalSecretsWithResponse request returning *ListGlobalSecretsResp

func (*ClientWithResponses) ListNamespacesWithResponse

func (c *ClientWithResponses) ListNamespacesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListNamespacesResp, error)

ListNamespacesWithResponse request returning *ListNamespacesResp

func (*ClientWithResponses) ListPipelineObjectsWithResponse

func (c *ClientWithResponses) ListPipelineObjectsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListPipelineObjectsResp, error)

ListPipelineObjectsWithResponse request returning *ListPipelineObjectsResp

func (*ClientWithResponses) ListPipelineSecretsWithResponse

func (c *ClientWithResponses) ListPipelineSecretsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListPipelineSecretsResp, error)

ListPipelineSecretsWithResponse request returning *ListPipelineSecretsResp

func (*ClientWithResponses) ListPipelinesWithResponse

func (c *ClientWithResponses) ListPipelinesWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*ListPipelinesResp, error)

ListPipelinesWithResponse request returning *ListPipelinesResp

func (*ClientWithResponses) ListRunObjectsWithResponse

func (c *ClientWithResponses) ListRunObjectsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*ListRunObjectsResp, error)

ListRunObjectsWithResponse request returning *ListRunObjectsResp

func (*ClientWithResponses) ListRunsWithResponse

func (c *ClientWithResponses) ListRunsWithResponse(ctx context.Context, namespaceId string, pipelineId string, params *ListRunsParams, reqEditors ...RequestEditorFn) (*ListRunsResp, error)

ListRunsWithResponse request returning *ListRunsResp

func (*ClientWithResponses) ListSubscriptionsWithResponse

func (c *ClientWithResponses) ListSubscriptionsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListSubscriptionsResp, error)

ListSubscriptionsWithResponse request returning *ListSubscriptionsResp

func (*ClientWithResponses) ListTaskExecutionsWithResponse

func (c *ClientWithResponses) ListTaskExecutionsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*ListTaskExecutionsResp, error)

ListTaskExecutionsWithResponse request returning *ListTaskExecutionsResp

func (*ClientWithResponses) ListTokensWithResponse

func (c *ClientWithResponses) ListTokensWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListTokensResp, error)

ListTokensWithResponse request returning *ListTokensResp

func (*ClientWithResponses) PutGlobalSecretWithBodyWithResponse

func (c *ClientWithResponses) PutGlobalSecretWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutGlobalSecretResp, error)

PutGlobalSecretWithBodyWithResponse request with arbitrary body returning *PutGlobalSecretResp

func (*ClientWithResponses) PutGlobalSecretWithResponse

func (c *ClientWithResponses) PutGlobalSecretWithResponse(ctx context.Context, body PutGlobalSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*PutGlobalSecretResp, error)

func (*ClientWithResponses) PutPipelineObjectWithBodyWithResponse

func (c *ClientWithResponses) PutPipelineObjectWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutPipelineObjectResp, error)

PutPipelineObjectWithBodyWithResponse request with arbitrary body returning *PutPipelineObjectResp

func (*ClientWithResponses) PutPipelineObjectWithResponse

func (c *ClientWithResponses) PutPipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*PutPipelineObjectResp, error)

func (*ClientWithResponses) PutPipelineSecretWithBodyWithResponse

func (c *ClientWithResponses) PutPipelineSecretWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutPipelineSecretResp, error)

PutPipelineSecretWithBodyWithResponse request with arbitrary body returning *PutPipelineSecretResp

func (*ClientWithResponses) PutPipelineSecretWithResponse

func (c *ClientWithResponses) PutPipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*PutPipelineSecretResp, error)

func (*ClientWithResponses) PutRunObjectWithBodyWithResponse

func (c *ClientWithResponses) PutRunObjectWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutRunObjectResp, error)

PutRunObjectWithBodyWithResponse request with arbitrary body returning *PutRunObjectResp

func (*ClientWithResponses) PutRunObjectWithResponse

func (c *ClientWithResponses) PutRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, body PutRunObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*PutRunObjectResp, error)

func (*ClientWithResponses) RegisterConfigWithBodyWithResponse

func (c *ClientWithResponses) RegisterConfigWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RegisterConfigResp, error)

RegisterConfigWithBodyWithResponse request with arbitrary body returning *RegisterConfigResp

func (*ClientWithResponses) RegisterConfigWithResponse

func (c *ClientWithResponses) RegisterConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, body RegisterConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*RegisterConfigResp, error)

func (*ClientWithResponses) StartRunWithBodyWithResponse

func (c *ClientWithResponses) StartRunWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*StartRunResp, error)

StartRunWithBodyWithResponse request with arbitrary body returning *StartRunResp

func (*ClientWithResponses) StartRunWithResponse

func (c *ClientWithResponses) StartRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, body StartRunJSONRequestBody, reqEditors ...RequestEditorFn) (*StartRunResp, error)

func (*ClientWithResponses) StreamEventsWithResponse

func (c *ClientWithResponses) StreamEventsWithResponse(ctx context.Context, params *StreamEventsParams, reqEditors ...RequestEditorFn) (*StreamEventsResp, error)

StreamEventsWithResponse request returning *StreamEventsResp

func (*ClientWithResponses) UninstallExtensionWithResponse

func (c *ClientWithResponses) UninstallExtensionWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*UninstallExtensionResp, error)

UninstallExtensionWithResponse request returning *UninstallExtensionResp

func (*ClientWithResponses) UpdateExtensionWithBodyWithResponse

func (c *ClientWithResponses) UpdateExtensionWithBodyWithResponse(ctx context.Context, extensionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateExtensionResp, error)

UpdateExtensionWithBodyWithResponse request with arbitrary body returning *UpdateExtensionResp

func (*ClientWithResponses) UpdateExtensionWithResponse

func (c *ClientWithResponses) UpdateExtensionWithResponse(ctx context.Context, extensionId string, body UpdateExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateExtensionResp, error)

func (*ClientWithResponses) UpdateNamespaceWithBodyWithResponse

func (c *ClientWithResponses) UpdateNamespaceWithBodyWithResponse(ctx context.Context, namespaceId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateNamespaceResp, error)

UpdateNamespaceWithBodyWithResponse request with arbitrary body returning *UpdateNamespaceResp

func (*ClientWithResponses) UpdateNamespaceWithResponse

func (c *ClientWithResponses) UpdateNamespaceWithResponse(ctx context.Context, namespaceId string, body UpdateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateNamespaceResp, error)

func (*ClientWithResponses) UpdatePipelineWithBodyWithResponse

func (c *ClientWithResponses) UpdatePipelineWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdatePipelineResp, error)

UpdatePipelineWithBodyWithResponse request with arbitrary body returning *UpdatePipelineResp

func (*ClientWithResponses) UpdatePipelineWithResponse

func (c *ClientWithResponses) UpdatePipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, body UpdatePipelineJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdatePipelineResp, error)

func (*ClientWithResponses) UpdateSubscriptionWithBodyWithResponse

func (c *ClientWithResponses) UpdateSubscriptionWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateSubscriptionResp, error)

UpdateSubscriptionWithBodyWithResponse request with arbitrary body returning *UpdateSubscriptionResp

func (*ClientWithResponses) UpdateSubscriptionWithResponse

func (c *ClientWithResponses) UpdateSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, body UpdateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateSubscriptionResp, error)

func (*ClientWithResponses) UpdateTokenWithBodyWithResponse

func (c *ClientWithResponses) UpdateTokenWithBodyWithResponse(ctx context.Context, id string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateTokenResp, error)

UpdateTokenWithBodyWithResponse request with arbitrary body returning *UpdateTokenResp

func (*ClientWithResponses) UpdateTokenWithResponse

func (c *ClientWithResponses) UpdateTokenWithResponse(ctx context.Context, id string, body UpdateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateTokenResp, error)

func (*ClientWithResponses) WhoamiWithResponse

func (c *ClientWithResponses) WhoamiWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*WhoamiResp, error)

WhoamiWithResponse request returning *WhoamiResp

type ClientWithResponsesInterface

type ClientWithResponsesInterface interface {
	// StreamEventsWithResponse request
	StreamEventsWithResponse(ctx context.Context, params *StreamEventsParams, reqEditors ...RequestEditorFn) (*StreamEventsResp, error)

	// DeleteEventWithResponse request
	DeleteEventWithResponse(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*DeleteEventResp, error)

	// GetEventWithResponse request
	GetEventWithResponse(ctx context.Context, eventId string, reqEditors ...RequestEditorFn) (*GetEventResp, error)

	// ListExtensionsWithResponse request
	ListExtensionsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListExtensionsResp, error)

	// InstallExtensionWithBodyWithResponse request with any body
	InstallExtensionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*InstallExtensionResp, error)

	InstallExtensionWithResponse(ctx context.Context, body InstallExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*InstallExtensionResp, error)

	// UninstallExtensionWithResponse request
	UninstallExtensionWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*UninstallExtensionResp, error)

	// GetExtensionWithResponse request
	GetExtensionWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*GetExtensionResp, error)

	// UpdateExtensionWithBodyWithResponse request with any body
	UpdateExtensionWithBodyWithResponse(ctx context.Context, extensionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateExtensionResp, error)

	UpdateExtensionWithResponse(ctx context.Context, extensionId string, body UpdateExtensionJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateExtensionResp, error)

	// GetExtensionLogsWithResponse request
	GetExtensionLogsWithResponse(ctx context.Context, extensionId string, reqEditors ...RequestEditorFn) (*GetExtensionLogsResp, error)

	// ListNamespacesWithResponse request
	ListNamespacesWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListNamespacesResp, error)

	// CreateNamespaceWithBodyWithResponse request with any body
	CreateNamespaceWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateNamespaceResp, error)

	CreateNamespaceWithResponse(ctx context.Context, body CreateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateNamespaceResp, error)

	// DeleteNamespaceWithResponse request
	DeleteNamespaceWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*DeleteNamespaceResp, error)

	// GetNamespaceWithResponse request
	GetNamespaceWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*GetNamespaceResp, error)

	// UpdateNamespaceWithBodyWithResponse request with any body
	UpdateNamespaceWithBodyWithResponse(ctx context.Context, namespaceId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateNamespaceResp, error)

	UpdateNamespaceWithResponse(ctx context.Context, namespaceId string, body UpdateNamespaceJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateNamespaceResp, error)

	// ListPipelinesWithResponse request
	ListPipelinesWithResponse(ctx context.Context, namespaceId string, reqEditors ...RequestEditorFn) (*ListPipelinesResp, error)

	// DeletePipelineWithResponse request
	DeletePipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*DeletePipelineResp, error)

	// GetPipelineWithResponse request
	GetPipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*GetPipelineResp, error)

	// UpdatePipelineWithBodyWithResponse request with any body
	UpdatePipelineWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdatePipelineResp, error)

	UpdatePipelineWithResponse(ctx context.Context, namespaceId string, pipelineId string, body UpdatePipelineJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdatePipelineResp, error)

	// ListConfigsWithResponse request
	ListConfigsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListConfigsResp, error)

	// RegisterConfigWithBodyWithResponse request with any body
	RegisterConfigWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RegisterConfigResp, error)

	RegisterConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, body RegisterConfigJSONRequestBody, reqEditors ...RequestEditorFn) (*RegisterConfigResp, error)

	// DeleteConfigWithResponse request
	DeleteConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*DeleteConfigResp, error)

	// GetConfigWithResponse request
	GetConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*GetConfigResp, error)

	// DeployConfigWithResponse request
	DeployConfigWithResponse(ctx context.Context, namespaceId string, pipelineId string, version int64, reqEditors ...RequestEditorFn) (*DeployConfigResp, error)

	// ListDeploymentsWithResponse request
	ListDeploymentsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListDeploymentsResp, error)

	// GetDeploymentWithResponse request
	GetDeploymentWithResponse(ctx context.Context, namespaceId string, pipelineId string, deploymentId uint64, reqEditors ...RequestEditorFn) (*GetDeploymentResp, error)

	// ListPipelineObjectsWithResponse request
	ListPipelineObjectsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListPipelineObjectsResp, error)

	// PutPipelineObjectWithBodyWithResponse request with any body
	PutPipelineObjectWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutPipelineObjectResp, error)

	PutPipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*PutPipelineObjectResp, error)

	// DeletePipelineObjectWithResponse request
	DeletePipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*DeletePipelineObjectResp, error)

	// GetPipelineObjectWithResponse request
	GetPipelineObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*GetPipelineObjectResp, error)

	// ListRunsWithResponse request
	ListRunsWithResponse(ctx context.Context, namespaceId string, pipelineId string, params *ListRunsParams, reqEditors ...RequestEditorFn) (*ListRunsResp, error)

	// StartRunWithBodyWithResponse request with any body
	StartRunWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*StartRunResp, error)

	StartRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, body StartRunJSONRequestBody, reqEditors ...RequestEditorFn) (*StartRunResp, error)

	// CancelRunWithResponse request
	CancelRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*CancelRunResp, error)

	// GetRunWithResponse request
	GetRunWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*GetRunResp, error)

	// ListRunObjectsWithResponse request
	ListRunObjectsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*ListRunObjectsResp, error)

	// PutRunObjectWithBodyWithResponse request with any body
	PutRunObjectWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutRunObjectResp, error)

	PutRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, body PutRunObjectJSONRequestBody, reqEditors ...RequestEditorFn) (*PutRunObjectResp, error)

	// DeleteRunObjectWithResponse request
	DeleteRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*DeleteRunObjectResp, error)

	// GetRunObjectWithResponse request
	GetRunObjectWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, key string, reqEditors ...RequestEditorFn) (*GetRunObjectResp, error)

	// ListTaskExecutionsWithResponse request
	ListTaskExecutionsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, reqEditors ...RequestEditorFn) (*ListTaskExecutionsResp, error)

	// CancelTaskExecutionWithResponse request
	CancelTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *CancelTaskExecutionParams, reqEditors ...RequestEditorFn) (*CancelTaskExecutionResp, error)

	// GetTaskExecutionWithResponse request
	GetTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*GetTaskExecutionResp, error)

	// AttachTaskExecutionWithResponse request
	AttachTaskExecutionWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, params *AttachTaskExecutionParams, reqEditors ...RequestEditorFn) (*AttachTaskExecutionResp, error)

	// DeleteLogsWithResponse request
	DeleteLogsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*DeleteLogsResp, error)

	// GetLogsWithResponse request
	GetLogsWithResponse(ctx context.Context, namespaceId string, pipelineId string, runId uint64, taskId string, reqEditors ...RequestEditorFn) (*GetLogsResp, error)

	// ListPipelineSecretsWithResponse request
	ListPipelineSecretsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListPipelineSecretsResp, error)

	// PutPipelineSecretWithBodyWithResponse request with any body
	PutPipelineSecretWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutPipelineSecretResp, error)

	PutPipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, body PutPipelineSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*PutPipelineSecretResp, error)

	// DeletePipelineSecretWithResponse request
	DeletePipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, reqEditors ...RequestEditorFn) (*DeletePipelineSecretResp, error)

	// GetPipelineSecretWithResponse request
	GetPipelineSecretWithResponse(ctx context.Context, namespaceId string, pipelineId string, key string, params *GetPipelineSecretParams, reqEditors ...RequestEditorFn) (*GetPipelineSecretResp, error)

	// ListSubscriptionsWithResponse request
	ListSubscriptionsWithResponse(ctx context.Context, namespaceId string, pipelineId string, reqEditors ...RequestEditorFn) (*ListSubscriptionsResp, error)

	// CreateSubscriptionWithBodyWithResponse request with any body
	CreateSubscriptionWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateSubscriptionResp, error)

	CreateSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, body CreateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateSubscriptionResp, error)

	// DeleteSubscriptionWithResponse request
	DeleteSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*DeleteSubscriptionResp, error)

	// GetSubscriptionWithResponse request
	GetSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, reqEditors ...RequestEditorFn) (*GetSubscriptionResp, error)

	// UpdateSubscriptionWithBodyWithResponse request with any body
	UpdateSubscriptionWithBodyWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateSubscriptionResp, error)

	UpdateSubscriptionWithResponse(ctx context.Context, namespaceId string, pipelineId string, extensionId string, subscriptionId string, body UpdateSubscriptionJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateSubscriptionResp, error)

	// ListGlobalSecretsWithResponse request
	ListGlobalSecretsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListGlobalSecretsResp, error)

	// PutGlobalSecretWithBodyWithResponse request with any body
	PutGlobalSecretWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutGlobalSecretResp, error)

	PutGlobalSecretWithResponse(ctx context.Context, body PutGlobalSecretJSONRequestBody, reqEditors ...RequestEditorFn) (*PutGlobalSecretResp, error)

	// DeleteGlobalSecretWithResponse request
	DeleteGlobalSecretWithResponse(ctx context.Context, key string, reqEditors ...RequestEditorFn) (*DeleteGlobalSecretResp, error)

	// GetGlobalSecretWithResponse request
	GetGlobalSecretWithResponse(ctx context.Context, key string, params *GetGlobalSecretParams, reqEditors ...RequestEditorFn) (*GetGlobalSecretResp, error)

	// GetMetadataWithResponse request
	GetMetadataWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMetadataResp, error)

	// ListTokensWithResponse request
	ListTokensWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListTokensResp, error)

	// CreateTokenWithBodyWithResponse request with any body
	CreateTokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateTokenResp, error)

	CreateTokenWithResponse(ctx context.Context, body CreateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateTokenResp, error)

	// CreateBootstrapTokenWithResponse request
	CreateBootstrapTokenWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*CreateBootstrapTokenResp, error)

	// WhoamiWithResponse request
	WhoamiWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*WhoamiResp, error)

	// DeleteTokenWithResponse request
	DeleteTokenWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*DeleteTokenResp, error)

	// GetTokenByIdWithResponse request
	GetTokenByIdWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*GetTokenByIdResp, error)

	// UpdateTokenWithBodyWithResponse request with any body
	UpdateTokenWithBodyWithResponse(ctx context.Context, id string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateTokenResp, error)

	UpdateTokenWithResponse(ctx context.Context, id string, body UpdateTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateTokenResp, error)
}

ClientWithResponsesInterface is the interface specification for the client with responses above.

type Config

type Config struct {
	// Deprecated Time in epoch milliseconds when this pipeline config was not longer used.
	Deprecated int `json:"deprecated"`

	// Description Description of pipeline's purpose and other details.
	Description string `json:"description"`

	// Name Human readable name for pipeline.
	Name string `json:"name"`

	// NamespaceId Unique identifier of the target namespace.
	NamespaceId string `json:"namespace_id"`

	// Parallelism The amount of runs allowed to happen at any given time.
	Parallelism uint64 `json:"parallelism"`

	// PipelineId Unique identifier of the target pipeline.
	PipelineId string `json:"pipeline_id"`

	// Registered Time in epoch milliseconds when this pipeline config was registered.
	Registered int `json:"registered"`

	// State The deployment state of the config. This is used to determine the state of this particular config and if it is currently being used or not.
	State ConfigState `json:"state"`

	// Tasks Tasks associated with this pipeline.
	Tasks map[string]Task `json:"tasks"`

	// Version The iteration number for this pipeline's configs.
	Version uint64 `json:"version"`
}

Config A representation of the user's configuration settings for a particular pipeline.

type ConfigState

type ConfigState struct {
	// contains filtered or unexported fields
}

ConfigState defines model for ConfigState.

func (ConfigState) AsConfigState0

func (t ConfigState) AsConfigState0() (ConfigState0, error)

AsConfigState0 returns the union data inside the ConfigState as a ConfigState0

func (ConfigState) AsConfigState1

func (t ConfigState) AsConfigState1() (ConfigState1, error)

AsConfigState1 returns the union data inside the ConfigState as a ConfigState1

func (ConfigState) AsConfigState2

func (t ConfigState) AsConfigState2() (ConfigState2, error)

AsConfigState2 returns the union data inside the ConfigState as a ConfigState2

func (ConfigState) AsConfigState3

func (t ConfigState) AsConfigState3() (ConfigState3, error)

AsConfigState3 returns the union data inside the ConfigState as a ConfigState3

func (*ConfigState) FromConfigState0

func (t *ConfigState) FromConfigState0(v ConfigState0) error

FromConfigState0 overwrites any union data inside the ConfigState as the provided ConfigState0

func (*ConfigState) FromConfigState1

func (t *ConfigState) FromConfigState1(v ConfigState1) error

FromConfigState1 overwrites any union data inside the ConfigState as the provided ConfigState1

func (*ConfigState) FromConfigState2

func (t *ConfigState) FromConfigState2(v ConfigState2) error

FromConfigState2 overwrites any union data inside the ConfigState as the provided ConfigState2

func (*ConfigState) FromConfigState3

func (t *ConfigState) FromConfigState3(v ConfigState3) error

FromConfigState3 overwrites any union data inside the ConfigState as the provided ConfigState3

func (ConfigState) MarshalJSON

func (t ConfigState) MarshalJSON() ([]byte, error)

func (*ConfigState) MergeConfigState0

func (t *ConfigState) MergeConfigState0(v ConfigState0) error

MergeConfigState0 performs a merge with any union data inside the ConfigState, using the provided ConfigState0

func (*ConfigState) MergeConfigState1

func (t *ConfigState) MergeConfigState1(v ConfigState1) error

MergeConfigState1 performs a merge with any union data inside the ConfigState, using the provided ConfigState1

func (*ConfigState) MergeConfigState2

func (t *ConfigState) MergeConfigState2(v ConfigState2) error

MergeConfigState2 performs a merge with any union data inside the ConfigState, using the provided ConfigState2

func (*ConfigState) MergeConfigState3

func (t *ConfigState) MergeConfigState3(v ConfigState3) error

MergeConfigState3 performs a merge with any union data inside the ConfigState, using the provided ConfigState3

func (*ConfigState) UnmarshalJSON

func (t *ConfigState) UnmarshalJSON(b []byte) error

type ConfigState0

type ConfigState0 string

ConfigState0 defines model for ConfigState.0.

const (
	ConfigState0Unknown ConfigState0 = "unknown"
)

Defines values for ConfigState0.

type ConfigState1

type ConfigState1 string

ConfigState1 Has never been deployed.

const (
	Unreleased ConfigState1 = "unreleased"
)

Defines values for ConfigState1.

type ConfigState2

type ConfigState2 string

ConfigState2 Currently deployed.

const (
	Live ConfigState2 = "live"
)

Defines values for ConfigState2.

type ConfigState3

type ConfigState3 string

ConfigState3 Has previously been deployed and is now defunct.

const (
	Deprecated ConfigState3 = "deprecated"
)

Defines values for ConfigState3.

type CreateBootstrapTokenResp

type CreateBootstrapTokenResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *CreateTokenResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseCreateBootstrapTokenResp

func ParseCreateBootstrapTokenResp(rsp *http.Response) (*CreateBootstrapTokenResp, error)

ParseCreateBootstrapTokenResp parses an HTTP response from a CreateBootstrapTokenWithResponse call

func (CreateBootstrapTokenResp) Status

func (r CreateBootstrapTokenResp) Status() string

Status returns HTTPResponse.Status

func (CreateBootstrapTokenResp) StatusCode

func (r CreateBootstrapTokenResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateNamespaceJSONRequestBody

type CreateNamespaceJSONRequestBody = CreateNamespaceRequest

CreateNamespaceJSONRequestBody defines body for CreateNamespace for application/json ContentType.

type CreateNamespaceRequest

type CreateNamespaceRequest struct {
	// Description Short description about what the namespace is used for.
	Description string `json:"description"`

	// Id The unique identifier for the namespace. Only accepts alphanumeric chars with hyphens. No spaces.
	Id string `json:"id"`

	// Name Humanized name for the namespace.
	Name string `json:"name"`
}

CreateNamespaceRequest defines model for CreateNamespaceRequest.

type CreateNamespaceResp

type CreateNamespaceResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *CreateNamespaceResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseCreateNamespaceResp

func ParseCreateNamespaceResp(rsp *http.Response) (*CreateNamespaceResp, error)

ParseCreateNamespaceResp parses an HTTP response from a CreateNamespaceWithResponse call

func (CreateNamespaceResp) Status

func (r CreateNamespaceResp) Status() string

Status returns HTTPResponse.Status

func (CreateNamespaceResp) StatusCode

func (r CreateNamespaceResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateNamespaceResponse

type CreateNamespaceResponse struct {
	// Namespace Information about the namespace created.
	Namespace Namespace `json:"namespace"`
}

CreateNamespaceResponse defines model for CreateNamespaceResponse.

type CreateSubscriptionJSONRequestBody

type CreateSubscriptionJSONRequestBody = CreateSubscriptionRequest

CreateSubscriptionJSONRequestBody defines body for CreateSubscription for application/json ContentType.

type CreateSubscriptionRequest

type CreateSubscriptionRequest struct {
	ExtensionId    string            `json:"extension_id"`
	Settings       map[string]string `json:"settings"`
	SubscriptionId string            `json:"subscription_id"`
}

CreateSubscriptionRequest defines model for CreateSubscriptionRequest.

type CreateSubscriptionResp

type CreateSubscriptionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *CreateSubscriptionResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseCreateSubscriptionResp

func ParseCreateSubscriptionResp(rsp *http.Response) (*CreateSubscriptionResp, error)

ParseCreateSubscriptionResp parses an HTTP response from a CreateSubscriptionWithResponse call

func (CreateSubscriptionResp) Status

func (r CreateSubscriptionResp) Status() string

Status returns HTTPResponse.Status

func (CreateSubscriptionResp) StatusCode

func (r CreateSubscriptionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateSubscriptionResponse

type CreateSubscriptionResponse struct {
	// Subscription Information about the subscription created.
	Subscription Subscription `json:"subscription"`
}

CreateSubscriptionResponse defines model for CreateSubscriptionResponse.

type CreateTokenJSONRequestBody

type CreateTokenJSONRequestBody = CreateTokenRequest

CreateTokenJSONRequestBody defines body for CreateToken for application/json ContentType.

type CreateTokenRequest

type CreateTokenRequest struct {
	// Expires The amount of time the token is valid for in seconds.
	Expires uint64 `json:"expires"`

	// Metadata Various other bits of data you can attach to tokens. This is used by Gofer to track some details about tokens, but can also be used by users to attach bits of information that would make the token easier to programmatically manage.
	Metadata map[string]string `json:"metadata"`

	// Namespaces The namespaces this token applies to. Token will be unauthorized for any namespace not listed. Accepts regexes.
	Namespaces []string `json:"namespaces"`

	// TokenType The type of token to be created. Can be management or client.
	TokenType TokenType `json:"token_type"`
}

CreateTokenRequest defines model for CreateTokenRequest.

type CreateTokenResp

type CreateTokenResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *CreateTokenResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseCreateTokenResp

func ParseCreateTokenResp(rsp *http.Response) (*CreateTokenResp, error)

ParseCreateTokenResp parses an HTTP response from a CreateTokenWithResponse call

func (CreateTokenResp) Status

func (r CreateTokenResp) Status() string

Status returns HTTPResponse.Status

func (CreateTokenResp) StatusCode

func (r CreateTokenResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateTokenResponse

type CreateTokenResponse struct {
	// Secret The actual token created. API Tokens should be protected in the same fashion as passwords.
	Secret string `json:"secret"`

	// TokenDetails Information about the token created.
	TokenDetails Token `json:"token_details"`
}

CreateTokenResponse defines model for CreateTokenResponse.

type DeleteConfigResp

type DeleteConfigResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteConfigResp

func ParseDeleteConfigResp(rsp *http.Response) (*DeleteConfigResp, error)

ParseDeleteConfigResp parses an HTTP response from a DeleteConfigWithResponse call

func (DeleteConfigResp) Status

func (r DeleteConfigResp) Status() string

Status returns HTTPResponse.Status

func (DeleteConfigResp) StatusCode

func (r DeleteConfigResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteEventResp

type DeleteEventResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteEventResp

func ParseDeleteEventResp(rsp *http.Response) (*DeleteEventResp, error)

ParseDeleteEventResp parses an HTTP response from a DeleteEventWithResponse call

func (DeleteEventResp) Status

func (r DeleteEventResp) Status() string

Status returns HTTPResponse.Status

func (DeleteEventResp) StatusCode

func (r DeleteEventResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteGlobalSecretResp

type DeleteGlobalSecretResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteGlobalSecretResp

func ParseDeleteGlobalSecretResp(rsp *http.Response) (*DeleteGlobalSecretResp, error)

ParseDeleteGlobalSecretResp parses an HTTP response from a DeleteGlobalSecretWithResponse call

func (DeleteGlobalSecretResp) Status

func (r DeleteGlobalSecretResp) Status() string

Status returns HTTPResponse.Status

func (DeleteGlobalSecretResp) StatusCode

func (r DeleteGlobalSecretResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteLogsResp

type DeleteLogsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteLogsResp

func ParseDeleteLogsResp(rsp *http.Response) (*DeleteLogsResp, error)

ParseDeleteLogsResp parses an HTTP response from a DeleteLogsWithResponse call

func (DeleteLogsResp) Status

func (r DeleteLogsResp) Status() string

Status returns HTTPResponse.Status

func (DeleteLogsResp) StatusCode

func (r DeleteLogsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteNamespaceResp

type DeleteNamespaceResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteNamespaceResp

func ParseDeleteNamespaceResp(rsp *http.Response) (*DeleteNamespaceResp, error)

ParseDeleteNamespaceResp parses an HTTP response from a DeleteNamespaceWithResponse call

func (DeleteNamespaceResp) Status

func (r DeleteNamespaceResp) Status() string

Status returns HTTPResponse.Status

func (DeleteNamespaceResp) StatusCode

func (r DeleteNamespaceResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeletePipelineObjectResp

type DeletePipelineObjectResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeletePipelineObjectResp

func ParseDeletePipelineObjectResp(rsp *http.Response) (*DeletePipelineObjectResp, error)

ParseDeletePipelineObjectResp parses an HTTP response from a DeletePipelineObjectWithResponse call

func (DeletePipelineObjectResp) Status

func (r DeletePipelineObjectResp) Status() string

Status returns HTTPResponse.Status

func (DeletePipelineObjectResp) StatusCode

func (r DeletePipelineObjectResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeletePipelineResp

type DeletePipelineResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeletePipelineResp

func ParseDeletePipelineResp(rsp *http.Response) (*DeletePipelineResp, error)

ParseDeletePipelineResp parses an HTTP response from a DeletePipelineWithResponse call

func (DeletePipelineResp) Status

func (r DeletePipelineResp) Status() string

Status returns HTTPResponse.Status

func (DeletePipelineResp) StatusCode

func (r DeletePipelineResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeletePipelineSecretResp

type DeletePipelineSecretResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeletePipelineSecretResp

func ParseDeletePipelineSecretResp(rsp *http.Response) (*DeletePipelineSecretResp, error)

ParseDeletePipelineSecretResp parses an HTTP response from a DeletePipelineSecretWithResponse call

func (DeletePipelineSecretResp) Status

func (r DeletePipelineSecretResp) Status() string

Status returns HTTPResponse.Status

func (DeletePipelineSecretResp) StatusCode

func (r DeletePipelineSecretResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteRunObjectResp

type DeleteRunObjectResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteRunObjectResp

func ParseDeleteRunObjectResp(rsp *http.Response) (*DeleteRunObjectResp, error)

ParseDeleteRunObjectResp parses an HTTP response from a DeleteRunObjectWithResponse call

func (DeleteRunObjectResp) Status

func (r DeleteRunObjectResp) Status() string

Status returns HTTPResponse.Status

func (DeleteRunObjectResp) StatusCode

func (r DeleteRunObjectResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteSubscriptionResp

type DeleteSubscriptionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteSubscriptionResp

func ParseDeleteSubscriptionResp(rsp *http.Response) (*DeleteSubscriptionResp, error)

ParseDeleteSubscriptionResp parses an HTTP response from a DeleteSubscriptionWithResponse call

func (DeleteSubscriptionResp) Status

func (r DeleteSubscriptionResp) Status() string

Status returns HTTPResponse.Status

func (DeleteSubscriptionResp) StatusCode

func (r DeleteSubscriptionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeleteTokenResp

type DeleteTokenResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeleteTokenResp

func ParseDeleteTokenResp(rsp *http.Response) (*DeleteTokenResp, error)

ParseDeleteTokenResp parses an HTTP response from a DeleteTokenWithResponse call

func (DeleteTokenResp) Status

func (r DeleteTokenResp) Status() string

Status returns HTTPResponse.Status

func (DeleteTokenResp) StatusCode

func (r DeleteTokenResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeployConfigResp

type DeployConfigResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *DeployPipelineConfigResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseDeployConfigResp

func ParseDeployConfigResp(rsp *http.Response) (*DeployConfigResp, error)

ParseDeployConfigResp parses an HTTP response from a DeployConfigWithResponse call

func (DeployConfigResp) Status

func (r DeployConfigResp) Status() string

Status returns HTTPResponse.Status

func (DeployConfigResp) StatusCode

func (r DeployConfigResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type DeployPipelineConfigResponse

type DeployPipelineConfigResponse struct {
	// Deployment Information about the pipeline created.
	Deployment Deployment `json:"deployment"`
}

DeployPipelineConfigResponse defines model for DeployPipelineConfigResponse.

type Deployment

type Deployment struct {
	// DeploymentId Unique identifier for the deployment.
	DeploymentId uint64 `json:"deployment_id"`

	// EndVersion Version of the pipeline being promoted.
	EndVersion uint64 `json:"end_version"`

	// Ended Time of deployment end in epoch milliseconds.
	Ended int `json:"ended"`

	// Logs The event logs from the deployment.
	Logs []Event `json:"logs"`

	// NamespaceId Unique identifier for the target namespace.
	NamespaceId string `json:"namespace_id"`

	// PipelineId Unique identifier for the target pipeline.
	PipelineId string `json:"pipeline_id"`

	// StartVersion Version of the pipeline is being deprecated.
	StartVersion uint64 `json:"start_version"`

	// Started Time of deployment start in epoch milliseconds.
	Started int `json:"started"`

	// State The current state of the deployment as it exists within Gofer's operating model.
	State DeploymentState `json:"state"`

	// Status The final status of the deployment.
	Status DeploymentStatus `json:"status"`

	// StatusReason Details about a deployment's specific status
	StatusReason *DeploymentStatusReason `json:"status_reason"`
}

Deployment A deployment represents a transition between two pipeline versions.

type DeploymentState

type DeploymentState struct {
	// contains filtered or unexported fields
}

DeploymentState defines model for deployment_state.

func (DeploymentState) AsDeploymentState0

func (t DeploymentState) AsDeploymentState0() (DeploymentState0, error)

AsDeploymentState0 returns the union data inside the DeploymentState as a DeploymentState0

func (DeploymentState) AsDeploymentState1

func (t DeploymentState) AsDeploymentState1() (DeploymentState1, error)

AsDeploymentState1 returns the union data inside the DeploymentState as a DeploymentState1

func (*DeploymentState) FromDeploymentState0

func (t *DeploymentState) FromDeploymentState0(v DeploymentState0) error

FromDeploymentState0 overwrites any union data inside the DeploymentState as the provided DeploymentState0

func (*DeploymentState) FromDeploymentState1

func (t *DeploymentState) FromDeploymentState1(v DeploymentState1) error

FromDeploymentState1 overwrites any union data inside the DeploymentState as the provided DeploymentState1

func (DeploymentState) MarshalJSON

func (t DeploymentState) MarshalJSON() ([]byte, error)

func (*DeploymentState) MergeDeploymentState0

func (t *DeploymentState) MergeDeploymentState0(v DeploymentState0) error

MergeDeploymentState0 performs a merge with any union data inside the DeploymentState, using the provided DeploymentState0

func (*DeploymentState) MergeDeploymentState1

func (t *DeploymentState) MergeDeploymentState1(v DeploymentState1) error

MergeDeploymentState1 performs a merge with any union data inside the DeploymentState, using the provided DeploymentState1

func (*DeploymentState) UnmarshalJSON

func (t *DeploymentState) UnmarshalJSON(b []byte) error

type DeploymentState0

type DeploymentState0 string

DeploymentState0 defines model for DeploymentState.0.

const (
	DeploymentState0Complete DeploymentState0 = "Complete"
	DeploymentState0Running  DeploymentState0 = "Running"
)

Defines values for DeploymentState0.

type DeploymentState1

type DeploymentState1 string

DeploymentState1 Should never be in this state.

const (
	DeploymentState1Unknown DeploymentState1 = "Unknown"
)

Defines values for DeploymentState1.

type DeploymentStatus

type DeploymentStatus struct {
	// contains filtered or unexported fields
}

DeploymentStatus defines model for deployment_status.

func (DeploymentStatus) AsDeploymentStatus0

func (t DeploymentStatus) AsDeploymentStatus0() (DeploymentStatus0, error)

AsDeploymentStatus0 returns the union data inside the DeploymentStatus as a DeploymentStatus0

func (DeploymentStatus) AsDeploymentStatus1

func (t DeploymentStatus) AsDeploymentStatus1() (DeploymentStatus1, error)

AsDeploymentStatus1 returns the union data inside the DeploymentStatus as a DeploymentStatus1

func (DeploymentStatus) AsDeploymentStatus2

func (t DeploymentStatus) AsDeploymentStatus2() (DeploymentStatus2, error)

AsDeploymentStatus2 returns the union data inside the DeploymentStatus as a DeploymentStatus2

func (*DeploymentStatus) FromDeploymentStatus0

func (t *DeploymentStatus) FromDeploymentStatus0(v DeploymentStatus0) error

FromDeploymentStatus0 overwrites any union data inside the DeploymentStatus as the provided DeploymentStatus0

func (*DeploymentStatus) FromDeploymentStatus1

func (t *DeploymentStatus) FromDeploymentStatus1(v DeploymentStatus1) error

FromDeploymentStatus1 overwrites any union data inside the DeploymentStatus as the provided DeploymentStatus1

func (*DeploymentStatus) FromDeploymentStatus2

func (t *DeploymentStatus) FromDeploymentStatus2(v DeploymentStatus2) error

FromDeploymentStatus2 overwrites any union data inside the DeploymentStatus as the provided DeploymentStatus2

func (DeploymentStatus) MarshalJSON

func (t DeploymentStatus) MarshalJSON() ([]byte, error)

func (*DeploymentStatus) MergeDeploymentStatus0

func (t *DeploymentStatus) MergeDeploymentStatus0(v DeploymentStatus0) error

MergeDeploymentStatus0 performs a merge with any union data inside the DeploymentStatus, using the provided DeploymentStatus0

func (*DeploymentStatus) MergeDeploymentStatus1

func (t *DeploymentStatus) MergeDeploymentStatus1(v DeploymentStatus1) error

MergeDeploymentStatus1 performs a merge with any union data inside the DeploymentStatus, using the provided DeploymentStatus1

func (*DeploymentStatus) MergeDeploymentStatus2

func (t *DeploymentStatus) MergeDeploymentStatus2(v DeploymentStatus2) error

MergeDeploymentStatus2 performs a merge with any union data inside the DeploymentStatus, using the provided DeploymentStatus2

func (*DeploymentStatus) UnmarshalJSON

func (t *DeploymentStatus) UnmarshalJSON(b []byte) error

type DeploymentStatus0

type DeploymentStatus0 string

DeploymentStatus0 Should only be in this state if the deployment is not yet complete.

const (
	DeploymentStatus0Unknown DeploymentStatus0 = "Unknown"
)

Defines values for DeploymentStatus0.

type DeploymentStatus1

type DeploymentStatus1 string

DeploymentStatus1 Has encountered an issue, either container issue or scheduling issue.

const (
	DeploymentStatus1Failed DeploymentStatus1 = "Failed"
)

Defines values for DeploymentStatus1.

type DeploymentStatus2

type DeploymentStatus2 string

DeploymentStatus2 Finished with a proper exit code.

const (
	DeploymentStatus2Successful DeploymentStatus2 = "Successful"
)

Defines values for DeploymentStatus2.

type DeploymentStatusReason

type DeploymentStatusReason struct {
	// Description A description of why the deployment might have failed and what was going on at the time.
	Description string `json:"description"`

	// Reason The specific type of deployment failure.
	Reason DeploymentStatusReasonType `json:"reason"`
}

DeploymentStatusReason defines model for deployment_status_reason.

type DeploymentStatusReasonType

type DeploymentStatusReasonType string

DeploymentStatusReasonType defines model for deployment_status_reason_type.

const (
	DeploymentStatusReasonTypeUnknown DeploymentStatusReasonType = "Unknown"
)

Defines values for DeploymentStatusReasonType.

type Documentation

type Documentation struct {
	// Body Anything the extension wants to explain to the user. This text is inserted into the documentation a user can look up about the extension. Supports AsciiDoc.
	Body string `json:"body"`

	// ConfigParams Each extension has configuration parameters that can be passed in at extension startup. These parameters should control extension behavior for it's entire lifetime.
	ConfigParams []Parameter `json:"config_params"`

	// PipelineSubscriptionParams Each extension has pipeline subscription parameters that are passed in by a pipeline when it attempts to subscribe to an extension. This controls how the extension treats that specific pipeline subscription.
	PipelineSubscriptionParams []Parameter `json:"pipeline_subscription_params"`
}

Documentation defines model for Documentation.

type Error

type Error struct {
	ErrorCode *string `json:"error_code,omitempty"`
	Message   string  `json:"message"`
	RequestId string  `json:"request_id"`
}

Error Error information from a response.

type Event

type Event struct {
	// Emitted Time event was performed in epoch milliseconds.
	Emitted int `json:"emitted"`

	// Id Unique identifier for event.
	Id string `json:"id"`

	// Kind The type of event it is.
	Kind Kind `json:"kind"`
}

Event A single event

type Extension

type Extension struct {
	// Documentation Extension given documentation usually in markdown.
	Documentation Documentation `json:"documentation"`

	// Registration Metadata about the extension as it is registered within Gofer.
	Registration Registration `json:"registration"`

	// Started The start time of the extension in epoch milliseconds.
	Started int `json:"started"`

	// State The current state of the extension as it exists within Gofer's operating model.
	State ExtensionState `json:"state"`

	// Url The network address used to communicate with the extension by the main process.
	Url string `json:"url"`
}

Extension An Extension is the way that pipelines add extra functionality to themselves. Pipelines can "subscribe" to extensions and extensions then act on behalf of that pipeline.

type ExtensionState

type ExtensionState struct {
	// contains filtered or unexported fields
}

ExtensionState defines model for extension_state.

func (ExtensionState) AsExtensionState0

func (t ExtensionState) AsExtensionState0() (ExtensionState0, error)

AsExtensionState0 returns the union data inside the ExtensionState as a ExtensionState0

func (ExtensionState) AsExtensionState1

func (t ExtensionState) AsExtensionState1() (ExtensionState1, error)

AsExtensionState1 returns the union data inside the ExtensionState as a ExtensionState1

func (ExtensionState) AsExtensionState2

func (t ExtensionState) AsExtensionState2() (ExtensionState2, error)

AsExtensionState2 returns the union data inside the ExtensionState as a ExtensionState2

func (ExtensionState) AsExtensionState3

func (t ExtensionState) AsExtensionState3() (ExtensionState3, error)

AsExtensionState3 returns the union data inside the ExtensionState as a ExtensionState3

func (*ExtensionState) FromExtensionState0

func (t *ExtensionState) FromExtensionState0(v ExtensionState0) error

FromExtensionState0 overwrites any union data inside the ExtensionState as the provided ExtensionState0

func (*ExtensionState) FromExtensionState1

func (t *ExtensionState) FromExtensionState1(v ExtensionState1) error

FromExtensionState1 overwrites any union data inside the ExtensionState as the provided ExtensionState1

func (*ExtensionState) FromExtensionState2

func (t *ExtensionState) FromExtensionState2(v ExtensionState2) error

FromExtensionState2 overwrites any union data inside the ExtensionState as the provided ExtensionState2

func (*ExtensionState) FromExtensionState3

func (t *ExtensionState) FromExtensionState3(v ExtensionState3) error

FromExtensionState3 overwrites any union data inside the ExtensionState as the provided ExtensionState3

func (ExtensionState) MarshalJSON

func (t ExtensionState) MarshalJSON() ([]byte, error)

func (*ExtensionState) MergeExtensionState0

func (t *ExtensionState) MergeExtensionState0(v ExtensionState0) error

MergeExtensionState0 performs a merge with any union data inside the ExtensionState, using the provided ExtensionState0

func (*ExtensionState) MergeExtensionState1

func (t *ExtensionState) MergeExtensionState1(v ExtensionState1) error

MergeExtensionState1 performs a merge with any union data inside the ExtensionState, using the provided ExtensionState1

func (*ExtensionState) MergeExtensionState2

func (t *ExtensionState) MergeExtensionState2(v ExtensionState2) error

MergeExtensionState2 performs a merge with any union data inside the ExtensionState, using the provided ExtensionState2

func (*ExtensionState) MergeExtensionState3

func (t *ExtensionState) MergeExtensionState3(v ExtensionState3) error

MergeExtensionState3 performs a merge with any union data inside the ExtensionState, using the provided ExtensionState3

func (*ExtensionState) UnmarshalJSON

func (t *ExtensionState) UnmarshalJSON(b []byte) error

type ExtensionState0

type ExtensionState0 string

ExtensionState0 Should never be in this state.

const (
	ExtensionState0Unknown ExtensionState0 = "unknown"
)

Defines values for ExtensionState0.

type ExtensionState1

type ExtensionState1 string

ExtensionState1 Pre-scheduling validation and prep.

const (
	ExtensionState1Processing ExtensionState1 = "processing"
)

Defines values for ExtensionState1.

type ExtensionState2

type ExtensionState2 string

ExtensionState2 Currently running as reported by scheduler.

const (
	ExtensionState2Running ExtensionState2 = "running"
)

Defines values for ExtensionState2.

type ExtensionState3

type ExtensionState3 string

ExtensionState3 Extension has exited; usually because of an error.

const (
	Exited ExtensionState3 = "exited"
)

Defines values for ExtensionState3.

type ExtensionStatus

type ExtensionStatus struct {
	// contains filtered or unexported fields
}

ExtensionStatus defines model for extension_status.

func (ExtensionStatus) AsExtensionStatus0

func (t ExtensionStatus) AsExtensionStatus0() (ExtensionStatus0, error)

AsExtensionStatus0 returns the union data inside the ExtensionStatus as a ExtensionStatus0

func (ExtensionStatus) AsExtensionStatus1

func (t ExtensionStatus) AsExtensionStatus1() (ExtensionStatus1, error)

AsExtensionStatus1 returns the union data inside the ExtensionStatus as a ExtensionStatus1

func (ExtensionStatus) AsExtensionStatus2

func (t ExtensionStatus) AsExtensionStatus2() (ExtensionStatus2, error)

AsExtensionStatus2 returns the union data inside the ExtensionStatus as a ExtensionStatus2

func (*ExtensionStatus) FromExtensionStatus0

func (t *ExtensionStatus) FromExtensionStatus0(v ExtensionStatus0) error

FromExtensionStatus0 overwrites any union data inside the ExtensionStatus as the provided ExtensionStatus0

func (*ExtensionStatus) FromExtensionStatus1

func (t *ExtensionStatus) FromExtensionStatus1(v ExtensionStatus1) error

FromExtensionStatus1 overwrites any union data inside the ExtensionStatus as the provided ExtensionStatus1

func (*ExtensionStatus) FromExtensionStatus2

func (t *ExtensionStatus) FromExtensionStatus2(v ExtensionStatus2) error

FromExtensionStatus2 overwrites any union data inside the ExtensionStatus as the provided ExtensionStatus2

func (ExtensionStatus) MarshalJSON

func (t ExtensionStatus) MarshalJSON() ([]byte, error)

func (*ExtensionStatus) MergeExtensionStatus0

func (t *ExtensionStatus) MergeExtensionStatus0(v ExtensionStatus0) error

MergeExtensionStatus0 performs a merge with any union data inside the ExtensionStatus, using the provided ExtensionStatus0

func (*ExtensionStatus) MergeExtensionStatus1

func (t *ExtensionStatus) MergeExtensionStatus1(v ExtensionStatus1) error

MergeExtensionStatus1 performs a merge with any union data inside the ExtensionStatus, using the provided ExtensionStatus1

func (*ExtensionStatus) MergeExtensionStatus2

func (t *ExtensionStatus) MergeExtensionStatus2(v ExtensionStatus2) error

MergeExtensionStatus2 performs a merge with any union data inside the ExtensionStatus, using the provided ExtensionStatus2

func (*ExtensionStatus) UnmarshalJSON

func (t *ExtensionStatus) UnmarshalJSON(b []byte) error

type ExtensionStatus0

type ExtensionStatus0 string

ExtensionStatus0 Cannot determine status of Extension; should never be in this status.

const (
	ExtensionStatus0Unknown ExtensionStatus0 = "unknown"
)

Defines values for ExtensionStatus0.

type ExtensionStatus1

type ExtensionStatus1 string

ExtensionStatus1 Installed and able to be used by pipelines.

const (
	Enabled ExtensionStatus1 = "enabled"
)

Defines values for ExtensionStatus1.

type ExtensionStatus2

type ExtensionStatus2 string

ExtensionStatus2 Not available to be used by pipelines, either through lack of installation or being disabled by an admin.

const (
	ExtensionStatus2Disabled ExtensionStatus2 = "disabled"
)

Defines values for ExtensionStatus2.

type GetConfigResp

type GetConfigResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetPipelineConfigResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetConfigResp

func ParseGetConfigResp(rsp *http.Response) (*GetConfigResp, error)

ParseGetConfigResp parses an HTTP response from a GetConfigWithResponse call

func (GetConfigResp) Status

func (r GetConfigResp) Status() string

Status returns HTTPResponse.Status

func (GetConfigResp) StatusCode

func (r GetConfigResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetDeploymentResp

type GetDeploymentResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetDeploymentResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetDeploymentResp

func ParseGetDeploymentResp(rsp *http.Response) (*GetDeploymentResp, error)

ParseGetDeploymentResp parses an HTTP response from a GetDeploymentWithResponse call

func (GetDeploymentResp) Status

func (r GetDeploymentResp) Status() string

Status returns HTTPResponse.Status

func (GetDeploymentResp) StatusCode

func (r GetDeploymentResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetDeploymentResponse

type GetDeploymentResponse struct {
	// Deployment The target deployment.
	Deployment Deployment `json:"deployment"`
}

GetDeploymentResponse defines model for GetDeploymentResponse.

type GetEventResp

type GetEventResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetEventResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetEventResp

func ParseGetEventResp(rsp *http.Response) (*GetEventResp, error)

ParseGetEventResp parses an HTTP response from a GetEventWithResponse call

func (GetEventResp) Status

func (r GetEventResp) Status() string

Status returns HTTPResponse.Status

func (GetEventResp) StatusCode

func (r GetEventResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetEventResponse

type GetEventResponse struct {
	// Event The target event.
	Event Event `json:"event"`
}

GetEventResponse defines model for GetEventResponse.

type GetExtensionLogsResp

type GetExtensionLogsResp struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseGetExtensionLogsResp

func ParseGetExtensionLogsResp(rsp *http.Response) (*GetExtensionLogsResp, error)

ParseGetExtensionLogsResp parses an HTTP response from a GetExtensionLogsWithResponse call

func (GetExtensionLogsResp) Status

func (r GetExtensionLogsResp) Status() string

Status returns HTTPResponse.Status

func (GetExtensionLogsResp) StatusCode

func (r GetExtensionLogsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetExtensionResp

type GetExtensionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetExtensionResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetExtensionResp

func ParseGetExtensionResp(rsp *http.Response) (*GetExtensionResp, error)

ParseGetExtensionResp parses an HTTP response from a GetExtensionWithResponse call

func (GetExtensionResp) Status

func (r GetExtensionResp) Status() string

Status returns HTTPResponse.Status

func (GetExtensionResp) StatusCode

func (r GetExtensionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetExtensionResponse

type GetExtensionResponse struct {
	// Extension The extension requested.
	Extension Extension `json:"extension"`
}

GetExtensionResponse defines model for GetExtensionResponse.

type GetGlobalSecretParams

type GetGlobalSecretParams struct {
	// IncludeSecret Includes the actual plaintext secret in the response.
	IncludeSecret bool `form:"include_secret" json:"include_secret"`
}

GetGlobalSecretParams defines parameters for GetGlobalSecret.

type GetGlobalSecretResp

type GetGlobalSecretResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetGlobalSecretResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetGlobalSecretResp

func ParseGetGlobalSecretResp(rsp *http.Response) (*GetGlobalSecretResp, error)

ParseGetGlobalSecretResp parses an HTTP response from a GetGlobalSecretWithResponse call

func (GetGlobalSecretResp) Status

func (r GetGlobalSecretResp) Status() string

Status returns HTTPResponse.Status

func (GetGlobalSecretResp) StatusCode

func (r GetGlobalSecretResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetGlobalSecretResponse

type GetGlobalSecretResponse struct {
	// Metadata The target secret metadata.
	Metadata Secret `json:"metadata"`

	// Secret The actual secret, only included if "include_secret" param is true.
	Secret *string `json:"secret"`
}

GetGlobalSecretResponse defines model for GetGlobalSecretResponse.

type GetLogsResp

type GetLogsResp struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseGetLogsResp

func ParseGetLogsResp(rsp *http.Response) (*GetLogsResp, error)

ParseGetLogsResp parses an HTTP response from a GetLogsWithResponse call

func (GetLogsResp) Status

func (r GetLogsResp) Status() string

Status returns HTTPResponse.Status

func (GetLogsResp) StatusCode

func (r GetLogsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetMetadataResp

type GetMetadataResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetSystemMetadataResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetMetadataResp

func ParseGetMetadataResp(rsp *http.Response) (*GetMetadataResp, error)

ParseGetMetadataResp parses an HTTP response from a GetMetadataWithResponse call

func (GetMetadataResp) Status

func (r GetMetadataResp) Status() string

Status returns HTTPResponse.Status

func (GetMetadataResp) StatusCode

func (r GetMetadataResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetNamespaceResp

type GetNamespaceResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetNamespaceResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetNamespaceResp

func ParseGetNamespaceResp(rsp *http.Response) (*GetNamespaceResp, error)

ParseGetNamespaceResp parses an HTTP response from a GetNamespaceWithResponse call

func (GetNamespaceResp) Status

func (r GetNamespaceResp) Status() string

Status returns HTTPResponse.Status

func (GetNamespaceResp) StatusCode

func (r GetNamespaceResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetNamespaceResponse

type GetNamespaceResponse struct {
	// Namespace The target namespace.
	Namespace Namespace `json:"namespace"`
}

GetNamespaceResponse defines model for GetNamespaceResponse.

type GetPipelineConfigResponse

type GetPipelineConfigResponse struct {
	// Config The target pipeline config.
	Config Config `json:"config"`
}

GetPipelineConfigResponse defines model for GetPipelineConfigResponse.

type GetPipelineObjectResp

type GetPipelineObjectResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetPipelineObjectResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetPipelineObjectResp

func ParseGetPipelineObjectResp(rsp *http.Response) (*GetPipelineObjectResp, error)

ParseGetPipelineObjectResp parses an HTTP response from a GetPipelineObjectWithResponse call

func (GetPipelineObjectResp) Status

func (r GetPipelineObjectResp) Status() string

Status returns HTTPResponse.Status

func (GetPipelineObjectResp) StatusCode

func (r GetPipelineObjectResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetPipelineObjectResponse

type GetPipelineObjectResponse struct {
	// Object The requested object data.
	Object []uint8 `json:"object"`
}

GetPipelineObjectResponse defines model for GetPipelineObjectResponse.

type GetPipelineResp

type GetPipelineResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetPipelineResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetPipelineResp

func ParseGetPipelineResp(rsp *http.Response) (*GetPipelineResp, error)

ParseGetPipelineResp parses an HTTP response from a GetPipelineWithResponse call

func (GetPipelineResp) Status

func (r GetPipelineResp) Status() string

Status returns HTTPResponse.Status

func (GetPipelineResp) StatusCode

func (r GetPipelineResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetPipelineResponse

type GetPipelineResponse struct {
	// Pipeline The metadata for the pipeline.
	Pipeline Metadata `json:"pipeline"`
}

GetPipelineResponse defines model for GetPipelineResponse.

type GetPipelineSecretParams

type GetPipelineSecretParams struct {
	// IncludeSecret Includes the actual plaintext secret in the response.
	IncludeSecret bool `form:"include_secret" json:"include_secret"`
}

GetPipelineSecretParams defines parameters for GetPipelineSecret.

type GetPipelineSecretResp

type GetPipelineSecretResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetPipelineSecretResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetPipelineSecretResp

func ParseGetPipelineSecretResp(rsp *http.Response) (*GetPipelineSecretResp, error)

ParseGetPipelineSecretResp parses an HTTP response from a GetPipelineSecretWithResponse call

func (GetPipelineSecretResp) Status

func (r GetPipelineSecretResp) Status() string

Status returns HTTPResponse.Status

func (GetPipelineSecretResp) StatusCode

func (r GetPipelineSecretResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetPipelineSecretResponse

type GetPipelineSecretResponse struct {
	// Metadata The target secret metadata.
	Metadata Secret `json:"metadata"`

	// Secret The actual secret, only included if "include_secret" param is true.
	Secret *string `json:"secret"`
}

GetPipelineSecretResponse defines model for GetPipelineSecretResponse.

type GetRunObjectResp

type GetRunObjectResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetRunObjectResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetRunObjectResp

func ParseGetRunObjectResp(rsp *http.Response) (*GetRunObjectResp, error)

ParseGetRunObjectResp parses an HTTP response from a GetRunObjectWithResponse call

func (GetRunObjectResp) Status

func (r GetRunObjectResp) Status() string

Status returns HTTPResponse.Status

func (GetRunObjectResp) StatusCode

func (r GetRunObjectResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetRunObjectResponse

type GetRunObjectResponse struct {
	// Object The requested object data.
	Object []uint8 `json:"object"`
}

GetRunObjectResponse defines model for GetRunObjectResponse.

type GetRunResp

type GetRunResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetRunResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetRunResp

func ParseGetRunResp(rsp *http.Response) (*GetRunResp, error)

ParseGetRunResp parses an HTTP response from a GetRunWithResponse call

func (GetRunResp) Status

func (r GetRunResp) Status() string

Status returns HTTPResponse.Status

func (GetRunResp) StatusCode

func (r GetRunResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetRunResponse

type GetRunResponse struct {
	// Run The run requested.
	Run Run `json:"run"`
}

GetRunResponse defines model for GetRunResponse.

type GetSubscriptionResp

type GetSubscriptionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetSubscriptionResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetSubscriptionResp

func ParseGetSubscriptionResp(rsp *http.Response) (*GetSubscriptionResp, error)

ParseGetSubscriptionResp parses an HTTP response from a GetSubscriptionWithResponse call

func (GetSubscriptionResp) Status

func (r GetSubscriptionResp) Status() string

Status returns HTTPResponse.Status

func (GetSubscriptionResp) StatusCode

func (r GetSubscriptionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetSubscriptionResponse

type GetSubscriptionResponse struct {
	// Subscription The metadata for the subscription.
	Subscription Subscription `json:"subscription"`
}

GetSubscriptionResponse defines model for GetSubscriptionResponse.

type GetSystemMetadataResponse

type GetSystemMetadataResponse struct {
	// Commit The commit of the current build.
	Commit string `json:"commit"`

	// Semver The semver version of the current build.
	Semver string `json:"semver"`
}

GetSystemMetadataResponse defines model for GetSystemMetadataResponse.

type GetTaskExecutionResp

type GetTaskExecutionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetTaskExecutionResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetTaskExecutionResp

func ParseGetTaskExecutionResp(rsp *http.Response) (*GetTaskExecutionResp, error)

ParseGetTaskExecutionResp parses an HTTP response from a GetTaskExecutionWithResponse call

func (GetTaskExecutionResp) Status

func (r GetTaskExecutionResp) Status() string

Status returns HTTPResponse.Status

func (GetTaskExecutionResp) StatusCode

func (r GetTaskExecutionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetTaskExecutionResponse

type GetTaskExecutionResponse struct {
	// TaskExecution The task execution requested.
	TaskExecution TaskExecution `json:"task_execution"`
}

GetTaskExecutionResponse defines model for GetTaskExecutionResponse.

type GetTokenByIDResponse

type GetTokenByIDResponse struct {
	// Token The target token.
	Token Token `json:"token"`
}

GetTokenByIDResponse defines model for GetTokenByIDResponse.

type GetTokenByIdResp

type GetTokenByIdResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetTokenByIDResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseGetTokenByIdResp

func ParseGetTokenByIdResp(rsp *http.Response) (*GetTokenByIdResp, error)

ParseGetTokenByIdResp parses an HTTP response from a GetTokenByIdWithResponse call

func (GetTokenByIdResp) Status

func (r GetTokenByIdResp) Status() string

Status returns HTTPResponse.Status

func (GetTokenByIdResp) StatusCode

func (r GetTokenByIdResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GoferAPIVersion

type GoferAPIVersion string

const (
	GoferAPIVersion0 GoferAPIVersion = "v0"
)

type HttpRequestDoer

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

Doer performs HTTP requests.

The standard http.Client implements this interface.

type Initiator

type Initiator struct {
	// Kind Which type of user initiated the run.
	Kind InitiatorType `json:"kind"`

	// Name The name of the user which initiated the run.
	Name string `json:"name"`

	// Reason The reason the run was initiated.
	Reason string `json:"reason"`
}

Initiator defines model for Initiator.

type InitiatorType

type InitiatorType string

InitiatorType defines model for InitiatorType.

const (
	InitiatorTypeBot       InitiatorType = "bot"
	InitiatorTypeExtension InitiatorType = "extension"
	InitiatorTypeHuman     InitiatorType = "human"
	InitiatorTypeOther     InitiatorType = "other"
)

Defines values for InitiatorType.

type InstallExtensionJSONRequestBody

type InstallExtensionJSONRequestBody = InstallExtensionRequest

InstallExtensionJSONRequestBody defines body for InstallExtension for application/json ContentType.

type InstallExtensionRequest

type InstallExtensionRequest struct {
	// Id A unique id for the extension. Since this needs to only be unique across extensions simply using the extension's name usually suffices.
	Id string `json:"id"`

	// Image The container image this extension should use.
	Image string `json:"image"`

	// RegistryAuth Registry auth credentials
	RegistryAuth *RegistryAuth `json:"registry_auth"`

	// Settings Each extension has a list of settings it takes to configure how it runs. You can usually find this in the documentation.
	Settings map[string]string `json:"settings"`
}

InstallExtensionRequest defines model for InstallExtensionRequest.

type InstallExtensionResp

type InstallExtensionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *InstallExtensionResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseInstallExtensionResp

func ParseInstallExtensionResp(rsp *http.Response) (*InstallExtensionResp, error)

ParseInstallExtensionResp parses an HTTP response from a InstallExtensionWithResponse call

func (InstallExtensionResp) Status

func (r InstallExtensionResp) Status() string

Status returns HTTPResponse.Status

func (InstallExtensionResp) StatusCode

func (r InstallExtensionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type InstallExtensionResponse

type InstallExtensionResponse struct {
	// Extension An Extension is the way that pipelines add extra functionality to themselves. Pipelines can "subscribe" to extensions and extensions then act on behalf of that pipeline.
	Extension Extension `json:"extension"`
}

InstallExtensionResponse defines model for InstallExtensionResponse.

type Kind

type Kind struct {
	// contains filtered or unexported fields
}

Kind defines model for Kind.

func (Kind) AsKind0

func (t Kind) AsKind0() (Kind0, error)

AsKind0 returns the union data inside the Kind as a Kind0

func (Kind) AsKind1

func (t Kind) AsKind1() (Kind1, error)

AsKind1 returns the union data inside the Kind as a Kind1

func (Kind) AsKind10

func (t Kind) AsKind10() (Kind10, error)

AsKind10 returns the union data inside the Kind as a Kind10

func (Kind) AsKind11

func (t Kind) AsKind11() (Kind11, error)

AsKind11 returns the union data inside the Kind as a Kind11

func (Kind) AsKind12

func (t Kind) AsKind12() (Kind12, error)

AsKind12 returns the union data inside the Kind as a Kind12

func (Kind) AsKind13

func (t Kind) AsKind13() (Kind13, error)

AsKind13 returns the union data inside the Kind as a Kind13

func (Kind) AsKind14

func (t Kind) AsKind14() (Kind14, error)

AsKind14 returns the union data inside the Kind as a Kind14

func (Kind) AsKind15

func (t Kind) AsKind15() (Kind15, error)

AsKind15 returns the union data inside the Kind as a Kind15

func (Kind) AsKind16

func (t Kind) AsKind16() (Kind16, error)

AsKind16 returns the union data inside the Kind as a Kind16

func (Kind) AsKind17

func (t Kind) AsKind17() (Kind17, error)

AsKind17 returns the union data inside the Kind as a Kind17

func (Kind) AsKind18

func (t Kind) AsKind18() (Kind18, error)

AsKind18 returns the union data inside the Kind as a Kind18

func (Kind) AsKind19

func (t Kind) AsKind19() (Kind19, error)

AsKind19 returns the union data inside the Kind as a Kind19

func (Kind) AsKind2

func (t Kind) AsKind2() (Kind2, error)

AsKind2 returns the union data inside the Kind as a Kind2

func (Kind) AsKind3

func (t Kind) AsKind3() (Kind3, error)

AsKind3 returns the union data inside the Kind as a Kind3

func (Kind) AsKind4

func (t Kind) AsKind4() (Kind4, error)

AsKind4 returns the union data inside the Kind as a Kind4

func (Kind) AsKind5

func (t Kind) AsKind5() (Kind5, error)

AsKind5 returns the union data inside the Kind as a Kind5

func (Kind) AsKind6

func (t Kind) AsKind6() (Kind6, error)

AsKind6 returns the union data inside the Kind as a Kind6

func (Kind) AsKind7

func (t Kind) AsKind7() (Kind7, error)

AsKind7 returns the union data inside the Kind as a Kind7

func (Kind) AsKind8

func (t Kind) AsKind8() (Kind8, error)

AsKind8 returns the union data inside the Kind as a Kind8

func (Kind) AsKind9

func (t Kind) AsKind9() (Kind9, error)

AsKind9 returns the union data inside the Kind as a Kind9

func (*Kind) FromKind0

func (t *Kind) FromKind0(v Kind0) error

FromKind0 overwrites any union data inside the Kind as the provided Kind0

func (*Kind) FromKind1

func (t *Kind) FromKind1(v Kind1) error

FromKind1 overwrites any union data inside the Kind as the provided Kind1

func (*Kind) FromKind10

func (t *Kind) FromKind10(v Kind10) error

FromKind10 overwrites any union data inside the Kind as the provided Kind10

func (*Kind) FromKind11

func (t *Kind) FromKind11(v Kind11) error

FromKind11 overwrites any union data inside the Kind as the provided Kind11

func (*Kind) FromKind12

func (t *Kind) FromKind12(v Kind12) error

FromKind12 overwrites any union data inside the Kind as the provided Kind12

func (*Kind) FromKind13

func (t *Kind) FromKind13(v Kind13) error

FromKind13 overwrites any union data inside the Kind as the provided Kind13

func (*Kind) FromKind14

func (t *Kind) FromKind14(v Kind14) error

FromKind14 overwrites any union data inside the Kind as the provided Kind14

func (*Kind) FromKind15

func (t *Kind) FromKind15(v Kind15) error

FromKind15 overwrites any union data inside the Kind as the provided Kind15

func (*Kind) FromKind16

func (t *Kind) FromKind16(v Kind16) error

FromKind16 overwrites any union data inside the Kind as the provided Kind16

func (*Kind) FromKind17

func (t *Kind) FromKind17(v Kind17) error

FromKind17 overwrites any union data inside the Kind as the provided Kind17

func (*Kind) FromKind18

func (t *Kind) FromKind18(v Kind18) error

FromKind18 overwrites any union data inside the Kind as the provided Kind18

func (*Kind) FromKind19

func (t *Kind) FromKind19(v Kind19) error

FromKind19 overwrites any union data inside the Kind as the provided Kind19

func (*Kind) FromKind2

func (t *Kind) FromKind2(v Kind2) error

FromKind2 overwrites any union data inside the Kind as the provided Kind2

func (*Kind) FromKind3

func (t *Kind) FromKind3(v Kind3) error

FromKind3 overwrites any union data inside the Kind as the provided Kind3

func (*Kind) FromKind4

func (t *Kind) FromKind4(v Kind4) error

FromKind4 overwrites any union data inside the Kind as the provided Kind4

func (*Kind) FromKind5

func (t *Kind) FromKind5(v Kind5) error

FromKind5 overwrites any union data inside the Kind as the provided Kind5

func (*Kind) FromKind6

func (t *Kind) FromKind6(v Kind6) error

FromKind6 overwrites any union data inside the Kind as the provided Kind6

func (*Kind) FromKind7

func (t *Kind) FromKind7(v Kind7) error

FromKind7 overwrites any union data inside the Kind as the provided Kind7

func (*Kind) FromKind8

func (t *Kind) FromKind8(v Kind8) error

FromKind8 overwrites any union data inside the Kind as the provided Kind8

func (*Kind) FromKind9

func (t *Kind) FromKind9(v Kind9) error

FromKind9 overwrites any union data inside the Kind as the provided Kind9

func (Kind) MarshalJSON

func (t Kind) MarshalJSON() ([]byte, error)

func (*Kind) MergeKind0

func (t *Kind) MergeKind0(v Kind0) error

MergeKind0 performs a merge with any union data inside the Kind, using the provided Kind0

func (*Kind) MergeKind1

func (t *Kind) MergeKind1(v Kind1) error

MergeKind1 performs a merge with any union data inside the Kind, using the provided Kind1

func (*Kind) MergeKind10

func (t *Kind) MergeKind10(v Kind10) error

MergeKind10 performs a merge with any union data inside the Kind, using the provided Kind10

func (*Kind) MergeKind11

func (t *Kind) MergeKind11(v Kind11) error

MergeKind11 performs a merge with any union data inside the Kind, using the provided Kind11

func (*Kind) MergeKind12

func (t *Kind) MergeKind12(v Kind12) error

MergeKind12 performs a merge with any union data inside the Kind, using the provided Kind12

func (*Kind) MergeKind13

func (t *Kind) MergeKind13(v Kind13) error

MergeKind13 performs a merge with any union data inside the Kind, using the provided Kind13

func (*Kind) MergeKind14

func (t *Kind) MergeKind14(v Kind14) error

MergeKind14 performs a merge with any union data inside the Kind, using the provided Kind14

func (*Kind) MergeKind15

func (t *Kind) MergeKind15(v Kind15) error

MergeKind15 performs a merge with any union data inside the Kind, using the provided Kind15

func (*Kind) MergeKind16

func (t *Kind) MergeKind16(v Kind16) error

MergeKind16 performs a merge with any union data inside the Kind, using the provided Kind16

func (*Kind) MergeKind17

func (t *Kind) MergeKind17(v Kind17) error

MergeKind17 performs a merge with any union data inside the Kind, using the provided Kind17

func (*Kind) MergeKind18

func (t *Kind) MergeKind18(v Kind18) error

MergeKind18 performs a merge with any union data inside the Kind, using the provided Kind18

func (*Kind) MergeKind19

func (t *Kind) MergeKind19(v Kind19) error

MergeKind19 performs a merge with any union data inside the Kind, using the provided Kind19

func (*Kind) MergeKind2

func (t *Kind) MergeKind2(v Kind2) error

MergeKind2 performs a merge with any union data inside the Kind, using the provided Kind2

func (*Kind) MergeKind3

func (t *Kind) MergeKind3(v Kind3) error

MergeKind3 performs a merge with any union data inside the Kind, using the provided Kind3

func (*Kind) MergeKind4

func (t *Kind) MergeKind4(v Kind4) error

MergeKind4 performs a merge with any union data inside the Kind, using the provided Kind4

func (*Kind) MergeKind5

func (t *Kind) MergeKind5(v Kind5) error

MergeKind5 performs a merge with any union data inside the Kind, using the provided Kind5

func (*Kind) MergeKind6

func (t *Kind) MergeKind6(v Kind6) error

MergeKind6 performs a merge with any union data inside the Kind, using the provided Kind6

func (*Kind) MergeKind7

func (t *Kind) MergeKind7(v Kind7) error

MergeKind7 performs a merge with any union data inside the Kind, using the provided Kind7

func (*Kind) MergeKind8

func (t *Kind) MergeKind8(v Kind8) error

MergeKind8 performs a merge with any union data inside the Kind, using the provided Kind8

func (*Kind) MergeKind9

func (t *Kind) MergeKind9(v Kind9) error

MergeKind9 performs a merge with any union data inside the Kind, using the provided Kind9

func (*Kind) UnmarshalJSON

func (t *Kind) UnmarshalJSON(b []byte) error

type Kind0

type Kind0 string

Kind0 The Any kind is a special event kind that denotes the caller wants to listen for any event. It should not be used as a normal event type(for example do not publish anything with it). It is internal only and not passed back on event streaming.

const (
	Kind0Any Kind0 = "any"
)

Defines values for Kind0.

type Kind1

type Kind1 struct {
	CreatedNamespace struct {
		NamespaceId string `json:"namespace_id"`
	} `json:"created_namespace"`
}

Kind1 defines model for .

type Kind10

type Kind10 struct {
	CompletedRun struct {
		NamespaceId string    `json:"namespace_id"`
		PipelineId  string    `json:"pipeline_id"`
		RunId       uint64    `json:"run_id"`
		Status      RunStatus `json:"status"`
	} `json:"completed_run"`
}

Kind10 defines model for .

type Kind11

type Kind11 struct {
	CreatedTaskExecution struct {
		NamespaceId     string `json:"namespace_id"`
		PipelineId      string `json:"pipeline_id"`
		RunId           uint64 `json:"run_id"`
		TaskExecutionId string `json:"task_execution_id"`
	} `json:"created_task_execution"`
}

Kind11 defines model for .

type Kind12

type Kind12 struct {
	StartedTaskExecution struct {
		NamespaceId     string `json:"namespace_id"`
		PipelineId      string `json:"pipeline_id"`
		RunId           uint64 `json:"run_id"`
		TaskExecutionId string `json:"task_execution_id"`
	} `json:"started_task_execution"`
}

Kind12 defines model for .

type Kind13

type Kind13 struct {
	CompletedTaskExecution struct {
		NamespaceId     string              `json:"namespace_id"`
		PipelineId      string              `json:"pipeline_id"`
		RunId           uint64              `json:"run_id"`
		Status          TaskExecutionStatus `json:"status"`
		TaskExecutionId string              `json:"task_execution_id"`
	} `json:"completed_task_execution"`
}

Kind13 defines model for .

type Kind14

type Kind14 struct {
	InstalledExtension struct {
		Id    string `json:"id"`
		Image string `json:"image"`
	} `json:"installed_extension"`
}

Kind14 defines model for .

type Kind15

type Kind15 struct {
	UninstalledExtension struct {
		Id    string `json:"id"`
		Image string `json:"image"`
	} `json:"uninstalled_extension"`
}

Kind15 defines model for .

type Kind16

type Kind16 struct {
	EnabledExtension struct {
		Id    string `json:"id"`
		Image string `json:"image"`
	} `json:"enabled_extension"`
}

Kind16 defines model for .

type Kind17

type Kind17 struct {
	DisabledExtension struct {
		Id    string `json:"id"`
		Image string `json:"image"`
	} `json:"disabled_extension"`
}

Kind17 defines model for .

type Kind18

type Kind18 struct {
	ExtensionSubscription struct {
		ExtensionId    string `json:"extension_id"`
		NamespaceId    string `json:"namespace_id"`
		PipelineId     string `json:"pipeline_id"`
		SubscriptionId string `json:"subscription_id"`
	} `json:"extension_subscription"`
}

Kind18 defines model for .

type Kind19

type Kind19 struct {
	ExtensionUnsubscription struct {
		ExtensionId    string `json:"extension_id"`
		NamespaceId    string `json:"namespace_id"`
		PipelineId     string `json:"pipeline_id"`
		SubscriptionId string `json:"subscription_id"`
	} `json:"extension_unsubscription"`
}

Kind19 defines model for .

type Kind2

type Kind2 struct {
	DeletedNamespace struct {
		NamespaceId string `json:"namespace_id"`
	} `json:"deleted_namespace"`
}

Kind2 defines model for .

type Kind3

type Kind3 struct {
	DisabledPipeline struct {
		NamespaceId string `json:"namespace_id"`
		PipelineId  string `json:"pipeline_id"`
	} `json:"disabled_pipeline"`
}

Kind3 defines model for .

type Kind4

type Kind4 struct {
	EnabledPipeline struct {
		NamespaceId string `json:"namespace_id"`
		PipelineId  string `json:"pipeline_id"`
	} `json:"enabled_pipeline"`
}

Kind4 defines model for .

type Kind5

type Kind5 struct {
	CreatedPipeline struct {
		NamespaceId string `json:"namespace_id"`
		PipelineId  string `json:"pipeline_id"`
	} `json:"created_pipeline"`
}

Kind5 defines model for .

type Kind6

type Kind6 struct {
	DeletedPipeline struct {
		NamespaceId string `json:"namespace_id"`
		PipelineId  string `json:"pipeline_id"`
	} `json:"deleted_pipeline"`
}

Kind6 defines model for .

type Kind7

type Kind7 struct {
	DeploymentStarted struct {
		EndVersion   uint64 `json:"end_version"`
		NamespaceId  string `json:"namespace_id"`
		PipelineId   string `json:"pipeline_id"`
		StartVersion uint64 `json:"start_version"`
	} `json:"deployment_started"`
}

Kind7 defines model for .

type Kind8

type Kind8 struct {
	DeploymentCompleted struct {
		EndVersion   uint64 `json:"end_version"`
		NamespaceId  string `json:"namespace_id"`
		PipelineId   string `json:"pipeline_id"`
		StartVersion uint64 `json:"start_version"`
	} `json:"deployment_completed"`
}

Kind8 defines model for .

type Kind9

type Kind9 struct {
	StartedRun struct {
		NamespaceId string `json:"namespace_id"`
		PipelineId  string `json:"pipeline_id"`
		RunId       uint64 `json:"run_id"`
	} `json:"started_run"`
}

Kind9 defines model for .

type ListConfigsResp

type ListConfigsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListPipelineConfigsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListConfigsResp

func ParseListConfigsResp(rsp *http.Response) (*ListConfigsResp, error)

ParseListConfigsResp parses an HTTP response from a ListConfigsWithResponse call

func (ListConfigsResp) Status

func (r ListConfigsResp) Status() string

Status returns HTTPResponse.Status

func (ListConfigsResp) StatusCode

func (r ListConfigsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListDeploymentsResp

type ListDeploymentsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListDeploymentsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListDeploymentsResp

func ParseListDeploymentsResp(rsp *http.Response) (*ListDeploymentsResp, error)

ParseListDeploymentsResp parses an HTTP response from a ListDeploymentsWithResponse call

func (ListDeploymentsResp) Status

func (r ListDeploymentsResp) Status() string

Status returns HTTPResponse.Status

func (ListDeploymentsResp) StatusCode

func (r ListDeploymentsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListDeploymentsResponse

type ListDeploymentsResponse struct {
	// Deployments A list of all deployments.
	Deployments []Deployment `json:"deployments"`
}

ListDeploymentsResponse defines model for ListDeploymentsResponse.

type ListExtensionsResp

type ListExtensionsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListExtensionsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListExtensionsResp

func ParseListExtensionsResp(rsp *http.Response) (*ListExtensionsResp, error)

ParseListExtensionsResp parses an HTTP response from a ListExtensionsWithResponse call

func (ListExtensionsResp) Status

func (r ListExtensionsResp) Status() string

Status returns HTTPResponse.Status

func (ListExtensionsResp) StatusCode

func (r ListExtensionsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListExtensionsResponse

type ListExtensionsResponse struct {
	// Extensions A list of all extensions.
	Extensions []Extension `json:"extensions"`
}

ListExtensionsResponse defines model for ListExtensionsResponse.

type ListGlobalSecretsResp

type ListGlobalSecretsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListGlobalSecretsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListGlobalSecretsResp

func ParseListGlobalSecretsResp(rsp *http.Response) (*ListGlobalSecretsResp, error)

ParseListGlobalSecretsResp parses an HTTP response from a ListGlobalSecretsWithResponse call

func (ListGlobalSecretsResp) Status

func (r ListGlobalSecretsResp) Status() string

Status returns HTTPResponse.Status

func (ListGlobalSecretsResp) StatusCode

func (r ListGlobalSecretsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListGlobalSecretsResponse

type ListGlobalSecretsResponse struct {
	// Secrets A list of all global secrets.
	Secrets []Secret `json:"secrets"`
}

ListGlobalSecretsResponse defines model for ListGlobalSecretsResponse.

type ListNamespacesResp

type ListNamespacesResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListNamespacesResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListNamespacesResp

func ParseListNamespacesResp(rsp *http.Response) (*ListNamespacesResp, error)

ParseListNamespacesResp parses an HTTP response from a ListNamespacesWithResponse call

func (ListNamespacesResp) Status

func (r ListNamespacesResp) Status() string

Status returns HTTPResponse.Status

func (ListNamespacesResp) StatusCode

func (r ListNamespacesResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListNamespacesResponse

type ListNamespacesResponse struct {
	// Namespaces A list of all namespaces.
	Namespaces []Namespace `json:"namespaces"`
}

ListNamespacesResponse defines model for ListNamespacesResponse.

type ListPipelineConfigsResponse

type ListPipelineConfigsResponse struct {
	// Configs A list of all pipelines configs.
	Configs []Config `json:"configs"`
}

ListPipelineConfigsResponse defines model for ListPipelineConfigsResponse.

type ListPipelineObjectsResp

type ListPipelineObjectsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListPipelineObjectsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListPipelineObjectsResp

func ParseListPipelineObjectsResp(rsp *http.Response) (*ListPipelineObjectsResp, error)

ParseListPipelineObjectsResp parses an HTTP response from a ListPipelineObjectsWithResponse call

func (ListPipelineObjectsResp) Status

func (r ListPipelineObjectsResp) Status() string

Status returns HTTPResponse.Status

func (ListPipelineObjectsResp) StatusCode

func (r ListPipelineObjectsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListPipelineObjectsResponse

type ListPipelineObjectsResponse struct {
	// Objects A list of all pipeline objects.
	Objects []Object `json:"objects"`
}

ListPipelineObjectsResponse defines model for ListPipelineObjectsResponse.

type ListPipelineSecretsResp

type ListPipelineSecretsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListPipelineSecretsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListPipelineSecretsResp

func ParseListPipelineSecretsResp(rsp *http.Response) (*ListPipelineSecretsResp, error)

ParseListPipelineSecretsResp parses an HTTP response from a ListPipelineSecretsWithResponse call

func (ListPipelineSecretsResp) Status

func (r ListPipelineSecretsResp) Status() string

Status returns HTTPResponse.Status

func (ListPipelineSecretsResp) StatusCode

func (r ListPipelineSecretsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListPipelineSecretsResponse

type ListPipelineSecretsResponse struct {
	// Secrets A list of all pipeline secrets.
	Secrets []Secret `json:"secrets"`
}

ListPipelineSecretsResponse defines model for ListPipelineSecretsResponse.

type ListPipelinesResp

type ListPipelinesResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListPipelinesResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListPipelinesResp

func ParseListPipelinesResp(rsp *http.Response) (*ListPipelinesResp, error)

ParseListPipelinesResp parses an HTTP response from a ListPipelinesWithResponse call

func (ListPipelinesResp) Status

func (r ListPipelinesResp) Status() string

Status returns HTTPResponse.Status

func (ListPipelinesResp) StatusCode

func (r ListPipelinesResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListPipelinesResponse

type ListPipelinesResponse struct {
	// Pipelines A list of all pipelines metadata.
	Pipelines []Metadata `json:"pipelines"`
}

ListPipelinesResponse defines model for ListPipelinesResponse.

type ListRunObjectsResp

type ListRunObjectsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListRunObjectsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListRunObjectsResp

func ParseListRunObjectsResp(rsp *http.Response) (*ListRunObjectsResp, error)

ParseListRunObjectsResp parses an HTTP response from a ListRunObjectsWithResponse call

func (ListRunObjectsResp) Status

func (r ListRunObjectsResp) Status() string

Status returns HTTPResponse.Status

func (ListRunObjectsResp) StatusCode

func (r ListRunObjectsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListRunObjectsResponse

type ListRunObjectsResponse struct {
	// Objects A list of all run objects.
	Objects []Object `json:"objects"`
}

ListRunObjectsResponse defines model for ListRunObjectsResponse.

type ListRunsParams

type ListRunsParams struct {
	Limit   *uint64 `form:"limit,omitempty" json:"limit,omitempty"`
	Offset  *uint64 `form:"offset,omitempty" json:"offset,omitempty"`
	Reverse *bool   `form:"reverse,omitempty" json:"reverse,omitempty"`
}

ListRunsParams defines parameters for ListRuns.

type ListRunsResp

type ListRunsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListRunsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListRunsResp

func ParseListRunsResp(rsp *http.Response) (*ListRunsResp, error)

ParseListRunsResp parses an HTTP response from a ListRunsWithResponse call

func (ListRunsResp) Status

func (r ListRunsResp) Status() string

Status returns HTTPResponse.Status

func (ListRunsResp) StatusCode

func (r ListRunsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListRunsResponse

type ListRunsResponse struct {
	// Runs A list of all runs.
	Runs []Run `json:"runs"`
}

ListRunsResponse defines model for ListRunsResponse.

type ListSubscriptionsResp

type ListSubscriptionsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListSubscriptionsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListSubscriptionsResp

func ParseListSubscriptionsResp(rsp *http.Response) (*ListSubscriptionsResp, error)

ParseListSubscriptionsResp parses an HTTP response from a ListSubscriptionsWithResponse call

func (ListSubscriptionsResp) Status

func (r ListSubscriptionsResp) Status() string

Status returns HTTPResponse.Status

func (ListSubscriptionsResp) StatusCode

func (r ListSubscriptionsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListSubscriptionsResponse

type ListSubscriptionsResponse struct {
	// Subscriptions A list of all pipeline subscriptions.
	Subscriptions []Subscription `json:"subscriptions"`
}

ListSubscriptionsResponse defines model for ListSubscriptionsResponse.

type ListTaskExecutionsResp

type ListTaskExecutionsResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListTaskExecutionsResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListTaskExecutionsResp

func ParseListTaskExecutionsResp(rsp *http.Response) (*ListTaskExecutionsResp, error)

ParseListTaskExecutionsResp parses an HTTP response from a ListTaskExecutionsWithResponse call

func (ListTaskExecutionsResp) Status

func (r ListTaskExecutionsResp) Status() string

Status returns HTTPResponse.Status

func (ListTaskExecutionsResp) StatusCode

func (r ListTaskExecutionsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListTaskExecutionsResponse

type ListTaskExecutionsResponse struct {
	// TaskExecutions A list of all task executions.
	TaskExecutions []TaskExecution `json:"task_executions"`
}

ListTaskExecutionsResponse defines model for ListTaskExecutionsResponse.

type ListTokensResp

type ListTokensResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListTokensResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseListTokensResp

func ParseListTokensResp(rsp *http.Response) (*ListTokensResp, error)

ParseListTokensResp parses an HTTP response from a ListTokensWithResponse call

func (ListTokensResp) Status

func (r ListTokensResp) Status() string

Status returns HTTPResponse.Status

func (ListTokensResp) StatusCode

func (r ListTokensResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListTokensResponse

type ListTokensResponse struct {
	// Tokens A list of all tokens.
	Tokens []Token `json:"tokens"`
}

ListTokensResponse defines model for ListTokensResponse.

type Metadata

type Metadata struct {
	// Created Time of pipeline creation in epoch milliseconds.
	Created int `json:"created"`

	// Modified Time pipeline was updated to a new version in epoch milliseconds.
	Modified int `json:"modified"`

	// NamespaceId Unique identifier of the target namespace.
	NamespaceId string `json:"namespace_id"`

	// PipelineId Unique identifier of the target pipeline.
	PipelineId string `json:"pipeline_id"`

	// State The current running state of the pipeline. This is used to determine if the pipeline should run or not.
	State PipelineState `json:"state"`
}

Metadata Details about the pipeline itself, not including the configuration that the user can change. All these values are changed by the system or never changed at all. This sits in contrast to the config which the user can change freely.

type Namespace

type Namespace struct {
	// Created Time in epoch milliseconds when namespace was created.
	Created int `json:"created"`

	// Description Short description about what the namespace is used for.
	Description string `json:"description"`

	// Id Unique identifier for the namespace.
	Id string `json:"id"`

	// Modified Time in epoch milliseconds when namespace would expire.
	Modified int `json:"modified"`

	// Name Humanized name for the namespace.
	Name string `json:"name"`
}

Namespace A namespace represents a grouping of pipelines. Normally it is used to divide teams or logically different sections of workloads. It is the highest level unit as it sits above pipelines in the hierarchy of Gofer.

type Object

type Object struct {
	// Created Time in epoch milliseconds that this object was registered.
	Created int `json:"created"`

	// Key The identifier for the object value.
	Key string `json:"key"`
}

Object defines model for Object.

type Parameter

type Parameter struct {
	Documentation string `json:"documentation"`
	Key           string `json:"key"`
	Required      bool   `json:"required"`
}

Parameter defines model for Parameter.

type Pipeline

type Pipeline struct {
	// Description Short description of what the pipeline is used for.
	Description *string `json:"description"`

	// Id Unique user defined identifier.
	Id string `json:"id"`

	// Name Humanized name, meant for display.
	Name string `json:"name"`

	// Parallelism Controls how many runs can be active at any single time. 0 defaults to whatever the global Gofer setting is.
	Parallelism int64 `json:"parallelism"`

	// Tasks A mapping of pipeline owned tasks.
	Tasks []Task2 `json:"tasks"`
}

Pipeline `Pipeline` represents a sequence of tasks, where each task is a discrete unit of work encapsulated within a container. This structure allows you to organize and define the workflow for the tasks you want to execute.

Example

The following example demonstrates how to create a simple pipeline in Gofer, which is familiar to those experienced with CI/CD tooling. It outlines how to define a simple task within a pipeline, use a standard Ubuntu container, and execute a basic command.

This simple example serves as a foundation, illustrating the pattern of defining tasks as building blocks of a pipeline. In practice, you would create custom containers designed specifically for the tasks in your Gofer workflows, keeping your pipeline configuration clean and focused on orchestration rather than embedding complex logic.

```ignore // Create a new pipeline with a name and a descriptive label. Pipeline::new("simple", "Simple Pipeline") .description("This pipeline demonstrates a simple Gofer pipeline that pulls in a container and runs a command. \ This pattern will be familiar to those experienced with CI/CD tools. \ Tasks in this pipeline are individual containers that can depend on other tasks, illustrating the modular nature of Gofer.") // Adding a single task to the pipeline. .tasks(vec![ Task::new("simple_task", "ubuntu:latest") .description("This task uses the Ubuntu container to print a 'Hello World' message.") .command(vec!["echo".to_string(), "Hello from Gofer!".to_string()]) ]) .finish() // Finalize and validate the pipeline setup. .unwrap(); // Handle potential errors during pipeline creation. ```

type Pipeline2

type Pipeline2 struct {
	// Config User controlled data for the targeted pipeline.
	Config Config `json:"config"`

	// Metadata Macro level details on the targeted pipeline.
	Metadata Metadata `json:"metadata"`
}

Pipeline2 A collection of logically grouped tasks. A task is a unit of work wrapped in a docker container. Pipeline is a secondary level unit being contained within namespaces and containing runs.

type PipelineState

type PipelineState string

PipelineState defines model for PipelineState.

const (
	PipelineStateActive   PipelineState = "active"
	PipelineStateDisabled PipelineState = "disabled"
	PipelineStateUnknown  PipelineState = "unknown"
)

Defines values for PipelineState.

type PutGlobalSecretJSONRequestBody

type PutGlobalSecretJSONRequestBody = PutGlobalSecretRequest

PutGlobalSecretJSONRequestBody defines body for PutGlobalSecret for application/json ContentType.

type PutGlobalSecretRequest

type PutGlobalSecretRequest struct {
	// Content The actual plaintext secret.
	Content string `json:"content"`

	// Force Overwrite a value of a secret if it already exists.
	Force bool `json:"force"`

	// Key The name for the secret you would like to store.
	Key string `json:"key"`

	// Namespaces The namespaces you want this secret to be accessible by. Accepts Regexes.
	Namespaces []string `json:"namespaces"`
}

PutGlobalSecretRequest defines model for PutGlobalSecretRequest.

type PutGlobalSecretResp

type PutGlobalSecretResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *PutGlobalSecretResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParsePutGlobalSecretResp

func ParsePutGlobalSecretResp(rsp *http.Response) (*PutGlobalSecretResp, error)

ParsePutGlobalSecretResp parses an HTTP response from a PutGlobalSecretWithResponse call

func (PutGlobalSecretResp) Status

func (r PutGlobalSecretResp) Status() string

Status returns HTTPResponse.Status

func (PutGlobalSecretResp) StatusCode

func (r PutGlobalSecretResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutGlobalSecretResponse

type PutGlobalSecretResponse struct {
	// Secret Information about the secret created.
	Secret Secret `json:"secret"`
}

PutGlobalSecretResponse defines model for PutGlobalSecretResponse.

type PutPipelineObjectJSONRequestBody

type PutPipelineObjectJSONRequestBody = PutPipelineObjectRequest

PutPipelineObjectJSONRequestBody defines body for PutPipelineObject for application/json ContentType.

type PutPipelineObjectRequest

type PutPipelineObjectRequest struct {
	// Content The bytes for the object.
	Content []uint8 `json:"content"`

	// Force Overwrite a value of a object if it already exists.
	Force bool `json:"force"`

	// Key The name for the object you would like to store.
	Key string `json:"key"`
}

PutPipelineObjectRequest defines model for PutPipelineObjectRequest.

type PutPipelineObjectResp

type PutPipelineObjectResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *PutPipelineObjectResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParsePutPipelineObjectResp

func ParsePutPipelineObjectResp(rsp *http.Response) (*PutPipelineObjectResp, error)

ParsePutPipelineObjectResp parses an HTTP response from a PutPipelineObjectWithResponse call

func (PutPipelineObjectResp) Status

func (r PutPipelineObjectResp) Status() string

Status returns HTTPResponse.Status

func (PutPipelineObjectResp) StatusCode

func (r PutPipelineObjectResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutPipelineObjectResponse

type PutPipelineObjectResponse struct {
	// Object Information about the object created.
	Object Object `json:"object"`
}

PutPipelineObjectResponse defines model for PutPipelineObjectResponse.

type PutPipelineSecretJSONRequestBody

type PutPipelineSecretJSONRequestBody = PutPipelineSecretRequest

PutPipelineSecretJSONRequestBody defines body for PutPipelineSecret for application/json ContentType.

type PutPipelineSecretRequest

type PutPipelineSecretRequest struct {
	// Content The actual plaintext secret.
	Content string `json:"content"`

	// Force Overwrite a value of a secret if it already exists.
	Force bool `json:"force"`

	// Key The name for the secret you would like to store.
	Key string `json:"key"`
}

PutPipelineSecretRequest defines model for PutPipelineSecretRequest.

type PutPipelineSecretResp

type PutPipelineSecretResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *PutPipelineSecretResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParsePutPipelineSecretResp

func ParsePutPipelineSecretResp(rsp *http.Response) (*PutPipelineSecretResp, error)

ParsePutPipelineSecretResp parses an HTTP response from a PutPipelineSecretWithResponse call

func (PutPipelineSecretResp) Status

func (r PutPipelineSecretResp) Status() string

Status returns HTTPResponse.Status

func (PutPipelineSecretResp) StatusCode

func (r PutPipelineSecretResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutPipelineSecretResponse

type PutPipelineSecretResponse struct {
	// Secret Information about the secret created.
	Secret Secret `json:"secret"`
}

PutPipelineSecretResponse defines model for PutPipelineSecretResponse.

type PutRunObjectJSONRequestBody

type PutRunObjectJSONRequestBody = PutRunObjectRequest

PutRunObjectJSONRequestBody defines body for PutRunObject for application/json ContentType.

type PutRunObjectRequest

type PutRunObjectRequest struct {
	// Content The bytes for the object.
	Content []uint8 `json:"content"`

	// Force Overwrite a value of a object if it already exists.
	Force bool `json:"force"`

	// Key The name for the object you would like to store.
	Key string `json:"key"`
}

PutRunObjectRequest defines model for PutRunObjectRequest.

type PutRunObjectResp

type PutRunObjectResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *PutRunObjectResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParsePutRunObjectResp

func ParsePutRunObjectResp(rsp *http.Response) (*PutRunObjectResp, error)

ParsePutRunObjectResp parses an HTTP response from a PutRunObjectWithResponse call

func (PutRunObjectResp) Status

func (r PutRunObjectResp) Status() string

Status returns HTTPResponse.Status

func (PutRunObjectResp) StatusCode

func (r PutRunObjectResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutRunObjectResponse

type PutRunObjectResponse struct {
	// Object Information about the object created.
	Object Object `json:"object"`
}

PutRunObjectResponse defines model for PutRunObjectResponse.

type RegisterConfigJSONRequestBody

type RegisterConfigJSONRequestBody = RegisterPipelineConfigRequest

RegisterConfigJSONRequestBody defines body for RegisterConfig for application/json ContentType.

type RegisterConfigResp

type RegisterConfigResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *RegisterPipelineConfigResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseRegisterConfigResp

func ParseRegisterConfigResp(rsp *http.Response) (*RegisterConfigResp, error)

ParseRegisterConfigResp parses an HTTP response from a RegisterConfigWithResponse call

func (RegisterConfigResp) Status

func (r RegisterConfigResp) Status() string

Status returns HTTPResponse.Status

func (RegisterConfigResp) StatusCode

func (r RegisterConfigResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RegisterPipelineConfigRequest

type RegisterPipelineConfigRequest struct {
	// Config The pipeline configuration. This is usually supplied by the CLI which translates written code into this format.
	Config Pipeline `json:"config"`
}

RegisterPipelineConfigRequest defines model for RegisterPipelineConfigRequest.

type RegisterPipelineConfigResponse

type RegisterPipelineConfigResponse struct {
	// Pipeline The current pipeline.
	Pipeline Pipeline2 `json:"pipeline"`
}

RegisterPipelineConfigResponse defines model for RegisterPipelineConfigResponse.

type Registration

type Registration struct {
	// Created Time of registration creation in epoch milliseconds.
	Created int `json:"created"`

	// ExtensionId Unique identifier for the extension.
	ExtensionId string `json:"extension_id"`

	// Image Which container image this extension should run.
	Image string `json:"image"`

	// Modified Time of last modification in epoch milliseconds.
	Modified int `json:"modified"`

	// RegistryAuth Auth credentials for the image's registry.
	RegistryAuth *RegistryAuth `json:"registry_auth"`

	// Settings Extensions allow configuration through env vars passed to them through this field. Refer to the extension's documentation for setting values.
	Settings []Variable `json:"settings"`

	// Status Whether the extension is enabled or not; extensions can be disabled to prevent use by admins.
	Status ExtensionStatus `json:"status"`
}

Registration When installing a new extension, we allow the extension installer to pass a bunch of settings that allow us to go get that extension on future startups.

type RegistryAuth

type RegistryAuth struct {
	Pass string `json:"pass"`
	User string `json:"user"`
}

RegistryAuth Authentication information for container registries.

type RegistryAuth2

type RegistryAuth2 struct {
	Pass string `json:"pass"`
	User string `json:"user"`
}

RegistryAuth2 defines model for RegistryAuth2.

type RequestEditorFn

type RequestEditorFn func(ctx context.Context, req *http.Request) error

RequestEditorFn is the function signature for the RequestEditor callback function

type RequiredParentStatus

type RequiredParentStatus string

RequiredParentStatus defines model for RequiredParentStatus.

const (
	RequiredParentStatusAny     RequiredParentStatus = "any"
	RequiredParentStatusFailure RequiredParentStatus = "failure"
	RequiredParentStatusSuccess RequiredParentStatus = "success"
	RequiredParentStatusUnknown RequiredParentStatus = "unknown"
)

Defines values for RequiredParentStatus.

type RequiredParentStatus2

type RequiredParentStatus2 string

RequiredParentStatus2 defines model for RequiredParentStatus2.

const (
	RequiredParentStatus2Any     RequiredParentStatus2 = "Any"
	RequiredParentStatus2Failure RequiredParentStatus2 = "Failure"
	RequiredParentStatus2Success RequiredParentStatus2 = "Success"
	RequiredParentStatus2Unknown RequiredParentStatus2 = "Unknown"
)

Defines values for RequiredParentStatus2.

type Run

type Run struct {
	// Ended Time of run end in epoch milliseconds.
	Ended int `json:"ended"`

	// Initiator Information about what started the run.
	Initiator Initiator `json:"initiator"`

	// NamespaceId Unique identifier of the target namespace.
	NamespaceId string `json:"namespace_id"`

	// PipelineConfigVersion Which version of the pipeline did this run execute.
	PipelineConfigVersion uint64 `json:"pipeline_config_version"`

	// PipelineId Unique identifier of the target pipeline.
	PipelineId string `json:"pipeline_id"`

	// RunId Unique identifier of the target run.
	RunId uint64 `json:"run_id"`

	// Started Time of run start in epoch milliseconds.
	Started int `json:"started"`

	// State The current state of the run within the Gofer execution model. Describes if the run is in progress or not.
	State RunState `json:"state"`

	// Status The final result of the run.
	Status RunStatus `json:"status"`

	// StatusReason More information on the circumstances around a particular run's status.
	StatusReason *RunStatusReason `json:"status_reason"`

	// StoreObjectsExpired Whether run level objects are deleted.
	StoreObjectsExpired bool `json:"store_objects_expired"`

	// TokenId The unique identifier for Gofer's auto-inject token. This feature is so that users can easily use Gofer's API with a ready injected token into the run just-in-time. If this is None this run had no tasks with the `inject_api_token` setting enabled.
	//
	// These tokens automatically expire after a pre-determined time.
	TokenId *string `json:"token_id"`

	// Variables Run level environment variables to be passed to each task execution.
	Variables []Variable `json:"variables"`
}

Run A run is one or more tasks being executed on behalf of some extension. Run is a third level unit containing tasks and being contained in a pipeline.

type RunState

type RunState struct {
	// contains filtered or unexported fields
}

RunState defines model for run_state.

func (RunState) AsRunState0

func (t RunState) AsRunState0() (RunState0, error)

AsRunState0 returns the union data inside the RunState as a RunState0

func (RunState) AsRunState1

func (t RunState) AsRunState1() (RunState1, error)

AsRunState1 returns the union data inside the RunState as a RunState1

func (RunState) AsRunState2

func (t RunState) AsRunState2() (RunState2, error)

AsRunState2 returns the union data inside the RunState as a RunState2

func (RunState) AsRunState3

func (t RunState) AsRunState3() (RunState3, error)

AsRunState3 returns the union data inside the RunState as a RunState3

func (*RunState) FromRunState0

func (t *RunState) FromRunState0(v RunState0) error

FromRunState0 overwrites any union data inside the RunState as the provided RunState0

func (*RunState) FromRunState1

func (t *RunState) FromRunState1(v RunState1) error

FromRunState1 overwrites any union data inside the RunState as the provided RunState1

func (*RunState) FromRunState2

func (t *RunState) FromRunState2(v RunState2) error

FromRunState2 overwrites any union data inside the RunState as the provided RunState2

func (*RunState) FromRunState3

func (t *RunState) FromRunState3(v RunState3) error

FromRunState3 overwrites any union data inside the RunState as the provided RunState3

func (RunState) MarshalJSON

func (t RunState) MarshalJSON() ([]byte, error)

func (*RunState) MergeRunState0

func (t *RunState) MergeRunState0(v RunState0) error

MergeRunState0 performs a merge with any union data inside the RunState, using the provided RunState0

func (*RunState) MergeRunState1

func (t *RunState) MergeRunState1(v RunState1) error

MergeRunState1 performs a merge with any union data inside the RunState, using the provided RunState1

func (*RunState) MergeRunState2

func (t *RunState) MergeRunState2(v RunState2) error

MergeRunState2 performs a merge with any union data inside the RunState, using the provided RunState2

func (*RunState) MergeRunState3

func (t *RunState) MergeRunState3(v RunState3) error

MergeRunState3 performs a merge with any union data inside the RunState, using the provided RunState3

func (*RunState) UnmarshalJSON

func (t *RunState) UnmarshalJSON(b []byte) error

type RunState0

type RunState0 string

RunState0 defines model for RunState.0.

const (
	RunState0Unknown RunState0 = "unknown"
)

Defines values for RunState0.

type RunState1

type RunState1 string

RunState1 Before the tasks in a run are sent to the scheduler it must complete various steps like validation checking. This state represents that step where the run and task executions are pre-checked.

const (
	Pending RunState1 = "pending"
)

Defines values for RunState1.

type RunState2

type RunState2 string

RunState2 Currently running.

const (
	RunState2Running RunState2 = "running"
)

Defines values for RunState2.

type RunState3

type RunState3 string

RunState3 All tasks have been resolved and the run is no longer being executed.

const (
	RunState3Complete RunState3 = "complete"
)

Defines values for RunState3.

type RunStatus

type RunStatus struct {
	// contains filtered or unexported fields
}

RunStatus defines model for run_status.

func (RunStatus) AsRunStatus0

func (t RunStatus) AsRunStatus0() (RunStatus0, error)

AsRunStatus0 returns the union data inside the RunStatus as a RunStatus0

func (RunStatus) AsRunStatus1

func (t RunStatus) AsRunStatus1() (RunStatus1, error)

AsRunStatus1 returns the union data inside the RunStatus as a RunStatus1

func (RunStatus) AsRunStatus2

func (t RunStatus) AsRunStatus2() (RunStatus2, error)

AsRunStatus2 returns the union data inside the RunStatus as a RunStatus2

func (RunStatus) AsRunStatus3

func (t RunStatus) AsRunStatus3() (RunStatus3, error)

AsRunStatus3 returns the union data inside the RunStatus as a RunStatus3

func (*RunStatus) FromRunStatus0

func (t *RunStatus) FromRunStatus0(v RunStatus0) error

FromRunStatus0 overwrites any union data inside the RunStatus as the provided RunStatus0

func (*RunStatus) FromRunStatus1

func (t *RunStatus) FromRunStatus1(v RunStatus1) error

FromRunStatus1 overwrites any union data inside the RunStatus as the provided RunStatus1

func (*RunStatus) FromRunStatus2

func (t *RunStatus) FromRunStatus2(v RunStatus2) error

FromRunStatus2 overwrites any union data inside the RunStatus as the provided RunStatus2

func (*RunStatus) FromRunStatus3

func (t *RunStatus) FromRunStatus3(v RunStatus3) error

FromRunStatus3 overwrites any union data inside the RunStatus as the provided RunStatus3

func (RunStatus) MarshalJSON

func (t RunStatus) MarshalJSON() ([]byte, error)

func (*RunStatus) MergeRunStatus0

func (t *RunStatus) MergeRunStatus0(v RunStatus0) error

MergeRunStatus0 performs a merge with any union data inside the RunStatus, using the provided RunStatus0

func (*RunStatus) MergeRunStatus1

func (t *RunStatus) MergeRunStatus1(v RunStatus1) error

MergeRunStatus1 performs a merge with any union data inside the RunStatus, using the provided RunStatus1

func (*RunStatus) MergeRunStatus2

func (t *RunStatus) MergeRunStatus2(v RunStatus2) error

MergeRunStatus2 performs a merge with any union data inside the RunStatus, using the provided RunStatus2

func (*RunStatus) MergeRunStatus3

func (t *RunStatus) MergeRunStatus3(v RunStatus3) error

MergeRunStatus3 performs a merge with any union data inside the RunStatus, using the provided RunStatus3

func (*RunStatus) UnmarshalJSON

func (t *RunStatus) UnmarshalJSON(b []byte) error

type RunStatus0

type RunStatus0 string

RunStatus0 Could not determine the current state of the status. Should only be in this state if the run has not yet completed.

const (
	RunStatus0Unknown RunStatus0 = "unknown"
)

Defines values for RunStatus0.

type RunStatus1

type RunStatus1 string

RunStatus1 One or more tasks in run have failed.

const (
	RunStatus1Failed RunStatus1 = "failed"
)

Defines values for RunStatus1.

type RunStatus2

type RunStatus2 string

RunStatus2 All tasks in a run have completed with a non-failure state.

const (
	RunStatus2Successful RunStatus2 = "successful"
)

Defines values for RunStatus2.

type RunStatus3

type RunStatus3 string

RunStatus3 One or more tasks in a run have been cancelled.

const (
	RunStatus3Cancelled RunStatus3 = "cancelled"
)

Defines values for RunStatus3.

type RunStatusReason

type RunStatusReason struct {
	// Description A description of why the run might have failed and what was going on at the time.
	Description string `json:"description"`

	// Reason The specific type of run failure.
	Reason RunStatusReasonType `json:"reason"`
}

RunStatusReason defines model for run_status_reason.

type RunStatusReasonType

type RunStatusReasonType struct {
	// contains filtered or unexported fields
}

RunStatusReasonType defines model for run_status_reason_type.

func (RunStatusReasonType) AsRunStatusReasonType0

func (t RunStatusReasonType) AsRunStatusReasonType0() (RunStatusReasonType0, error)

AsRunStatusReasonType0 returns the union data inside the RunStatusReasonType as a RunStatusReasonType0

func (RunStatusReasonType) AsRunStatusReasonType1

func (t RunStatusReasonType) AsRunStatusReasonType1() (RunStatusReasonType1, error)

AsRunStatusReasonType1 returns the union data inside the RunStatusReasonType as a RunStatusReasonType1

func (RunStatusReasonType) AsRunStatusReasonType2

func (t RunStatusReasonType) AsRunStatusReasonType2() (RunStatusReasonType2, error)

AsRunStatusReasonType2 returns the union data inside the RunStatusReasonType as a RunStatusReasonType2

func (RunStatusReasonType) AsRunStatusReasonType3

func (t RunStatusReasonType) AsRunStatusReasonType3() (RunStatusReasonType3, error)

AsRunStatusReasonType3 returns the union data inside the RunStatusReasonType as a RunStatusReasonType3

func (RunStatusReasonType) AsRunStatusReasonType4

func (t RunStatusReasonType) AsRunStatusReasonType4() (RunStatusReasonType4, error)

AsRunStatusReasonType4 returns the union data inside the RunStatusReasonType as a RunStatusReasonType4

func (RunStatusReasonType) AsRunStatusReasonType5

func (t RunStatusReasonType) AsRunStatusReasonType5() (RunStatusReasonType5, error)

AsRunStatusReasonType5 returns the union data inside the RunStatusReasonType as a RunStatusReasonType5

func (*RunStatusReasonType) FromRunStatusReasonType0

func (t *RunStatusReasonType) FromRunStatusReasonType0(v RunStatusReasonType0) error

FromRunStatusReasonType0 overwrites any union data inside the RunStatusReasonType as the provided RunStatusReasonType0

func (*RunStatusReasonType) FromRunStatusReasonType1

func (t *RunStatusReasonType) FromRunStatusReasonType1(v RunStatusReasonType1) error

FromRunStatusReasonType1 overwrites any union data inside the RunStatusReasonType as the provided RunStatusReasonType1

func (*RunStatusReasonType) FromRunStatusReasonType2

func (t *RunStatusReasonType) FromRunStatusReasonType2(v RunStatusReasonType2) error

FromRunStatusReasonType2 overwrites any union data inside the RunStatusReasonType as the provided RunStatusReasonType2

func (*RunStatusReasonType) FromRunStatusReasonType3

func (t *RunStatusReasonType) FromRunStatusReasonType3(v RunStatusReasonType3) error

FromRunStatusReasonType3 overwrites any union data inside the RunStatusReasonType as the provided RunStatusReasonType3

func (*RunStatusReasonType) FromRunStatusReasonType4

func (t *RunStatusReasonType) FromRunStatusReasonType4(v RunStatusReasonType4) error

FromRunStatusReasonType4 overwrites any union data inside the RunStatusReasonType as the provided RunStatusReasonType4

func (*RunStatusReasonType) FromRunStatusReasonType5

func (t *RunStatusReasonType) FromRunStatusReasonType5(v RunStatusReasonType5) error

FromRunStatusReasonType5 overwrites any union data inside the RunStatusReasonType as the provided RunStatusReasonType5

func (RunStatusReasonType) MarshalJSON

func (t RunStatusReasonType) MarshalJSON() ([]byte, error)

func (*RunStatusReasonType) MergeRunStatusReasonType0

func (t *RunStatusReasonType) MergeRunStatusReasonType0(v RunStatusReasonType0) error

MergeRunStatusReasonType0 performs a merge with any union data inside the RunStatusReasonType, using the provided RunStatusReasonType0

func (*RunStatusReasonType) MergeRunStatusReasonType1

func (t *RunStatusReasonType) MergeRunStatusReasonType1(v RunStatusReasonType1) error

MergeRunStatusReasonType1 performs a merge with any union data inside the RunStatusReasonType, using the provided RunStatusReasonType1

func (*RunStatusReasonType) MergeRunStatusReasonType2

func (t *RunStatusReasonType) MergeRunStatusReasonType2(v RunStatusReasonType2) error

MergeRunStatusReasonType2 performs a merge with any union data inside the RunStatusReasonType, using the provided RunStatusReasonType2

func (*RunStatusReasonType) MergeRunStatusReasonType3

func (t *RunStatusReasonType) MergeRunStatusReasonType3(v RunStatusReasonType3) error

MergeRunStatusReasonType3 performs a merge with any union data inside the RunStatusReasonType, using the provided RunStatusReasonType3

func (*RunStatusReasonType) MergeRunStatusReasonType4

func (t *RunStatusReasonType) MergeRunStatusReasonType4(v RunStatusReasonType4) error

MergeRunStatusReasonType4 performs a merge with any union data inside the RunStatusReasonType, using the provided RunStatusReasonType4

func (*RunStatusReasonType) MergeRunStatusReasonType5

func (t *RunStatusReasonType) MergeRunStatusReasonType5(v RunStatusReasonType5) error

MergeRunStatusReasonType5 performs a merge with any union data inside the RunStatusReasonType, using the provided RunStatusReasonType5

func (*RunStatusReasonType) UnmarshalJSON

func (t *RunStatusReasonType) UnmarshalJSON(b []byte) error

type RunStatusReasonType0

type RunStatusReasonType0 string

RunStatusReasonType0 Gofer has no fucking clue how the run got into this state.

const (
	RunStatusReasonType0Unknown RunStatusReasonType0 = "unknown"
)

Defines values for RunStatusReasonType0.

type RunStatusReasonType1

type RunStatusReasonType1 string

RunStatusReasonType1 While executing the run, one or more tasks exited with an abnormal exit code.

const (
	RunStatusReasonType1AbnormalExit RunStatusReasonType1 = "abnormal_exit"
)

Defines values for RunStatusReasonType1.

type RunStatusReasonType2

type RunStatusReasonType2 string

RunStatusReasonType2 While executing the run, one or more tasks returned errors from the scheduler or could not be scheduled.

const (
	RunStatusReasonType2SchedulerError RunStatusReasonType2 = "scheduler_error"
)

Defines values for RunStatusReasonType2.

type RunStatusReasonType3

type RunStatusReasonType3 string

RunStatusReasonType3 The run could not be executed as requested due to user defined attributes given.

const (
	RunStatusReasonType3FailedPrecondition RunStatusReasonType3 = "failed_precondition"
)

Defines values for RunStatusReasonType3.

type RunStatusReasonType4

type RunStatusReasonType4 string

RunStatusReasonType4 One or more tasks could not be completed due to a user cancelling the run.

const (
	UserCancelled RunStatusReasonType4 = "user_cancelled"
)

Defines values for RunStatusReasonType4.

type RunStatusReasonType5

type RunStatusReasonType5 string

RunStatusReasonType5 One or more tasks could not be completed due to the system or admin cancelling the run.

const (
	AdminCancelled RunStatusReasonType5 = "admin_cancelled"
)

Defines values for RunStatusReasonType5.

type Secret

type Secret struct {
	// Created Time in epoch milliseconds that this secret was registered.
	Created int `json:"created"`

	// Key The identifier for the secret value.
	Key string `json:"key"`

	// Namespaces The namespaces this secret is allowed to be accessed from. Accepts regexes.
	Namespaces []string `json:"namespaces"`
}

Secret defines model for Secret.

type StartRunJSONRequestBody

type StartRunJSONRequestBody = StartRunRequest

StartRunJSONRequestBody defines body for StartRun for application/json ContentType.

type StartRunRequest

type StartRunRequest struct {
	Initiator Initiator         `json:"initiator"`
	Variables map[string]string `json:"variables"`
}

StartRunRequest defines model for StartRunRequest.

type StartRunResp

type StartRunResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON201      *StartRunResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseStartRunResp

func ParseStartRunResp(rsp *http.Response) (*StartRunResp, error)

ParseStartRunResp parses an HTTP response from a StartRunWithResponse call

func (StartRunResp) Status

func (r StartRunResp) Status() string

Status returns HTTPResponse.Status

func (StartRunResp) StatusCode

func (r StartRunResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type StartRunResponse

type StartRunResponse struct {
	// Run Information about the run started.
	Run Run `json:"run"`
}

StartRunResponse defines model for StartRunResponse.

type StreamEventsParams

type StreamEventsParams struct {
	// History If set to true Gofer first exhausts events that have already passed before it starts to stream new events.
	History *bool `form:"history,omitempty" json:"history,omitempty"`

	// Reverse Reverses the order of events by the time they were emitted. By default Gofer lists events in ascending order; setting reverse to true causes events to be in descending order.
	Reverse *bool `form:"reverse,omitempty" json:"reverse,omitempty"`
}

StreamEventsParams defines parameters for StreamEvents.

type StreamEventsResp

type StreamEventsResp struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseStreamEventsResp

func ParseStreamEventsResp(rsp *http.Response) (*StreamEventsResp, error)

ParseStreamEventsResp parses an HTTP response from a StreamEventsWithResponse call

func (StreamEventsResp) Status

func (r StreamEventsResp) Status() string

Status returns HTTPResponse.Status

func (StreamEventsResp) StatusCode

func (r StreamEventsResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type Subscription

type Subscription struct {
	// ExtensionId Unique identifier of the target extension.
	ExtensionId string `json:"extension_id"`

	// NamespaceId Unique identifier of the target namespace.
	NamespaceId string `json:"namespace_id"`

	// PipelineId Unique identifier of the target pipeline.
	PipelineId string `json:"pipeline_id"`

	// Settings The extension's pipeline configuration settings.
	Settings map[string]string `json:"settings"`

	// Status The state of the subscription.
	Status SubscriptionStatus `json:"status"`

	// StatusReason A further description about the status.
	StatusReason *SubscriptionStatusReason `json:"status_reason"`

	// SubscriptionId A unique label differentiating this subscription from other subscriptions.
	SubscriptionId string `json:"subscription_id"`
}

Subscription defines model for Subscription.

type SubscriptionStatus

type SubscriptionStatus string

SubscriptionStatus defines model for subscription_status.

const (
	SubscriptionStatusActive   SubscriptionStatus = "active"
	SubscriptionStatusDisabled SubscriptionStatus = "disabled"
	SubscriptionStatusError    SubscriptionStatus = "error"
	SubscriptionStatusUnknown  SubscriptionStatus = "unknown"
)

Defines values for SubscriptionStatus.

type SubscriptionStatusReason

type SubscriptionStatusReason struct {
	// Description A description of why the subscription might have failed and what was going on at the time.
	Description string `json:"description"`

	// Reason The specific type of subscription failure.
	Reason SubscriptionStatusReasonType `json:"reason"`
}

SubscriptionStatusReason defines model for subscription_status_reason.

type SubscriptionStatusReasonType

type SubscriptionStatusReasonType string

SubscriptionStatusReasonType defines model for subscription_status_reason_type.

const (
	SubscriptionStatusReasonTypeFailed   SubscriptionStatusReasonType = "failed"
	SubscriptionStatusReasonTypeNotFound SubscriptionStatusReasonType = "not_found"
	SubscriptionStatusReasonTypeUnknown  SubscriptionStatusReasonType = "unknown"
)

Defines values for SubscriptionStatusReasonType.

type Task

type Task struct {
	// Command Command to run on init of container; follows normal docker convention of command: https://docs.docker.com/reference/dockerfile/#cmd
	Command *[]string `json:"command"`

	// DependsOn Which other tasks (by id) this task depends on.
	DependsOn map[string]RequiredParentStatus `json:"depends_on"`

	// Description Short description about the workload.
	Description string `json:"description"`

	// Entrypoint Command to run on init of container; follows normal docker convention for entrypoint: https://docs.docker.com/reference/dockerfile/#entrypoint
	Entrypoint *[]string `json:"entrypoint"`

	// Id Unique identifier for the task.
	Id string `json:"id"`

	// Image Which container image to run for this specific task.
	//
	// Example: "ubuntu:latest"
	Image string `json:"image"`

	// InjectApiToken Whether to inject a run specific Gofer API key. Useful for using Gofer API within the container.
	InjectApiToken bool `json:"inject_api_token"`

	// RegistryAuth Auth credentials for the image's registry
	RegistryAuth *RegistryAuth `json:"registry_auth"`

	// Variables Variables which will be passed in as env vars to the task.
	Variables []Variable `json:"variables"`
}

Task A task represents a particular workload within a pipeline. Tasks are composable within a larger pipeline, meaning they can be run before, after, or alongside other tasks. Tasks represent the lowest level of the Gofer hierarchy and is what Gofer references to see how a user might want their workload handled.

type Task2

type Task2 struct {
	Command        *[]string                        `json:"command"`
	DependsOn      map[string]RequiredParentStatus2 `json:"depends_on"`
	Description    *string                          `json:"description"`
	Entrypoint     *[]string                        `json:"entrypoint"`
	Id             string                           `json:"id"`
	Image          string                           `json:"image"`
	InjectApiToken bool                             `json:"inject_api_token"`
	RegistryAuth   *RegistryAuth2                   `json:"registry_auth"`
	Variables      map[string]string                `json:"variables"`
}

Task2 Represents a single task within a [`Pipeline`]. A task is a unit of work that operates within its own container. Each task defines the operations to be performed and the container environment in which these operations will run.

Example Usage ```ignore // Define a new task within a pipeline. let task = Task { id: "example_task".to_string(), description: Some("This task executes a simple print command in an Ubuntu container.".to_string()), image: "ubuntu:latest".to_string(), registry_auth: None, depends_on: HashMap::new(), // No dependencies, so it starts immediately when the pipeline runs. variables: HashMap::from([("KEY", "value".to_string())]), entrypoint: None, // Use the image's default entrypoint. command: Some(vec!["echo".to_string(), "Hello World!".to_string()]), inject_api_token: false, }; ```

type TaskExecution

type TaskExecution struct {
	// Created Time of task execution creation in epoch milliseconds.
	Created int `json:"created"`

	// Ended Time of task execution end in epoch milliseconds.
	Ended int `json:"ended"`

	// ExitCode The exit code of the task execution completion if it is finished.
	ExitCode *uint8 `json:"exit_code"`

	// LogsExpired Whether the logs have past their retention time.
	LogsExpired bool `json:"logs_expired"`

	// LogsRemoved If the logs for this execution have been removed. This can be due to user request or automatic action based on expiry time.
	LogsRemoved bool `json:"logs_removed"`

	// NamespaceId Unique identifier of the target namespace.
	NamespaceId string `json:"namespace_id"`

	// PipelineId Unique identifier of the target pipeline.
	PipelineId string `json:"pipeline_id"`

	// RunId Unique identifier of the target run.
	RunId uint64 `json:"run_id"`

	// Started Time of task execution start in epoch milliseconds.
	Started int `json:"started"`

	// State The current state of the task execution within the Gofer execution model. Describes if the execution is in progress or not.
	State TaskExecutionState `json:"state"`

	// Status The final result of the task execution.
	Status TaskExecutionStatus `json:"status"`

	// StatusReason More information on the circumstances around a particular task execution's status.
	StatusReason *TaskExecutionStatusReason `json:"status_reason"`

	// Task Information about the underlying task this task execution ran.
	Task Task `json:"task"`

	// TaskId Unique identifier of the current task being executed.
	TaskId string `json:"task_id"`

	// Variables The environment variables injected during this particular task execution.
	Variables []Variable `json:"variables"`
}

TaskExecution a task execution is a specific execution of a task/container. It represents a 4th level unit in the hierarchy. namespace -> pipeline -> run -> task execution. It is the last and most specific object in Gofer's execution model.

type TaskExecutionState

type TaskExecutionState struct {
	// contains filtered or unexported fields
}

TaskExecutionState defines model for task_execution_state.

func (TaskExecutionState) AsTaskExecutionState0

func (t TaskExecutionState) AsTaskExecutionState0() (TaskExecutionState0, error)

AsTaskExecutionState0 returns the union data inside the TaskExecutionState as a TaskExecutionState0

func (TaskExecutionState) AsTaskExecutionState1

func (t TaskExecutionState) AsTaskExecutionState1() (TaskExecutionState1, error)

AsTaskExecutionState1 returns the union data inside the TaskExecutionState as a TaskExecutionState1

func (TaskExecutionState) AsTaskExecutionState2

func (t TaskExecutionState) AsTaskExecutionState2() (TaskExecutionState2, error)

AsTaskExecutionState2 returns the union data inside the TaskExecutionState as a TaskExecutionState2

func (TaskExecutionState) AsTaskExecutionState3

func (t TaskExecutionState) AsTaskExecutionState3() (TaskExecutionState3, error)

AsTaskExecutionState3 returns the union data inside the TaskExecutionState as a TaskExecutionState3

func (TaskExecutionState) AsTaskExecutionState4

func (t TaskExecutionState) AsTaskExecutionState4() (TaskExecutionState4, error)

AsTaskExecutionState4 returns the union data inside the TaskExecutionState as a TaskExecutionState4

func (*TaskExecutionState) FromTaskExecutionState0

func (t *TaskExecutionState) FromTaskExecutionState0(v TaskExecutionState0) error

FromTaskExecutionState0 overwrites any union data inside the TaskExecutionState as the provided TaskExecutionState0

func (*TaskExecutionState) FromTaskExecutionState1

func (t *TaskExecutionState) FromTaskExecutionState1(v TaskExecutionState1) error

FromTaskExecutionState1 overwrites any union data inside the TaskExecutionState as the provided TaskExecutionState1

func (*TaskExecutionState) FromTaskExecutionState2

func (t *TaskExecutionState) FromTaskExecutionState2(v TaskExecutionState2) error

FromTaskExecutionState2 overwrites any union data inside the TaskExecutionState as the provided TaskExecutionState2

func (*TaskExecutionState) FromTaskExecutionState3

func (t *TaskExecutionState) FromTaskExecutionState3(v TaskExecutionState3) error

FromTaskExecutionState3 overwrites any union data inside the TaskExecutionState as the provided TaskExecutionState3

func (*TaskExecutionState) FromTaskExecutionState4

func (t *TaskExecutionState) FromTaskExecutionState4(v TaskExecutionState4) error

FromTaskExecutionState4 overwrites any union data inside the TaskExecutionState as the provided TaskExecutionState4

func (TaskExecutionState) MarshalJSON

func (t TaskExecutionState) MarshalJSON() ([]byte, error)

func (*TaskExecutionState) MergeTaskExecutionState0

func (t *TaskExecutionState) MergeTaskExecutionState0(v TaskExecutionState0) error

MergeTaskExecutionState0 performs a merge with any union data inside the TaskExecutionState, using the provided TaskExecutionState0

func (*TaskExecutionState) MergeTaskExecutionState1

func (t *TaskExecutionState) MergeTaskExecutionState1(v TaskExecutionState1) error

MergeTaskExecutionState1 performs a merge with any union data inside the TaskExecutionState, using the provided TaskExecutionState1

func (*TaskExecutionState) MergeTaskExecutionState2

func (t *TaskExecutionState) MergeTaskExecutionState2(v TaskExecutionState2) error

MergeTaskExecutionState2 performs a merge with any union data inside the TaskExecutionState, using the provided TaskExecutionState2

func (*TaskExecutionState) MergeTaskExecutionState3

func (t *TaskExecutionState) MergeTaskExecutionState3(v TaskExecutionState3) error

MergeTaskExecutionState3 performs a merge with any union data inside the TaskExecutionState, using the provided TaskExecutionState3

func (*TaskExecutionState) MergeTaskExecutionState4

func (t *TaskExecutionState) MergeTaskExecutionState4(v TaskExecutionState4) error

MergeTaskExecutionState4 performs a merge with any union data inside the TaskExecutionState, using the provided TaskExecutionState4

func (*TaskExecutionState) UnmarshalJSON

func (t *TaskExecutionState) UnmarshalJSON(b []byte) error

type TaskExecutionState0

type TaskExecutionState0 string

TaskExecutionState0 defines model for TaskExecutionState.0.

const (
	TaskExecutionState0Complete TaskExecutionState0 = "complete"
)

Defines values for TaskExecutionState0.

type TaskExecutionState1

type TaskExecutionState1 string

TaskExecutionState1 Should never be in this state.

const (
	TaskExecutionState1Unknown TaskExecutionState1 = "unknown"
)

Defines values for TaskExecutionState1.

type TaskExecutionState2

type TaskExecutionState2 string

TaskExecutionState2 Pre-scheduler validation and prep.

const (
	TaskExecutionState2Processing TaskExecutionState2 = "processing"
)

Defines values for TaskExecutionState2.

type TaskExecutionState3

type TaskExecutionState3 string

TaskExecutionState3 Waiting to be scheduled.

const (
	Waiting TaskExecutionState3 = "waiting"
)

Defines values for TaskExecutionState3.

type TaskExecutionState4

type TaskExecutionState4 string

TaskExecutionState4 Currently running as reported by scheduler.

const (
	TaskExecutionState4Running TaskExecutionState4 = "running"
)

Defines values for TaskExecutionState4.

type TaskExecutionStatus

type TaskExecutionStatus struct {
	// contains filtered or unexported fields
}

TaskExecutionStatus defines model for task_execution_status.

func (TaskExecutionStatus) AsTaskExecutionStatus0

func (t TaskExecutionStatus) AsTaskExecutionStatus0() (TaskExecutionStatus0, error)

AsTaskExecutionStatus0 returns the union data inside the TaskExecutionStatus as a TaskExecutionStatus0

func (TaskExecutionStatus) AsTaskExecutionStatus1

func (t TaskExecutionStatus) AsTaskExecutionStatus1() (TaskExecutionStatus1, error)

AsTaskExecutionStatus1 returns the union data inside the TaskExecutionStatus as a TaskExecutionStatus1

func (TaskExecutionStatus) AsTaskExecutionStatus2

func (t TaskExecutionStatus) AsTaskExecutionStatus2() (TaskExecutionStatus2, error)

AsTaskExecutionStatus2 returns the union data inside the TaskExecutionStatus as a TaskExecutionStatus2

func (TaskExecutionStatus) AsTaskExecutionStatus3

func (t TaskExecutionStatus) AsTaskExecutionStatus3() (TaskExecutionStatus3, error)

AsTaskExecutionStatus3 returns the union data inside the TaskExecutionStatus as a TaskExecutionStatus3

func (TaskExecutionStatus) AsTaskExecutionStatus4

func (t TaskExecutionStatus) AsTaskExecutionStatus4() (TaskExecutionStatus4, error)

AsTaskExecutionStatus4 returns the union data inside the TaskExecutionStatus as a TaskExecutionStatus4

func (*TaskExecutionStatus) FromTaskExecutionStatus0

func (t *TaskExecutionStatus) FromTaskExecutionStatus0(v TaskExecutionStatus0) error

FromTaskExecutionStatus0 overwrites any union data inside the TaskExecutionStatus as the provided TaskExecutionStatus0

func (*TaskExecutionStatus) FromTaskExecutionStatus1

func (t *TaskExecutionStatus) FromTaskExecutionStatus1(v TaskExecutionStatus1) error

FromTaskExecutionStatus1 overwrites any union data inside the TaskExecutionStatus as the provided TaskExecutionStatus1

func (*TaskExecutionStatus) FromTaskExecutionStatus2

func (t *TaskExecutionStatus) FromTaskExecutionStatus2(v TaskExecutionStatus2) error

FromTaskExecutionStatus2 overwrites any union data inside the TaskExecutionStatus as the provided TaskExecutionStatus2

func (*TaskExecutionStatus) FromTaskExecutionStatus3

func (t *TaskExecutionStatus) FromTaskExecutionStatus3(v TaskExecutionStatus3) error

FromTaskExecutionStatus3 overwrites any union data inside the TaskExecutionStatus as the provided TaskExecutionStatus3

func (*TaskExecutionStatus) FromTaskExecutionStatus4

func (t *TaskExecutionStatus) FromTaskExecutionStatus4(v TaskExecutionStatus4) error

FromTaskExecutionStatus4 overwrites any union data inside the TaskExecutionStatus as the provided TaskExecutionStatus4

func (TaskExecutionStatus) MarshalJSON

func (t TaskExecutionStatus) MarshalJSON() ([]byte, error)

func (*TaskExecutionStatus) MergeTaskExecutionStatus0

func (t *TaskExecutionStatus) MergeTaskExecutionStatus0(v TaskExecutionStatus0) error

MergeTaskExecutionStatus0 performs a merge with any union data inside the TaskExecutionStatus, using the provided TaskExecutionStatus0

func (*TaskExecutionStatus) MergeTaskExecutionStatus1

func (t *TaskExecutionStatus) MergeTaskExecutionStatus1(v TaskExecutionStatus1) error

MergeTaskExecutionStatus1 performs a merge with any union data inside the TaskExecutionStatus, using the provided TaskExecutionStatus1

func (*TaskExecutionStatus) MergeTaskExecutionStatus2

func (t *TaskExecutionStatus) MergeTaskExecutionStatus2(v TaskExecutionStatus2) error

MergeTaskExecutionStatus2 performs a merge with any union data inside the TaskExecutionStatus, using the provided TaskExecutionStatus2

func (*TaskExecutionStatus) MergeTaskExecutionStatus3

func (t *TaskExecutionStatus) MergeTaskExecutionStatus3(v TaskExecutionStatus3) error

MergeTaskExecutionStatus3 performs a merge with any union data inside the TaskExecutionStatus, using the provided TaskExecutionStatus3

func (*TaskExecutionStatus) MergeTaskExecutionStatus4

func (t *TaskExecutionStatus) MergeTaskExecutionStatus4(v TaskExecutionStatus4) error

MergeTaskExecutionStatus4 performs a merge with any union data inside the TaskExecutionStatus, using the provided TaskExecutionStatus4

func (*TaskExecutionStatus) UnmarshalJSON

func (t *TaskExecutionStatus) UnmarshalJSON(b []byte) error

type TaskExecutionStatus0

type TaskExecutionStatus0 string

TaskExecutionStatus0 defines model for TaskExecutionStatus.0.

const (
	TaskExecutionStatus0Unknown TaskExecutionStatus0 = "unknown"
)

Defines values for TaskExecutionStatus0.

type TaskExecutionStatus1

type TaskExecutionStatus1 string

TaskExecutionStatus1 Has encountered an issue, either container issue or scheduling issue.

const (
	Failed TaskExecutionStatus1 = "failed"
)

Defines values for TaskExecutionStatus1.

type TaskExecutionStatus2

type TaskExecutionStatus2 string

TaskExecutionStatus2 Finished with a proper exit code.

const (
	Successful TaskExecutionStatus2 = "successful"
)

Defines values for TaskExecutionStatus2.

type TaskExecutionStatus3

type TaskExecutionStatus3 string

TaskExecutionStatus3 Cancelled mid run due to user requested cancellation.

const (
	TaskExecutionStatus3Cancelled TaskExecutionStatus3 = "cancelled"
)

Defines values for TaskExecutionStatus3.

type TaskExecutionStatus4

type TaskExecutionStatus4 string

TaskExecutionStatus4 Not run due to dependencies not being met.

const (
	Skipped TaskExecutionStatus4 = "skipped"
)

Defines values for TaskExecutionStatus4.

type TaskExecutionStatusReason

type TaskExecutionStatusReason struct {
	// Description A description of why the task execution might have failed and what was going on at the time.
	Description string `json:"description"`

	// Reason The specific type of task execution failure.
	Reason TaskExecutionStatusReasonType `json:"reason"`
}

TaskExecutionStatusReason defines model for task_execution_status_reason.

type TaskExecutionStatusReasonType

type TaskExecutionStatusReasonType struct {
	// contains filtered or unexported fields
}

TaskExecutionStatusReasonType defines model for task_execution_status_reason_type.

func (TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType0

func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType0() (TaskExecutionStatusReasonType0, error)

AsTaskExecutionStatusReasonType0 returns the union data inside the TaskExecutionStatusReasonType as a TaskExecutionStatusReasonType0

func (TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType1

func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType1() (TaskExecutionStatusReasonType1, error)

AsTaskExecutionStatusReasonType1 returns the union data inside the TaskExecutionStatusReasonType as a TaskExecutionStatusReasonType1

func (TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType2

func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType2() (TaskExecutionStatusReasonType2, error)

AsTaskExecutionStatusReasonType2 returns the union data inside the TaskExecutionStatusReasonType as a TaskExecutionStatusReasonType2

func (TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType3

func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType3() (TaskExecutionStatusReasonType3, error)

AsTaskExecutionStatusReasonType3 returns the union data inside the TaskExecutionStatusReasonType as a TaskExecutionStatusReasonType3

func (TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType4

func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType4() (TaskExecutionStatusReasonType4, error)

AsTaskExecutionStatusReasonType4 returns the union data inside the TaskExecutionStatusReasonType as a TaskExecutionStatusReasonType4

func (TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType5

func (t TaskExecutionStatusReasonType) AsTaskExecutionStatusReasonType5() (TaskExecutionStatusReasonType5, error)

AsTaskExecutionStatusReasonType5 returns the union data inside the TaskExecutionStatusReasonType as a TaskExecutionStatusReasonType5

func (*TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType0

func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType0(v TaskExecutionStatusReasonType0) error

FromTaskExecutionStatusReasonType0 overwrites any union data inside the TaskExecutionStatusReasonType as the provided TaskExecutionStatusReasonType0

func (*TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType1

func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType1(v TaskExecutionStatusReasonType1) error

FromTaskExecutionStatusReasonType1 overwrites any union data inside the TaskExecutionStatusReasonType as the provided TaskExecutionStatusReasonType1

func (*TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType2

func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType2(v TaskExecutionStatusReasonType2) error

FromTaskExecutionStatusReasonType2 overwrites any union data inside the TaskExecutionStatusReasonType as the provided TaskExecutionStatusReasonType2

func (*TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType3

func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType3(v TaskExecutionStatusReasonType3) error

FromTaskExecutionStatusReasonType3 overwrites any union data inside the TaskExecutionStatusReasonType as the provided TaskExecutionStatusReasonType3

func (*TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType4

func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType4(v TaskExecutionStatusReasonType4) error

FromTaskExecutionStatusReasonType4 overwrites any union data inside the TaskExecutionStatusReasonType as the provided TaskExecutionStatusReasonType4

func (*TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType5

func (t *TaskExecutionStatusReasonType) FromTaskExecutionStatusReasonType5(v TaskExecutionStatusReasonType5) error

FromTaskExecutionStatusReasonType5 overwrites any union data inside the TaskExecutionStatusReasonType as the provided TaskExecutionStatusReasonType5

func (TaskExecutionStatusReasonType) MarshalJSON

func (t TaskExecutionStatusReasonType) MarshalJSON() ([]byte, error)

func (*TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType0

func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType0(v TaskExecutionStatusReasonType0) error

MergeTaskExecutionStatusReasonType0 performs a merge with any union data inside the TaskExecutionStatusReasonType, using the provided TaskExecutionStatusReasonType0

func (*TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType1

func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType1(v TaskExecutionStatusReasonType1) error

MergeTaskExecutionStatusReasonType1 performs a merge with any union data inside the TaskExecutionStatusReasonType, using the provided TaskExecutionStatusReasonType1

func (*TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType2

func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType2(v TaskExecutionStatusReasonType2) error

MergeTaskExecutionStatusReasonType2 performs a merge with any union data inside the TaskExecutionStatusReasonType, using the provided TaskExecutionStatusReasonType2

func (*TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType3

func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType3(v TaskExecutionStatusReasonType3) error

MergeTaskExecutionStatusReasonType3 performs a merge with any union data inside the TaskExecutionStatusReasonType, using the provided TaskExecutionStatusReasonType3

func (*TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType4

func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType4(v TaskExecutionStatusReasonType4) error

MergeTaskExecutionStatusReasonType4 performs a merge with any union data inside the TaskExecutionStatusReasonType, using the provided TaskExecutionStatusReasonType4

func (*TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType5

func (t *TaskExecutionStatusReasonType) MergeTaskExecutionStatusReasonType5(v TaskExecutionStatusReasonType5) error

MergeTaskExecutionStatusReasonType5 performs a merge with any union data inside the TaskExecutionStatusReasonType, using the provided TaskExecutionStatusReasonType5

func (*TaskExecutionStatusReasonType) UnmarshalJSON

func (t *TaskExecutionStatusReasonType) UnmarshalJSON(b []byte) error

type TaskExecutionStatusReasonType0

type TaskExecutionStatusReasonType0 string

TaskExecutionStatusReasonType0 Gofer has no fucking clue how the run got into this state.

const (
	Unknown TaskExecutionStatusReasonType0 = "unknown"
)

Defines values for TaskExecutionStatusReasonType0.

type TaskExecutionStatusReasonType1

type TaskExecutionStatusReasonType1 string

TaskExecutionStatusReasonType1 A non-zero exit code has been received.

const (
	TaskExecutionStatusReasonType1AbnormalExit TaskExecutionStatusReasonType1 = "abnormal_exit"
)

Defines values for TaskExecutionStatusReasonType1.

type TaskExecutionStatusReasonType2

type TaskExecutionStatusReasonType2 string

TaskExecutionStatusReasonType2 Encountered an error with the container scheduler.

const (
	TaskExecutionStatusReasonType2SchedulerError TaskExecutionStatusReasonType2 = "scheduler_error"
)

Defines values for TaskExecutionStatusReasonType2.

type TaskExecutionStatusReasonType3

type TaskExecutionStatusReasonType3 string

TaskExecutionStatusReasonType3 User error in task execution parameters.

const (
	TaskExecutionStatusReasonType3FailedPrecondition TaskExecutionStatusReasonType3 = "failed_precondition"
)

Defines values for TaskExecutionStatusReasonType3.

type TaskExecutionStatusReasonType4

type TaskExecutionStatusReasonType4 string

TaskExecutionStatusReasonType4 User invoked cancellation.k

const (
	Cancelled TaskExecutionStatusReasonType4 = "cancelled"
)

Defines values for TaskExecutionStatusReasonType4.

type TaskExecutionStatusReasonType5

type TaskExecutionStatusReasonType5 string

TaskExecutionStatusReasonType5 Task execution was lost due to extreme internal error.

const (
	Orphaned TaskExecutionStatusReasonType5 = "orphaned"
)

Defines values for TaskExecutionStatusReasonType5.

type Token

type Token struct {
	// Created Time in epoch milliseconds when token was created.
	Created int `json:"created"`

	// Disabled If the token is inactive or not; disabled tokens cannot be used for requests.
	Disabled bool `json:"disabled"`

	// Expires Time in epoch milliseconds when token would expire.
	Expires int `json:"expires"`

	// Id Unique identifier for token.
	Id string `json:"id"`

	// Metadata Extra information about this token in label form
	Metadata map[string]string `json:"metadata"`

	// Namespaces List of namespaces this token has access to, strings in this list can be a regex
	Namespaces []string `json:"namespaces"`

	// TokenType The type of token. Management tokens are essentially root.
	TokenType TokenType `json:"token_type"`
}

Token Gofer API Token.

type TokenType

type TokenType struct {
	// contains filtered or unexported fields
}

TokenType defines model for TokenType.

func (TokenType) AsTokenType0

func (t TokenType) AsTokenType0() (TokenType0, error)

AsTokenType0 returns the union data inside the TokenType as a TokenType0

func (TokenType) AsTokenType1

func (t TokenType) AsTokenType1() (TokenType1, error)

AsTokenType1 returns the union data inside the TokenType as a TokenType1

func (TokenType) AsTokenType2

func (t TokenType) AsTokenType2() (TokenType2, error)

AsTokenType2 returns the union data inside the TokenType as a TokenType2

func (TokenType) AsTokenType3

func (t TokenType) AsTokenType3() (TokenType3, error)

AsTokenType3 returns the union data inside the TokenType as a TokenType3

func (*TokenType) FromTokenType0

func (t *TokenType) FromTokenType0(v TokenType0) error

FromTokenType0 overwrites any union data inside the TokenType as the provided TokenType0

func (*TokenType) FromTokenType1

func (t *TokenType) FromTokenType1(v TokenType1) error

FromTokenType1 overwrites any union data inside the TokenType as the provided TokenType1

func (*TokenType) FromTokenType2

func (t *TokenType) FromTokenType2(v TokenType2) error

FromTokenType2 overwrites any union data inside the TokenType as the provided TokenType2

func (*TokenType) FromTokenType3

func (t *TokenType) FromTokenType3(v TokenType3) error

FromTokenType3 overwrites any union data inside the TokenType as the provided TokenType3

func (TokenType) MarshalJSON

func (t TokenType) MarshalJSON() ([]byte, error)

func (*TokenType) MergeTokenType0

func (t *TokenType) MergeTokenType0(v TokenType0) error

MergeTokenType0 performs a merge with any union data inside the TokenType, using the provided TokenType0

func (*TokenType) MergeTokenType1

func (t *TokenType) MergeTokenType1(v TokenType1) error

MergeTokenType1 performs a merge with any union data inside the TokenType, using the provided TokenType1

func (*TokenType) MergeTokenType2

func (t *TokenType) MergeTokenType2(v TokenType2) error

MergeTokenType2 performs a merge with any union data inside the TokenType, using the provided TokenType2

func (*TokenType) MergeTokenType3

func (t *TokenType) MergeTokenType3(v TokenType3) error

MergeTokenType3 performs a merge with any union data inside the TokenType, using the provided TokenType3

func (*TokenType) UnmarshalJSON

func (t *TokenType) UnmarshalJSON(b []byte) error

type TokenType0

type TokenType0 string

TokenType0 Admin token; has access to just about everything.

const (
	Management TokenType0 = "Management"
)

Defines values for TokenType0.

type TokenType1

type TokenType1 string

TokenType1 Only has read/write access to namespaces granted.

const (
	User TokenType1 = "User"
)

Defines values for TokenType1.

type TokenType2

type TokenType2 string

TokenType2 Special token given to extensions. Has access to any namespace, but does not have management access.

const (
	TokenType2Extension TokenType2 = "Extension"
)

Defines values for TokenType2.

type TokenType3

type TokenType3 string

TokenType3 Gofer has a special function that allows users to autogenerate a token and inject it into their run such that they can use it easily during the run. Has same access properties the user token with a more focused namespace.

const (
	TokenType3Run TokenType3 = "Run"
)

Defines values for TokenType3.

type UninstallExtensionResp

type UninstallExtensionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseUninstallExtensionResp

func ParseUninstallExtensionResp(rsp *http.Response) (*UninstallExtensionResp, error)

ParseUninstallExtensionResp parses an HTTP response from a UninstallExtensionWithResponse call

func (UninstallExtensionResp) Status

func (r UninstallExtensionResp) Status() string

Status returns HTTPResponse.Status

func (UninstallExtensionResp) StatusCode

func (r UninstallExtensionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateExtensionJSONRequestBody

type UpdateExtensionJSONRequestBody = UpdateExtensionRequest

UpdateExtensionJSONRequestBody defines body for UpdateExtension for application/json ContentType.

type UpdateExtensionRequest

type UpdateExtensionRequest struct {
	Enable bool `json:"enable"`
}

UpdateExtensionRequest defines model for UpdateExtensionRequest.

type UpdateExtensionResp

type UpdateExtensionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseUpdateExtensionResp

func ParseUpdateExtensionResp(rsp *http.Response) (*UpdateExtensionResp, error)

ParseUpdateExtensionResp parses an HTTP response from a UpdateExtensionWithResponse call

func (UpdateExtensionResp) Status

func (r UpdateExtensionResp) Status() string

Status returns HTTPResponse.Status

func (UpdateExtensionResp) StatusCode

func (r UpdateExtensionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateNamespaceJSONRequestBody

type UpdateNamespaceJSONRequestBody = UpdateNamespaceRequest

UpdateNamespaceJSONRequestBody defines body for UpdateNamespace for application/json ContentType.

type UpdateNamespaceRequest

type UpdateNamespaceRequest struct {
	// Description Short description about what the namespace is used for.
	Description *string `json:"description"`

	// Name Humanized name for the namespace.
	Name *string `json:"name"`
}

UpdateNamespaceRequest defines model for UpdateNamespaceRequest.

type UpdateNamespaceResp

type UpdateNamespaceResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *UpdateNamespaceResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseUpdateNamespaceResp

func ParseUpdateNamespaceResp(rsp *http.Response) (*UpdateNamespaceResp, error)

ParseUpdateNamespaceResp parses an HTTP response from a UpdateNamespaceWithResponse call

func (UpdateNamespaceResp) Status

func (r UpdateNamespaceResp) Status() string

Status returns HTTPResponse.Status

func (UpdateNamespaceResp) StatusCode

func (r UpdateNamespaceResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateNamespaceResponse

type UpdateNamespaceResponse struct {
	// Namespace Information about the namespace updated.
	Namespace Namespace `json:"namespace"`
}

UpdateNamespaceResponse defines model for UpdateNamespaceResponse.

type UpdatePipelineJSONRequestBody

type UpdatePipelineJSONRequestBody = UpdatePipelineRequest

UpdatePipelineJSONRequestBody defines body for UpdatePipeline for application/json ContentType.

type UpdatePipelineRequest

type UpdatePipelineRequest struct {
	State *PipelineState `json:"state"`
}

UpdatePipelineRequest defines model for UpdatePipelineRequest.

type UpdatePipelineResp

type UpdatePipelineResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseUpdatePipelineResp

func ParseUpdatePipelineResp(rsp *http.Response) (*UpdatePipelineResp, error)

ParseUpdatePipelineResp parses an HTTP response from a UpdatePipelineWithResponse call

func (UpdatePipelineResp) Status

func (r UpdatePipelineResp) Status() string

Status returns HTTPResponse.Status

func (UpdatePipelineResp) StatusCode

func (r UpdatePipelineResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateSubscriptionJSONRequestBody

type UpdateSubscriptionJSONRequestBody = UpdateSubscriptionRequest

UpdateSubscriptionJSONRequestBody defines body for UpdateSubscription for application/json ContentType.

type UpdateSubscriptionRequest

type UpdateSubscriptionRequest struct {
	Status *UpdateSubscriptionStatus `json:"status"`
}

UpdateSubscriptionRequest defines model for UpdateSubscriptionRequest.

type UpdateSubscriptionResp

type UpdateSubscriptionResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseUpdateSubscriptionResp

func ParseUpdateSubscriptionResp(rsp *http.Response) (*UpdateSubscriptionResp, error)

ParseUpdateSubscriptionResp parses an HTTP response from a UpdateSubscriptionWithResponse call

func (UpdateSubscriptionResp) Status

func (r UpdateSubscriptionResp) Status() string

Status returns HTTPResponse.Status

func (UpdateSubscriptionResp) StatusCode

func (r UpdateSubscriptionResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateSubscriptionStatus

type UpdateSubscriptionStatus string

UpdateSubscriptionStatus defines model for UpdateSubscriptionStatus.

const (
	UpdateSubscriptionStatusActive   UpdateSubscriptionStatus = "active"
	UpdateSubscriptionStatusDisabled UpdateSubscriptionStatus = "disabled"
)

Defines values for UpdateSubscriptionStatus.

type UpdateTokenJSONRequestBody

type UpdateTokenJSONRequestBody = UpdateTokenRequest

UpdateTokenJSONRequestBody defines body for UpdateToken for application/json ContentType.

type UpdateTokenRequest

type UpdateTokenRequest struct {
	Disabled *bool `json:"disabled"`
}

UpdateTokenRequest defines model for UpdateTokenRequest.

type UpdateTokenResp

type UpdateTokenResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseUpdateTokenResp

func ParseUpdateTokenResp(rsp *http.Response) (*UpdateTokenResp, error)

ParseUpdateTokenResp parses an HTTP response from a UpdateTokenWithResponse call

func (UpdateTokenResp) Status

func (r UpdateTokenResp) Status() string

Status returns HTTPResponse.Status

func (UpdateTokenResp) StatusCode

func (r UpdateTokenResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type Variable

type Variable struct {
	Key    string         `json:"key"`
	Source VariableSource `json:"source"`
	Value  string         `json:"value"`
}

Variable A variable is a key value pair that is used either at a run or task level. The variable is inserted as an environment variable to an eventual task execution. It can be owned by different parts of the system which control where the potentially sensitive variables might show up.

type VariableSource

type VariableSource struct {
	// contains filtered or unexported fields
}

VariableSource defines model for VariableSource.

func (VariableSource) AsVariableSource0

func (t VariableSource) AsVariableSource0() (VariableSource0, error)

AsVariableSource0 returns the union data inside the VariableSource as a VariableSource0

func (VariableSource) AsVariableSource1

func (t VariableSource) AsVariableSource1() (VariableSource1, error)

AsVariableSource1 returns the union data inside the VariableSource as a VariableSource1

func (VariableSource) AsVariableSource2

func (t VariableSource) AsVariableSource2() (VariableSource2, error)

AsVariableSource2 returns the union data inside the VariableSource as a VariableSource2

func (VariableSource) AsVariableSource3

func (t VariableSource) AsVariableSource3() (VariableSource3, error)

AsVariableSource3 returns the union data inside the VariableSource as a VariableSource3

func (VariableSource) AsVariableSource4

func (t VariableSource) AsVariableSource4() (VariableSource4, error)

AsVariableSource4 returns the union data inside the VariableSource as a VariableSource4

func (*VariableSource) FromVariableSource0

func (t *VariableSource) FromVariableSource0(v VariableSource0) error

FromVariableSource0 overwrites any union data inside the VariableSource as the provided VariableSource0

func (*VariableSource) FromVariableSource1

func (t *VariableSource) FromVariableSource1(v VariableSource1) error

FromVariableSource1 overwrites any union data inside the VariableSource as the provided VariableSource1

func (*VariableSource) FromVariableSource2

func (t *VariableSource) FromVariableSource2(v VariableSource2) error

FromVariableSource2 overwrites any union data inside the VariableSource as the provided VariableSource2

func (*VariableSource) FromVariableSource3

func (t *VariableSource) FromVariableSource3(v VariableSource3) error

FromVariableSource3 overwrites any union data inside the VariableSource as the provided VariableSource3

func (*VariableSource) FromVariableSource4

func (t *VariableSource) FromVariableSource4(v VariableSource4) error

FromVariableSource4 overwrites any union data inside the VariableSource as the provided VariableSource4

func (VariableSource) MarshalJSON

func (t VariableSource) MarshalJSON() ([]byte, error)

func (*VariableSource) MergeVariableSource0

func (t *VariableSource) MergeVariableSource0(v VariableSource0) error

MergeVariableSource0 performs a merge with any union data inside the VariableSource, using the provided VariableSource0

func (*VariableSource) MergeVariableSource1

func (t *VariableSource) MergeVariableSource1(v VariableSource1) error

MergeVariableSource1 performs a merge with any union data inside the VariableSource, using the provided VariableSource1

func (*VariableSource) MergeVariableSource2

func (t *VariableSource) MergeVariableSource2(v VariableSource2) error

MergeVariableSource2 performs a merge with any union data inside the VariableSource, using the provided VariableSource2

func (*VariableSource) MergeVariableSource3

func (t *VariableSource) MergeVariableSource3(v VariableSource3) error

MergeVariableSource3 performs a merge with any union data inside the VariableSource, using the provided VariableSource3

func (*VariableSource) MergeVariableSource4

func (t *VariableSource) MergeVariableSource4(v VariableSource4) error

MergeVariableSource4 performs a merge with any union data inside the VariableSource, using the provided VariableSource4

func (*VariableSource) UnmarshalJSON

func (t *VariableSource) UnmarshalJSON(b []byte) error

type VariableSource0

type VariableSource0 string

VariableSource0 defines model for VariableSource.0.

const (
	VariableSource0Unknown VariableSource0 = "unknown"
)

Defines values for VariableSource0.

type VariableSource1

type VariableSource1 string

VariableSource1 From the user's own pipeline configuration.

const (
	PipelineConfig VariableSource1 = "pipeline_config"
)

Defines values for VariableSource1.

type VariableSource2

type VariableSource2 string

VariableSource2 From the Gofer API executor itself.

const (
	System VariableSource2 = "system"
)

Defines values for VariableSource2.

type VariableSource3

type VariableSource3 string

VariableSource3 Injected at the beginning of a particular run.

const (
	RunOptions VariableSource3 = "run_options"
)

Defines values for VariableSource3.

type VariableSource4

type VariableSource4 string

VariableSource4 Injected by a subscribed extension.

const (
	VariableSource4Extension VariableSource4 = "extension"
)

Defines values for VariableSource4.

type WhoAmIResponse

type WhoAmIResponse struct {
	// Token The target token.
	Token Token `json:"token"`
}

WhoAmIResponse defines model for WhoAmIResponse.

type WhoamiResp

type WhoamiResp struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *WhoAmIResponse
	JSON4XX      *Error
	JSON5XX      *Error
}

func ParseWhoamiResp

func ParseWhoamiResp(rsp *http.Response) (*WhoamiResp, error)

ParseWhoamiResp parses an HTTP response from a WhoamiWithResponse call

func (WhoamiResp) Status

func (r WhoamiResp) Status() string

Status returns HTTPResponse.Status

func (WhoamiResp) StatusCode

func (r WhoamiResp) StatusCode() int

StatusCode returns HTTPResponse.StatusCode