client

package

Go to main page

Versions in this module

v0

v0.5.8

Nov 1, 2026

v0.5.8-rc.3

Nov 1, 2026

v0.5.8-rc.2

Nov 1, 2026

v0.5.8-rc.1

Oct 29, 2026

v0.5.7

Oct 27, 2026

v0.5.7-rc.1

Oct 27, 2026

v0.5.6

Oct 23, 2026

Changes in this version

+ type AuthUnavailable = Error

type IssueTokenResponse

+ ApplicationproblemJSON503 *AuthUnavailable

+ Headers503 *IssueTokenResponse503Headers

+ func (r IssueTokenResponse) GetApplicationproblemJSON503() *AuthUnavailable

+ type IssueTokenResponse503Headers struct

+ RetryAfter *int

type RenewTokenResponse

+ ApplicationproblemJSON503 *AuthUnavailable

+ Headers503 *RenewTokenResponse503Headers

+ func (r RenewTokenResponse) GetApplicationproblemJSON503() *AuthUnavailable

+ type RenewTokenResponse503Headers struct

+ RetryAfter *int

v0.5.6-rc.2

Oct 23, 2026

v0.5.6-rc.1

Oct 23, 2026

v0.5.5

Oct 22, 2026

Changes in this version

+ var ErrCITokenNotServed = errors.New("the server does not serve " + ciTokenPath)

+ type CITokenRequest struct

+ Token string

+ type CITokenResponse struct

+ AccessToken string

+ ExpiresAt time.Time

+ ExpiresIn int

+ Issuer string

+ Role string

+ Scopes []string

+ Tenant string

+ TokenType string

+ type ClearVersionNotApplied = []struct

type Client

+ func (c *Client) ExchangeCIToken(ctx context.Context, body CITokenRequest, reqEditors ...RequestEditorFn) (*CITokenResponse, error)

type DAGRun

+ RunOnLatestVersionNotApplied *ClearVersionNotApplied

+ type DeployBuildKit struct

+ Namespace string

+ PodSelector string

+ type DeployCIOIDC struct

+ Issuers []DeployCIOIDCIssuer

+ type DeployCIOIDCIssuer struct

+ Audience string

+ Issuer string

+ Name string

+ Provider string

+ type DeployCloudBuild struct

+ Project string

+ Region string

+ ServiceAccount string

+ WorkerPool string

type DeployDefaults

+ CIOIDC *DeployCIOIDC

+ RemoteBuilder *DeployRemoteBuilder

+ SourceModeImage string

+ TaskServiceAccount string

+ WarmPools *DeployWarmPools

+ type DeployRemoteBuilder struct

+ BuildKit *DeployBuildKit

+ CloudBuild *DeployCloudBuild

+ type DeployWarmPools struct

+ Enabled bool

+ MaxPoolSize int

+ MinIdleWorkers int

type RegisterDagVersionResponse

+ Headers403 *RegisterDagVersionResponse403Headers

+ type RegisterDagVersionResponse403Headers struct

+ DexaflowDeployVia *string

type SetDagCurrentVersionResponse

+ Headers403 *SetDagCurrentVersionResponse403Headers

+ type SetDagCurrentVersionResponse403Headers struct

+ DexaflowDeployVia *string

type TaskInstanceCollection

+ RunOnLatestVersionNotApplied *ClearVersionNotApplied

type TaskInstanceState

+ const TaskInstanceStateRemoved

+ type TaskPodsReport struct

+ RunAsNonRoot bool

+ ServiceAccounts []TaskServiceAccountCheck

+ type TaskServiceAccountCheck struct

+ Detail *string

+ ImagePullSecrets *int

+ Name string

+ State string

+ Tasks []string

type VersionRegistration

+ TaskPods *TaskPodsReport

v0.5.5-rc.3

Oct 22, 2026

v0.5.5-rc.2

Oct 22, 2026

v0.5.5-rc.1

Oct 21, 2026

v0.5.4

Oct 16, 2026

Changes in this version

+ const DeviceGrantType

+ var ErrAuthMethodsNotServed = errors.New("the server does not serve " + authMethodsPath)

+ var ErrCLILoginCodeRefused = errors.New("the server refused the sign-in code")

+ var ErrDeployDefaultsNotServed = errors.New("the server does not serve " + deployDefaultsPath)

+ var ErrDeviceAccessDenied = errors.New("the sign-in was canceled in the browser")

+ var ErrDeviceAuthorizationPending = errors.New("the sign-in is waiting for its approval in the browser")

+ var ErrDeviceExpired = errors.New("the sign-in expired")

+ var ErrDeviceLoginNotServed = errors.New("the server does not serve " + cliDevicePath)

+ var ErrDeviceSlowDown = errors.New("polling too fast")

+ func DryRunRegister(_ context.Context, req *http.Request) error

+ func NewClearDagRunRequest(server string, dagId DagID, dagRunId DagRunID, body ClearDagRunJSONRequestBody) (*http.Request, error)

+ func NewClearDagRunRequestWithBody(server string, dagId DagID, dagRunId DagRunID, contentType string, ...) (*http.Request, error)

+ func NewCreateAPITokenRequest(server string, body CreateAPITokenJSONRequestBody) (*http.Request, error)

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

+ func NewListAPITokensRequest(server string, params *ListAPITokensParams) (*http.Request, error)

+ func NewPatchTaskInstanceDryRunRequest(server string, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Request, error)

+ func NewPatchTaskInstanceDryRunRequestWithBody(server string, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Request, error)

+ func NewPatchTaskInstanceRequest(server string, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Request, error)

+ func NewPatchTaskInstanceRequestWithBody(server string, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Request, error)

+ func NewRegisterDagVersionRequest(server string, dagId DagID, params *RegisterDagVersionParams, ...) (*http.Request, error)

+ func NewRegisterDagVersionRequestWithBody(server string, dagId DagID, params *RegisterDagVersionParams, ...) (*http.Request, error)

+ func NewRevokeAPITokenRequest(server string, tokenId string) (*http.Request, error)

+ func NewSetDagCurrentVersionRequest(server string, dagId DagID, body SetDagCurrentVersionJSONRequestBody) (*http.Request, error)

+ func NewSetDagCurrentVersionRequestWithBody(server string, dagId DagID, contentType string, body io.Reader) (*http.Request, error)

+ type APIToken struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ Id string

+ LastUsedAt *time.Time

+ Name string

+ OwnerEmail *string

+ Scopes []string

+ type APITokenCollection struct

+ ApiTokens *[]APIToken

+ TotalEntries *int

+ type AuthMethods struct

+ Device bool

+ Password bool

+ SSO bool

+ type BuildInfo struct

+ BaseImage *string

+ Builder *string

+ CliVersion *string

+ Commit *string

+ PipelineUrl *string

+ Repo *string

+ type CLIDeviceAuthorization struct

+ DeviceCode string

+ ExpiresIn int

+ Interval int

+ UserCode string

+ VerificationURI string

+ VerificationURIComplete string

+ type CLITokenRequest struct

+ Code string

+ CodeVerifier string

+ RedirectURI string

+ type ClearDagRun200JSONResponseBody struct

+ func (t *ClearDagRun200JSONResponseBody) FromDAGRun(v DAGRun) error

+ func (t *ClearDagRun200JSONResponseBody) FromTaskInstanceCollection(v TaskInstanceCollection) error

+ func (t *ClearDagRun200JSONResponseBody) MergeDAGRun(v DAGRun) error

+ func (t *ClearDagRun200JSONResponseBody) MergeTaskInstanceCollection(v TaskInstanceCollection) error

+ func (t *ClearDagRun200JSONResponseBody) UnmarshalJSON(b []byte) error

+ func (t ClearDagRun200JSONResponseBody) AsDAGRun() (DAGRun, error)

+ func (t ClearDagRun200JSONResponseBody) AsTaskInstanceCollection() (TaskInstanceCollection, error)

+ func (t ClearDagRun200JSONResponseBody) MarshalJSON() ([]byte, error)

+ type ClearDagRunJSONRequestBody = DAGRunClearRequest

+ type ClearDagRunResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *ClearDagRun200JSONResponseBody

+ JSON400 *Error

+ JSON403 *Error

+ JSON404 *NotFound

+ JSON409 *Error

+ func ParseClearDagRunResponse(rsp *http.Response) (*ClearDagRunResponse, error)

+ func (r ClearDagRunResponse) ContentType() string

+ func (r ClearDagRunResponse) GetBody() []byte

+ func (r ClearDagRunResponse) GetJSON200() *ClearDagRun200JSONResponseBody

+ func (r ClearDagRunResponse) GetJSON400() *Error

+ func (r ClearDagRunResponse) GetJSON403() *Error

+ func (r ClearDagRunResponse) GetJSON404() *NotFound

+ func (r ClearDagRunResponse) GetJSON409() *Error

+ func (r ClearDagRunResponse) Status() string

