pkg/client

import "github.com/neochaotic/leoflow/pkg/client"

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 NewCreateUserRequest(server string, body CreateUserJSONRequestBody) (*http.Request, error)

func NewCreateUserRequestWithBody(server string, contentType string, body io.Reader) (*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 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 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 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 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   `json:"dag_run_id,omitempty"`
    OnlyFailed   *bool     `json:"only_failed,omitempty"`
    OnlyRunning  *bool     `json:"only_running,omitempty"`
    ResetDagRuns *bool     `json:"reset_dag_runs,omitempty"`
    TaskIds      *[]string `json:"task_ids,omitempty"`
}

type ClearTaskInstancesResponse struct {
    Body         []byte
    HTTPResponse *http.Response
    // JSON200 the response for an HTTP 200 `application/json` 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 {
    // 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
}

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

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

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

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

func (c *Client) CreateUserWithBody(ctx context.Context, contentType string, body io.Reader, 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, reqEditors ...RequestEditorFn) (*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, reqEditors ...RequestEditorFn) (*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, reqEditors ...RequestEditorFn) (*http.Response, error)

func (c *Client) GetTaskLogs(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, tryNumber int, 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, reqEditors ...RequestEditorFn) (*http.Response, error)

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

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

func (c *Client) ListDagRuns(ctx context.Context, dagId DagID, params *ListDagRunsParams, reqEditors ...RequestEditorFn) (*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, reqEditors ...RequestEditorFn) (*http.Response, error)

func (c *Client) ListUsers(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*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, reqEditors ...RequestEditorFn) (*http.Response, error)

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

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

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