+ func (r ClearDagRunResponse) StatusCode() int

type ClearTaskInstancesResponse

+ JSON409 *Error

+ func (r ClearTaskInstancesResponse) GetJSON409() *Error

type Client

+ func (c *Client) ClearDagRun(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*http.Response, error)

+ func (c *Client) ClearDagRunWithBody(ctx context.Context, dagId DagID, dagRunId DagRunID, contentType string, ...) (*http.Response, error)

+ func (c *Client) CreateAPIToken(ctx context.Context, body CreateAPITokenJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) CreateAPITokenWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) ExchangeCLILoginCode(ctx context.Context, body CLITokenRequest, reqEditors ...RequestEditorFn) (*TokenResponse, error)

+ func (c *Client) GetAuthMethods(ctx context.Context, reqEditors ...RequestEditorFn) (*AuthMethods, error)

+ func (c *Client) GetDagVersionSpec(ctx context.Context, dagID string, versionNumber int, ...) (json.RawMessage, error)

+ func (c *Client) GetDeployDefaults(ctx context.Context, reqEditors ...RequestEditorFn) (*DeployDefaults, error)

+ func (c *Client) ListAPITokens(ctx context.Context, params *ListAPITokensParams, ...) (*http.Response, error)

+ func (c *Client) PatchTaskInstance(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ func (c *Client) PatchTaskInstanceDryRun(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ func (c *Client) PatchTaskInstanceDryRunWithBody(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ func (c *Client) PatchTaskInstanceWithBody(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ func (c *Client) PollCLIDeviceLogin(ctx context.Context, deviceCode string, reqEditors ...RequestEditorFn) (*TokenResponse, error)

+ func (c *Client) RegisterDagVersion(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*http.Response, error)

+ func (c *Client) RegisterDagVersionWithBody(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*http.Response, error)

+ func (c *Client) RevokeAPIToken(ctx context.Context, tokenId string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) SetDagCurrentVersion(ctx context.Context, dagId DagID, body SetDagCurrentVersionJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) SetDagCurrentVersionWithBody(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) StartCLIDeviceLogin(ctx context.Context, reqEditors ...RequestEditorFn) (*CLIDeviceAuthorization, error)

type ClientInterface

+ ClearDagRun func(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*http.Response, error)

+ ClearDagRunWithBody func(ctx context.Context, dagId DagID, dagRunId DagRunID, contentType string, ...) (*http.Response, error)

+ CreateAPIToken func(ctx context.Context, body CreateAPITokenJSONRequestBody, ...) (*http.Response, error)

+ CreateAPITokenWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ ListAPITokens func(ctx context.Context, params *ListAPITokensParams, ...) (*http.Response, error)

+ PatchTaskInstance func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ PatchTaskInstanceDryRun func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ PatchTaskInstanceDryRunWithBody func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ PatchTaskInstanceWithBody func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ RegisterDagVersion func(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*http.Response, error)

+ RegisterDagVersionWithBody func(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*http.Response, error)

+ RevokeAPIToken func(ctx context.Context, tokenId string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ SetDagCurrentVersion func(ctx context.Context, dagId DagID, body SetDagCurrentVersionJSONRequestBody, ...) (*http.Response, error)

+ SetDagCurrentVersionWithBody func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

type ClientWithResponses

+ func (c *ClientWithResponses) ClearDagRunWithBodyWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, contentType string, ...) (*ClearDagRunResponse, error)

+ func (c *ClientWithResponses) ClearDagRunWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*ClearDagRunResponse, error)

+ func (c *ClientWithResponses) CreateAPITokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateAPITokenResponse, error)

+ func (c *ClientWithResponses) CreateAPITokenWithResponse(ctx context.Context, body CreateAPITokenJSONRequestBody, ...) (*CreateAPITokenResponse, error)

+ func (c *ClientWithResponses) ListAPITokensWithResponse(ctx context.Context, params *ListAPITokensParams, ...) (*ListAPITokensResponse, error)

+ func (c *ClientWithResponses) PatchTaskInstanceDryRunWithBodyWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceDryRunResponse, error)

+ func (c *ClientWithResponses) PatchTaskInstanceDryRunWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceDryRunResponse, error)

+ func (c *ClientWithResponses) PatchTaskInstanceWithBodyWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceResponse, error)

+ func (c *ClientWithResponses) PatchTaskInstanceWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceResponse, error)

+ func (c *ClientWithResponses) RegisterDagVersionWithBodyWithResponse(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*RegisterDagVersionResponse, error)

+ func (c *ClientWithResponses) RegisterDagVersionWithResponse(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*RegisterDagVersionResponse, error)

+ func (c *ClientWithResponses) RevokeAPITokenWithResponse(ctx context.Context, tokenId string, reqEditors ...RequestEditorFn) (*RevokeAPITokenResponse, error)

+ func (c *ClientWithResponses) SetDagCurrentVersionWithBodyWithResponse(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*SetDagCurrentVersionResponse, error)

+ func (c *ClientWithResponses) SetDagCurrentVersionWithResponse(ctx context.Context, dagId DagID, body SetDagCurrentVersionJSONRequestBody, ...) (*SetDagCurrentVersionResponse, error)

type ClientWithResponsesInterface

+ ClearDagRunWithBodyWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, contentType string, ...) (*ClearDagRunResponse, error)

+ ClearDagRunWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*ClearDagRunResponse, error)

+ CreateAPITokenWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*CreateAPITokenResponse, error)

+ CreateAPITokenWithResponse func(ctx context.Context, body CreateAPITokenJSONRequestBody, ...) (*CreateAPITokenResponse, error)

+ ListAPITokensWithResponse func(ctx context.Context, params *ListAPITokensParams, ...) (*ListAPITokensResponse, error)

+ PatchTaskInstanceDryRunWithBodyWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceDryRunResponse, error)

+ PatchTaskInstanceDryRunWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceDryRunResponse, error)

+ PatchTaskInstanceWithBodyWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceResponse, error)

+ PatchTaskInstanceWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*PatchTaskInstanceResponse, error)

+ RegisterDagVersionWithBodyWithResponse func(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*RegisterDagVersionResponse, error)

+ RegisterDagVersionWithResponse func(ctx context.Context, dagId DagID, params *RegisterDagVersionParams, ...) (*RegisterDagVersionResponse, error)

+ RevokeAPITokenWithResponse func(ctx context.Context, tokenId string, reqEditors ...RequestEditorFn) (*RevokeAPITokenResponse, error)

+ SetDagCurrentVersionWithBodyWithResponse func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*SetDagCurrentVersionResponse, error)

+ SetDagCurrentVersionWithResponse func(ctx context.Context, dagId DagID, body SetDagCurrentVersionJSONRequestBody, ...) (*SetDagCurrentVersionResponse, error)

type Connection

+ ExtraUnreadable *bool

+ type CreateAPITokenJSONRequestBody = CreateAPITokenRequest

+ type CreateAPITokenRequest struct

+ ExpiresInSeconds *int64

+ Name string

+ Scope CreateAPITokenRequestScope

+ type CreateAPITokenRequestScope string

+ const Deploy

+ const Read

+ func (e CreateAPITokenRequestScope) Valid() bool

+ type CreateAPITokenResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *CreatedAPIToken

+ JSON400 *Error

+ JSON401 *Unauthorized

+ JSON403 *Error

+ JSON409 *Error

+ func ParseCreateAPITokenResponse(rsp *http.Response) (*CreateAPITokenResponse, error)

+ func (r CreateAPITokenResponse) ContentType() string

+ func (r CreateAPITokenResponse) GetBody() []byte

+ func (r CreateAPITokenResponse) GetJSON201() *CreatedAPIToken

+ func (r CreateAPITokenResponse) GetJSON400() *Error

+ func (r CreateAPITokenResponse) GetJSON401() *Unauthorized

+ func (r CreateAPITokenResponse) GetJSON403() *Error

+ func (r CreateAPITokenResponse) GetJSON409() *Error

+ func (r CreateAPITokenResponse) Status() string

+ func (r CreateAPITokenResponse) StatusCode() int

+ type CreatedAPIToken struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ Id string

+ LastUsedAt *time.Time

+ Name string

+ OwnerEmail *string

+ Scopes []string

+ Token string

+ type DAGRunClearRequest struct

+ DryRun *bool

+ Note *string

+ OnlyFailed *bool

+ OnlyNew *bool

+ RunOnLatestVersion *bool

type DAGRunCollection

+ NextCursor *string

+ PreviousCursor *string

+ type DagCurrentVersionChange struct

+ Changed bool

+ DagId string

+ From *DagVersion

+ To DagVersion

+ Warnings *[]string

+ type DagCurrentVersionRequest struct

+ Version *string

+ VersionNumber *int

+ type DagSpec struct

+ AdditionalProperties map[string]interface{}

+ DagId string

+ DagVersion string

+ Image string

+ SchemaVersion string

+ Tasks []map[string]interface{}

+ func (a *DagSpec) Set(fieldName string, value interface{})

+ func (a *DagSpec) UnmarshalJSON(b []byte) error

+ func (a DagSpec) Get(fieldName string) (value interface{}, found bool)

+ func (a DagSpec) MarshalJSON() ([]byte, error)

type DagVersion

+ BuildInfo *BuildInfo

+ CreatedBy *string

+ Image *string

+ IsCurrent *bool

+ SpecHash *string

+ type DeployDefaults struct

+ BaseImage string

+ Platforms []string

+ Registry string

+ type ExecutionReport struct

+ Pool WarmPoolReport

+ Tasks []TaskExecution

+ WarmPools bool

type GetDagSourceResponse

+ JSON400 *Error

+ func (r GetDagSourceResponse) GetJSON400() *Error

+ type ListAPITokensParams struct

+ Limit *Limit

+ Offset *Offset

+ type ListAPITokensResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *APITokenCollection

+ JSON401 *Unauthorized

+ JSON403 *Error

+ func ParseListAPITokensResponse(rsp *http.Response) (*ListAPITokensResponse, error)

+ func (r ListAPITokensResponse) ContentType() string

+ func (r ListAPITokensResponse) GetBody() []byte

+ func (r ListAPITokensResponse) GetJSON200() *APITokenCollection

+ func (r ListAPITokensResponse) GetJSON401() *Unauthorized

+ func (r ListAPITokensResponse) GetJSON403() *Error

+ func (r ListAPITokensResponse) Status() string

+ func (r ListAPITokensResponse) StatusCode() int

+ type PatchTaskInstanceDryRunJSONRequestBody = TaskInstanceStateUpdate

+ type PatchTaskInstanceDryRunResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *TaskInstanceCollection

+ JSON400 *Error

+ JSON404 *NotFound

+ func ParsePatchTaskInstanceDryRunResponse(rsp *http.Response) (*PatchTaskInstanceDryRunResponse, error)

+ func (r PatchTaskInstanceDryRunResponse) ContentType() string

+ func (r PatchTaskInstanceDryRunResponse) GetBody() []byte

+ func (r PatchTaskInstanceDryRunResponse) GetJSON200() *TaskInstanceCollection

+ func (r PatchTaskInstanceDryRunResponse) GetJSON400() *Error

+ func (r PatchTaskInstanceDryRunResponse) GetJSON404() *NotFound

+ func (r PatchTaskInstanceDryRunResponse) Status() string

+ func (r PatchTaskInstanceDryRunResponse) StatusCode() int

+ type PatchTaskInstanceJSONRequestBody = TaskInstanceStateUpdate

+ type PatchTaskInstanceResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *TaskInstanceCollection

+ JSON400 *Error

+ JSON404 *NotFound

+ func ParsePatchTaskInstanceResponse(rsp *http.Response) (*PatchTaskInstanceResponse, error)

+ func (r PatchTaskInstanceResponse) ContentType() string

+ func (r PatchTaskInstanceResponse) GetBody() []byte

+ func (r PatchTaskInstanceResponse) GetJSON200() *TaskInstanceCollection

+ func (r PatchTaskInstanceResponse) GetJSON400() *Error

+ func (r PatchTaskInstanceResponse) GetJSON404() *NotFound

+ func (r PatchTaskInstanceResponse) Status() string

+ func (r PatchTaskInstanceResponse) StatusCode() int

+ type RegisterDagVersionJSONRequestBody = DagSpec

+ type RegisterDagVersionParams struct

+ BuildBaseImage *string

+ BuildBuilder *string

+ BuildCliVersion *string

+ BuildCommit *string

+ BuildPipelineUrl *string

+ BuildRepo *string

+ IsPaused *bool

+ PromotedFrom *string

+ PromotedFromServer *string

+ type RegisterDagVersionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *VersionRegistration

+ JSON201 *VersionRegistration

+ JSON400 *Error

+ JSON401 *Unauthorized

+ JSON403 *Error

+ JSON409 *Error

+ func ParseRegisterDagVersionResponse(rsp *http.Response) (*RegisterDagVersionResponse, error)

+ func (r RegisterDagVersionResponse) ContentType() string

+ func (r RegisterDagVersionResponse) GetBody() []byte

+ func (r RegisterDagVersionResponse) GetJSON200() *VersionRegistration

+ func (r RegisterDagVersionResponse) GetJSON201() *VersionRegistration

+ func (r RegisterDagVersionResponse) GetJSON400() *Error

+ func (r RegisterDagVersionResponse) GetJSON401() *Unauthorized

+ func (r RegisterDagVersionResponse) GetJSON403() *Error

+ func (r RegisterDagVersionResponse) GetJSON409() *Error

+ func (r RegisterDagVersionResponse) Status() string

+ func (r RegisterDagVersionResponse) StatusCode() int

type RequestEditorFn

+ func WithDagSourceVersion(n int) RequestEditorFn

+ type RevokeAPITokenResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON401 *Unauthorized

+ JSON403 *Error

+ JSON404 *NotFound

+ func ParseRevokeAPITokenResponse(rsp *http.Response) (*RevokeAPITokenResponse, error)

+ func (r RevokeAPITokenResponse) ContentType() string

+ func (r RevokeAPITokenResponse) GetBody() []byte

+ func (r RevokeAPITokenResponse) GetJSON401() *Unauthorized

+ func (r RevokeAPITokenResponse) GetJSON403() *Error

+ func (r RevokeAPITokenResponse) GetJSON404() *NotFound

+ func (r RevokeAPITokenResponse) Status() string

+ func (r RevokeAPITokenResponse) StatusCode() int

+ type SetDagCurrentVersionJSONRequestBody = DagCurrentVersionRequest

+ type SetDagCurrentVersionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DagCurrentVersionChange

+ JSON400 *Error

+ JSON401 *Unauthorized

+ JSON403 *Error

+ JSON404 *NotFound

+ func ParseSetDagCurrentVersionResponse(rsp *http.Response) (*SetDagCurrentVersionResponse, error)

+ func (r SetDagCurrentVersionResponse) ContentType() string

+ func (r SetDagCurrentVersionResponse) GetBody() []byte

+ func (r SetDagCurrentVersionResponse) GetJSON200() *DagCurrentVersionChange

+ func (r SetDagCurrentVersionResponse) GetJSON400() *Error

+ func (r SetDagCurrentVersionResponse) GetJSON401() *Unauthorized

+ func (r SetDagCurrentVersionResponse) GetJSON403() *Error

+ func (r SetDagCurrentVersionResponse) GetJSON404() *NotFound

+ func (r SetDagCurrentVersionResponse) Status() string

+ func (r SetDagCurrentVersionResponse) StatusCode() int

+ type StatusError struct

+ Body []byte

+ Path string

+ StatusCode int

+ func (e *StatusError) Error() string

+ type TaskExecution struct

+ Mode TaskExecutionMode

+ Reason *string

+ TaskId string

+ type TaskExecutionMode string

+ const TaskExecutionModeDedicated

+ const TaskExecutionModeWarm

+ func (e TaskExecutionMode) Valid() bool

type TaskInstanceCollection

+ NextCursor *string

+ PreviousCursor *string

+ type TaskInstanceStateUpdate struct

+ NewState TaskInstanceStateUpdateNewState

+ type TaskInstanceStateUpdateNewState string

+ const TaskInstanceStateUpdateNewStateFailed

+ const TaskInstanceStateUpdateNewStateSkipped

+ const TaskInstanceStateUpdateNewStateSuccess

+ func (e TaskInstanceStateUpdateNewState) Valid() bool

type Variable

+ ValueUnreadable *bool

+ type VersionRegistration struct

+ Created *bool

+ DagCreated *bool

+ DagId *string

+ DryRun *bool

+ Execution *ExecutionReport

+ IsPaused *bool

+ SpecHash *string

+ Version *string

+ Warnings *[]string

+ type WarmPoolReport struct

+ Detail string

+ MaxPoolSize *int

+ MinIdleWorkers *int

+ PreviousPool *WarmPoolReportPreviousPool

+ State WarmPoolReportState

+ type WarmPoolReportPreviousPool string

+ const WarmPoolReportPreviousPoolDraining

+ func (e WarmPoolReportPreviousPool) Valid() bool

+ type WarmPoolReportState string

+ const WarmPoolReportStateNone

+ const WarmPoolReportStateOff

+ const WarmPoolReportStateOn

+ func (e WarmPoolReportState) Valid() bool

v0.5.4-rc.1

Oct 15, 2026

v0.5.3

Oct 12, 2026

Changes in this version

type UpdateDagResponse

+ JSON400 *Error

+ func (r UpdateDagResponse) GetJSON400() *Error

v0.5.3-rc.1

Oct 10, 2026

v0.5.2

Oct 8, 2026

v0.5.2-rc.1

Oct 8, 2026

v0.5.1