type ClientInterface interface {

    // RenewToken Renew a still-valid JWT into a fresh short-lived token
    //
    // Transparent renewal: given a still-valid user bearer, re-mints the same identity with a fresh short TTL, bounded by a server-side max_lifetime measured from first login. Lets a long CLI/dev session avoid re-logging in every token TTL while keeping the access token short-lived. Returns 401 when the presented token is invalid, expired, or past max_lifetime, in which case the client must log in again.
    //
    // Corresponds with POST /api/v2/auth/token/renew (the `RenewToken` operationId).
    RenewToken(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetDagSource Get a DAG's source (the dag.py text)
    //
    // Corresponds with GET /api/v2/dagSources/{dag_id} (the `GetDagSource` operationId).
    GetDagSource(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

    // ListDags List DAGs
    //
    // Corresponds with GET /api/v2/dags (the `ListDags` operationId).
    ListDags(ctx context.Context, params *ListDagsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetDag Get a DAG
    //
    // Corresponds with GET /api/v2/dags/{dag_id} (the `GetDag` operationId).
    GetDag(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

    // UpdateDagWithBody Update DAG (typically pause/unpause)
    //
    // Takes any type of body and a specified content type.
    //
    // Corresponds with PATCH /api/v2/dags/{dag_id} (the `UpdateDag` operationId).
    UpdateDagWithBody(ctx context.Context, dagId DagID, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

    // UpdateDag Update DAG (typically pause/unpause)
    //
    // Takes a body of the `application/json` content type.
    //
    // Corresponds with PATCH /api/v2/dags/{dag_id} (the `UpdateDag` operationId).
    UpdateDag(ctx context.Context, dagId DagID, body UpdateDagJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

    // ClearTaskInstancesWithBody Clear task instances (queue them for re-run)
    //
    // Takes any type of body and a specified content type.
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/clearTaskInstances (the `ClearTaskInstances` operationId).
    ClearTaskInstancesWithBody(ctx context.Context, dagId DagID, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

    // ClearTaskInstances Clear task instances (queue them for re-run)
    //
    // Takes a body of the `application/json` content type.
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/clearTaskInstances (the `ClearTaskInstances` operationId).
    ClearTaskInstances(ctx context.Context, dagId DagID, body ClearTaskInstancesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

    // ListDagRuns List DAG runs
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns (the `ListDagRuns` operationId).
    ListDagRuns(ctx context.Context, dagId DagID, params *ListDagRunsParams, reqEditors ...RequestEditorFn) (*http.Response, error)

    // TriggerDagRunWithBody Trigger a DAG run
    //
    // Takes any type of body and a specified content type.
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/dagRuns (the `TriggerDagRun` operationId).
    TriggerDagRunWithBody(ctx context.Context, dagId DagID, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

    // TriggerDagRun Trigger a DAG run
    //
    // Takes a body of the `application/json` content type.
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/dagRuns (the `TriggerDagRun` operationId).
    TriggerDagRun(ctx context.Context, dagId DagID, body TriggerDagRunJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetDagRun Get a DAG run
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id} (the `GetDagRun` operationId).
    GetDagRun(ctx context.Context, dagId DagID, dagRunId DagRunID, reqEditors ...RequestEditorFn) (*http.Response, error)

    // ListTaskInstances List task instances of a DAG run
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances (the `ListTaskInstances` operationId).
    ListTaskInstances(ctx context.Context, dagId DagID, dagRunId DagRunID, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetTaskInstance Get a task instance
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} (the `GetTaskInstance` operationId).
    GetTaskInstance(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetTaskLogs Get task logs
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{try_number} (the `GetTaskLogs` operationId).
    GetTaskLogs(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, tryNumber int, reqEditors ...RequestEditorFn) (*http.Response, error)

    // ListDagVersions List a DAG's registered versions
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagVersions (the `ListDagVersions` operationId).
    ListDagVersions(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetDagVersion Get a specific registered DAG version
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagVersions/{version_number} (the `GetDagVersion` operationId).
    GetDagVersion(ctx context.Context, dagId DagID, versionNumber int, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetDagSpec Get a DAG's compiled spec (the dag.json artifact)
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/spec (the `GetDagSpec` operationId).
    GetDagSpec(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetMonitorExecutor Executor capability and configuration
    //
    // Corresponds with GET /api/v2/monitor/executor (the `GetMonitorExecutor` operationId).
    GetMonitorExecutor(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetMonitorHealth Control-plane health (Airflow HealthInfoResponse shape)
    //
    // Corresponds with GET /api/v2/monitor/health (the `GetMonitorHealth` operationId).
    GetMonitorHealth(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

    // ListUsers List users
    //
    // Lists the tenant's control-plane accounts, newest first. Each entry
    // carries the full set of roles the user holds; the password and its hash
    // are write-only and never returned. Requires the read:user permission.
    //
    // Corresponds with GET /api/v2/users (the `ListUsers` operationId).
    ListUsers(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*http.Response, error)

    // CreateUserWithBody Create a user
    //
    // Admin-only. Creates a control-plane account with the given email and
    // password and grants the requested roles. The password is write-only and
    // is never returned. Requires the write:user permission.
    //
    // Takes any type of body and a specified content type.
    //
    // Corresponds with POST /api/v2/users (the `CreateUser` operationId).
    CreateUserWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

    // CreateUser Create a user
    //
    // Admin-only. Creates a control-plane account with the given email and
    // password and grants the requested roles. The password is write-only and
    // is never returned. Requires the write:user permission.
    //
    // Takes a body of the `application/json` content type.
    //
    // Corresponds with POST /api/v2/users (the `CreateUser` operationId).
    CreateUser(ctx context.Context, body CreateUserJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetVersion Control-plane version (Airflow VersionInfo shape)
    //
    // Corresponds with GET /api/v2/version (the `GetVersion` operationId).
    GetVersion(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetXcomEntry Read XCom value (read-only proxy for the Redis backend)
    //
    // Corresponds with GET /api/v2/xcoms/{dag_id}/{dag_run_id}/{task_id}/{key} (the `GetXcomEntry` operationId).
    GetXcomEntry(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, key string, reqEditors ...RequestEditorFn) (*http.Response, error)

    // IssueTokenWithBody Issue a JWT for username/password credentials
    //
    // Takes any type of body and a specified content type.
    //
    // Corresponds with POST /auth/token (the `IssueToken` operationId).
    IssueTokenWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

    // IssueToken Issue a JWT for username/password credentials
    //
    // Takes a body of the `application/json` content type.
    //
    // Corresponds with POST /auth/token (the `IssueToken` operationId).
    IssueToken(ctx context.Context, body IssueTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetHealthz Liveness probe
    //
    // Corresponds with GET /healthz (the `GetHealthz` operationId).
    GetHealthz(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

    // GetReadyz Readiness probe
    //
    // Corresponds with GET /readyz (the `GetReadyz` operationId).
    GetReadyz(ctx context.Context, reqEditors ...RequestEditorFn) (*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 {
    ClientInterface
}

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, reqEditors ...RequestEditorFn) (*ClearTaskInstancesResponse, error)

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

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

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

func (c *ClientWithResponses) GetDagRunWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, reqEditors ...RequestEditorFn) (*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, reqEditors ...RequestEditorFn) (*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, reqEditors ...RequestEditorFn) (*GetTaskInstanceResponse, error)

func (c *ClientWithResponses) GetTaskLogsWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, tryNumber int, reqEditors ...RequestEditorFn) (*GetTaskLogsResponse, 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, reqEditors ...RequestEditorFn) (*GetXcomEntryResponse, error)

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

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

func (c *ClientWithResponses) ListDagRunsWithResponse(ctx context.Context, dagId DagID, params *ListDagRunsParams, reqEditors ...RequestEditorFn) (*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, reqEditors ...RequestEditorFn) (*ListTaskInstancesResponse, error)

func (c *ClientWithResponses) ListUsersWithResponse(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*ListUsersResponse, 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, reqEditors ...RequestEditorFn) (*TriggerDagRunResponse, error)

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

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

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

type ClientWithResponsesInterface interface {

    // RenewTokenWithResponse Renew a still-valid JWT into a fresh short-lived token
    //
    // Transparent renewal: given a still-valid user bearer, re-mints the same identity with a fresh short TTL, bounded by a server-side max_lifetime measured from first login. Lets a long CLI/dev session avoid re-logging in every token TTL while keeping the access token short-lived. Returns 401 when the presented token is invalid, expired, or past max_lifetime, in which case the client must log in again.
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /api/v2/auth/token/renew (the `RenewToken` operationId).
    RenewTokenWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RenewTokenResponse, error)

    // GetDagSourceWithResponse Get a DAG's source (the dag.py text)
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dagSources/{dag_id} (the `GetDagSource` operationId).
    GetDagSourceWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagSourceResponse, error)

    // ListDagsWithResponse List DAGs
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags (the `ListDags` operationId).
    ListDagsWithResponse(ctx context.Context, params *ListDagsParams, reqEditors ...RequestEditorFn) (*ListDagsResponse, error)

    // GetDagWithResponse Get a DAG
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id} (the `GetDag` operationId).
    GetDagWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagResponse, error)

    // UpdateDagWithBodyWithResponse Update DAG (typically pause/unpause)
    //
    // Takes any type of body and a specified content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with PATCH /api/v2/dags/{dag_id} (the `UpdateDag` operationId).
    UpdateDagWithBodyWithResponse(ctx context.Context, dagId DagID, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateDagResponse, error)

    // UpdateDagWithResponse Update DAG (typically pause/unpause)
    //
    // Takes a body of the `application/json` content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with PATCH /api/v2/dags/{dag_id} (the `UpdateDag` operationId).
    UpdateDagWithResponse(ctx context.Context, dagId DagID, body UpdateDagJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateDagResponse, error)

    // ClearTaskInstancesWithBodyWithResponse Clear task instances (queue them for re-run)
    //
    // Takes any type of body and a specified content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/clearTaskInstances (the `ClearTaskInstances` operationId).
    ClearTaskInstancesWithBodyWithResponse(ctx context.Context, dagId DagID, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ClearTaskInstancesResponse, error)

    // ClearTaskInstancesWithResponse Clear task instances (queue them for re-run)
    //
    // Takes a body of the `application/json` content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/clearTaskInstances (the `ClearTaskInstances` operationId).
    ClearTaskInstancesWithResponse(ctx context.Context, dagId DagID, body ClearTaskInstancesJSONRequestBody, reqEditors ...RequestEditorFn) (*ClearTaskInstancesResponse, error)

    // ListDagRunsWithResponse List DAG runs
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns (the `ListDagRuns` operationId).
    ListDagRunsWithResponse(ctx context.Context, dagId DagID, params *ListDagRunsParams, reqEditors ...RequestEditorFn) (*ListDagRunsResponse, error)

    // TriggerDagRunWithBodyWithResponse Trigger a DAG run
    //
    // Takes any type of body and a specified content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/dagRuns (the `TriggerDagRun` operationId).
    TriggerDagRunWithBodyWithResponse(ctx context.Context, dagId DagID, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TriggerDagRunResponse, error)

    // TriggerDagRunWithResponse Trigger a DAG run
    //
    // Takes a body of the `application/json` content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /api/v2/dags/{dag_id}/dagRuns (the `TriggerDagRun` operationId).
    TriggerDagRunWithResponse(ctx context.Context, dagId DagID, body TriggerDagRunJSONRequestBody, reqEditors ...RequestEditorFn) (*TriggerDagRunResponse, error)

    // GetDagRunWithResponse Get a DAG run
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id} (the `GetDagRun` operationId).
    GetDagRunWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, reqEditors ...RequestEditorFn) (*GetDagRunResponse, error)

    // ListTaskInstancesWithResponse List task instances of a DAG run
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances (the `ListTaskInstances` operationId).
    ListTaskInstancesWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, reqEditors ...RequestEditorFn) (*ListTaskInstancesResponse, error)

    // GetTaskInstanceWithResponse Get a task instance
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id} (the `GetTaskInstance` operationId).
    GetTaskInstanceWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, reqEditors ...RequestEditorFn) (*GetTaskInstanceResponse, error)

    // GetTaskLogsWithResponse Get task logs
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{try_number} (the `GetTaskLogs` operationId).
    GetTaskLogsWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, tryNumber int, reqEditors ...RequestEditorFn) (*GetTaskLogsResponse, error)

    // ListDagVersionsWithResponse List a DAG's registered versions
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagVersions (the `ListDagVersions` operationId).
    ListDagVersionsWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*ListDagVersionsResponse, error)

    // GetDagVersionWithResponse Get a specific registered DAG version
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/dagVersions/{version_number} (the `GetDagVersion` operationId).
    GetDagVersionWithResponse(ctx context.Context, dagId DagID, versionNumber int, reqEditors ...RequestEditorFn) (*GetDagVersionResponse, error)

    // GetDagSpecWithResponse Get a DAG's compiled spec (the dag.json artifact)
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/dags/{dag_id}/spec (the `GetDagSpec` operationId).
    GetDagSpecWithResponse(ctx context.Context, dagId DagID, reqEditors ...RequestEditorFn) (*GetDagSpecResponse, error)

    // GetMonitorExecutorWithResponse Executor capability and configuration
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/monitor/executor (the `GetMonitorExecutor` operationId).
    GetMonitorExecutorWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMonitorExecutorResponse, error)

    // GetMonitorHealthWithResponse Control-plane health (Airflow HealthInfoResponse shape)
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/monitor/health (the `GetMonitorHealth` operationId).
    GetMonitorHealthWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetMonitorHealthResponse, error)

    // ListUsersWithResponse List users
    //
    // Lists the tenant's control-plane accounts, newest first. Each entry
    // carries the full set of roles the user holds; the password and its hash
    // are write-only and never returned. Requires the read:user permission.
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/users (the `ListUsers` operationId).
    ListUsersWithResponse(ctx context.Context, params *ListUsersParams, reqEditors ...RequestEditorFn) (*ListUsersResponse, error)

    // CreateUserWithBodyWithResponse Create a user
    //
    // Admin-only. Creates a control-plane account with the given email and
    // password and grants the requested roles. The password is write-only and
    // is never returned. Requires the write:user permission.
    //
    // Takes any type of body and a specified content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /api/v2/users (the `CreateUser` operationId).
    CreateUserWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateUserResponse, error)

    // CreateUserWithResponse Create a user
    //
    // Admin-only. Creates a control-plane account with the given email and
    // password and grants the requested roles. The password is write-only and
    // is never returned. Requires the write:user permission.
    //
    // Takes a body of the `application/json` content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /api/v2/users (the `CreateUser` operationId).
    CreateUserWithResponse(ctx context.Context, body CreateUserJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateUserResponse, error)

    // GetVersionWithResponse Control-plane version (Airflow VersionInfo shape)
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/version (the `GetVersion` operationId).
    GetVersionWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetVersionResponse, error)

    // GetXcomEntryWithResponse Read XCom value (read-only proxy for the Redis backend)
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /api/v2/xcoms/{dag_id}/{dag_run_id}/{task_id}/{key} (the `GetXcomEntry` operationId).
    GetXcomEntryWithResponse(ctx context.Context, dagId DagID, dagRunId DagRunID, taskId TaskID, key string, reqEditors ...RequestEditorFn) (*GetXcomEntryResponse, error)

    // IssueTokenWithBodyWithResponse Issue a JWT for username/password credentials
    //
    // Takes any type of body and a specified content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /auth/token (the `IssueToken` operationId).
    IssueTokenWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*IssueTokenResponse, error)

    // IssueTokenWithResponse Issue a JWT for username/password credentials
    //
    // Takes a body of the `application/json` content type, and returns a wrapper object for the known response body format(s).
    //
    // Corresponds with POST /auth/token (the `IssueToken` operationId).
    IssueTokenWithResponse(ctx context.Context, body IssueTokenJSONRequestBody, reqEditors ...RequestEditorFn) (*IssueTokenResponse, error)

    // GetHealthzWithResponse Liveness probe
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /healthz (the `GetHealthz` operationId).
    GetHealthzWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetHealthzResponse, error)

    // GetReadyzWithResponse Readiness probe
    //
    // Returns a wrapper object for the known response body format(s).
    //
    // Corresponds with GET /readyz (the `GetReadyz` operationId).
    GetReadyzWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetReadyzResponse, error)
}