Oct 6, 2026

Changes in this version

+ type Cursor = string

type ListDagRunsParams

+ Cursor *Cursor

v0.5.1-rc.1

Oct 5, 2026

v0.5.0

Oct 3, 2026

Changes in this version

+ func NewClearTaskInstancesRequest(server string, dagId DagID, body ClearTaskInstancesJSONRequestBody) (*http.Request, error)

+ func NewClearTaskInstancesRequestWithBody(server string, dagId DagID, contentType string, body io.Reader) (*http.Request, error)

+ func NewCreateConnectionRequest(server string, body CreateConnectionJSONRequestBody) (*http.Request, error)

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

+ func NewCreateUserRequest(server string, body CreateUserJSONRequestBody) (*http.Request, error)

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

+ func NewCreateVariableRequest(server string, body CreateVariableJSONRequestBody) (*http.Request, error)

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

+ func NewDeleteConnectionRequest(server string, connectionId ConnectionID) (*http.Request, error)

+ func NewDeleteVariableRequest(server string, variableKey VariableKey) (*http.Request, error)

+ func NewGetConnectionRequest(server string, connectionId ConnectionID) (*http.Request, error)

+ func NewGetDagRequest(server string, dagId DagID) (*http.Request, error)

+ func NewGetDagRunRequest(server string, dagId DagID, dagRunId DagRunID) (*http.Request, error)

+ func NewGetDagSourceRequest(server string, dagId DagID) (*http.Request, error)

+ func NewGetDagSpecRequest(server string, dagId DagID) (*http.Request, error)

+ func NewGetDagVersionRequest(server string, dagId DagID, versionNumber int) (*http.Request, error)

+ func NewGetHealthzRequest(server string) (*http.Request, error)

+ func NewGetMonitorExecutorRequest(server string) (*http.Request, error)

+ func NewGetMonitorHealthRequest(server string) (*http.Request, error)

+ func NewGetReadyzRequest(server string) (*http.Request, error)

+ func NewGetTaskInstanceRequest(server string, dagId DagID, dagRunId DagRunID, taskId TaskID) (*http.Request, error)

+ func NewGetTaskLogsRequest(server string, dagId DagID, dagRunId DagRunID, taskId TaskID, tryNumber int) (*http.Request, error)

+ func NewGetVariableRequest(server string, variableKey VariableKey) (*http.Request, error)

+ func NewGetVersionRequest(server string) (*http.Request, error)

+ func NewGetXcomEntryRequest(server string, dagId DagID, dagRunId DagRunID, taskId TaskID, key string) (*http.Request, error)

+ func NewIssueTokenRequest(server string, body IssueTokenJSONRequestBody) (*http.Request, error)

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

+ func NewListConnectionsRequest(server string, params *ListConnectionsParams) (*http.Request, error)

+ func NewListDagRunsRequest(server string, dagId DagID, params *ListDagRunsParams) (*http.Request, error)

+ func NewListDagVersionsRequest(server string, dagId DagID) (*http.Request, error)

+ func NewListDagsRequest(server string, params *ListDagsParams) (*http.Request, error)

+ func NewListTaskInstancesRequest(server string, dagId DagID, dagRunId DagRunID) (*http.Request, error)

+ func NewListUsersRequest(server string, params *ListUsersParams) (*http.Request, error)

+ func NewListVariablesRequest(server string, params *ListVariablesParams) (*http.Request, error)

+ func NewRenewTokenRequest(server string) (*http.Request, error)

+ func NewTriggerDagRunRequest(server string, dagId DagID, body TriggerDagRunJSONRequestBody) (*http.Request, error)

+ func NewTriggerDagRunRequestWithBody(server string, dagId DagID, contentType string, body io.Reader) (*http.Request, error)

+ func NewUpdateConnectionRequest(server string, connectionId ConnectionID, body UpdateConnectionJSONRequestBody) (*http.Request, error)

+ func NewUpdateConnectionRequestWithBody(server string, connectionId ConnectionID, contentType string, body io.Reader) (*http.Request, error)

+ func NewUpdateDagRequest(server string, dagId DagID, body UpdateDagJSONRequestBody) (*http.Request, error)

+ func NewUpdateDagRequestWithBody(server string, dagId DagID, contentType string, body io.Reader) (*http.Request, error)

+ type ClearTaskInstancesJSONRequestBody = ClearTaskInstancesRequest

+ type ClearTaskInstancesRequest struct

+ DagRunId *string

+ DryRun *bool

+ IncludeDownstream *bool

+ IncludeFuture *bool

+ IncludePast *bool

+ IncludeUpstream *bool

+ OnlyFailed *bool

+ OnlyRunning *bool

+ ResetDagRuns *bool

+ RunOnLatestVersion *bool

+ TaskIds *[]string

+ type ClearTaskInstancesResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *TaskInstanceCollection

+ func ParseClearTaskInstancesResponse(rsp *http.Response) (*ClearTaskInstancesResponse, error)

+ func (r ClearTaskInstancesResponse) ContentType() string

+ func (r ClearTaskInstancesResponse) GetBody() []byte

+ func (r ClearTaskInstancesResponse) GetJSON200() *TaskInstanceCollection

+ func (r ClearTaskInstancesResponse) Status() string

+ func (r ClearTaskInstancesResponse) StatusCode() int

+ type Client struct

+ Client HttpRequestDoer

+ RequestEditors []RequestEditorFn

+ Server string

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

+ func (c *Client) ClearTaskInstances(ctx context.Context, dagId DagID, body ClearTaskInstancesJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) ClearTaskInstancesWithBody(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) CreateConnection(ctx context.Context, body CreateConnectionJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) CreateConnectionWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) CreateUser(ctx context.Context, body CreateUserJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) CreateUserWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) CreateVariable(ctx context.Context, body CreateVariableJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) CreateVariableWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) DeleteConnection(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) DeleteVariable(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetConnection(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetDag(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetDagRun(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*http.Response, error)

+ func (c *Client) GetDagSource(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetDagSpec(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetDagVersion(ctx context.Context, dagId DagID, versionNumber int, ...) (*http.Response, error)

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

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

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

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

+ func (c *Client) GetTaskInstance(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ func (c *Client) GetTaskLogs(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ func (c *Client) GetVariable(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*http.Response, error)

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

+ func (c *Client) GetXcomEntry(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, key string, ...) (*http.Response, error)

+ func (c *Client) IssueToken(ctx context.Context, body IssueTokenJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) IssueTokenWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) ListConnections(ctx context.Context, params *ListConnectionsParams, ...) (*http.Response, error)

+ func (c *Client) ListDagRuns(ctx context.Context, dagId DagID, params *ListDagRunsParams, ...) (*http.Response, error)

+ func (c *Client) ListDagVersions(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) ListDags(ctx context.Context, params *ListDagsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) ListTaskInstances(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*http.Response, error)

+ func (c *Client) ListUsers(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) ListVariables(ctx context.Context, params *ListVariablesParams, ...) (*http.Response, error)

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

+ func (c *Client) TriggerDagRun(ctx context.Context, dagId DagID, body TriggerDagRunJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) TriggerDagRunWithBody(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) UpdateConnection(ctx context.Context, connectionId ConnectionID, ...) (*http.Response, error)

+ func (c *Client) UpdateConnectionWithBody(ctx context.Context, connectionId ConnectionID, contentType string, ...) (*http.Response, error)

+ func (c *Client) UpdateDag(ctx context.Context, dagId DagID, body UpdateDagJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) UpdateDagWithBody(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientInterface interface

+ ClearTaskInstances func(ctx context.Context, dagId DagID, body ClearTaskInstancesJSONRequestBody, ...) (*http.Response, error)

+ ClearTaskInstancesWithBody func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

+ CreateConnection func(ctx context.Context, body CreateConnectionJSONRequestBody, ...) (*http.Response, error)

+ CreateConnectionWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ CreateUser func(ctx context.Context, body CreateUserJSONRequestBody, ...) (*http.Response, error)

+ CreateUserWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ CreateVariable func(ctx context.Context, body CreateVariableJSONRequestBody, ...) (*http.Response, error)

+ CreateVariableWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ DeleteConnection func(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ DeleteVariable func(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetConnection func(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetDag func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetDagRun func(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*http.Response, error)

+ GetDagSource func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetDagSpec func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetDagVersion func(ctx context.Context, dagId DagID, versionNumber int, ...) (*http.Response, error)

+ GetHealthz func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetMonitorExecutor func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetMonitorHealth func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetReadyz func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetTaskInstance func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ GetTaskLogs func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*http.Response, error)

+ GetVariable func(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetVersion func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetXcomEntry func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, key string, ...) (*http.Response, error)

+ IssueToken func(ctx context.Context, body IssueTokenJSONRequestBody, ...) (*http.Response, error)

+ IssueTokenWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ ListConnections func(ctx context.Context, params *ListConnectionsParams, ...) (*http.Response, error)

+ ListDagRuns func(ctx context.Context, dagId DagID, params *ListDagRunsParams, ...) (*http.Response, error)

+ ListDagVersions func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ ListDags func(ctx context.Context, params *ListDagsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

+ ListTaskInstances func(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*http.Response, error)

+ ListUsers func(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*http.Response, error)

+ ListVariables func(ctx context.Context, params *ListVariablesParams, ...) (*http.Response, error)

+ RenewToken func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ TriggerDagRun func(ctx context.Context, dagId DagID, body TriggerDagRunJSONRequestBody, ...) (*http.Response, error)

+ TriggerDagRunWithBody func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

+ UpdateConnection func(ctx context.Context, connectionId ConnectionID, ...) (*http.Response, error)

+ UpdateConnectionWithBody func(ctx context.Context, connectionId ConnectionID, contentType string, ...) (*http.Response, error)

+ UpdateDag func(ctx context.Context, dagId DagID, body UpdateDagJSONRequestBody, ...) (*http.Response, error)

+ UpdateDagWithBody func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientOption func(*Client) error

+ func WithBaseURL(baseURL string) ClientOption

+ func WithHTTPClient(doer HttpRequestDoer) ClientOption

+ func WithRequestEditorFn(fn RequestEditorFn) ClientOption

+ type ClientWithResponses struct

+ func New(baseURL, token string, opts ...ClientOption) (*ClientWithResponses, error)

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

+ func (c *ClientWithResponses) ClearTaskInstancesWithBodyWithResponse(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*ClearTaskInstancesResponse, error)

+ func (c *ClientWithResponses) ClearTaskInstancesWithResponse(ctx context.Context, dagId DagID, body ClearTaskInstancesJSONRequestBody, ...) (*ClearTaskInstancesResponse, error)

+ func (c *ClientWithResponses) CreateConnectionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateConnectionResponse, error)

+ func (c *ClientWithResponses) CreateConnectionWithResponse(ctx context.Context, body CreateConnectionJSONRequestBody, ...) (*CreateConnectionResponse, error)

+ func (c *ClientWithResponses) CreateUserWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateUserResponse, error)

+ func (c *ClientWithResponses) CreateUserWithResponse(ctx context.Context, body CreateUserJSONRequestBody, ...) (*CreateUserResponse, error)

+ func (c *ClientWithResponses) CreateVariableWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateVariableResponse, error)

+ func (c *ClientWithResponses) CreateVariableWithResponse(ctx context.Context, body CreateVariableJSONRequestBody, ...) (*CreateVariableResponse, error)

+ func (c *ClientWithResponses) DeleteConnectionWithResponse(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*DeleteConnectionResponse, error)

+ func (c *ClientWithResponses) DeleteVariableWithResponse(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*DeleteVariableResponse, error)

+ func (c *ClientWithResponses) GetConnectionWithResponse(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*GetConnectionResponse, error)

+ func (c *ClientWithResponses) GetDagRunWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*GetDagRunResponse, error)

+ func (c *ClientWithResponses) GetDagSourceWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagSourceResponse, error)

+ func (c *ClientWithResponses) GetDagSpecWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagSpecResponse, error)

+ func (c *ClientWithResponses) GetDagVersionWithResponse(ctx context.Context, dagId DagID, versionNumber int, ...) (*GetDagVersionResponse, error)

+ func (c *ClientWithResponses) GetDagWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagResponse, error)

+ func (c *ClientWithResponses) GetHealthzWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetHealthzResponse, error)

+ func (c *ClientWithResponses) GetMonitorExecutorWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMonitorExecutorResponse, error)

+ func (c *ClientWithResponses) GetMonitorHealthWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMonitorHealthResponse, error)

+ func (c *ClientWithResponses) GetReadyzWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetReadyzResponse, error)

+ func (c *ClientWithResponses) GetTaskInstanceWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*GetTaskInstanceResponse, error)

+ func (c *ClientWithResponses) GetTaskLogsWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*GetTaskLogsResponse, error)

+ func (c *ClientWithResponses) GetVariableWithResponse(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*GetVariableResponse, error)

+ func (c *ClientWithResponses) GetVersionWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetVersionResponse, error)

+ func (c *ClientWithResponses) GetXcomEntryWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, key string, ...) (*GetXcomEntryResponse, error)

+ func (c *ClientWithResponses) IssueTokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*IssueTokenResponse, error)

+ func (c *ClientWithResponses) IssueTokenWithResponse(ctx context.Context, body IssueTokenJSONRequestBody, ...) (*IssueTokenResponse, error)

+ func (c *ClientWithResponses) ListConnectionsWithResponse(ctx context.Context, params *ListConnectionsParams, ...) (*ListConnectionsResponse, error)

+ func (c *ClientWithResponses) ListDagRunsWithResponse(ctx context.Context, dagId DagID, params *ListDagRunsParams, ...) (*ListDagRunsResponse, error)

+ func (c *ClientWithResponses) ListDagVersionsWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*ListDagVersionsResponse, error)

+ func (c *ClientWithResponses) ListDagsWithResponse(ctx context.Context, params *ListDagsParams, reqEditors ...RequestEditorFn) (*ListDagsResponse, error)

+ func (c *ClientWithResponses) ListTaskInstancesWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*ListTaskInstancesResponse, error)

+ func (c *ClientWithResponses) ListUsersWithResponse(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*ListUsersResponse, error)

+ func (c *ClientWithResponses) ListVariablesWithResponse(ctx context.Context, params *ListVariablesParams, ...) (*ListVariablesResponse, error)

+ func (c *ClientWithResponses) RenewTokenWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RenewTokenResponse, error)

+ func (c *ClientWithResponses) TriggerDagRunWithBodyWithResponse(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*TriggerDagRunResponse, error)

+ func (c *ClientWithResponses) TriggerDagRunWithResponse(ctx context.Context, dagId DagID, body TriggerDagRunJSONRequestBody, ...) (*TriggerDagRunResponse, error)

+ func (c *ClientWithResponses) UpdateConnectionWithBodyWithResponse(ctx context.Context, connectionId ConnectionID, contentType string, ...) (*UpdateConnectionResponse, error)

+ func (c *ClientWithResponses) UpdateConnectionWithResponse(ctx context.Context, connectionId ConnectionID, ...) (*UpdateConnectionResponse, error)

+ func (c *ClientWithResponses) UpdateDagWithBodyWithResponse(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*UpdateDagResponse, error)

+ func (c *ClientWithResponses) UpdateDagWithResponse(ctx context.Context, dagId DagID, body UpdateDagJSONRequestBody, ...) (*UpdateDagResponse, error)

+ type ClientWithResponsesInterface interface

+ ClearTaskInstancesWithBodyWithResponse func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*ClearTaskInstancesResponse, error)

+ ClearTaskInstancesWithResponse func(ctx context.Context, dagId DagID, body ClearTaskInstancesJSONRequestBody, ...) (*ClearTaskInstancesResponse, error)

+ CreateConnectionWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*CreateConnectionResponse, error)

+ CreateConnectionWithResponse func(ctx context.Context, body CreateConnectionJSONRequestBody, ...) (*CreateConnectionResponse, error)

+ CreateUserWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*CreateUserResponse, error)

+ CreateUserWithResponse func(ctx context.Context, body CreateUserJSONRequestBody, ...) (*CreateUserResponse, error)

+ CreateVariableWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*CreateVariableResponse, error)

+ CreateVariableWithResponse func(ctx context.Context, body CreateVariableJSONRequestBody, ...) (*CreateVariableResponse, error)

+ DeleteConnectionWithResponse func(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*DeleteConnectionResponse, error)

+ DeleteVariableWithResponse func(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*DeleteVariableResponse, error)

+ GetConnectionWithResponse func(ctx context.Context, connectionId ConnectionID, reqEditors ...RequestEditorFn) (*GetConnectionResponse, error)

+ GetDagRunWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*GetDagRunResponse, error)

+ GetDagSourceWithResponse func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagSourceResponse, error)

+ GetDagSpecWithResponse func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagSpecResponse, error)

+ GetDagVersionWithResponse func(ctx context.Context, dagId DagID, versionNumber int, ...) (*GetDagVersionResponse, error)

+ GetDagWithResponse func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagResponse, error)

+ GetHealthzWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetHealthzResponse, error)

+ GetMonitorExecutorWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMonitorExecutorResponse, error)

+ GetMonitorHealthWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMonitorHealthResponse, error)

+ GetReadyzWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetReadyzResponse, error)

+ GetTaskInstanceWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*GetTaskInstanceResponse, error)

+ GetTaskLogsWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, ...) (*GetTaskLogsResponse, error)

+ GetVariableWithResponse func(ctx context.Context, variableKey VariableKey, reqEditors ...RequestEditorFn) (*GetVariableResponse, error)

+ GetVersionWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetVersionResponse, error)

+ GetXcomEntryWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, key string, ...) (*GetXcomEntryResponse, error)

+ IssueTokenWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*IssueTokenResponse, error)

+ IssueTokenWithResponse func(ctx context.Context, body IssueTokenJSONRequestBody, ...) (*IssueTokenResponse, error)

+ ListConnectionsWithResponse func(ctx context.Context, params *ListConnectionsParams, ...) (*ListConnectionsResponse, error)

+ ListDagRunsWithResponse func(ctx context.Context, dagId DagID, params *ListDagRunsParams, ...) (*ListDagRunsResponse, error)

+ ListDagVersionsWithResponse func(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*ListDagVersionsResponse, error)

+ ListDagsWithResponse func(ctx context.Context, params *ListDagsParams, reqEditors ...RequestEditorFn) (*ListDagsResponse, error)

+ ListTaskInstancesWithResponse func(ctx context.Context, dagId DagID, dagRunId DagRunID, ...) (*ListTaskInstancesResponse, error)

+ ListUsersWithResponse func(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*ListUsersResponse, error)

+ ListVariablesWithResponse func(ctx context.Context, params *ListVariablesParams, ...) (*ListVariablesResponse, error)

+ RenewTokenWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*RenewTokenResponse, error)

+ TriggerDagRunWithBodyWithResponse func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*TriggerDagRunResponse, error)

+ TriggerDagRunWithResponse func(ctx context.Context, dagId DagID, body TriggerDagRunJSONRequestBody, ...) (*TriggerDagRunResponse, error)

+ UpdateConnectionWithBodyWithResponse func(ctx context.Context, connectionId ConnectionID, contentType string, ...) (*UpdateConnectionResponse, error)

+ UpdateConnectionWithResponse func(ctx context.Context, connectionId ConnectionID, ...) (*UpdateConnectionResponse, error)

+ UpdateDagWithBodyWithResponse func(ctx context.Context, dagId DagID, contentType string, body io.Reader, ...) (*UpdateDagResponse, error)

+ UpdateDagWithResponse func(ctx context.Context, dagId DagID, body UpdateDagJSONRequestBody, ...) (*UpdateDagResponse, error)

+ type ComponentHealth struct

+ LatestDagProcessorHeartbeat *string

+ LatestSchedulerHeartbeat *string

+ LatestTriggererHeartbeat *string

+ Status *string

+ type Connection struct

+ ConnType string

+ ConnectionId string

+ Description *string

+ Extra *string

+ Host *string

+ Login *string

+ Port *int

+ Schema *string

+ type ConnectionBody struct

+ ConnType string

+ ConnectionId *string

+ Description *string

+ Extra *string

+ Host *string

+ Login *string

+ Password *string

+ Port *int

+ Schema *string

+ type ConnectionCollection struct

+ Connections *[]Connection

+ TotalEntries *int

+ type ConnectionID = string

+ type CreateConnectionJSONRequestBody = ConnectionBody

+ type CreateConnectionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *Connection

+ JSON400 *Error

+ JSON401 *Unauthorized

+ JSON503 *EncryptionUnavailable

+ func ParseCreateConnectionResponse(rsp *http.Response) (*CreateConnectionResponse, error)

+ func (r CreateConnectionResponse) ContentType() string

+ func (r CreateConnectionResponse) GetBody() []byte

+ func (r CreateConnectionResponse) GetJSON201() *Connection

+ func (r CreateConnectionResponse) GetJSON400() *Error

+ func (r CreateConnectionResponse) GetJSON401() *Unauthorized

+ func (r CreateConnectionResponse) GetJSON503() *EncryptionUnavailable

+ func (r CreateConnectionResponse) Status() string

+ func (r CreateConnectionResponse) StatusCode() int

+ type CreateUserJSONRequestBody = CreateUserRequest

+ type CreateUserRequest struct

+ Email string

+ Password *string

+ Roles *[]string

+ type CreateUserResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *User

+ JSON400 *Error

+ JSON401 *Unauthorized

+ JSON409 *Error

+ func ParseCreateUserResponse(rsp *http.Response) (*CreateUserResponse, error)

+ func (r CreateUserResponse) ContentType() string

+ func (r CreateUserResponse) GetBody() []byte

+ func (r CreateUserResponse) GetJSON201() *User

+ func (r CreateUserResponse) GetJSON400() *Error

+ func (r CreateUserResponse) GetJSON401() *Unauthorized

+ func (r CreateUserResponse) GetJSON409() *Error

+ func (r CreateUserResponse) Status() string

+ func (r CreateUserResponse) StatusCode() int

+ type CreateVariableJSONRequestBody = VariableBody

+ type CreateVariableResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *Variable

+ JSON400 *Error

+ JSON401 *Unauthorized

+ func ParseCreateVariableResponse(rsp *http.Response) (*CreateVariableResponse, error)

+ func (r CreateVariableResponse) ContentType() string

+ func (r CreateVariableResponse) GetBody() []byte

+ func (r CreateVariableResponse) GetJSON201() *Variable

+ func (r CreateVariableResponse) GetJSON400() *Error

+ func (r CreateVariableResponse) GetJSON401() *Unauthorized

+ func (r CreateVariableResponse) Status() string

+ func (r CreateVariableResponse) StatusCode() int

+ type DAG struct

+ Catchup *bool

+ DagDisplayName *string

+ DagId *string

+ Description *string

+ Fileloc *string

+ HasTaskConcurrencyLimits *bool

+ IsActive *bool

+ IsPaused *bool

+ LastParsedTime *time.Time

+ MaxActiveRuns *int

+ NextDagrun *time.Time

+ Owners *[]string

+ ScheduleInterval *map[string]interface{}

+ Tags ...

+ TimetableDescription *string

+ type DAGCollection struct

+ Dags *[]DAG

+ TotalEntries *int

+ type DAGRun struct

+ Conf *map[string]interface{}

+ DagId *string

+ DagRunId *string

+ DataIntervalEnd *time.Time

+ DataIntervalStart *time.Time

+ EndDate *time.Time

+ LogicalDate *time.Time

+ Note *string

+ QueuedAt *time.Time

+ RunType *DAGRunRunType

+ StartDate *time.Time

+ State *DAGRunState

+ type DAGRunCollection struct

+ DagRuns *[]DAGRun

+ TotalEntries *int

+ type DAGRunCreate struct

+ Conf *map[string]interface{}

+ DagRunId *string

+ LogicalDate *time.Time

+ Note *string

+ type DAGRunRunType string

+ const DAGRunRunTypeBackfill

+ const DAGRunRunTypeDatasetTriggered

+ const DAGRunRunTypeManual

+ const DAGRunRunTypeScheduled

+ func (e DAGRunRunType) Valid() bool

+ type DAGRunState string

+ const DAGRunStateFailed

+ const DAGRunStateQueued

+ const DAGRunStateRunning

+ const DAGRunStateSuccess

+ func (e DAGRunState) Valid() bool

+ type DAGUpdate struct

+ IsPaused *bool

+ type DagID = string

+ type DagRunID = string

+ type DagSource struct

+ Content *string

+ DagDisplayName *string

+ DagId *string

+ VersionNumber *int

+ type DagVersion struct

+ BundleName *string

+ BundleUrl *string

+ BundleVersion *string

+ CreatedAt *time.Time

+ DagDisplayName *string

+ DagId *string

+ Id *string

+ VersionNumber *int

+ type DagVersionCollection struct

+ DagVersions *[]DagVersion

+ TotalEntries *int

+ type DeleteConnectionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON401 *Unauthorized

+ JSON404 *NotFound

+ func ParseDeleteConnectionResponse(rsp *http.Response) (*DeleteConnectionResponse, error)

+ func (r DeleteConnectionResponse) ContentType() string

+ func (r DeleteConnectionResponse) GetBody() []byte

+ func (r DeleteConnectionResponse) GetJSON401() *Unauthorized

+ func (r DeleteConnectionResponse) GetJSON404() *NotFound

+ func (r DeleteConnectionResponse) Status() string

+ func (r DeleteConnectionResponse) StatusCode() int

+ type DeleteVariableResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON401 *Unauthorized

+ JSON404 *NotFound

+ func ParseDeleteVariableResponse(rsp *http.Response) (*DeleteVariableResponse, error)

+ func (r DeleteVariableResponse) ContentType() string

+ func (r DeleteVariableResponse) GetBody() []byte

+ func (r DeleteVariableResponse) GetJSON401() *Unauthorized

+ func (r DeleteVariableResponse) GetJSON404() *NotFound

+ func (r DeleteVariableResponse) Status() string

+ func (r DeleteVariableResponse) StatusCode() int

+ type EncryptionUnavailable = Error

+ type Error struct

+ Detail *string

+ Instance *string

+ Status *int

+ Title *string

+ Type *string

+ type ExecutorInfo struct

+ AgentControlPlaneAddr *string

+ ExecutionModes *[]string

+ PodDispatchEnabled *bool

+ TaskNamespace *string

+ type GetConnectionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *Connection

+ JSON401 *Unauthorized

+ JSON404 *NotFound

+ func ParseGetConnectionResponse(rsp *http.Response) (*GetConnectionResponse, error)

+ func (r GetConnectionResponse) ContentType() string

+ func (r GetConnectionResponse) GetBody() []byte

+ func (r GetConnectionResponse) GetJSON200() *Connection

+ func (r GetConnectionResponse) GetJSON401() *Unauthorized

+ func (r GetConnectionResponse) GetJSON404() *NotFound

+ func (r GetConnectionResponse) Status() string

+ func (r GetConnectionResponse) StatusCode() int

+ type GetDagResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DAG

+ JSON404 *NotFound

+ func ParseGetDagResponse(rsp *http.Response) (*GetDagResponse, error)

+ func (r GetDagResponse) ContentType() string

+ func (r GetDagResponse) GetBody() []byte

+ func (r GetDagResponse) GetJSON200() *DAG

+ func (r GetDagResponse) GetJSON404() *NotFound

+ func (r GetDagResponse) Status() string

+ func (r GetDagResponse) StatusCode() int

+ type GetDagRunResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DAGRun

+ JSON404 *NotFound

+ func ParseGetDagRunResponse(rsp *http.Response) (*GetDagRunResponse, error)

+ func (r GetDagRunResponse) ContentType() string

+ func (r GetDagRunResponse) GetBody() []byte

+ func (r GetDagRunResponse) GetJSON200() *DAGRun

+ func (r GetDagRunResponse) GetJSON404() *NotFound

+ func (r GetDagRunResponse) Status() string

+ func (r GetDagRunResponse) StatusCode() int

+ type GetDagSourceResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DagSource

+ JSON404 *NotFound

+ func ParseGetDagSourceResponse(rsp *http.Response) (*GetDagSourceResponse, error)

+ func (r GetDagSourceResponse) ContentType() string

+ func (r GetDagSourceResponse) GetBody() []byte

+ func (r GetDagSourceResponse) GetJSON200() *DagSource

+ func (r GetDagSourceResponse) GetJSON404() *NotFound

+ func (r GetDagSourceResponse) Status() string

+ func (r GetDagSourceResponse) StatusCode() int

+ type GetDagSpecResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *map[string]interface{}

+ JSON404 *NotFound

+ func ParseGetDagSpecResponse(rsp *http.Response) (*GetDagSpecResponse, error)

+ func (r GetDagSpecResponse) ContentType() string

+ func (r GetDagSpecResponse) GetBody() []byte

+ func (r GetDagSpecResponse) GetJSON200() *map[string]interface{}

+ func (r GetDagSpecResponse) GetJSON404() *NotFound

+ func (r GetDagSpecResponse) Status() string

+ func (r GetDagSpecResponse) StatusCode() int

+ type GetDagVersionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DagVersion

+ JSON404 *NotFound

+ func ParseGetDagVersionResponse(rsp *http.Response) (*GetDagVersionResponse, error)

+ func (r GetDagVersionResponse) ContentType() string

+ func (r GetDagVersionResponse) GetBody() []byte

+ func (r GetDagVersionResponse) GetJSON200() *DagVersion

+ func (r GetDagVersionResponse) GetJSON404() *NotFound

+ func (r GetDagVersionResponse) Status() string

+ func (r GetDagVersionResponse) StatusCode() int

+ type GetHealthzResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseGetHealthzResponse(rsp *http.Response) (*GetHealthzResponse, error)

+ func (r GetHealthzResponse) ContentType() string

+ func (r GetHealthzResponse) GetBody() []byte

+ func (r GetHealthzResponse) Status() string

+ func (r GetHealthzResponse) StatusCode() int

+ type GetMonitorExecutorResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *ExecutorInfo

+ func ParseGetMonitorExecutorResponse(rsp *http.Response) (*GetMonitorExecutorResponse, error)

+ func (r GetMonitorExecutorResponse) ContentType() string

+ func (r GetMonitorExecutorResponse) GetBody() []byte

+ func (r GetMonitorExecutorResponse) GetJSON200() *ExecutorInfo

+ func (r GetMonitorExecutorResponse) Status() string

+ func (r GetMonitorExecutorResponse) StatusCode() int

+ type GetMonitorHealthResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *HealthInfo

+ func ParseGetMonitorHealthResponse(rsp *http.Response) (*GetMonitorHealthResponse, error)

+ func (r GetMonitorHealthResponse) ContentType() string

+ func (r GetMonitorHealthResponse) GetBody() []byte

+ func (r GetMonitorHealthResponse) GetJSON200() *HealthInfo

+ func (r GetMonitorHealthResponse) Status() string

+ func (r GetMonitorHealthResponse) StatusCode() int

+ type GetReadyzResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseGetReadyzResponse(rsp *http.Response) (*GetReadyzResponse, error)

+ func (r GetReadyzResponse) ContentType() string

+ func (r GetReadyzResponse) GetBody() []byte

+ func (r GetReadyzResponse) Status() string

+ func (r GetReadyzResponse) StatusCode() int

+ type GetTaskInstanceResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *TaskInstance

+ func ParseGetTaskInstanceResponse(rsp *http.Response) (*GetTaskInstanceResponse, error)

+ func (r GetTaskInstanceResponse) ContentType() string

+ func (r GetTaskInstanceResponse) GetBody() []byte

+ func (r GetTaskInstanceResponse) GetJSON200() *TaskInstance

+ func (r GetTaskInstanceResponse) Status() string

+ func (r GetTaskInstanceResponse) StatusCode() int

+ type GetTaskLogsResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseGetTaskLogsResponse(rsp *http.Response) (*GetTaskLogsResponse, error)

+ func (r GetTaskLogsResponse) ContentType() string

+ func (r GetTaskLogsResponse) GetBody() []byte

+ func (r GetTaskLogsResponse) Status() string

+ func (r GetTaskLogsResponse) StatusCode() int

+ type GetVariableResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *Variable

+ JSON401 *Unauthorized

+ JSON404 *NotFound

+ func ParseGetVariableResponse(rsp *http.Response) (*GetVariableResponse, error)

+ func (r GetVariableResponse) ContentType() string

+ func (r GetVariableResponse) GetBody() []byte

+ func (r GetVariableResponse) GetJSON200() *Variable

+ func (r GetVariableResponse) GetJSON401() *Unauthorized

+ func (r GetVariableResponse) GetJSON404() *NotFound

+ func (r GetVariableResponse) Status() string

+ func (r GetVariableResponse) StatusCode() int

+ type GetVersionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *VersionInfo

+ func ParseGetVersionResponse(rsp *http.Response) (*GetVersionResponse, error)

+ func (r GetVersionResponse) ContentType() string

+ func (r GetVersionResponse) GetBody() []byte

+ func (r GetVersionResponse) GetJSON200() *VersionInfo

+ func (r GetVersionResponse) Status() string

+ func (r GetVersionResponse) StatusCode() int

+ type GetXcomEntryResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *XComEntry

+ JSON404 *NotFound

+ func ParseGetXcomEntryResponse(rsp *http.Response) (*GetXcomEntryResponse, error)

+ func (r GetXcomEntryResponse) ContentType() string

+ func (r GetXcomEntryResponse) GetBody() []byte

+ func (r GetXcomEntryResponse) GetJSON200() *XComEntry

+ func (r GetXcomEntryResponse) GetJSON404() *NotFound

+ func (r GetXcomEntryResponse) Status() string

+ func (r GetXcomEntryResponse) StatusCode() int

+ type HealthInfo struct

+ DagProcessor *ComponentHealth

+ Metadatabase *ComponentHealth

+ Scheduler *ComponentHealth

+ Triggerer *ComponentHealth

+ type HttpRequestDoer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type IssueTokenJSONRequestBody = TokenRequest

+ type IssueTokenResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ Headers200 *IssueTokenResponse200Headers

+ JSON200 *TokenResponse

+ JSON401 *Unauthorized

+ func ParseIssueTokenResponse(rsp *http.Response) (*IssueTokenResponse, error)

+ func (r IssueTokenResponse) ContentType() string

+ func (r IssueTokenResponse) GetBody() []byte

+ func (r IssueTokenResponse) GetJSON200() *TokenResponse

+ func (r IssueTokenResponse) GetJSON401() *Unauthorized

+ func (r IssueTokenResponse) Status() string

+ func (r IssueTokenResponse) StatusCode() int

+ type IssueTokenResponse200Headers struct

+ SetCookie *string

+ type Limit = int

+ type ListConnectionsParams struct

+ Limit *Limit

+ Offset *Offset

+ type ListConnectionsResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *ConnectionCollection

+ JSON401 *Unauthorized

+ func ParseListConnectionsResponse(rsp *http.Response) (*ListConnectionsResponse, error)

+ func (r ListConnectionsResponse) ContentType() string

+ func (r ListConnectionsResponse) GetBody() []byte

+ func (r ListConnectionsResponse) GetJSON200() *ConnectionCollection

+ func (r ListConnectionsResponse) GetJSON401() *Unauthorized

+ func (r ListConnectionsResponse) Status() string

+ func (r ListConnectionsResponse) StatusCode() int

+ type ListDagRunsParams struct

+ Limit *Limit

+ Offset *Offset

+ State *[]ListDagRunsParamsState

+ type ListDagRunsParamsState string

+ const ListDagRunsParamsStateFailed

+ const ListDagRunsParamsStateQueued

+ const ListDagRunsParamsStateRunning

+ const ListDagRunsParamsStateSuccess

+ func (e ListDagRunsParamsState) Valid() bool

+ type ListDagRunsResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DAGRunCollection

+ func ParseListDagRunsResponse(rsp *http.Response) (*ListDagRunsResponse, error)

+ func (r ListDagRunsResponse) ContentType() string

+ func (r ListDagRunsResponse) GetBody() []byte

+ func (r ListDagRunsResponse) GetJSON200() *DAGRunCollection

+ func (r ListDagRunsResponse) Status() string

+ func (r ListDagRunsResponse) StatusCode() int

+ type ListDagVersionsResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DagVersionCollection

+ func ParseListDagVersionsResponse(rsp *http.Response) (*ListDagVersionsResponse, error)

+ func (r ListDagVersionsResponse) ContentType() string

+ func (r ListDagVersionsResponse) GetBody() []byte

+ func (r ListDagVersionsResponse) GetJSON200() *DagVersionCollection

+ func (r ListDagVersionsResponse) Status() string

+ func (r ListDagVersionsResponse) StatusCode() int

+ type ListDagsParams struct

+ Limit *Limit

+ Offset *Offset

+ OnlyActive *bool

+ Paused *bool

+ Tags *[]string

+ type ListDagsResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DAGCollection

+ func ParseListDagsResponse(rsp *http.Response) (*ListDagsResponse, error)

+ func (r ListDagsResponse) ContentType() string

+ func (r ListDagsResponse) GetBody() []byte

+ func (r ListDagsResponse) GetJSON200() *DAGCollection

+ func (r ListDagsResponse) Status() string

+ func (r ListDagsResponse) StatusCode() int

+ type ListTaskInstancesResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *TaskInstanceCollection

+ func ParseListTaskInstancesResponse(rsp *http.Response) (*ListTaskInstancesResponse, error)

+ func (r ListTaskInstancesResponse) ContentType() string

+ func (r ListTaskInstancesResponse) GetBody() []byte

+ func (r ListTaskInstancesResponse) GetJSON200() *TaskInstanceCollection

+ func (r ListTaskInstancesResponse) Status() string

+ func (r ListTaskInstancesResponse) StatusCode() int

+ type ListUsersParams struct

+ Limit *Limit

+ Offset *Offset

+ type ListUsersResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *UserCollection

+ JSON401 *Unauthorized

+ func ParseListUsersResponse(rsp *http.Response) (*ListUsersResponse, error)

+ func (r ListUsersResponse) ContentType() string

+ func (r ListUsersResponse) GetBody() []byte

+ func (r ListUsersResponse) GetJSON200() *UserCollection

+ func (r ListUsersResponse) GetJSON401() *Unauthorized

+ func (r ListUsersResponse) Status() string

+ func (r ListUsersResponse) StatusCode() int

+ type ListVariablesParams struct

+ Limit *Limit

+ Offset *Offset

+ type ListVariablesResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *VariableCollection

+ JSON401 *Unauthorized

+ func ParseListVariablesResponse(rsp *http.Response) (*ListVariablesResponse, error)

+ func (r ListVariablesResponse) ContentType() string

+ func (r ListVariablesResponse) GetBody() []byte

+ func (r ListVariablesResponse) GetJSON200() *VariableCollection

+ func (r ListVariablesResponse) GetJSON401() *Unauthorized

+ func (r ListVariablesResponse) Status() string

+ func (r ListVariablesResponse) StatusCode() int

+ type NotFound = Error

+ type Offset = int

+ type RenewTokenResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *TokenResponse

+ JSON401 *Unauthorized

+ func ParseRenewTokenResponse(rsp *http.Response) (*RenewTokenResponse, error)

+ func (r RenewTokenResponse) ContentType() string

+ func (r RenewTokenResponse) GetBody() []byte

+ func (r RenewTokenResponse) GetJSON200() *TokenResponse

+ func (r RenewTokenResponse) GetJSON401() *Unauthorized

+ func (r RenewTokenResponse) Status() string

+ func (r RenewTokenResponse) StatusCode() int

+ type RequestEditorFn func(ctx context.Context, req *http.Request) error

+ type TaskID = string

+ type TaskInstance struct

+ DagId *string

+ DagRunId *string

+ Duration *float32

+ EndDate *time.Time

+ FailureReason *string

+ Hostname *string

+ MapIndex *int

+ MaxTries *int

+ Operator *string

+ Pool *string

+ StartDate *time.Time

+ State *TaskInstanceState

+ TaskId *string

+ TryNumber *int

+ type TaskInstanceCollection struct

+ TaskInstances *[]TaskInstance

+ TotalEntries *int

+ type TaskInstanceState string

+ const TaskInstanceStateFailed

+ const TaskInstanceStateNone

+ const TaskInstanceStateQueued

+ const TaskInstanceStateRunning

+ const TaskInstanceStateScheduled

+ const TaskInstanceStateSkipped

+ const TaskInstanceStateSuccess

+ const TaskInstanceStateUpForRetry

+ const TaskInstanceStateUpstreamFailed

+ func (e TaskInstanceState) Valid() bool

+ type TokenRequest struct

+ Password string

+ Username string

+ type TokenResponse struct

+ AccessToken *string

+ ExpiresIn *int

+ TokenType *string

+ type TriggerDagRunJSONRequestBody = DAGRunCreate

+ type TriggerDagRunResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DAGRun

+ func ParseTriggerDagRunResponse(rsp *http.Response) (*TriggerDagRunResponse, error)

+ func (r TriggerDagRunResponse) ContentType() string

+ func (r TriggerDagRunResponse) GetBody() []byte

+ func (r TriggerDagRunResponse) GetJSON200() *DAGRun

+ func (r TriggerDagRunResponse) Status() string

+ func (r TriggerDagRunResponse) StatusCode() int

+ type Unauthorized = Error

+ type UpdateConnectionJSONRequestBody = ConnectionBody

+ type UpdateConnectionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *Connection

+ JSON400 *Error

+ JSON401 *Unauthorized

+ JSON404 *NotFound

+ JSON503 *EncryptionUnavailable

+ func ParseUpdateConnectionResponse(rsp *http.Response) (*UpdateConnectionResponse, error)

+ func (r UpdateConnectionResponse) ContentType() string

+ func (r UpdateConnectionResponse) GetBody() []byte

+ func (r UpdateConnectionResponse) GetJSON200() *Connection

+ func (r UpdateConnectionResponse) GetJSON400() *Error

+ func (r UpdateConnectionResponse) GetJSON401() *Unauthorized

+ func (r UpdateConnectionResponse) GetJSON404() *NotFound

+ func (r UpdateConnectionResponse) GetJSON503() *EncryptionUnavailable

+ func (r UpdateConnectionResponse) Status() string

+ func (r UpdateConnectionResponse) StatusCode() int

+ type UpdateDagJSONRequestBody = DAGUpdate

+ type UpdateDagResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *DAG

+ func ParseUpdateDagResponse(rsp *http.Response) (*UpdateDagResponse, error)

+ func (r UpdateDagResponse) ContentType() string

+ func (r UpdateDagResponse) GetBody() []byte

+ func (r UpdateDagResponse) GetJSON200() *DAG

+ func (r UpdateDagResponse) Status() string

+ func (r UpdateDagResponse) StatusCode() int

+ type User struct

+ CreatedAt time.Time

+ Email string

+ Id string

+ IsActive bool

+ Roles []string

+ type UserCollection struct

+ TotalEntries *int

+ Users *[]UserListItem

+ type UserListItem struct

+ CreatedAt time.Time

+ Email string

+ Id string

+ IsActive bool

+ Roles []string

+ type Variable struct

+ Description *string

+ IsEncrypted bool

+ Key string

+ TeamName *string

+ Value string

+ type VariableBody struct

+ Description *string

+ Key string

+ Value *string

+ type VariableCollection struct

+ TotalEntries *int

+ Variables *[]Variable

+ type VariableKey = string

+ type VersionInfo struct

+ GitVersion *string

+ Version *string

+ type XComEntry struct

+ DagId *string

+ DagRunId *string

+ Key *string

+ TaskId *string

+ Timestamp *time.Time

+ Value interface{}

v0.5.0-rc.1

Oct 2, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL