runtimeapi

package
v0.0.41 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 14, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

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

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

Index

Constants

View Source
const (
	BearerAuthScopes = "bearerAuth.Scopes"
)

Variables

This section is empty.

Functions

func Handler

func Handler(si ServerInterface) http.Handler

Handler creates http.Handler with routing matching OpenAPI spec.

func HandlerFromMux

func HandlerFromMux(si ServerInterface, r chi.Router) http.Handler

HandlerFromMux creates http.Handler with routing matching OpenAPI spec based on the provided mux.

func HandlerFromMuxWithBaseURL

func HandlerFromMuxWithBaseURL(si ServerInterface, r chi.Router, baseURL string) http.Handler

func HandlerWithOptions

func HandlerWithOptions(si ServerInterface, options ChiServerOptions) http.Handler

HandlerWithOptions creates http.Handler with additional options

func NewAddChapterWithLeaseRequest

func NewAddChapterWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, body AddChapterWithLeaseJSONRequestBody) (*http.Request, error)

NewAddChapterWithLeaseRequest calls the generic AddChapterWithLease builder with application/json body

func NewAddChapterWithLeaseRequestWithBody

func NewAddChapterWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewAddChapterWithLeaseRequestWithBody generates requests for AddChapterWithLease with any type of body

func NewArchiveJobSchemaRequest added in v0.0.9

func NewArchiveJobSchemaRequest(server string, tenantId TenantId, schemaHash JobSchemaHash) (*http.Request, error)

NewArchiveJobSchemaRequest generates requests for ArchiveJobSchema

func NewArchiveScheduleRequest

func NewArchiveScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, body ArchiveScheduleJSONRequestBody) (*http.Request, error)

NewArchiveScheduleRequest calls the generic ArchiveSchedule builder with application/json body

func NewArchiveScheduleRequestWithBody

func NewArchiveScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader) (*http.Request, error)

NewArchiveScheduleRequestWithBody generates requests for ArchiveSchedule with any type of body

func NewCancelJobRequest

func NewCancelJobRequest(server string, tenantId TenantId, jobId JobId, body CancelJobJSONRequestBody) (*http.Request, error)

NewCancelJobRequest calls the generic CancelJob builder with application/json body

func NewCancelJobRequestWithBody

func NewCancelJobRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, body io.Reader) (*http.Request, error)

NewCancelJobRequestWithBody generates requests for CancelJob with any type of body

func NewCommitChapterIfWaitingRequest

func NewCommitChapterIfWaitingRequest(server string, tenantId TenantId, jobId JobId, ordinal Ordinal, body CommitChapterIfWaitingJSONRequestBody) (*http.Request, error)

NewCommitChapterIfWaitingRequest calls the generic CommitChapterIfWaiting builder with application/json body

func NewCommitChapterIfWaitingRequestWithBody

func NewCommitChapterIfWaitingRequestWithBody(server string, tenantId TenantId, jobId JobId, ordinal Ordinal, contentType string, body io.Reader) (*http.Request, error)

NewCommitChapterIfWaitingRequestWithBody generates requests for CommitChapterIfWaiting with any type of body

func NewCompleteJobWithLeaseRequest

func NewCompleteJobWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, body CompleteJobWithLeaseJSONRequestBody) (*http.Request, error)

NewCompleteJobWithLeaseRequest calls the generic CompleteJobWithLease builder with application/json body

func NewCompleteJobWithLeaseRequestWithBody

func NewCompleteJobWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewCompleteJobWithLeaseRequestWithBody generates requests for CompleteJobWithLease with any type of body

func NewGetChapterRequest

func NewGetChapterRequest(server string, tenantId TenantId, jobId JobId, ordinal Ordinal) (*http.Request, error)

NewGetChapterRequest generates requests for GetChapter

func NewGetConfigurationWithLeaseRequest added in v0.0.33

func NewGetConfigurationWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *GetConfigurationWithLeaseParams) (*http.Request, error)

NewGetConfigurationWithLeaseRequest generates requests for GetConfigurationWithLease

func NewGetJobLeaseRequest

func NewGetJobLeaseRequest(server string, tenantId TenantId, jobId JobId, body GetJobLeaseJSONRequestBody) (*http.Request, error)

NewGetJobLeaseRequest calls the generic GetJobLease builder with application/json body

func NewGetJobLeaseRequestWithBody

func NewGetJobLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, body io.Reader) (*http.Request, error)

NewGetJobLeaseRequestWithBody generates requests for GetJobLease with any type of body

func NewGetJobRequest

func NewGetJobRequest(server string, tenantId TenantId, jobId JobId) (*http.Request, error)

NewGetJobRequest generates requests for GetJob

func NewGetJobSchemaRequest added in v0.0.9

func NewGetJobSchemaRequest(server string, tenantId TenantId, schemaHash JobSchemaHash) (*http.Request, error)

NewGetJobSchemaRequest generates requests for GetJobSchema

func NewGetScheduleRequest

func NewGetScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId) (*http.Request, error)

NewGetScheduleRequest generates requests for GetSchedule

func NewGetTenantConfigurationRequest added in v0.0.33

func NewGetTenantConfigurationRequest(server string, tenantId TenantId) (*http.Request, error)

NewGetTenantConfigurationRequest generates requests for GetTenantConfiguration

func NewKeepAliveLeaseRequest

func NewKeepAliveLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *KeepAliveLeaseParams) (*http.Request, error)

NewKeepAliveLeaseRequest generates requests for KeepAliveLease

func NewListChaptersRequest

func NewListChaptersRequest(server string, tenantId TenantId, jobId JobId, params *ListChaptersParams) (*http.Request, error)

NewListChaptersRequest generates requests for ListChapters

func NewListJobSchemasRequest added in v0.0.9

func NewListJobSchemasRequest(server string, tenantId TenantId, params *ListJobSchemasParams) (*http.Request, error)

NewListJobSchemasRequest generates requests for ListJobSchemas

func NewListJobsRequest

func NewListJobsRequest(server string, tenantId TenantId, body ListJobsJSONRequestBody) (*http.Request, error)

NewListJobsRequest calls the generic ListJobs builder with application/json body

func NewListJobsRequestWithBody

func NewListJobsRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)

NewListJobsRequestWithBody generates requests for ListJobs with any type of body

func NewListScheduleRunsRequest

func NewListScheduleRunsRequest(server string, tenantId TenantId, scheduleId ScheduleId, body ListScheduleRunsJSONRequestBody) (*http.Request, error)

NewListScheduleRunsRequest calls the generic ListScheduleRuns builder with application/json body

func NewListScheduleRunsRequestWithBody

func NewListScheduleRunsRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader) (*http.Request, error)

NewListScheduleRunsRequestWithBody generates requests for ListScheduleRuns with any type of body

func NewListSchedulesRequest

func NewListSchedulesRequest(server string, tenantId TenantId, body ListSchedulesJSONRequestBody) (*http.Request, error)

NewListSchedulesRequest calls the generic ListSchedules builder with application/json body

func NewListSchedulesRequestWithBody

func NewListSchedulesRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)

NewListSchedulesRequestWithBody generates requests for ListSchedules with any type of body

func NewOpenArtifactRequest

func NewOpenArtifactRequest(server string, tenantId TenantId, jobId JobId, ordinal Ordinal, name ArtifactName) (*http.Request, error)

NewOpenArtifactRequest generates requests for OpenArtifact

func NewPauseScheduleRequest

func NewPauseScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, body PauseScheduleJSONRequestBody) (*http.Request, error)

NewPauseScheduleRequest calls the generic PauseSchedule builder with application/json body

func NewPauseScheduleRequestWithBody

func NewPauseScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader) (*http.Request, error)

NewPauseScheduleRequestWithBody generates requests for PauseSchedule with any type of body

func NewPollWorkRequest

func NewPollWorkRequest(server string, body PollWorkJSONRequestBody) (*http.Request, error)

NewPollWorkRequest calls the generic PollWork builder with application/json body

func NewPollWorkRequestWithBody

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

NewPollWorkRequestWithBody generates requests for PollWork with any type of body

func NewPutJobRequest

func NewPutJobRequest(server string, tenantId TenantId, jobId JobId, body PutJobJSONRequestBody) (*http.Request, error)

NewPutJobRequest calls the generic PutJob builder with application/json body

func NewPutJobRequestWithBody

func NewPutJobRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, body io.Reader) (*http.Request, error)

NewPutJobRequestWithBody generates requests for PutJob with any type of body

func NewPutJobWithLeaseRequest added in v0.0.13

func NewPutJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, body PutJobWithLeaseJSONRequestBody) (*http.Request, error)

NewPutJobWithLeaseRequest calls the generic PutJobWithLease builder with application/json body

func NewPutJobWithLeaseRequestWithBody added in v0.0.13

func NewPutJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewPutJobWithLeaseRequestWithBody generates requests for PutJobWithLease with any type of body

func NewPutRestartJobRequest

func NewPutRestartJobRequest(server string, tenantId TenantId, jobId JobId, body PutRestartJobJSONRequestBody) (*http.Request, error)

NewPutRestartJobRequest calls the generic PutRestartJob builder with application/json body

func NewPutRestartJobRequestWithBody

func NewPutRestartJobRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, body io.Reader) (*http.Request, error)

NewPutRestartJobRequestWithBody generates requests for PutRestartJob with any type of body

func NewPutRestartJobWithLeaseRequest added in v0.0.13

func NewPutRestartJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, body PutRestartJobWithLeaseJSONRequestBody) (*http.Request, error)

NewPutRestartJobWithLeaseRequest calls the generic PutRestartJobWithLease builder with application/json body

func NewPutRestartJobWithLeaseRequestWithBody added in v0.0.13

func NewPutRestartJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewPutRestartJobWithLeaseRequestWithBody generates requests for PutRestartJobWithLease with any type of body

func NewRegisterJobSchemaRequest added in v0.0.9

func NewRegisterJobSchemaRequest(server string, tenantId TenantId, body RegisterJobSchemaJSONRequestBody) (*http.Request, error)

NewRegisterJobSchemaRequest calls the generic RegisterJobSchema builder with application/json body

func NewRegisterJobSchemaRequestWithBody added in v0.0.9

func NewRegisterJobSchemaRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)

NewRegisterJobSchemaRequestWithBody generates requests for RegisterJobSchema with any type of body

func NewRemoveTenantConfigurationValueRequest added in v0.0.33

func NewRemoveTenantConfigurationValueRequest(server string, tenantId TenantId, params *RemoveTenantConfigurationValueParams, body RemoveTenantConfigurationValueJSONRequestBody) (*http.Request, error)

NewRemoveTenantConfigurationValueRequest calls the generic RemoveTenantConfigurationValue builder with application/json body

func NewRemoveTenantConfigurationValueRequestWithBody added in v0.0.33

func NewRemoveTenantConfigurationValueRequestWithBody(server string, tenantId TenantId, params *RemoveTenantConfigurationValueParams, contentType string, body io.Reader) (*http.Request, error)

NewRemoveTenantConfigurationValueRequestWithBody generates requests for RemoveTenantConfigurationValue with any type of body

func NewRescheduleJobWithLeaseRequest

func NewRescheduleJobWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, body RescheduleJobWithLeaseJSONRequestBody) (*http.Request, error)

NewRescheduleJobWithLeaseRequest calls the generic RescheduleJobWithLease builder with application/json body

func NewRescheduleJobWithLeaseRequestWithBody

func NewRescheduleJobWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewRescheduleJobWithLeaseRequestWithBody generates requests for RescheduleJobWithLease with any type of body

func NewResolveSecretsWithLeaseRequest added in v0.0.29

func NewResolveSecretsWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, body ResolveSecretsWithLeaseJSONRequestBody) (*http.Request, error)

NewResolveSecretsWithLeaseRequest calls the generic ResolveSecretsWithLease builder with application/json body

func NewResolveSecretsWithLeaseRequestWithBody added in v0.0.29

func NewResolveSecretsWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewResolveSecretsWithLeaseRequestWithBody generates requests for ResolveSecretsWithLease with any type of body

func NewResumeScheduleRequest

func NewResumeScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, body ResumeScheduleJSONRequestBody) (*http.Request, error)

NewResumeScheduleRequest calls the generic ResumeSchedule builder with application/json body

func NewResumeScheduleRequestWithBody

func NewResumeScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader) (*http.Request, error)

NewResumeScheduleRequestWithBody generates requests for ResumeSchedule with any type of body

func NewSetTenantConfigurationValueRequest added in v0.0.33

func NewSetTenantConfigurationValueRequest(server string, tenantId TenantId, params *SetTenantConfigurationValueParams, body SetTenantConfigurationValueJSONRequestBody) (*http.Request, error)

NewSetTenantConfigurationValueRequest calls the generic SetTenantConfigurationValue builder with application/json body

func NewSetTenantConfigurationValueRequestWithBody added in v0.0.33

func NewSetTenantConfigurationValueRequestWithBody(server string, tenantId TenantId, params *SetTenantConfigurationValueParams, contentType string, body io.Reader) (*http.Request, error)

NewSetTenantConfigurationValueRequestWithBody generates requests for SetTenantConfigurationValue with any type of body

func NewSubmitJobRequest

func NewSubmitJobRequest(server string, tenantId TenantId, body SubmitJobJSONRequestBody) (*http.Request, error)

NewSubmitJobRequest calls the generic SubmitJob builder with application/json body

func NewSubmitJobRequestWithBody

func NewSubmitJobRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)

NewSubmitJobRequestWithBody generates requests for SubmitJob with any type of body

func NewSubmitJobWithLeaseRequest added in v0.0.13

func NewSubmitJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, body SubmitJobWithLeaseJSONRequestBody) (*http.Request, error)

NewSubmitJobWithLeaseRequest calls the generic SubmitJobWithLease builder with application/json body

func NewSubmitJobWithLeaseRequestWithBody added in v0.0.13

func NewSubmitJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewSubmitJobWithLeaseRequestWithBody generates requests for SubmitJobWithLease with any type of body

func NewSubmitRestartJobRequest

func NewSubmitRestartJobRequest(server string, tenantId TenantId, body SubmitRestartJobJSONRequestBody) (*http.Request, error)

NewSubmitRestartJobRequest calls the generic SubmitRestartJob builder with application/json body

func NewSubmitRestartJobRequestWithBody

func NewSubmitRestartJobRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)

NewSubmitRestartJobRequestWithBody generates requests for SubmitRestartJob with any type of body

func NewSubmitRestartJobWithLeaseRequest added in v0.0.13

func NewSubmitRestartJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, body SubmitRestartJobWithLeaseJSONRequestBody) (*http.Request, error)

NewSubmitRestartJobWithLeaseRequest calls the generic SubmitRestartJobWithLease builder with application/json body

func NewSubmitRestartJobWithLeaseRequestWithBody added in v0.0.13

func NewSubmitRestartJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, contentType string, body io.Reader) (*http.Request, error)

NewSubmitRestartJobWithLeaseRequestWithBody generates requests for SubmitRestartJobWithLease with any type of body

func NewTriggerScheduleRequest

func NewTriggerScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, body TriggerScheduleJSONRequestBody) (*http.Request, error)

NewTriggerScheduleRequest calls the generic TriggerSchedule builder with application/json body

func NewTriggerScheduleRequestWithBody

func NewTriggerScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader) (*http.Request, error)

NewTriggerScheduleRequestWithBody generates requests for TriggerSchedule with any type of body

func NewUpsertScheduleRequest

func NewUpsertScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, body UpsertScheduleJSONRequestBody) (*http.Request, error)

NewUpsertScheduleRequest calls the generic UpsertSchedule builder with application/json body

func NewUpsertScheduleRequestWithBody

func NewUpsertScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader) (*http.Request, error)

NewUpsertScheduleRequestWithBody generates requests for UpsertSchedule with any type of body

Types

type AddChapterRequest

type AddChapterRequest struct {
	// ArtifactUploads Artifact payloads attached to this chapter write. Missing and empty
	// arrays are both treated as no uploads; artifacts do not exist as
	// independent durable resources until the chapter commit succeeds.
	ArtifactUploads *[]ArtifactWrite `json:"artifactUploads,omitempty"`
	Chapter         ChapterRecord    `json:"chapter"`
}

AddChapterRequest defines model for AddChapterRequest.

type AddChapterWithLease204Response

type AddChapterWithLease204Response struct {
}

func (AddChapterWithLease204Response) VisitAddChapterWithLeaseResponse

func (response AddChapterWithLease204Response) VisitAddChapterWithLeaseResponse(w http.ResponseWriter) error

type AddChapterWithLease409Response

type AddChapterWithLease409Response struct {
}

func (AddChapterWithLease409Response) VisitAddChapterWithLeaseResponse

func (response AddChapterWithLease409Response) VisitAddChapterWithLeaseResponse(w http.ResponseWriter) error

type AddChapterWithLeaseHTTPResponse

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

func ParseAddChapterWithLeaseHTTPResponse

func ParseAddChapterWithLeaseHTTPResponse(rsp *http.Response) (*AddChapterWithLeaseHTTPResponse, error)

ParseAddChapterWithLeaseHTTPResponse parses an HTTP response from a AddChapterWithLeaseWithResponse call

func (AddChapterWithLeaseHTTPResponse) Status

Status returns HTTPResponse.Status

func (AddChapterWithLeaseHTTPResponse) StatusCode

func (r AddChapterWithLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type AddChapterWithLeaseJSONRequestBody

type AddChapterWithLeaseJSONRequestBody = AddChapterRequest

AddChapterWithLeaseJSONRequestBody defines body for AddChapterWithLease for application/json ContentType.

type AddChapterWithLeaseParams

type AddChapterWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

AddChapterWithLeaseParams defines parameters for AddChapterWithLease.

type AddChapterWithLeaseRequestObject

type AddChapterWithLeaseRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	LeaseId  LeaseId  `json:"leaseId"`
	Params   AddChapterWithLeaseParams
	Body     *AddChapterWithLeaseJSONRequestBody
}

type AddChapterWithLeaseResponseObject

type AddChapterWithLeaseResponseObject interface {
	VisitAddChapterWithLeaseResponse(w http.ResponseWriter) error
}

type AppErrorPayload

type AppErrorPayload struct {
	Attrs      *Metadata       `json:"attrs,omitempty"`
	InputRef   *InputReference `json:"inputRef,omitempty"`
	Level      *string         `json:"level,omitempty"`
	Message    string          `json:"message"`
	Stacktrace *[]string       `json:"stacktrace,omitempty"`
}

AppErrorPayload defines model for AppErrorPayload.

type ApplicationPayload

type ApplicationPayload = json.RawMessage

ApplicationPayload Caller-owned application JSON payload embedded directly in REST requests and responses. This value is any valid JSON value: object, array, string, number, boolean, or null. It is never base64-encoded and never wrapped in a protobuf `Any`-style envelope on the REST boundary.

type ArchiveJobSchema200JSONResponse added in v0.0.9

type ArchiveJobSchema200JSONResponse JobSchemaInfo

func (ArchiveJobSchema200JSONResponse) VisitArchiveJobSchemaResponse added in v0.0.9

func (response ArchiveJobSchema200JSONResponse) VisitArchiveJobSchemaResponse(w http.ResponseWriter) error

type ArchiveJobSchemaHTTPResponse added in v0.0.9

type ArchiveJobSchemaHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobSchemaInfo
}

func ParseArchiveJobSchemaHTTPResponse added in v0.0.9

func ParseArchiveJobSchemaHTTPResponse(rsp *http.Response) (*ArchiveJobSchemaHTTPResponse, error)

ParseArchiveJobSchemaHTTPResponse parses an HTTP response from a ArchiveJobSchemaWithResponse call

func (ArchiveJobSchemaHTTPResponse) Status added in v0.0.9

Status returns HTTPResponse.Status

func (ArchiveJobSchemaHTTPResponse) StatusCode added in v0.0.9

func (r ArchiveJobSchemaHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ArchiveJobSchemaRequestObject added in v0.0.9

type ArchiveJobSchemaRequestObject struct {
	TenantId   TenantId      `json:"tenantId"`
	SchemaHash JobSchemaHash `json:"schemaHash"`
}

type ArchiveJobSchemaResponseObject added in v0.0.9

type ArchiveJobSchemaResponseObject interface {
	VisitArchiveJobSchemaResponse(w http.ResponseWriter) error
}

type ArchiveSchedule200JSONResponse

type ArchiveSchedule200JSONResponse ScheduleInfo

func (ArchiveSchedule200JSONResponse) VisitArchiveScheduleResponse

func (response ArchiveSchedule200JSONResponse) VisitArchiveScheduleResponse(w http.ResponseWriter) error

type ArchiveScheduleHTTPResponse

type ArchiveScheduleHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ScheduleInfo
}

func ParseArchiveScheduleHTTPResponse

func ParseArchiveScheduleHTTPResponse(rsp *http.Response) (*ArchiveScheduleHTTPResponse, error)

ParseArchiveScheduleHTTPResponse parses an HTTP response from a ArchiveScheduleWithResponse call

func (ArchiveScheduleHTTPResponse) Status

Status returns HTTPResponse.Status

func (ArchiveScheduleHTTPResponse) StatusCode

func (r ArchiveScheduleHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ArchiveScheduleJSONRequestBody

type ArchiveScheduleJSONRequestBody = ScheduleMutationRequest

ArchiveScheduleJSONRequestBody defines body for ArchiveSchedule for application/json ContentType.

type ArchiveScheduleRequestObject

type ArchiveScheduleRequestObject struct {
	TenantId   TenantId   `json:"tenantId"`
	ScheduleId ScheduleId `json:"scheduleId"`
	Body       *ArchiveScheduleJSONRequestBody
}

type ArchiveScheduleResponseObject

type ArchiveScheduleResponseObject interface {
	VisitArchiveScheduleResponse(w http.ResponseWriter) error
}

type ArtifactName

type ArtifactName = string

ArtifactName defines model for ArtifactName.

type ArtifactUpload

type ArtifactUpload struct {
	ContentBase64 []byte `json:"contentBase64"`
	Name          string `json:"name"`
	Size          int64  `json:"size"`
}

ArtifactUpload defines model for ArtifactUpload.

type ArtifactWrite

type ArtifactWrite = ArtifactUpload

ArtifactWrite defines model for ArtifactWrite.

type CancelJob204Response

type CancelJob204Response struct {
}

func (CancelJob204Response) VisitCancelJobResponse

func (response CancelJob204Response) VisitCancelJobResponse(w http.ResponseWriter) error

type CancelJobHTTPResponse

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

func ParseCancelJobHTTPResponse

func ParseCancelJobHTTPResponse(rsp *http.Response) (*CancelJobHTTPResponse, error)

ParseCancelJobHTTPResponse parses an HTTP response from a CancelJobWithResponse call

func (CancelJobHTTPResponse) Status

func (r CancelJobHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (CancelJobHTTPResponse) StatusCode

func (r CancelJobHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CancelJobJSONRequestBody

type CancelJobJSONRequestBody = CancelJobRequest

CancelJobJSONRequestBody defines body for CancelJob for application/json ContentType.

type CancelJobRequest

type CancelJobRequest struct {
	Reason   *string `json:"reason,omitempty"`
	WorkerId *string `json:"workerId,omitempty"`
}

CancelJobRequest defines model for CancelJobRequest.

type CancelJobRequestObject

type CancelJobRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	Body     *CancelJobJSONRequestBody
}

type CancelJobResponseObject

type CancelJobResponseObject interface {
	VisitCancelJobResponse(w http.ResponseWriter) error
}

type ChapterBody

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

ChapterBody defines model for ChapterBody.

func (ChapterBody) AsExecutionChapter added in v0.0.36

func (t ChapterBody) AsExecutionChapter() (ExecutionChapter, error)

AsExecutionChapter returns the union data inside the ChapterBody as a ExecutionChapter

func (ChapterBody) AsJobAttemptOutcomeChapter

func (t ChapterBody) AsJobAttemptOutcomeChapter() (JobAttemptOutcomeChapter, error)

AsJobAttemptOutcomeChapter returns the union data inside the ChapterBody as a JobAttemptOutcomeChapter

func (ChapterBody) AsJobStartChapter

func (t ChapterBody) AsJobStartChapter() (JobStartChapter, error)

AsJobStartChapter returns the union data inside the ChapterBody as a JobStartChapter

func (ChapterBody) AsRestartExtraChapter

func (t ChapterBody) AsRestartExtraChapter() (RestartExtraChapter, error)

AsRestartExtraChapter returns the union data inside the ChapterBody as a RestartExtraChapter

func (ChapterBody) AsTaskAttemptOutcomeChapter

func (t ChapterBody) AsTaskAttemptOutcomeChapter() (TaskAttemptOutcomeChapter, error)

AsTaskAttemptOutcomeChapter returns the union data inside the ChapterBody as a TaskAttemptOutcomeChapter

func (ChapterBody) Discriminator

func (t ChapterBody) Discriminator() (string, error)

func (*ChapterBody) FromExecutionChapter added in v0.0.36

func (t *ChapterBody) FromExecutionChapter(v ExecutionChapter) error

FromExecutionChapter overwrites any union data inside the ChapterBody as the provided ExecutionChapter

func (*ChapterBody) FromJobAttemptOutcomeChapter

func (t *ChapterBody) FromJobAttemptOutcomeChapter(v JobAttemptOutcomeChapter) error

FromJobAttemptOutcomeChapter overwrites any union data inside the ChapterBody as the provided JobAttemptOutcomeChapter

func (*ChapterBody) FromJobStartChapter

func (t *ChapterBody) FromJobStartChapter(v JobStartChapter) error

FromJobStartChapter overwrites any union data inside the ChapterBody as the provided JobStartChapter

func (*ChapterBody) FromRestartExtraChapter

func (t *ChapterBody) FromRestartExtraChapter(v RestartExtraChapter) error

FromRestartExtraChapter overwrites any union data inside the ChapterBody as the provided RestartExtraChapter

func (*ChapterBody) FromTaskAttemptOutcomeChapter

func (t *ChapterBody) FromTaskAttemptOutcomeChapter(v TaskAttemptOutcomeChapter) error

FromTaskAttemptOutcomeChapter overwrites any union data inside the ChapterBody as the provided TaskAttemptOutcomeChapter

func (ChapterBody) MarshalJSON

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

func (*ChapterBody) MergeExecutionChapter added in v0.0.36

func (t *ChapterBody) MergeExecutionChapter(v ExecutionChapter) error

MergeExecutionChapter performs a merge with any union data inside the ChapterBody, using the provided ExecutionChapter

func (*ChapterBody) MergeJobAttemptOutcomeChapter

func (t *ChapterBody) MergeJobAttemptOutcomeChapter(v JobAttemptOutcomeChapter) error

MergeJobAttemptOutcomeChapter performs a merge with any union data inside the ChapterBody, using the provided JobAttemptOutcomeChapter

func (*ChapterBody) MergeJobStartChapter

func (t *ChapterBody) MergeJobStartChapter(v JobStartChapter) error

MergeJobStartChapter performs a merge with any union data inside the ChapterBody, using the provided JobStartChapter

func (*ChapterBody) MergeRestartExtraChapter

func (t *ChapterBody) MergeRestartExtraChapter(v RestartExtraChapter) error

MergeRestartExtraChapter performs a merge with any union data inside the ChapterBody, using the provided RestartExtraChapter

func (*ChapterBody) MergeTaskAttemptOutcomeChapter

func (t *ChapterBody) MergeTaskAttemptOutcomeChapter(v TaskAttemptOutcomeChapter) error

MergeTaskAttemptOutcomeChapter performs a merge with any union data inside the ChapterBody, using the provided TaskAttemptOutcomeChapter

func (*ChapterBody) UnmarshalJSON

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

func (ChapterBody) ValueByDiscriminator

func (t ChapterBody) ValueByDiscriminator() (interface{}, error)

type ChapterRecord

type ChapterRecord struct {
	Artifacts            []StoredArtifact `json:"artifacts"`
	Attempt              *int32           `json:"attempt,omitempty"`
	BackoffMillis        *int64           `json:"backoffMillis,omitempty"`
	Body                 ChapterBody      `json:"body"`
	CreatedAt            time.Time        `json:"createdAt"`
	FinishedAt           *time.Time       `json:"finishedAt,omitempty"`
	InitialPayloadDigest *string          `json:"initialPayloadDigest,omitempty"`

	// Input Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Input         *ApplicationPayload `json:"input,omitempty"`
	InputHash     *string             `json:"inputHash,omitempty"`
	InputRef      *InputReference     `json:"inputRef,omitempty"`
	MaxAttempts   *int32              `json:"maxAttempts,omitempty"`
	Metadata      *Metadata           `json:"metadata,omitempty"`
	NextAttemptAt *time.Time          `json:"nextAttemptAt,omitempty"`
	Ordinal       int64               `json:"ordinal"`
	Prerequisites *[]JobPrerequisite  `json:"prerequisites,omitempty"`
	Retryable     *bool               `json:"retryable,omitempty"`
	RunPolicy     *RunPolicy          `json:"runPolicy,omitempty"`
	StartedAt     *time.Time          `json:"startedAt,omitempty"`
	TaskType      *string             `json:"taskType,omitempty"`
	WorkerId      *string             `json:"workerId,omitempty"`
}

ChapterRecord defines model for ChapterRecord.

type ChiServerOptions

type ChiServerOptions struct {
	BaseURL          string
	BaseRouter       chi.Router
	Middlewares      []MiddlewareFunc
	ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type ChildJobId added in v0.0.13

type ChildJobId = string

ChildJobId defines model for ChildJobId.

type Client

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

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

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

Client which conforms to the OpenAPI3 specification for this service.

func NewClient

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

Creates a new Client, with reasonable defaults

func (*Client) AddChapterWithLease

func (c *Client) AddChapterWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, body AddChapterWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) AddChapterWithLeaseWithBody

func (c *Client) AddChapterWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ArchiveJobSchema added in v0.0.9

func (c *Client) ArchiveJobSchema(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ArchiveSchedule

func (c *Client) ArchiveSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ArchiveScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ArchiveScheduleWithBody

func (c *Client) ArchiveScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CancelJob

func (c *Client) CancelJob(ctx context.Context, tenantId TenantId, jobId JobId, body CancelJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CancelJobWithBody

func (c *Client) CancelJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CommitChapterIfWaiting

func (c *Client) CommitChapterIfWaiting(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, body CommitChapterIfWaitingJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CommitChapterIfWaitingWithBody

func (c *Client) CommitChapterIfWaitingWithBody(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CompleteJobWithLease

func (c *Client) CompleteJobWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, body CompleteJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) CompleteJobWithLeaseWithBody

func (c *Client) CompleteJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetChapter

func (c *Client) GetChapter(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetConfigurationWithLease added in v0.0.33

func (c *Client) GetConfigurationWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *GetConfigurationWithLeaseParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetJob

func (c *Client) GetJob(ctx context.Context, tenantId TenantId, jobId JobId, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetJobLease

func (c *Client) GetJobLease(ctx context.Context, tenantId TenantId, jobId JobId, body GetJobLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetJobLeaseWithBody

func (c *Client) GetJobLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetJobSchema added in v0.0.9

func (c *Client) GetJobSchema(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetSchedule

func (c *Client) GetSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) GetTenantConfiguration added in v0.0.33

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

func (*Client) KeepAliveLease

func (c *Client) KeepAliveLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *KeepAliveLeaseParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListChapters

func (c *Client) ListChapters(ctx context.Context, tenantId TenantId, jobId JobId, params *ListChaptersParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListJobSchemas added in v0.0.9

func (c *Client) ListJobSchemas(ctx context.Context, tenantId TenantId, params *ListJobSchemasParams, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListJobs

func (c *Client) ListJobs(ctx context.Context, tenantId TenantId, body ListJobsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListJobsWithBody

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

func (*Client) ListScheduleRuns

func (c *Client) ListScheduleRuns(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ListScheduleRunsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListScheduleRunsWithBody

func (c *Client) ListScheduleRunsWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListSchedules

func (c *Client) ListSchedules(ctx context.Context, tenantId TenantId, body ListSchedulesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ListSchedulesWithBody

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

func (*Client) OpenArtifact

func (c *Client) OpenArtifact(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, name ArtifactName, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PauseSchedule

func (c *Client) PauseSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body PauseScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PauseScheduleWithBody

func (c *Client) PauseScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PollWork

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

func (*Client) PollWorkWithBody

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

func (*Client) PutJob

func (c *Client) PutJob(ctx context.Context, tenantId TenantId, jobId JobId, body PutJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutJobWithBody

func (c *Client) PutJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutJobWithLease added in v0.0.13

func (c *Client) PutJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, body PutJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutJobWithLeaseWithBody added in v0.0.13

func (c *Client) PutJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutRestartJob

func (c *Client) PutRestartJob(ctx context.Context, tenantId TenantId, jobId JobId, body PutRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutRestartJobWithBody

func (c *Client) PutRestartJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutRestartJobWithLease added in v0.0.13

func (c *Client) PutRestartJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, body PutRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) PutRestartJobWithLeaseWithBody added in v0.0.13

func (c *Client) PutRestartJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RegisterJobSchema added in v0.0.9

func (c *Client) RegisterJobSchema(ctx context.Context, tenantId TenantId, body RegisterJobSchemaJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RegisterJobSchemaWithBody added in v0.0.9

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

func (*Client) RemoveTenantConfigurationValue added in v0.0.33

func (c *Client) RemoveTenantConfigurationValue(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, body RemoveTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RemoveTenantConfigurationValueWithBody added in v0.0.33

func (c *Client) RemoveTenantConfigurationValueWithBody(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RescheduleJobWithLease

func (c *Client) RescheduleJobWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, body RescheduleJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) RescheduleJobWithLeaseWithBody

func (c *Client) RescheduleJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ResolveSecretsWithLease added in v0.0.29

func (c *Client) ResolveSecretsWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, body ResolveSecretsWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ResolveSecretsWithLeaseWithBody added in v0.0.29

func (c *Client) ResolveSecretsWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ResumeSchedule

func (c *Client) ResumeSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ResumeScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) ResumeScheduleWithBody

func (c *Client) ResumeScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SetTenantConfigurationValue added in v0.0.33

func (c *Client) SetTenantConfigurationValue(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, body SetTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SetTenantConfigurationValueWithBody added in v0.0.33

func (c *Client) SetTenantConfigurationValueWithBody(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SubmitJob

func (c *Client) SubmitJob(ctx context.Context, tenantId TenantId, body SubmitJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SubmitJobWithBody

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

func (*Client) SubmitJobWithLease added in v0.0.13

func (c *Client) SubmitJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, body SubmitJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SubmitJobWithLeaseWithBody added in v0.0.13

func (c *Client) SubmitJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SubmitRestartJob

func (c *Client) SubmitRestartJob(ctx context.Context, tenantId TenantId, body SubmitRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SubmitRestartJobWithBody

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

func (*Client) SubmitRestartJobWithLease added in v0.0.13

func (c *Client) SubmitRestartJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, body SubmitRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) SubmitRestartJobWithLeaseWithBody added in v0.0.13

func (c *Client) SubmitRestartJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) TriggerSchedule

func (c *Client) TriggerSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body TriggerScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) TriggerScheduleWithBody

func (c *Client) TriggerScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpsertSchedule

func (c *Client) UpsertSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body UpsertScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

func (*Client) UpsertScheduleWithBody

func (c *Client) UpsertScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

type ClientInterface

type ClientInterface interface {
	// PollWorkWithBody request with any body
	PollWorkWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PollWork(ctx context.Context, body PollWorkJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetTenantConfiguration request
	GetTenantConfiguration(ctx context.Context, tenantId TenantId, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RemoveTenantConfigurationValueWithBody request with any body
	RemoveTenantConfigurationValueWithBody(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	RemoveTenantConfigurationValue(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, body RemoveTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SetTenantConfigurationValueWithBody request with any body
	SetTenantConfigurationValueWithBody(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SetTenantConfigurationValue(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, body SetTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	SubmitJob(ctx context.Context, tenantId TenantId, body SubmitJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	ListJobs(ctx context.Context, tenantId TenantId, body ListJobsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	SubmitRestartJob(ctx context.Context, tenantId TenantId, body SubmitRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetJob request
	GetJob(ctx context.Context, tenantId TenantId, jobId JobId, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutJobWithBody request with any body
	PutJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutJob(ctx context.Context, tenantId TenantId, jobId JobId, body PutJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CancelJobWithBody request with any body
	CancelJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CancelJob(ctx context.Context, tenantId TenantId, jobId JobId, body CancelJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListChapters request
	ListChapters(ctx context.Context, tenantId TenantId, jobId JobId, params *ListChaptersParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetChapter request
	GetChapter(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, reqEditors ...RequestEditorFn) (*http.Response, error)

	// OpenArtifact request
	OpenArtifact(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, name ArtifactName, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CommitChapterIfWaitingWithBody request with any body
	CommitChapterIfWaitingWithBody(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CommitChapterIfWaiting(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, body CommitChapterIfWaitingJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetJobLeaseWithBody request with any body
	GetJobLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	GetJobLease(ctx context.Context, tenantId TenantId, jobId JobId, body GetJobLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AddChapterWithLeaseWithBody request with any body
	AddChapterWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	AddChapterWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, body AddChapterWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// CompleteJobWithLeaseWithBody request with any body
	CompleteJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	CompleteJobWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, body CompleteJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetConfigurationWithLease request
	GetConfigurationWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *GetConfigurationWithLeaseParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// KeepAliveLease request
	KeepAliveLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *KeepAliveLeaseParams, reqEditors ...RequestEditorFn) (*http.Response, error)

	// RescheduleJobWithLeaseWithBody request with any body
	RescheduleJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	RescheduleJobWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, body RescheduleJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ResolveSecretsWithLeaseWithBody request with any body
	ResolveSecretsWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ResolveSecretsWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, body ResolveSecretsWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutRestartJobWithBody request with any body
	PutRestartJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutRestartJob(ctx context.Context, tenantId TenantId, jobId JobId, body PutRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SubmitJobWithLeaseWithBody request with any body
	SubmitJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SubmitJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, body SubmitJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// SubmitRestartJobWithLeaseWithBody request with any body
	SubmitRestartJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	SubmitRestartJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, body SubmitRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutJobWithLeaseWithBody request with any body
	PutJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, body PutJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PutRestartJobWithLeaseWithBody request with any body
	PutRestartJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PutRestartJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, body PutRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	ListSchedules(ctx context.Context, tenantId TenantId, body ListSchedulesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetSchedule request
	GetSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, reqEditors ...RequestEditorFn) (*http.Response, error)

	// UpsertScheduleWithBody request with any body
	UpsertScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	UpsertSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body UpsertScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ArchiveScheduleWithBody request with any body
	ArchiveScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ArchiveSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ArchiveScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// PauseScheduleWithBody request with any body
	PauseScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	PauseSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body PauseScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ResumeScheduleWithBody request with any body
	ResumeScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ResumeSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ResumeScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListScheduleRunsWithBody request with any body
	ListScheduleRunsWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	ListScheduleRuns(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ListScheduleRunsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// TriggerScheduleWithBody request with any body
	TriggerScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	TriggerSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body TriggerScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ListJobSchemas request
	ListJobSchemas(ctx context.Context, tenantId TenantId, params *ListJobSchemasParams, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	RegisterJobSchema(ctx context.Context, tenantId TenantId, body RegisterJobSchemaJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetJobSchema request
	GetJobSchema(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*http.Response, error)

	// ArchiveJobSchema request
	ArchiveJobSchema(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*http.Response, error)
}

The interface specification for the client above.

type ClientOption

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient

func WithHTTPClient(doer HttpRequestDoer) ClientOption

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

func WithRequestEditorFn

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

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

type ClientPayloadUpdate added in v0.0.18

type ClientPayloadUpdate = clientpayload.Update

ClientPayloadUpdate defines model for ClientPayloadUpdate.

type ClientWithResponses

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func NewClientWithResponses

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

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

func (*ClientWithResponses) AddChapterWithLeaseWithBodyWithResponse

func (c *ClientWithResponses) AddChapterWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddChapterWithLeaseHTTPResponse, error)

AddChapterWithLeaseWithBodyWithResponse request with arbitrary body returning *AddChapterWithLeaseHTTPResponse

func (*ClientWithResponses) AddChapterWithLeaseWithResponse

func (c *ClientWithResponses) AddChapterWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, body AddChapterWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*AddChapterWithLeaseHTTPResponse, error)

func (*ClientWithResponses) ArchiveJobSchemaWithResponse added in v0.0.9

func (c *ClientWithResponses) ArchiveJobSchemaWithResponse(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*ArchiveJobSchemaHTTPResponse, error)

ArchiveJobSchemaWithResponse request returning *ArchiveJobSchemaHTTPResponse

func (*ClientWithResponses) ArchiveScheduleWithBodyWithResponse

func (c *ClientWithResponses) ArchiveScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ArchiveScheduleHTTPResponse, error)

ArchiveScheduleWithBodyWithResponse request with arbitrary body returning *ArchiveScheduleHTTPResponse

func (*ClientWithResponses) ArchiveScheduleWithResponse

func (c *ClientWithResponses) ArchiveScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ArchiveScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*ArchiveScheduleHTTPResponse, error)

func (*ClientWithResponses) CancelJobWithBodyWithResponse

func (c *ClientWithResponses) CancelJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CancelJobHTTPResponse, error)

CancelJobWithBodyWithResponse request with arbitrary body returning *CancelJobHTTPResponse

func (*ClientWithResponses) CancelJobWithResponse

func (c *ClientWithResponses) CancelJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body CancelJobJSONRequestBody, reqEditors ...RequestEditorFn) (*CancelJobHTTPResponse, error)

func (*ClientWithResponses) CommitChapterIfWaitingWithBodyWithResponse

func (c *ClientWithResponses) CommitChapterIfWaitingWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CommitChapterIfWaitingHTTPResponse, error)

CommitChapterIfWaitingWithBodyWithResponse request with arbitrary body returning *CommitChapterIfWaitingHTTPResponse

func (*ClientWithResponses) CommitChapterIfWaitingWithResponse

func (c *ClientWithResponses) CommitChapterIfWaitingWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, body CommitChapterIfWaitingJSONRequestBody, reqEditors ...RequestEditorFn) (*CommitChapterIfWaitingHTTPResponse, error)

func (*ClientWithResponses) CompleteJobWithLeaseWithBodyWithResponse

func (c *ClientWithResponses) CompleteJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CompleteJobWithLeaseHTTPResponse, error)

CompleteJobWithLeaseWithBodyWithResponse request with arbitrary body returning *CompleteJobWithLeaseHTTPResponse

func (*ClientWithResponses) CompleteJobWithLeaseWithResponse

func (c *ClientWithResponses) CompleteJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, body CompleteJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*CompleteJobWithLeaseHTTPResponse, error)

func (*ClientWithResponses) GetChapterWithResponse

func (c *ClientWithResponses) GetChapterWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, reqEditors ...RequestEditorFn) (*GetChapterHTTPResponse, error)

GetChapterWithResponse request returning *GetChapterHTTPResponse

func (*ClientWithResponses) GetConfigurationWithLeaseWithResponse added in v0.0.33

func (c *ClientWithResponses) GetConfigurationWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *GetConfigurationWithLeaseParams, reqEditors ...RequestEditorFn) (*GetConfigurationWithLeaseHTTPResponse, error)

GetConfigurationWithLeaseWithResponse request returning *GetConfigurationWithLeaseHTTPResponse

func (*ClientWithResponses) GetJobLeaseWithBodyWithResponse

func (c *ClientWithResponses) GetJobLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*GetJobLeaseHTTPResponse, error)

GetJobLeaseWithBodyWithResponse request with arbitrary body returning *GetJobLeaseHTTPResponse

func (*ClientWithResponses) GetJobLeaseWithResponse

func (c *ClientWithResponses) GetJobLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body GetJobLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*GetJobLeaseHTTPResponse, error)

func (*ClientWithResponses) GetJobSchemaWithResponse added in v0.0.9

func (c *ClientWithResponses) GetJobSchemaWithResponse(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*GetJobSchemaHTTPResponse, error)

GetJobSchemaWithResponse request returning *GetJobSchemaHTTPResponse

func (*ClientWithResponses) GetJobWithResponse

func (c *ClientWithResponses) GetJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, reqEditors ...RequestEditorFn) (*GetJobHTTPResponse, error)

GetJobWithResponse request returning *GetJobHTTPResponse

func (*ClientWithResponses) GetScheduleWithResponse

func (c *ClientWithResponses) GetScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, reqEditors ...RequestEditorFn) (*GetScheduleHTTPResponse, error)

GetScheduleWithResponse request returning *GetScheduleHTTPResponse

func (*ClientWithResponses) GetTenantConfigurationWithResponse added in v0.0.33

func (c *ClientWithResponses) GetTenantConfigurationWithResponse(ctx context.Context, tenantId TenantId, reqEditors ...RequestEditorFn) (*GetTenantConfigurationHTTPResponse, error)

GetTenantConfigurationWithResponse request returning *GetTenantConfigurationHTTPResponse

func (*ClientWithResponses) KeepAliveLeaseWithResponse

func (c *ClientWithResponses) KeepAliveLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *KeepAliveLeaseParams, reqEditors ...RequestEditorFn) (*KeepAliveLeaseHTTPResponse, error)

KeepAliveLeaseWithResponse request returning *KeepAliveLeaseHTTPResponse

func (*ClientWithResponses) ListChaptersWithResponse

func (c *ClientWithResponses) ListChaptersWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, params *ListChaptersParams, reqEditors ...RequestEditorFn) (*ListChaptersHTTPResponse, error)

ListChaptersWithResponse request returning *ListChaptersHTTPResponse

func (*ClientWithResponses) ListJobSchemasWithResponse added in v0.0.9

func (c *ClientWithResponses) ListJobSchemasWithResponse(ctx context.Context, tenantId TenantId, params *ListJobSchemasParams, reqEditors ...RequestEditorFn) (*ListJobSchemasHTTPResponse, error)

ListJobSchemasWithResponse request returning *ListJobSchemasHTTPResponse

func (*ClientWithResponses) ListJobsWithBodyWithResponse

func (c *ClientWithResponses) ListJobsWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ListJobsHTTPResponse, error)

ListJobsWithBodyWithResponse request with arbitrary body returning *ListJobsHTTPResponse

func (*ClientWithResponses) ListJobsWithResponse

func (c *ClientWithResponses) ListJobsWithResponse(ctx context.Context, tenantId TenantId, body ListJobsJSONRequestBody, reqEditors ...RequestEditorFn) (*ListJobsHTTPResponse, error)

func (*ClientWithResponses) ListScheduleRunsWithBodyWithResponse

func (c *ClientWithResponses) ListScheduleRunsWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ListScheduleRunsHTTPResponse, error)

ListScheduleRunsWithBodyWithResponse request with arbitrary body returning *ListScheduleRunsHTTPResponse

func (*ClientWithResponses) ListScheduleRunsWithResponse

func (c *ClientWithResponses) ListScheduleRunsWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ListScheduleRunsJSONRequestBody, reqEditors ...RequestEditorFn) (*ListScheduleRunsHTTPResponse, error)

func (*ClientWithResponses) ListSchedulesWithBodyWithResponse

func (c *ClientWithResponses) ListSchedulesWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ListSchedulesHTTPResponse, error)

ListSchedulesWithBodyWithResponse request with arbitrary body returning *ListSchedulesHTTPResponse

func (*ClientWithResponses) ListSchedulesWithResponse

func (c *ClientWithResponses) ListSchedulesWithResponse(ctx context.Context, tenantId TenantId, body ListSchedulesJSONRequestBody, reqEditors ...RequestEditorFn) (*ListSchedulesHTTPResponse, error)

func (*ClientWithResponses) OpenArtifactWithResponse

func (c *ClientWithResponses) OpenArtifactWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, name ArtifactName, reqEditors ...RequestEditorFn) (*OpenArtifactHTTPResponse, error)

OpenArtifactWithResponse request returning *OpenArtifactHTTPResponse

func (*ClientWithResponses) PauseScheduleWithBodyWithResponse

func (c *ClientWithResponses) PauseScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PauseScheduleHTTPResponse, error)

PauseScheduleWithBodyWithResponse request with arbitrary body returning *PauseScheduleHTTPResponse

func (*ClientWithResponses) PauseScheduleWithResponse

func (c *ClientWithResponses) PauseScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body PauseScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*PauseScheduleHTTPResponse, error)

func (*ClientWithResponses) PollWorkWithBodyWithResponse

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

PollWorkWithBodyWithResponse request with arbitrary body returning *PollWorkHTTPResponse

func (*ClientWithResponses) PollWorkWithResponse

func (c *ClientWithResponses) PollWorkWithResponse(ctx context.Context, body PollWorkJSONRequestBody, reqEditors ...RequestEditorFn) (*PollWorkHTTPResponse, error)

func (*ClientWithResponses) PutJobWithBodyWithResponse

func (c *ClientWithResponses) PutJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutJobHTTPResponse, error)

PutJobWithBodyWithResponse request with arbitrary body returning *PutJobHTTPResponse

func (*ClientWithResponses) PutJobWithLeaseWithBodyWithResponse added in v0.0.13

func (c *ClientWithResponses) PutJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutJobWithLeaseHTTPResponse, error)

PutJobWithLeaseWithBodyWithResponse request with arbitrary body returning *PutJobWithLeaseHTTPResponse

func (*ClientWithResponses) PutJobWithLeaseWithResponse added in v0.0.13

func (c *ClientWithResponses) PutJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, body PutJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*PutJobWithLeaseHTTPResponse, error)

func (*ClientWithResponses) PutJobWithResponse

func (c *ClientWithResponses) PutJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body PutJobJSONRequestBody, reqEditors ...RequestEditorFn) (*PutJobHTTPResponse, error)

func (*ClientWithResponses) PutRestartJobWithBodyWithResponse

func (c *ClientWithResponses) PutRestartJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutRestartJobHTTPResponse, error)

PutRestartJobWithBodyWithResponse request with arbitrary body returning *PutRestartJobHTTPResponse

func (*ClientWithResponses) PutRestartJobWithLeaseWithBodyWithResponse added in v0.0.13

func (c *ClientWithResponses) PutRestartJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutRestartJobWithLeaseHTTPResponse, error)

PutRestartJobWithLeaseWithBodyWithResponse request with arbitrary body returning *PutRestartJobWithLeaseHTTPResponse

func (*ClientWithResponses) PutRestartJobWithLeaseWithResponse added in v0.0.13

func (c *ClientWithResponses) PutRestartJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, body PutRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*PutRestartJobWithLeaseHTTPResponse, error)

func (*ClientWithResponses) PutRestartJobWithResponse

func (c *ClientWithResponses) PutRestartJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body PutRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*PutRestartJobHTTPResponse, error)

func (*ClientWithResponses) RegisterJobSchemaWithBodyWithResponse added in v0.0.9

func (c *ClientWithResponses) RegisterJobSchemaWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RegisterJobSchemaHTTPResponse, error)

RegisterJobSchemaWithBodyWithResponse request with arbitrary body returning *RegisterJobSchemaHTTPResponse

func (*ClientWithResponses) RegisterJobSchemaWithResponse added in v0.0.9

func (c *ClientWithResponses) RegisterJobSchemaWithResponse(ctx context.Context, tenantId TenantId, body RegisterJobSchemaJSONRequestBody, reqEditors ...RequestEditorFn) (*RegisterJobSchemaHTTPResponse, error)

func (*ClientWithResponses) RemoveTenantConfigurationValueWithBodyWithResponse added in v0.0.33

func (c *ClientWithResponses) RemoveTenantConfigurationValueWithBodyWithResponse(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RemoveTenantConfigurationValueHTTPResponse, error)

RemoveTenantConfigurationValueWithBodyWithResponse request with arbitrary body returning *RemoveTenantConfigurationValueHTTPResponse

func (*ClientWithResponses) RemoveTenantConfigurationValueWithResponse added in v0.0.33

func (*ClientWithResponses) RescheduleJobWithLeaseWithBodyWithResponse

func (c *ClientWithResponses) RescheduleJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RescheduleJobWithLeaseHTTPResponse, error)

RescheduleJobWithLeaseWithBodyWithResponse request with arbitrary body returning *RescheduleJobWithLeaseHTTPResponse

func (*ClientWithResponses) RescheduleJobWithLeaseWithResponse

func (c *ClientWithResponses) RescheduleJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, body RescheduleJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*RescheduleJobWithLeaseHTTPResponse, error)

func (*ClientWithResponses) ResolveSecretsWithLeaseWithBodyWithResponse added in v0.0.29

func (c *ClientWithResponses) ResolveSecretsWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ResolveSecretsWithLeaseHTTPResponse, error)

ResolveSecretsWithLeaseWithBodyWithResponse request with arbitrary body returning *ResolveSecretsWithLeaseHTTPResponse

func (*ClientWithResponses) ResolveSecretsWithLeaseWithResponse added in v0.0.29

func (c *ClientWithResponses) ResolveSecretsWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, body ResolveSecretsWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*ResolveSecretsWithLeaseHTTPResponse, error)

func (*ClientWithResponses) ResumeScheduleWithBodyWithResponse

func (c *ClientWithResponses) ResumeScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ResumeScheduleHTTPResponse, error)

ResumeScheduleWithBodyWithResponse request with arbitrary body returning *ResumeScheduleHTTPResponse

func (*ClientWithResponses) ResumeScheduleWithResponse

func (c *ClientWithResponses) ResumeScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ResumeScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*ResumeScheduleHTTPResponse, error)

func (*ClientWithResponses) SetTenantConfigurationValueWithBodyWithResponse added in v0.0.33

func (c *ClientWithResponses) SetTenantConfigurationValueWithBodyWithResponse(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SetTenantConfigurationValueHTTPResponse, error)

SetTenantConfigurationValueWithBodyWithResponse request with arbitrary body returning *SetTenantConfigurationValueHTTPResponse

func (*ClientWithResponses) SetTenantConfigurationValueWithResponse added in v0.0.33

func (*ClientWithResponses) SubmitJobWithBodyWithResponse

func (c *ClientWithResponses) SubmitJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitJobHTTPResponse, error)

SubmitJobWithBodyWithResponse request with arbitrary body returning *SubmitJobHTTPResponse

func (*ClientWithResponses) SubmitJobWithLeaseWithBodyWithResponse added in v0.0.13

func (c *ClientWithResponses) SubmitJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitJobWithLeaseHTTPResponse, error)

SubmitJobWithLeaseWithBodyWithResponse request with arbitrary body returning *SubmitJobWithLeaseHTTPResponse

func (*ClientWithResponses) SubmitJobWithLeaseWithResponse added in v0.0.13

func (c *ClientWithResponses) SubmitJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, body SubmitJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitJobWithLeaseHTTPResponse, error)

func (*ClientWithResponses) SubmitJobWithResponse

func (c *ClientWithResponses) SubmitJobWithResponse(ctx context.Context, tenantId TenantId, body SubmitJobJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitJobHTTPResponse, error)

func (*ClientWithResponses) SubmitRestartJobWithBodyWithResponse

func (c *ClientWithResponses) SubmitRestartJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitRestartJobHTTPResponse, error)

SubmitRestartJobWithBodyWithResponse request with arbitrary body returning *SubmitRestartJobHTTPResponse

func (*ClientWithResponses) SubmitRestartJobWithLeaseWithBodyWithResponse added in v0.0.13

func (c *ClientWithResponses) SubmitRestartJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitRestartJobWithLeaseHTTPResponse, error)

SubmitRestartJobWithLeaseWithBodyWithResponse request with arbitrary body returning *SubmitRestartJobWithLeaseHTTPResponse

func (*ClientWithResponses) SubmitRestartJobWithLeaseWithResponse added in v0.0.13

func (c *ClientWithResponses) SubmitRestartJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, body SubmitRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitRestartJobWithLeaseHTTPResponse, error)

func (*ClientWithResponses) SubmitRestartJobWithResponse

func (c *ClientWithResponses) SubmitRestartJobWithResponse(ctx context.Context, tenantId TenantId, body SubmitRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitRestartJobHTTPResponse, error)

func (*ClientWithResponses) TriggerScheduleWithBodyWithResponse

func (c *ClientWithResponses) TriggerScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TriggerScheduleHTTPResponse, error)

TriggerScheduleWithBodyWithResponse request with arbitrary body returning *TriggerScheduleHTTPResponse

func (*ClientWithResponses) TriggerScheduleWithResponse

func (c *ClientWithResponses) TriggerScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body TriggerScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*TriggerScheduleHTTPResponse, error)

func (*ClientWithResponses) UpsertScheduleWithBodyWithResponse

func (c *ClientWithResponses) UpsertScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpsertScheduleHTTPResponse, error)

UpsertScheduleWithBodyWithResponse request with arbitrary body returning *UpsertScheduleHTTPResponse

func (*ClientWithResponses) UpsertScheduleWithResponse

func (c *ClientWithResponses) UpsertScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body UpsertScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*UpsertScheduleHTTPResponse, error)

type ClientWithResponsesInterface

type ClientWithResponsesInterface interface {
	// PollWorkWithBodyWithResponse request with any body
	PollWorkWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PollWorkHTTPResponse, error)

	PollWorkWithResponse(ctx context.Context, body PollWorkJSONRequestBody, reqEditors ...RequestEditorFn) (*PollWorkHTTPResponse, error)

	// GetTenantConfigurationWithResponse request
	GetTenantConfigurationWithResponse(ctx context.Context, tenantId TenantId, reqEditors ...RequestEditorFn) (*GetTenantConfigurationHTTPResponse, error)

	// RemoveTenantConfigurationValueWithBodyWithResponse request with any body
	RemoveTenantConfigurationValueWithBodyWithResponse(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RemoveTenantConfigurationValueHTTPResponse, error)

	RemoveTenantConfigurationValueWithResponse(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, body RemoveTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*RemoveTenantConfigurationValueHTTPResponse, error)

	// SetTenantConfigurationValueWithBodyWithResponse request with any body
	SetTenantConfigurationValueWithBodyWithResponse(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SetTenantConfigurationValueHTTPResponse, error)

	SetTenantConfigurationValueWithResponse(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, body SetTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*SetTenantConfigurationValueHTTPResponse, error)

	// SubmitJobWithBodyWithResponse request with any body
	SubmitJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitJobHTTPResponse, error)

	SubmitJobWithResponse(ctx context.Context, tenantId TenantId, body SubmitJobJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitJobHTTPResponse, error)

	// ListJobsWithBodyWithResponse request with any body
	ListJobsWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ListJobsHTTPResponse, error)

	ListJobsWithResponse(ctx context.Context, tenantId TenantId, body ListJobsJSONRequestBody, reqEditors ...RequestEditorFn) (*ListJobsHTTPResponse, error)

	// SubmitRestartJobWithBodyWithResponse request with any body
	SubmitRestartJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitRestartJobHTTPResponse, error)

	SubmitRestartJobWithResponse(ctx context.Context, tenantId TenantId, body SubmitRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitRestartJobHTTPResponse, error)

	// GetJobWithResponse request
	GetJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, reqEditors ...RequestEditorFn) (*GetJobHTTPResponse, error)

	// PutJobWithBodyWithResponse request with any body
	PutJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutJobHTTPResponse, error)

	PutJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body PutJobJSONRequestBody, reqEditors ...RequestEditorFn) (*PutJobHTTPResponse, error)

	// CancelJobWithBodyWithResponse request with any body
	CancelJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CancelJobHTTPResponse, error)

	CancelJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body CancelJobJSONRequestBody, reqEditors ...RequestEditorFn) (*CancelJobHTTPResponse, error)

	// ListChaptersWithResponse request
	ListChaptersWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, params *ListChaptersParams, reqEditors ...RequestEditorFn) (*ListChaptersHTTPResponse, error)

	// GetChapterWithResponse request
	GetChapterWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, reqEditors ...RequestEditorFn) (*GetChapterHTTPResponse, error)

	// OpenArtifactWithResponse request
	OpenArtifactWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, name ArtifactName, reqEditors ...RequestEditorFn) (*OpenArtifactHTTPResponse, error)

	// CommitChapterIfWaitingWithBodyWithResponse request with any body
	CommitChapterIfWaitingWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CommitChapterIfWaitingHTTPResponse, error)

	CommitChapterIfWaitingWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, body CommitChapterIfWaitingJSONRequestBody, reqEditors ...RequestEditorFn) (*CommitChapterIfWaitingHTTPResponse, error)

	// GetJobLeaseWithBodyWithResponse request with any body
	GetJobLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*GetJobLeaseHTTPResponse, error)

	GetJobLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body GetJobLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*GetJobLeaseHTTPResponse, error)

	// AddChapterWithLeaseWithBodyWithResponse request with any body
	AddChapterWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AddChapterWithLeaseHTTPResponse, error)

	AddChapterWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *AddChapterWithLeaseParams, body AddChapterWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*AddChapterWithLeaseHTTPResponse, error)

	// CompleteJobWithLeaseWithBodyWithResponse request with any body
	CompleteJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CompleteJobWithLeaseHTTPResponse, error)

	CompleteJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *CompleteJobWithLeaseParams, body CompleteJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*CompleteJobWithLeaseHTTPResponse, error)

	// GetConfigurationWithLeaseWithResponse request
	GetConfigurationWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *GetConfigurationWithLeaseParams, reqEditors ...RequestEditorFn) (*GetConfigurationWithLeaseHTTPResponse, error)

	// KeepAliveLeaseWithResponse request
	KeepAliveLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *KeepAliveLeaseParams, reqEditors ...RequestEditorFn) (*KeepAliveLeaseHTTPResponse, error)

	// RescheduleJobWithLeaseWithBodyWithResponse request with any body
	RescheduleJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RescheduleJobWithLeaseHTTPResponse, error)

	RescheduleJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *RescheduleJobWithLeaseParams, body RescheduleJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*RescheduleJobWithLeaseHTTPResponse, error)

	// ResolveSecretsWithLeaseWithBodyWithResponse request with any body
	ResolveSecretsWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ResolveSecretsWithLeaseHTTPResponse, error)

	ResolveSecretsWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, params *ResolveSecretsWithLeaseParams, body ResolveSecretsWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*ResolveSecretsWithLeaseHTTPResponse, error)

	// PutRestartJobWithBodyWithResponse request with any body
	PutRestartJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutRestartJobHTTPResponse, error)

	PutRestartJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, body PutRestartJobJSONRequestBody, reqEditors ...RequestEditorFn) (*PutRestartJobHTTPResponse, error)

	// SubmitJobWithLeaseWithBodyWithResponse request with any body
	SubmitJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitJobWithLeaseHTTPResponse, error)

	SubmitJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitJobWithLeaseParams, body SubmitJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitJobWithLeaseHTTPResponse, error)

	// SubmitRestartJobWithLeaseWithBodyWithResponse request with any body
	SubmitRestartJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*SubmitRestartJobWithLeaseHTTPResponse, error)

	SubmitRestartJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params *SubmitRestartJobWithLeaseParams, body SubmitRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*SubmitRestartJobWithLeaseHTTPResponse, error)

	// PutJobWithLeaseWithBodyWithResponse request with any body
	PutJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutJobWithLeaseHTTPResponse, error)

	PutJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutJobWithLeaseParams, body PutJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*PutJobWithLeaseHTTPResponse, error)

	// PutRestartJobWithLeaseWithBodyWithResponse request with any body
	PutRestartJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PutRestartJobWithLeaseHTTPResponse, error)

	PutRestartJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params *PutRestartJobWithLeaseParams, body PutRestartJobWithLeaseJSONRequestBody, reqEditors ...RequestEditorFn) (*PutRestartJobWithLeaseHTTPResponse, error)

	// ListSchedulesWithBodyWithResponse request with any body
	ListSchedulesWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ListSchedulesHTTPResponse, error)

	ListSchedulesWithResponse(ctx context.Context, tenantId TenantId, body ListSchedulesJSONRequestBody, reqEditors ...RequestEditorFn) (*ListSchedulesHTTPResponse, error)

	// GetScheduleWithResponse request
	GetScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, reqEditors ...RequestEditorFn) (*GetScheduleHTTPResponse, error)

	// UpsertScheduleWithBodyWithResponse request with any body
	UpsertScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpsertScheduleHTTPResponse, error)

	UpsertScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body UpsertScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*UpsertScheduleHTTPResponse, error)

	// ArchiveScheduleWithBodyWithResponse request with any body
	ArchiveScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ArchiveScheduleHTTPResponse, error)

	ArchiveScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ArchiveScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*ArchiveScheduleHTTPResponse, error)

	// PauseScheduleWithBodyWithResponse request with any body
	PauseScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PauseScheduleHTTPResponse, error)

	PauseScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body PauseScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*PauseScheduleHTTPResponse, error)

	// ResumeScheduleWithBodyWithResponse request with any body
	ResumeScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ResumeScheduleHTTPResponse, error)

	ResumeScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ResumeScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*ResumeScheduleHTTPResponse, error)

	// ListScheduleRunsWithBodyWithResponse request with any body
	ListScheduleRunsWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*ListScheduleRunsHTTPResponse, error)

	ListScheduleRunsWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ListScheduleRunsJSONRequestBody, reqEditors ...RequestEditorFn) (*ListScheduleRunsHTTPResponse, error)

	// TriggerScheduleWithBodyWithResponse request with any body
	TriggerScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TriggerScheduleHTTPResponse, error)

	TriggerScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body TriggerScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*TriggerScheduleHTTPResponse, error)

	// ListJobSchemasWithResponse request
	ListJobSchemasWithResponse(ctx context.Context, tenantId TenantId, params *ListJobSchemasParams, reqEditors ...RequestEditorFn) (*ListJobSchemasHTTPResponse, error)

	// RegisterJobSchemaWithBodyWithResponse request with any body
	RegisterJobSchemaWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*RegisterJobSchemaHTTPResponse, error)

	RegisterJobSchemaWithResponse(ctx context.Context, tenantId TenantId, body RegisterJobSchemaJSONRequestBody, reqEditors ...RequestEditorFn) (*RegisterJobSchemaHTTPResponse, error)

	// GetJobSchemaWithResponse request
	GetJobSchemaWithResponse(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*GetJobSchemaHTTPResponse, error)

	// ArchiveJobSchemaWithResponse request
	ArchiveJobSchemaWithResponse(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, reqEditors ...RequestEditorFn) (*ArchiveJobSchemaHTTPResponse, error)
}

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

type CommitChapterIfWaiting204Response

type CommitChapterIfWaiting204Response struct {
}

func (CommitChapterIfWaiting204Response) VisitCommitChapterIfWaitingResponse

func (response CommitChapterIfWaiting204Response) VisitCommitChapterIfWaitingResponse(w http.ResponseWriter) error

type CommitChapterIfWaiting409Response

type CommitChapterIfWaiting409Response struct {
}

func (CommitChapterIfWaiting409Response) VisitCommitChapterIfWaitingResponse

func (response CommitChapterIfWaiting409Response) VisitCommitChapterIfWaitingResponse(w http.ResponseWriter) error

type CommitChapterIfWaitingHTTPResponse

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

func ParseCommitChapterIfWaitingHTTPResponse

func ParseCommitChapterIfWaitingHTTPResponse(rsp *http.Response) (*CommitChapterIfWaitingHTTPResponse, error)

ParseCommitChapterIfWaitingHTTPResponse parses an HTTP response from a CommitChapterIfWaitingWithResponse call

func (CommitChapterIfWaitingHTTPResponse) Status

Status returns HTTPResponse.Status

func (CommitChapterIfWaitingHTTPResponse) StatusCode

func (r CommitChapterIfWaitingHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CommitChapterIfWaitingJSONRequestBody

type CommitChapterIfWaitingJSONRequestBody = CommitChapterIfWaitingRequest

CommitChapterIfWaitingJSONRequestBody defines body for CommitChapterIfWaiting for application/json ContentType.

type CommitChapterIfWaitingRequest

type CommitChapterIfWaitingRequest struct {
	Data TaskDataWrite `json:"data"`

	// InputHash Optional guard for deterministic input matching.
	InputHash *string `json:"inputHash,omitempty"`

	// InputOrdinal Optional guard for the input chapter ordinal.
	InputOrdinal *int64 `json:"inputOrdinal,omitempty"`

	// OutputOrdinal Optional guard for the output chapter ordinal; should match the path ordinal when provided.
	OutputOrdinal *int64 `json:"outputOrdinal,omitempty"`

	// ResumeJobType Optional guard for the resume job type.
	ResumeJobType *string `json:"resumeJobType,omitempty"`
	Route         Route   `json:"route"`
}

CommitChapterIfWaitingRequest Completes an external task without changing client payload.

type CommitChapterIfWaitingRequestObject

type CommitChapterIfWaitingRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	Ordinal  Ordinal  `json:"ordinal"`
	Body     *CommitChapterIfWaitingJSONRequestBody
}

type CommitChapterIfWaitingResponseObject

type CommitChapterIfWaitingResponseObject interface {
	VisitCommitChapterIfWaitingResponse(w http.ResponseWriter) error
}

type CompleteExecutionRequest

type CompleteExecutionRequest struct {
	// ArtifactUploads Artifact payloads attached to the final chapter written as part of
	// lease completion. Missing and empty arrays are both treated as no
	// uploads; artifacts do not exist as durable resources unless the
	// complete operation succeeds.
	ArtifactUploads     *[]ArtifactWrite     `json:"artifactUploads,omitempty"`
	Chapter             ChapterRecord        `json:"chapter"`
	ClientPayloadUpdate *ClientPayloadUpdate `json:"clientPayloadUpdate,omitempty"`
	Detail              *string              `json:"detail,omitempty"`
	Status              string               `json:"status"`
}

CompleteExecutionRequest defines model for CompleteExecutionRequest.

type CompleteJobWithLease204Response

type CompleteJobWithLease204Response struct {
}

func (CompleteJobWithLease204Response) VisitCompleteJobWithLeaseResponse

func (response CompleteJobWithLease204Response) VisitCompleteJobWithLeaseResponse(w http.ResponseWriter) error

type CompleteJobWithLeaseHTTPResponse

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

func ParseCompleteJobWithLeaseHTTPResponse

func ParseCompleteJobWithLeaseHTTPResponse(rsp *http.Response) (*CompleteJobWithLeaseHTTPResponse, error)

ParseCompleteJobWithLeaseHTTPResponse parses an HTTP response from a CompleteJobWithLeaseWithResponse call

func (CompleteJobWithLeaseHTTPResponse) Status

Status returns HTTPResponse.Status

func (CompleteJobWithLeaseHTTPResponse) StatusCode

func (r CompleteJobWithLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CompleteJobWithLeaseJSONRequestBody

type CompleteJobWithLeaseJSONRequestBody = CompleteExecutionRequest

CompleteJobWithLeaseJSONRequestBody defines body for CompleteJobWithLease for application/json ContentType.

type CompleteJobWithLeaseParams

type CompleteJobWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

CompleteJobWithLeaseParams defines parameters for CompleteJobWithLease.

type CompleteJobWithLeaseRequestObject

type CompleteJobWithLeaseRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	LeaseId  LeaseId  `json:"leaseId"`
	Params   CompleteJobWithLeaseParams
	Body     *CompleteJobWithLeaseJSONRequestBody
}

type CompleteJobWithLeaseResponseObject

type CompleteJobWithLeaseResponseObject interface {
	VisitCompleteJobWithLeaseResponse(w http.ResponseWriter) error
}

type ConfigurationSnapshot added in v0.0.33

type ConfigurationSnapshot struct {
	Revision string                        `json:"revision"`
	Values   map[string]ApplicationPayload `json:"values"`
}

ConfigurationSnapshot defines model for ConfigurationSnapshot.

type EndOrdinal

type EndOrdinal = int64

EndOrdinal defines model for EndOrdinal.

type ErrorCode

type ErrorCode string

ErrorCode defines model for ErrorCode.

const (
	ChapterNotFound               ErrorCode = "chapter_not_found"
	ConfigurationFailed           ErrorCode = "configuration_failed"
	ConfigurationReadTooLarge     ErrorCode = "configuration_read_too_large"
	ConfigurationRevisionMismatch ErrorCode = "configuration_revision_mismatch"
	ConfigurationTooLarge         ErrorCode = "configuration_too_large"
	ConfigurationUnavailable      ErrorCode = "configuration_unavailable"
	Conflict                      ErrorCode = "conflict"
	ExecutionLeaseLost            ErrorCode = "execution_lease_lost"
	ExistingJobMismatch           ErrorCode = "existing_job_mismatch"
	Internal                      ErrorCode = "internal"
	InvalidConfigurationRequest   ErrorCode = "invalid_configuration_request"
	InvalidRequest                ErrorCode = "invalid_request"
	JobNotComplete                ErrorCode = "job_not_complete"
	JobNotFound                   ErrorCode = "job_not_found"
	JobSchemaArchived             ErrorCode = "job_schema_archived"
	JobSchemaNotFound             ErrorCode = "job_schema_not_found"
	JobSchemaValidationFailed     ErrorCode = "job_schema_validation_failed"
	NotFound                      ErrorCode = "not_found"
	WorkflowNotDeterministic      ErrorCode = "workflow_not_deterministic"
)

Defines values for ErrorCode.

type ErrorResponse

type ErrorResponse struct {
	Code    ErrorCode `json:"code"`
	Message string    `json:"message"`
}

ErrorResponse defines model for ErrorResponse.

type ExecutionChapter added in v0.0.36

type ExecutionChapter struct {
	Kind ExecutionChapterKind `json:"kind"`

	// Record Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Record ApplicationPayload `json:"record"`
}

ExecutionChapter defines model for ExecutionChapter.

type ExecutionChapterKind added in v0.0.36

type ExecutionChapterKind string

ExecutionChapterKind defines model for ExecutionChapter.Kind.

const (
	Execution ExecutionChapterKind = "execution"
)

Defines values for ExecutionChapterKind.

type ExecutionLease

type ExecutionLease struct {
	ClientPayload         json.RawMessage `json:"clientPayload,omitempty"`
	ClientPayloadRevision string          `json:"clientPayloadRevision"`
	ExecutionState        ExecutionState  `json:"executionState"`

	// ExpiresAt Safe validity deadline, including capability expiration.
	ExpiresAt  *time.Time     `json:"expiresAt,omitempty"`
	Job        JobHandle      `json:"job"`
	LeaseId    string         `json:"leaseId"`
	LeaseToken string         `json:"leaseToken"`
	Route      Route          `json:"route"`
	SchemaHash *JobSchemaHash `json:"schemaHash,omitempty"`
	WorkerId   *string        `json:"workerId,omitempty"`
}

ExecutionLease defines model for ExecutionLease.

type ExecutionRestart added in v0.0.36

type ExecutionRestart struct {
	// Payload Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Payload *ApplicationPayload `json:"payload,omitempty"`
	ScopeId string              `json:"scopeId"`
}

ExecutionRestart defines model for ExecutionRestart.

type ExecutionState added in v0.0.18

type ExecutionState struct {
	RunPolicy *RunPolicy `json:"runPolicy,omitempty"`
	TaskWait  *TaskWait  `json:"taskWait,omitempty"`
}

ExecutionState defines model for ExecutionState.

type GetChapter200JSONResponse

type GetChapter200JSONResponse ChapterRecord

func (GetChapter200JSONResponse) VisitGetChapterResponse

func (response GetChapter200JSONResponse) VisitGetChapterResponse(w http.ResponseWriter) error

type GetChapterHTTPResponse

type GetChapterHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ChapterRecord
}

func ParseGetChapterHTTPResponse

func ParseGetChapterHTTPResponse(rsp *http.Response) (*GetChapterHTTPResponse, error)

ParseGetChapterHTTPResponse parses an HTTP response from a GetChapterWithResponse call

func (GetChapterHTTPResponse) Status

func (r GetChapterHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (GetChapterHTTPResponse) StatusCode

func (r GetChapterHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetChapterRequestObject

type GetChapterRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	Ordinal  Ordinal  `json:"ordinal"`
}

type GetChapterResponseObject

type GetChapterResponseObject interface {
	VisitGetChapterResponse(w http.ResponseWriter) error
}

type GetConfigurationWithLease200JSONResponse added in v0.0.33

type GetConfigurationWithLease200JSONResponse struct {
	Body    ConfigurationSnapshot
	Headers GetConfigurationWithLease200ResponseHeaders
}

func (GetConfigurationWithLease200JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease200JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease200ResponseHeaders added in v0.0.33

type GetConfigurationWithLease200ResponseHeaders struct {
	CacheControl string
	ETag         string
}

type GetConfigurationWithLease400JSONResponse added in v0.0.33

type GetConfigurationWithLease400JSONResponse struct {
	Body    ErrorResponse
	Headers GetConfigurationWithLease400ResponseHeaders
}

func (GetConfigurationWithLease400JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease400JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease400ResponseHeaders added in v0.0.33

type GetConfigurationWithLease400ResponseHeaders struct {
	CacheControl string
}

type GetConfigurationWithLease401JSONResponse added in v0.0.33

type GetConfigurationWithLease401JSONResponse struct {
	Body    ErrorResponse
	Headers GetConfigurationWithLease401ResponseHeaders
}

func (GetConfigurationWithLease401JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease401JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease401ResponseHeaders added in v0.0.33

type GetConfigurationWithLease401ResponseHeaders struct {
	CacheControl string
}

type GetConfigurationWithLease403JSONResponse added in v0.0.33

type GetConfigurationWithLease403JSONResponse struct {
	Body    ErrorResponse
	Headers GetConfigurationWithLease403ResponseHeaders
}

func (GetConfigurationWithLease403JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease403JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease403ResponseHeaders added in v0.0.33

type GetConfigurationWithLease403ResponseHeaders struct {
	CacheControl string
}

type GetConfigurationWithLease409JSONResponse added in v0.0.33

type GetConfigurationWithLease409JSONResponse struct {
	Body    ErrorResponse
	Headers GetConfigurationWithLease409ResponseHeaders
}

func (GetConfigurationWithLease409JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease409JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease409ResponseHeaders added in v0.0.33

type GetConfigurationWithLease409ResponseHeaders struct {
	CacheControl string
}

type GetConfigurationWithLease413JSONResponse added in v0.0.33

type GetConfigurationWithLease413JSONResponse struct {
	Body    ErrorResponse
	Headers GetConfigurationWithLease413ResponseHeaders
}

func (GetConfigurationWithLease413JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease413JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease413ResponseHeaders added in v0.0.33

type GetConfigurationWithLease413ResponseHeaders struct {
	CacheControl string
}

type GetConfigurationWithLease500JSONResponse added in v0.0.33

type GetConfigurationWithLease500JSONResponse struct {
	Body    ErrorResponse
	Headers GetConfigurationWithLease500ResponseHeaders
}

func (GetConfigurationWithLease500JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease500JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease500ResponseHeaders added in v0.0.33

type GetConfigurationWithLease500ResponseHeaders struct {
	CacheControl string
}

type GetConfigurationWithLease503JSONResponse added in v0.0.33

type GetConfigurationWithLease503JSONResponse struct {
	Body    ErrorResponse
	Headers GetConfigurationWithLease503ResponseHeaders
}

func (GetConfigurationWithLease503JSONResponse) VisitGetConfigurationWithLeaseResponse added in v0.0.33

func (response GetConfigurationWithLease503JSONResponse) VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error

type GetConfigurationWithLease503ResponseHeaders added in v0.0.33

type GetConfigurationWithLease503ResponseHeaders struct {
	CacheControl string
}

type GetConfigurationWithLeaseHTTPResponse added in v0.0.33

type GetConfigurationWithLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ConfigurationSnapshot
	JSON400      *ErrorResponse
	JSON401      *ErrorResponse
	JSON403      *ErrorResponse
	JSON409      *ErrorResponse
	JSON413      *ErrorResponse
	JSON500      *ErrorResponse
	JSON503      *ErrorResponse
}

func ParseGetConfigurationWithLeaseHTTPResponse added in v0.0.33

func ParseGetConfigurationWithLeaseHTTPResponse(rsp *http.Response) (*GetConfigurationWithLeaseHTTPResponse, error)

ParseGetConfigurationWithLeaseHTTPResponse parses an HTTP response from a GetConfigurationWithLeaseWithResponse call

func (GetConfigurationWithLeaseHTTPResponse) Status added in v0.0.33

Status returns HTTPResponse.Status

func (GetConfigurationWithLeaseHTTPResponse) StatusCode added in v0.0.33

StatusCode returns HTTPResponse.StatusCode

type GetConfigurationWithLeaseParams added in v0.0.33

type GetConfigurationWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

GetConfigurationWithLeaseParams defines parameters for GetConfigurationWithLease.

type GetConfigurationWithLeaseRequestObject added in v0.0.33

type GetConfigurationWithLeaseRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	LeaseId  LeaseId  `json:"leaseId"`
	Params   GetConfigurationWithLeaseParams
}

type GetConfigurationWithLeaseResponseObject added in v0.0.33

type GetConfigurationWithLeaseResponseObject interface {
	VisitGetConfigurationWithLeaseResponse(w http.ResponseWriter) error
}

type GetJob200JSONResponse

type GetJob200JSONResponse JobInfo

func (GetJob200JSONResponse) VisitGetJobResponse

func (response GetJob200JSONResponse) VisitGetJobResponse(w http.ResponseWriter) error

type GetJobHTTPResponse

type GetJobHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobInfo
}

func ParseGetJobHTTPResponse

func ParseGetJobHTTPResponse(rsp *http.Response) (*GetJobHTTPResponse, error)

ParseGetJobHTTPResponse parses an HTTP response from a GetJobWithResponse call

func (GetJobHTTPResponse) Status

func (r GetJobHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (GetJobHTTPResponse) StatusCode

func (r GetJobHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetJobLease200JSONResponse

type GetJobLease200JSONResponse GetJobLeaseResponse

func (GetJobLease200JSONResponse) VisitGetJobLeaseResponse

func (response GetJobLease200JSONResponse) VisitGetJobLeaseResponse(w http.ResponseWriter) error

type GetJobLeaseHTTPResponse

type GetJobLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *GetJobLeaseResponse
}

func ParseGetJobLeaseHTTPResponse

func ParseGetJobLeaseHTTPResponse(rsp *http.Response) (*GetJobLeaseHTTPResponse, error)

ParseGetJobLeaseHTTPResponse parses an HTTP response from a GetJobLeaseWithResponse call

func (GetJobLeaseHTTPResponse) Status

func (r GetJobLeaseHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (GetJobLeaseHTTPResponse) StatusCode

func (r GetJobLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetJobLeaseJSONRequestBody

type GetJobLeaseJSONRequestBody = GetJobLeaseRequest

GetJobLeaseJSONRequestBody defines body for GetJobLease for application/json ContentType.

type GetJobLeaseRequest

type GetJobLeaseRequest struct {
	// LeaseDuration Duration string controlling how long the acquired lease should be held.
	LeaseDuration *string `json:"leaseDuration,omitempty"`
	Routes        []Route `json:"routes"`
	WorkerId      *string `json:"workerId,omitempty"`
}

GetJobLeaseRequest defines model for GetJobLeaseRequest.

type GetJobLeaseRequestObject

type GetJobLeaseRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	Body     *GetJobLeaseJSONRequestBody
}

type GetJobLeaseResponse

type GetJobLeaseResponse struct {
	// Lease Targeted lease when the job is currently leaseable; `null` otherwise.
	Lease *ExecutionLease `json:"lease"`
}

GetJobLeaseResponse defines model for GetJobLeaseResponse.

type GetJobLeaseResponseObject

type GetJobLeaseResponseObject interface {
	VisitGetJobLeaseResponse(w http.ResponseWriter) error
}

type GetJobRequestObject

type GetJobRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
}

type GetJobResponseObject

type GetJobResponseObject interface {
	VisitGetJobResponse(w http.ResponseWriter) error
}

type GetJobSchema200JSONResponse added in v0.0.9

type GetJobSchema200JSONResponse JobSchemaInfo

func (GetJobSchema200JSONResponse) VisitGetJobSchemaResponse added in v0.0.9

func (response GetJobSchema200JSONResponse) VisitGetJobSchemaResponse(w http.ResponseWriter) error

type GetJobSchemaHTTPResponse added in v0.0.9

type GetJobSchemaHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobSchemaInfo
}

func ParseGetJobSchemaHTTPResponse added in v0.0.9

func ParseGetJobSchemaHTTPResponse(rsp *http.Response) (*GetJobSchemaHTTPResponse, error)

ParseGetJobSchemaHTTPResponse parses an HTTP response from a GetJobSchemaWithResponse call

func (GetJobSchemaHTTPResponse) Status added in v0.0.9

func (r GetJobSchemaHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (GetJobSchemaHTTPResponse) StatusCode added in v0.0.9

func (r GetJobSchemaHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetJobSchemaRequestObject added in v0.0.9

type GetJobSchemaRequestObject struct {
	TenantId   TenantId      `json:"tenantId"`
	SchemaHash JobSchemaHash `json:"schemaHash"`
}

type GetJobSchemaResponseObject added in v0.0.9

type GetJobSchemaResponseObject interface {
	VisitGetJobSchemaResponse(w http.ResponseWriter) error
}

type GetSchedule200JSONResponse

type GetSchedule200JSONResponse ScheduleInfo

func (GetSchedule200JSONResponse) VisitGetScheduleResponse

func (response GetSchedule200JSONResponse) VisitGetScheduleResponse(w http.ResponseWriter) error

type GetScheduleHTTPResponse

type GetScheduleHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ScheduleInfo
}

func ParseGetScheduleHTTPResponse

func ParseGetScheduleHTTPResponse(rsp *http.Response) (*GetScheduleHTTPResponse, error)

ParseGetScheduleHTTPResponse parses an HTTP response from a GetScheduleWithResponse call

func (GetScheduleHTTPResponse) Status

func (r GetScheduleHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (GetScheduleHTTPResponse) StatusCode

func (r GetScheduleHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetScheduleRequestObject

type GetScheduleRequestObject struct {
	TenantId   TenantId   `json:"tenantId"`
	ScheduleId ScheduleId `json:"scheduleId"`
}

type GetScheduleResponseObject

type GetScheduleResponseObject interface {
	VisitGetScheduleResponse(w http.ResponseWriter) error
}

type GetTenantConfiguration200JSONResponse added in v0.0.33

type GetTenantConfiguration200JSONResponse struct {
	Body    ConfigurationSnapshot
	Headers GetTenantConfiguration200ResponseHeaders
}

func (GetTenantConfiguration200JSONResponse) VisitGetTenantConfigurationResponse added in v0.0.33

func (response GetTenantConfiguration200JSONResponse) VisitGetTenantConfigurationResponse(w http.ResponseWriter) error

type GetTenantConfiguration200ResponseHeaders added in v0.0.33

type GetTenantConfiguration200ResponseHeaders struct {
	CacheControl string
	ETag         string
}

type GetTenantConfiguration400JSONResponse added in v0.0.33

type GetTenantConfiguration400JSONResponse struct {
	Body    ErrorResponse
	Headers GetTenantConfiguration400ResponseHeaders
}

func (GetTenantConfiguration400JSONResponse) VisitGetTenantConfigurationResponse added in v0.0.33

func (response GetTenantConfiguration400JSONResponse) VisitGetTenantConfigurationResponse(w http.ResponseWriter) error

type GetTenantConfiguration400ResponseHeaders added in v0.0.33

type GetTenantConfiguration400ResponseHeaders struct {
	CacheControl string
}

type GetTenantConfiguration401JSONResponse added in v0.0.33

type GetTenantConfiguration401JSONResponse struct {
	Body    ErrorResponse
	Headers GetTenantConfiguration401ResponseHeaders
}

func (GetTenantConfiguration401JSONResponse) VisitGetTenantConfigurationResponse added in v0.0.33

func (response GetTenantConfiguration401JSONResponse) VisitGetTenantConfigurationResponse(w http.ResponseWriter) error

type GetTenantConfiguration401ResponseHeaders added in v0.0.33

type GetTenantConfiguration401ResponseHeaders struct {
	CacheControl string
}

type GetTenantConfiguration403JSONResponse added in v0.0.33

type GetTenantConfiguration403JSONResponse struct {
	Body    ErrorResponse
	Headers GetTenantConfiguration403ResponseHeaders
}

func (GetTenantConfiguration403JSONResponse) VisitGetTenantConfigurationResponse added in v0.0.33

func (response GetTenantConfiguration403JSONResponse) VisitGetTenantConfigurationResponse(w http.ResponseWriter) error

type GetTenantConfiguration403ResponseHeaders added in v0.0.33

type GetTenantConfiguration403ResponseHeaders struct {
	CacheControl string
}

type GetTenantConfiguration413JSONResponse added in v0.0.33

type GetTenantConfiguration413JSONResponse struct {
	Body    ErrorResponse
	Headers GetTenantConfiguration413ResponseHeaders
}

func (GetTenantConfiguration413JSONResponse) VisitGetTenantConfigurationResponse added in v0.0.33

func (response GetTenantConfiguration413JSONResponse) VisitGetTenantConfigurationResponse(w http.ResponseWriter) error

type GetTenantConfiguration413ResponseHeaders added in v0.0.33

type GetTenantConfiguration413ResponseHeaders struct {
	CacheControl string
}

type GetTenantConfiguration500JSONResponse added in v0.0.33

type GetTenantConfiguration500JSONResponse struct {
	Body    ErrorResponse
	Headers GetTenantConfiguration500ResponseHeaders
}

func (GetTenantConfiguration500JSONResponse) VisitGetTenantConfigurationResponse added in v0.0.33

func (response GetTenantConfiguration500JSONResponse) VisitGetTenantConfigurationResponse(w http.ResponseWriter) error

type GetTenantConfiguration500ResponseHeaders added in v0.0.33

type GetTenantConfiguration500ResponseHeaders struct {
	CacheControl string
}

type GetTenantConfiguration503JSONResponse added in v0.0.33

type GetTenantConfiguration503JSONResponse struct {
	Body    ErrorResponse
	Headers GetTenantConfiguration503ResponseHeaders
}

func (GetTenantConfiguration503JSONResponse) VisitGetTenantConfigurationResponse added in v0.0.33

func (response GetTenantConfiguration503JSONResponse) VisitGetTenantConfigurationResponse(w http.ResponseWriter) error

type GetTenantConfiguration503ResponseHeaders added in v0.0.33

type GetTenantConfiguration503ResponseHeaders struct {
	CacheControl string
}

type GetTenantConfigurationHTTPResponse added in v0.0.33

type GetTenantConfigurationHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ConfigurationSnapshot
	JSON400      *ErrorResponse
	JSON401      *ErrorResponse
	JSON403      *ErrorResponse
	JSON413      *ErrorResponse
	JSON500      *ErrorResponse
	JSON503      *ErrorResponse
}

func ParseGetTenantConfigurationHTTPResponse added in v0.0.33

func ParseGetTenantConfigurationHTTPResponse(rsp *http.Response) (*GetTenantConfigurationHTTPResponse, error)

ParseGetTenantConfigurationHTTPResponse parses an HTTP response from a GetTenantConfigurationWithResponse call

func (GetTenantConfigurationHTTPResponse) Status added in v0.0.33

Status returns HTTPResponse.Status

func (GetTenantConfigurationHTTPResponse) StatusCode added in v0.0.33

func (r GetTenantConfigurationHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetTenantConfigurationRequestObject added in v0.0.33

type GetTenantConfigurationRequestObject struct {
	TenantId TenantId `json:"tenantId"`
}

type GetTenantConfigurationResponseObject added in v0.0.33

type GetTenantConfigurationResponseObject interface {
	VisitGetTenantConfigurationResponse(w http.ResponseWriter) error
}

type HttpRequestDoer

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

Doer performs HTTP requests.

The standard http.Client implements this interface.

type InputReference

type InputReference struct {
	Hash    *string `json:"hash,omitempty"`
	Ordinal int64   `json:"ordinal"`
}

InputReference defines model for InputReference.

type InvalidParamFormatError

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

func (*InvalidParamFormatError) Error

func (e *InvalidParamFormatError) Error() string

func (*InvalidParamFormatError) Unwrap

func (e *InvalidParamFormatError) Unwrap() error

type JobAttemptOutcomeChapter

type JobAttemptOutcomeChapter struct {
	Kind    JobAttemptOutcomeChapterKind `json:"kind"`
	Outcome TaskOutcome                  `json:"outcome"`
}

JobAttemptOutcomeChapter defines model for JobAttemptOutcomeChapter.

type JobAttemptOutcomeChapterKind

type JobAttemptOutcomeChapterKind string

JobAttemptOutcomeChapterKind defines model for JobAttemptOutcomeChapter.Kind.

const (
	JobAttemptOutcome JobAttemptOutcomeChapterKind = "jobAttemptOutcome"
)

Defines values for JobAttemptOutcomeChapterKind.

type JobHandle

type JobHandle struct {
	JobKey JobKey `json:"jobKey"`
}

JobHandle defines model for JobHandle.

type JobId

type JobId = string

JobId defines model for JobId.

type JobInfo

type JobInfo struct {
	ClientPayload         json.RawMessage `json:"clientPayload,omitempty"`
	ClientPayloadRevision string          `json:"clientPayloadRevision"`

	// Data Terminal task data when materialized. A `null` value should be
	// treated as a lazily unavailable `TaskData`, for example when the job
	// has not completed yet.
	Data           *StoredTaskData `json:"data"`
	ExecutionState ExecutionState  `json:"executionState"`
	SchemaHash     *JobSchemaHash  `json:"schemaHash,omitempty"`
	Status         JobStatus       `json:"status"`
}

JobInfo defines model for JobInfo.

type JobKey

type JobKey struct {
	JobId    string `json:"jobId"`
	TenantId string `json:"tenantId"`
}

JobKey defines model for JobKey.

type JobPrerequisite

type JobPrerequisite struct {
	Condition JobPrerequisiteCondition `json:"condition"`
	JobId     string                   `json:"jobId"`
}

JobPrerequisite defines model for JobPrerequisite.

type JobPrerequisiteCondition

type JobPrerequisiteCondition string

JobPrerequisiteCondition defines model for JobPrerequisite.Condition.

const (
	JobPrerequisiteConditionComplete JobPrerequisiteCondition = "complete"
	JobPrerequisiteConditionSuccess  JobPrerequisiteCondition = "success"
)

Defines values for JobPrerequisiteCondition.

type JobSchemaDocument added in v0.0.9

type JobSchemaDocument = json.RawMessage

JobSchemaDocument JobDB schema envelope. Each shape is a JSON Schema draft 2020-12 schema fragment that validates a visible chapter record.

type JobSchemaHash added in v0.0.9

type JobSchemaHash = string

JobSchemaHash defines model for JobSchemaHash.

type JobSchemaInfo added in v0.0.9

type JobSchemaInfo struct {
	ArchivedAt *time.Time `json:"archivedAt,omitempty"`
	CreatedAt  time.Time  `json:"createdAt"`

	// Schema JobDB schema envelope. Each shape is a JSON Schema draft 2020-12 schema fragment that validates a visible chapter record.
	Schema     JobSchemaDocument `json:"schema"`
	SchemaHash JobSchemaHash     `json:"schemaHash"`
	State      JobSchemaState    `json:"state"`
	TenantId   string            `json:"tenantId"`
}

JobSchemaInfo defines model for JobSchemaInfo.

type JobSchemaListState added in v0.0.9

type JobSchemaListState string

JobSchemaListState defines model for JobSchemaListState.

const (
	JobSchemaListStateACTIVE   JobSchemaListState = "ACTIVE"
	JobSchemaListStateALL      JobSchemaListState = "ALL"
	JobSchemaListStateARCHIVED JobSchemaListState = "ARCHIVED"
)

Defines values for JobSchemaListState.

type JobSchemaSelector added in v0.0.9

type JobSchemaSelector struct {
	// Schema JobDB schema envelope. Each shape is a JSON Schema draft 2020-12 schema fragment that validates a visible chapter record.
	Schema     *JobSchemaDocument `json:"schema,omitempty"`
	SchemaHash *JobSchemaHash     `json:"schemaHash,omitempty"`
}

JobSchemaSelector defines model for JobSchemaSelector.

type JobSchemaState added in v0.0.9

type JobSchemaState string

JobSchemaState defines model for JobSchemaState.

const (
	JobSchemaStateACTIVE   JobSchemaState = "ACTIVE"
	JobSchemaStateARCHIVED JobSchemaState = "ARCHIVED"
)

Defines values for JobSchemaState.

type JobStartChapter

type JobStartChapter struct {
	// Input Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Input ApplicationPayload  `json:"input"`
	Kind  JobStartChapterKind `json:"kind"`
}

JobStartChapter defines model for JobStartChapter.

type JobStartChapterKind

type JobStartChapterKind string

JobStartChapterKind defines model for JobStartChapter.Kind.

const (
	JobStart JobStartChapterKind = "jobStart"
)

Defines values for JobStartChapterKind.

type JobStatus

type JobStatus string

JobStatus defines model for JobStatus.

const (
	JobStatusACTIVE         JobStatus = "ACTIVE"
	JobStatusAWAITINGFUTURE JobStatus = "AWAITING_FUTURE"
	JobStatusCANCELLED      JobStatus = "CANCELLED"
	JobStatusCOMPLETED      JobStatus = "COMPLETED"
	JobStatusCRASHCONCERN   JobStatus = "CRASH_CONCERN"
	JobStatusEXPIRED        JobStatus = "EXPIRED"
	JobStatusPENDINGJOBS    JobStatus = "PENDING_JOBS"
	JobStatusREADY          JobStatus = "READY"
)

Defines values for JobStatus.

type JobStore

type JobStore string

JobStore defines model for JobStore.

const (
	JobStoreACTIVE   JobStore = "ACTIVE"
	JobStoreARCHIVED JobStore = "ARCHIVED"
)

Defines values for JobStore.

type JobSummary

type JobSummary struct {
	ArchivedAt            *time.Time      `json:"archivedAt,omitempty"`
	AvailableAt           time.Time       `json:"availableAt"`
	CancelRequested       bool            `json:"cancelRequested"`
	ClientPayload         json.RawMessage `json:"clientPayload,omitempty"`
	ClientPayloadRevision string          `json:"clientPayloadRevision"`

	// CompletionDetail Persisted terminal completion detail. Empty is valid, including for success.
	CompletionDetail *string `json:"completionDetail,omitempty"`

	// CompletionStatus Persisted terminal outcome, independent of scheduler status. Absent or empty means unavailable. Unfamiliar values are preserved.
	CompletionStatus *string        `json:"completionStatus,omitempty"`
	CreatedAt        time.Time      `json:"createdAt"`
	ExecutionState   ExecutionState `json:"executionState"`
	ExpiresAt        *time.Time     `json:"expiresAt,omitempty"`
	JobKey           JobKey         `json:"jobKey"`
	JobType          string         `json:"jobType"`
	LeaseExpiresAt   *time.Time     `json:"leaseExpiresAt,omitempty"`
	Metadata         *Metadata      `json:"metadata,omitempty"`
	NextRoute        *Route         `json:"nextRoute,omitempty"`
	ParentJobId      *string        `json:"parentJobId,omitempty"`
	SchemaHash       *JobSchemaHash `json:"schemaHash,omitempty"`
	Status           JobStatus      `json:"status"`
	WaitFor          []string       `json:"waitFor"`
}

JobSummary defines model for JobSummary.

type JobTaskFilter

type JobTaskFilter struct {
	JobType  string `json:"jobType"`
	TaskType string `json:"taskType"`
}

JobTaskFilter defines model for JobTaskFilter.

type JsonSchemaFragment added in v0.0.10

type JsonSchemaFragment = json.RawMessage

JsonSchemaFragment JSON Schema draft 2020-12 object or boolean schema fragment.

type KeepAliveLease200JSONResponse

type KeepAliveLease200JSONResponse KeepAliveLeaseResponse

func (KeepAliveLease200JSONResponse) VisitKeepAliveLeaseResponse

func (response KeepAliveLease200JSONResponse) VisitKeepAliveLeaseResponse(w http.ResponseWriter) error

type KeepAliveLeaseHTTPResponse

type KeepAliveLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *KeepAliveLeaseResponse
}

func ParseKeepAliveLeaseHTTPResponse

func ParseKeepAliveLeaseHTTPResponse(rsp *http.Response) (*KeepAliveLeaseHTTPResponse, error)

ParseKeepAliveLeaseHTTPResponse parses an HTTP response from a KeepAliveLeaseWithResponse call

func (KeepAliveLeaseHTTPResponse) Status

Status returns HTTPResponse.Status

func (KeepAliveLeaseHTTPResponse) StatusCode

func (r KeepAliveLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type KeepAliveLeaseParams

type KeepAliveLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

KeepAliveLeaseParams defines parameters for KeepAliveLease.

type KeepAliveLeaseRequestObject

type KeepAliveLeaseRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	LeaseId  LeaseId  `json:"leaseId"`
	Params   KeepAliveLeaseParams
}

type KeepAliveLeaseResponse

type KeepAliveLeaseResponse struct {
	Lease      *ExecutionLease `json:"lease,omitempty"`
	LeaseToken string          `json:"leaseToken"`
}

KeepAliveLeaseResponse defines model for KeepAliveLeaseResponse.

type KeepAliveLeaseResponseObject

type KeepAliveLeaseResponseObject interface {
	VisitKeepAliveLeaseResponse(w http.ResponseWriter) error
}

type LeaseId

type LeaseId = string

LeaseId defines model for LeaseId.

type LeaseTokenHeader

type LeaseTokenHeader = string

LeaseTokenHeader defines model for LeaseTokenHeader.

type ListChapters200JSONResponse

type ListChapters200JSONResponse ListChaptersResponse

func (ListChapters200JSONResponse) VisitListChaptersResponse

func (response ListChapters200JSONResponse) VisitListChaptersResponse(w http.ResponseWriter) error

type ListChaptersHTTPResponse

type ListChaptersHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListChaptersResponse
}

func ParseListChaptersHTTPResponse

func ParseListChaptersHTTPResponse(rsp *http.Response) (*ListChaptersHTTPResponse, error)

ParseListChaptersHTTPResponse parses an HTTP response from a ListChaptersWithResponse call

func (ListChaptersHTTPResponse) Status

func (r ListChaptersHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (ListChaptersHTTPResponse) StatusCode

func (r ListChaptersHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListChaptersParams

type ListChaptersParams struct {
	StartOrdinal StartOrdinal `form:"startOrdinal" json:"startOrdinal"`
	EndOrdinal   *EndOrdinal  `form:"endOrdinal,omitempty" json:"endOrdinal,omitempty"`
}

ListChaptersParams defines parameters for ListChapters.

type ListChaptersRequestObject

type ListChaptersRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	Params   ListChaptersParams
}

type ListChaptersResponse

type ListChaptersResponse struct {
	Chapters []ChapterRecord `json:"chapters"`
}

ListChaptersResponse defines model for ListChaptersResponse.

type ListChaptersResponseObject

type ListChaptersResponseObject interface {
	VisitListChaptersResponse(w http.ResponseWriter) error
}

type ListJobSchemas200JSONResponse added in v0.0.9

type ListJobSchemas200JSONResponse ListJobSchemasResponse

func (ListJobSchemas200JSONResponse) VisitListJobSchemasResponse added in v0.0.9

func (response ListJobSchemas200JSONResponse) VisitListJobSchemasResponse(w http.ResponseWriter) error

type ListJobSchemasHTTPResponse added in v0.0.9

type ListJobSchemasHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListJobSchemasResponse
}

func ParseListJobSchemasHTTPResponse added in v0.0.9

func ParseListJobSchemasHTTPResponse(rsp *http.Response) (*ListJobSchemasHTTPResponse, error)

ParseListJobSchemasHTTPResponse parses an HTTP response from a ListJobSchemasWithResponse call

func (ListJobSchemasHTTPResponse) Status added in v0.0.9

Status returns HTTPResponse.Status

func (ListJobSchemasHTTPResponse) StatusCode added in v0.0.9

func (r ListJobSchemasHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListJobSchemasParams added in v0.0.9

type ListJobSchemasParams struct {
	State *JobSchemaListState `form:"state,omitempty" json:"state,omitempty"`
}

ListJobSchemasParams defines parameters for ListJobSchemas.

type ListJobSchemasRequestObject added in v0.0.9

type ListJobSchemasRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Params   ListJobSchemasParams
}

type ListJobSchemasResponse added in v0.0.9

type ListJobSchemasResponse struct {
	Schemas []JobSchemaInfo `json:"schemas"`
}

ListJobSchemasResponse defines model for ListJobSchemasResponse.

type ListJobSchemasResponseObject added in v0.0.9

type ListJobSchemasResponseObject interface {
	VisitListJobSchemasResponse(w http.ResponseWriter) error
}

type ListJobs200JSONResponse

type ListJobs200JSONResponse ListJobsResponse

func (ListJobs200JSONResponse) VisitListJobsResponse

func (response ListJobs200JSONResponse) VisitListJobsResponse(w http.ResponseWriter) error

type ListJobsHTTPResponse

type ListJobsHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListJobsResponse
}

func ParseListJobsHTTPResponse

func ParseListJobsHTTPResponse(rsp *http.Response) (*ListJobsHTTPResponse, error)

ParseListJobsHTTPResponse parses an HTTP response from a ListJobsWithResponse call

func (ListJobsHTTPResponse) Status

func (r ListJobsHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (ListJobsHTTPResponse) StatusCode

func (r ListJobsHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListJobsJSONRequestBody

type ListJobsJSONRequestBody = ListJobsRequest

ListJobsJSONRequestBody defines body for ListJobs for application/json ContentType.

type ListJobsRequest

type ListJobsRequest struct {
	CreatedAfter  *time.Time       `json:"createdAfter,omitempty"`
	CreatedBefore *time.Time       `json:"createdBefore,omitempty"`
	JobKeys       *[]JobKey        `json:"jobKeys,omitempty"`
	JobTasks      *[]JobTaskFilter `json:"jobTasks,omitempty"`
	JobTypes      *[]string        `json:"jobTypes,omitempty"`

	// MetadataPredicates Wire-format projection of `MetadataFilter`. Each predicate is a
	// top-level equality match; multiple `values` on one predicate mean OR
	// on the same field.
	MetadataPredicates *[]MetadataPredicate `json:"metadataPredicates,omitempty"`
	PageSize           *int                 `json:"pageSize,omitempty"`
	PageToken          *string              `json:"pageToken,omitempty"`

	// ParentJobIds Direct parent job IDs whose children should be returned.
	ParentJobIds *[]string `json:"parentJobIds,omitempty"`

	// RootOnly Return only jobs without a parent job ID.
	RootOnly *bool        `json:"rootOnly,omitempty"`
	Statuses *[]JobStatus `json:"statuses,omitempty"`
	Stores   *[]JobStore  `json:"stores,omitempty"`
}

ListJobsRequest defines model for ListJobsRequest.

type ListJobsRequestObject

type ListJobsRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Body     *ListJobsJSONRequestBody
}

type ListJobsResponse

type ListJobsResponse struct {
	Jobs          []JobSummary `json:"jobs"`
	NextPageToken *string      `json:"nextPageToken,omitempty"`
}

ListJobsResponse defines model for ListJobsResponse.

type ListJobsResponseObject

type ListJobsResponseObject interface {
	VisitListJobsResponse(w http.ResponseWriter) error
}

type ListScheduleRuns200JSONResponse

type ListScheduleRuns200JSONResponse ListScheduleRunsResponse

func (ListScheduleRuns200JSONResponse) VisitListScheduleRunsResponse

func (response ListScheduleRuns200JSONResponse) VisitListScheduleRunsResponse(w http.ResponseWriter) error

type ListScheduleRunsHTTPResponse

type ListScheduleRunsHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListScheduleRunsResponse
}

func ParseListScheduleRunsHTTPResponse

func ParseListScheduleRunsHTTPResponse(rsp *http.Response) (*ListScheduleRunsHTTPResponse, error)

ParseListScheduleRunsHTTPResponse parses an HTTP response from a ListScheduleRunsWithResponse call

func (ListScheduleRunsHTTPResponse) Status

Status returns HTTPResponse.Status

func (ListScheduleRunsHTTPResponse) StatusCode

func (r ListScheduleRunsHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListScheduleRunsJSONRequestBody

type ListScheduleRunsJSONRequestBody = ListScheduleRunsRequest

ListScheduleRunsJSONRequestBody defines body for ListScheduleRuns for application/json ContentType.

type ListScheduleRunsRequest

type ListScheduleRunsRequest struct {
	PageSize        *int         `json:"pageSize,omitempty"`
	PageToken       *string      `json:"pageToken,omitempty"`
	ScheduledAfter  *time.Time   `json:"scheduledAfter,omitempty"`
	ScheduledBefore *time.Time   `json:"scheduledBefore,omitempty"`
	Statuses        *[]JobStatus `json:"statuses,omitempty"`
}

ListScheduleRunsRequest defines model for ListScheduleRunsRequest.

type ListScheduleRunsRequestObject

type ListScheduleRunsRequestObject struct {
	TenantId   TenantId   `json:"tenantId"`
	ScheduleId ScheduleId `json:"scheduleId"`
	Body       *ListScheduleRunsJSONRequestBody
}

type ListScheduleRunsResponse

type ListScheduleRunsResponse struct {
	NextPageToken *string              `json:"nextPageToken,omitempty"`
	Runs          []ScheduleRunSummary `json:"runs"`
}

ListScheduleRunsResponse defines model for ListScheduleRunsResponse.

type ListScheduleRunsResponseObject

type ListScheduleRunsResponseObject interface {
	VisitListScheduleRunsResponse(w http.ResponseWriter) error
}

type ListSchedules200JSONResponse

type ListSchedules200JSONResponse ListSchedulesResponse

func (ListSchedules200JSONResponse) VisitListSchedulesResponse

func (response ListSchedules200JSONResponse) VisitListSchedulesResponse(w http.ResponseWriter) error

type ListSchedulesHTTPResponse

type ListSchedulesHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ListSchedulesResponse
}

func ParseListSchedulesHTTPResponse

func ParseListSchedulesHTTPResponse(rsp *http.Response) (*ListSchedulesHTTPResponse, error)

ParseListSchedulesHTTPResponse parses an HTTP response from a ListSchedulesWithResponse call

func (ListSchedulesHTTPResponse) Status

func (r ListSchedulesHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (ListSchedulesHTTPResponse) StatusCode

func (r ListSchedulesHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ListSchedulesJSONRequestBody

type ListSchedulesJSONRequestBody = ListSchedulesRequest

ListSchedulesJSONRequestBody defines body for ListSchedules for application/json ContentType.

type ListSchedulesRequest

type ListSchedulesRequest struct {
	PageSize       *int             `json:"pageSize,omitempty"`
	PageToken      *string          `json:"pageToken,omitempty"`
	ScheduleIds    *[]string        `json:"scheduleIds,omitempty"`
	States         *[]ScheduleState `json:"states,omitempty"`
	TargetJobTypes *[]string        `json:"targetJobTypes,omitempty"`
}

ListSchedulesRequest defines model for ListSchedulesRequest.

type ListSchedulesRequestObject

type ListSchedulesRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Body     *ListSchedulesJSONRequestBody
}

type ListSchedulesResponse

type ListSchedulesResponse struct {
	NextPageToken *string        `json:"nextPageToken,omitempty"`
	Schedules     []ScheduleInfo `json:"schedules"`
}

ListSchedulesResponse defines model for ListSchedulesResponse.

type ListSchedulesResponseObject

type ListSchedulesResponseObject interface {
	VisitListSchedulesResponse(w http.ResponseWriter) error
}

type Metadata

type Metadata struct {
	Fields map[string]MetadataValue `json:"fields"`
}

Metadata defines model for Metadata.

type MetadataBool

type MetadataBool struct {
	BoolValue bool             `json:"boolValue"`
	Kind      MetadataBoolKind `json:"kind"`
}

MetadataBool defines model for MetadataBool.

type MetadataBoolKind

type MetadataBoolKind string

MetadataBoolKind defines model for MetadataBool.Kind.

const (
	Bool MetadataBoolKind = "bool"
)

Defines values for MetadataBoolKind.

type MetadataDouble

type MetadataDouble struct {
	DoubleValue float64            `json:"doubleValue"`
	Kind        MetadataDoubleKind `json:"kind"`
}

MetadataDouble defines model for MetadataDouble.

type MetadataDoubleKind

type MetadataDoubleKind string

MetadataDoubleKind defines model for MetadataDouble.Kind.

const (
	Double MetadataDoubleKind = "double"
)

Defines values for MetadataDoubleKind.

type MetadataInt

type MetadataInt struct {
	IntValue int64           `json:"intValue"`
	Kind     MetadataIntKind `json:"kind"`
}

MetadataInt defines model for MetadataInt.

type MetadataIntKind

type MetadataIntKind string

MetadataIntKind defines model for MetadataInt.Kind.

const (
	Int MetadataIntKind = "int"
)

Defines values for MetadataIntKind.

type MetadataList

type MetadataList struct {
	Kind      MetadataListKind `json:"kind"`
	ListValue []MetadataValue  `json:"listValue"`
}

MetadataList defines model for MetadataList.

type MetadataListKind

type MetadataListKind string

MetadataListKind defines model for MetadataList.Kind.

const (
	List MetadataListKind = "list"
)

Defines values for MetadataListKind.

type MetadataMap

type MetadataMap struct {
	Kind     MetadataMapKind `json:"kind"`
	MapValue Metadata        `json:"mapValue"`
}

MetadataMap defines model for MetadataMap.

type MetadataMapKind

type MetadataMapKind string

MetadataMapKind defines model for MetadataMap.Kind.

const (
	Map MetadataMapKind = "map"
)

Defines values for MetadataMapKind.

type MetadataNull

type MetadataNull struct {
	Kind MetadataNullKind `json:"kind"`
}

MetadataNull defines model for MetadataNull.

type MetadataNullKind

type MetadataNullKind string

MetadataNullKind defines model for MetadataNull.Kind.

const (
	Null MetadataNullKind = "null"
)

Defines values for MetadataNullKind.

type MetadataPredicate

type MetadataPredicate struct {
	// Path Metadata field path segments.
	Path []string `json:"path"`

	// Values Equality match values for the field at `path`; multiple values mean OR on the same field.
	Values []MetadataValue `json:"values"`
}

MetadataPredicate defines model for MetadataPredicate.

type MetadataString

type MetadataString struct {
	Kind        MetadataStringKind `json:"kind"`
	StringValue string             `json:"stringValue"`
}

MetadataString defines model for MetadataString.

type MetadataStringKind

type MetadataStringKind string

MetadataStringKind defines model for MetadataString.Kind.

const (
	String MetadataStringKind = "string"
)

Defines values for MetadataStringKind.

type MetadataValue

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

MetadataValue defines model for MetadataValue.

func (MetadataValue) AsMetadataBool

func (t MetadataValue) AsMetadataBool() (MetadataBool, error)

AsMetadataBool returns the union data inside the MetadataValue as a MetadataBool

func (MetadataValue) AsMetadataDouble

func (t MetadataValue) AsMetadataDouble() (MetadataDouble, error)

AsMetadataDouble returns the union data inside the MetadataValue as a MetadataDouble

func (MetadataValue) AsMetadataInt

func (t MetadataValue) AsMetadataInt() (MetadataInt, error)

AsMetadataInt returns the union data inside the MetadataValue as a MetadataInt

func (MetadataValue) AsMetadataList

func (t MetadataValue) AsMetadataList() (MetadataList, error)

AsMetadataList returns the union data inside the MetadataValue as a MetadataList

func (MetadataValue) AsMetadataMap

func (t MetadataValue) AsMetadataMap() (MetadataMap, error)

AsMetadataMap returns the union data inside the MetadataValue as a MetadataMap

func (MetadataValue) AsMetadataNull

func (t MetadataValue) AsMetadataNull() (MetadataNull, error)

AsMetadataNull returns the union data inside the MetadataValue as a MetadataNull

func (MetadataValue) AsMetadataString

func (t MetadataValue) AsMetadataString() (MetadataString, error)

AsMetadataString returns the union data inside the MetadataValue as a MetadataString

func (MetadataValue) Discriminator

func (t MetadataValue) Discriminator() (string, error)

func (*MetadataValue) FromMetadataBool

func (t *MetadataValue) FromMetadataBool(v MetadataBool) error

FromMetadataBool overwrites any union data inside the MetadataValue as the provided MetadataBool

func (*MetadataValue) FromMetadataDouble

func (t *MetadataValue) FromMetadataDouble(v MetadataDouble) error

FromMetadataDouble overwrites any union data inside the MetadataValue as the provided MetadataDouble

func (*MetadataValue) FromMetadataInt

func (t *MetadataValue) FromMetadataInt(v MetadataInt) error

FromMetadataInt overwrites any union data inside the MetadataValue as the provided MetadataInt

func (*MetadataValue) FromMetadataList

func (t *MetadataValue) FromMetadataList(v MetadataList) error

FromMetadataList overwrites any union data inside the MetadataValue as the provided MetadataList

func (*MetadataValue) FromMetadataMap

func (t *MetadataValue) FromMetadataMap(v MetadataMap) error

FromMetadataMap overwrites any union data inside the MetadataValue as the provided MetadataMap

func (*MetadataValue) FromMetadataNull

func (t *MetadataValue) FromMetadataNull(v MetadataNull) error

FromMetadataNull overwrites any union data inside the MetadataValue as the provided MetadataNull

func (*MetadataValue) FromMetadataString

func (t *MetadataValue) FromMetadataString(v MetadataString) error

FromMetadataString overwrites any union data inside the MetadataValue as the provided MetadataString

func (MetadataValue) MarshalJSON

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

func (*MetadataValue) MergeMetadataBool

func (t *MetadataValue) MergeMetadataBool(v MetadataBool) error

MergeMetadataBool performs a merge with any union data inside the MetadataValue, using the provided MetadataBool

func (*MetadataValue) MergeMetadataDouble

func (t *MetadataValue) MergeMetadataDouble(v MetadataDouble) error

MergeMetadataDouble performs a merge with any union data inside the MetadataValue, using the provided MetadataDouble

func (*MetadataValue) MergeMetadataInt

func (t *MetadataValue) MergeMetadataInt(v MetadataInt) error

MergeMetadataInt performs a merge with any union data inside the MetadataValue, using the provided MetadataInt

func (*MetadataValue) MergeMetadataList

func (t *MetadataValue) MergeMetadataList(v MetadataList) error

MergeMetadataList performs a merge with any union data inside the MetadataValue, using the provided MetadataList

func (*MetadataValue) MergeMetadataMap

func (t *MetadataValue) MergeMetadataMap(v MetadataMap) error

MergeMetadataMap performs a merge with any union data inside the MetadataValue, using the provided MetadataMap

func (*MetadataValue) MergeMetadataNull

func (t *MetadataValue) MergeMetadataNull(v MetadataNull) error

MergeMetadataNull performs a merge with any union data inside the MetadataValue, using the provided MetadataNull

func (*MetadataValue) MergeMetadataString

func (t *MetadataValue) MergeMetadataString(v MetadataString) error

MergeMetadataString performs a merge with any union data inside the MetadataValue, using the provided MetadataString

func (*MetadataValue) UnmarshalJSON

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

func (MetadataValue) ValueByDiscriminator

func (t MetadataValue) ValueByDiscriminator() (interface{}, error)

type MiddlewareFunc

type MiddlewareFunc func(http.Handler) http.Handler

type OpenArtifact200ApplicationoctetStreamResponse

type OpenArtifact200ApplicationoctetStreamResponse struct {
	Body          io.Reader
	ContentLength int64
}

func (OpenArtifact200ApplicationoctetStreamResponse) VisitOpenArtifactResponse

func (response OpenArtifact200ApplicationoctetStreamResponse) VisitOpenArtifactResponse(w http.ResponseWriter) error

type OpenArtifactHTTPResponse

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

func ParseOpenArtifactHTTPResponse

func ParseOpenArtifactHTTPResponse(rsp *http.Response) (*OpenArtifactHTTPResponse, error)

ParseOpenArtifactHTTPResponse parses an HTTP response from a OpenArtifactWithResponse call

func (OpenArtifactHTTPResponse) Status

func (r OpenArtifactHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (OpenArtifactHTTPResponse) StatusCode

func (r OpenArtifactHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type OpenArtifactRequestObject

type OpenArtifactRequestObject struct {
	TenantId TenantId     `json:"tenantId"`
	JobId    JobId        `json:"jobId"`
	Ordinal  Ordinal      `json:"ordinal"`
	Name     ArtifactName `json:"name"`
}

type OpenArtifactResponseObject

type OpenArtifactResponseObject interface {
	VisitOpenArtifactResponse(w http.ResponseWriter) error
}

type Ordinal

type Ordinal = int64

Ordinal defines model for Ordinal.

type ParentJobId added in v0.0.13

type ParentJobId = string

ParentJobId defines model for ParentJobId.

type PauseSchedule200JSONResponse

type PauseSchedule200JSONResponse ScheduleInfo

func (PauseSchedule200JSONResponse) VisitPauseScheduleResponse

func (response PauseSchedule200JSONResponse) VisitPauseScheduleResponse(w http.ResponseWriter) error

type PauseScheduleHTTPResponse

type PauseScheduleHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ScheduleInfo
}

func ParsePauseScheduleHTTPResponse

func ParsePauseScheduleHTTPResponse(rsp *http.Response) (*PauseScheduleHTTPResponse, error)

ParsePauseScheduleHTTPResponse parses an HTTP response from a PauseScheduleWithResponse call

func (PauseScheduleHTTPResponse) Status

func (r PauseScheduleHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (PauseScheduleHTTPResponse) StatusCode

func (r PauseScheduleHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PauseScheduleJSONRequestBody

type PauseScheduleJSONRequestBody = ScheduleMutationRequest

PauseScheduleJSONRequestBody defines body for PauseSchedule for application/json ContentType.

type PauseScheduleRequestObject

type PauseScheduleRequestObject struct {
	TenantId   TenantId   `json:"tenantId"`
	ScheduleId ScheduleId `json:"scheduleId"`
	Body       *PauseScheduleJSONRequestBody
}

type PauseScheduleResponseObject

type PauseScheduleResponseObject interface {
	VisitPauseScheduleResponse(w http.ResponseWriter) error
}

type PollWork200JSONResponse

type PollWork200JSONResponse struct {
	Leases []ExecutionLease `json:"leases"`
}

func (PollWork200JSONResponse) VisitPollWorkResponse

func (response PollWork200JSONResponse) VisitPollWorkResponse(w http.ResponseWriter) error

type PollWorkHTTPResponse

type PollWorkHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *struct {
		Leases []ExecutionLease `json:"leases"`
	}
}

func ParsePollWorkHTTPResponse

func ParsePollWorkHTTPResponse(rsp *http.Response) (*PollWorkHTTPResponse, error)

ParsePollWorkHTTPResponse parses an HTTP response from a PollWorkWithResponse call

func (PollWorkHTTPResponse) Status

func (r PollWorkHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (PollWorkHTTPResponse) StatusCode

func (r PollWorkHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PollWorkJSONRequestBody

type PollWorkJSONRequestBody = PollWorkRequest

PollWorkJSONRequestBody defines body for PollWork for application/json ContentType.

type PollWorkRequest

type PollWorkRequest struct {
	// LeaseDuration Duration string controlling how long acquired leases should be held.
	LeaseDuration *string    `json:"leaseDuration,omitempty"`
	Limit         int        `json:"limit"`
	LongPollUntil *time.Time `json:"longPollUntil,omitempty"`

	// MetadataEquals Metadata equality predicates applied during polling. Multiple
	// predicates mean AND across fields; multiple `values` on one
	// predicate mean OR on the same field.
	MetadataEquals *[]MetadataPredicate `json:"metadataEquals,omitempty"`
	Routes         []Route              `json:"routes"`

	// TenantId Required tenant polling target. Polling is scoped only to this tenant.
	TenantId string `json:"tenantId"`
	WorkerId string `json:"workerId"`
}

PollWorkRequest defines model for PollWorkRequest.

type PollWorkRequestObject

type PollWorkRequestObject struct {
	Body *PollWorkJSONRequestBody
}

type PollWorkResponseObject

type PollWorkResponseObject interface {
	VisitPollWorkResponse(w http.ResponseWriter) error
}

type PutJob200JSONResponse

type PutJob200JSONResponse JobHandle

func (PutJob200JSONResponse) VisitPutJobResponse

func (response PutJob200JSONResponse) VisitPutJobResponse(w http.ResponseWriter) error

type PutJob409JSONResponse

type PutJob409JSONResponse ErrorResponse

func (PutJob409JSONResponse) VisitPutJobResponse

func (response PutJob409JSONResponse) VisitPutJobResponse(w http.ResponseWriter) error

type PutJobHTTPResponse

type PutJobHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
	JSON409      *ErrorResponse
}

func ParsePutJobHTTPResponse

func ParsePutJobHTTPResponse(rsp *http.Response) (*PutJobHTTPResponse, error)

ParsePutJobHTTPResponse parses an HTTP response from a PutJobWithResponse call

func (PutJobHTTPResponse) Status

func (r PutJobHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (PutJobHTTPResponse) StatusCode

func (r PutJobHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutJobJSONRequestBody

type PutJobJSONRequestBody = SubmitJobRequest

PutJobJSONRequestBody defines body for PutJob for application/json ContentType.

type PutJobRequestObject

type PutJobRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	Body     *PutJobJSONRequestBody
}

type PutJobResponseObject

type PutJobResponseObject interface {
	VisitPutJobResponse(w http.ResponseWriter) error
}

type PutJobWithLease200JSONResponse added in v0.0.13

type PutJobWithLease200JSONResponse JobHandle

func (PutJobWithLease200JSONResponse) VisitPutJobWithLeaseResponse added in v0.0.13

func (response PutJobWithLease200JSONResponse) VisitPutJobWithLeaseResponse(w http.ResponseWriter) error

type PutJobWithLease409JSONResponse added in v0.0.13

type PutJobWithLease409JSONResponse ErrorResponse

func (PutJobWithLease409JSONResponse) VisitPutJobWithLeaseResponse added in v0.0.13

func (response PutJobWithLease409JSONResponse) VisitPutJobWithLeaseResponse(w http.ResponseWriter) error

type PutJobWithLeaseHTTPResponse added in v0.0.13

type PutJobWithLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
	JSON409      *ErrorResponse
}

func ParsePutJobWithLeaseHTTPResponse added in v0.0.13

func ParsePutJobWithLeaseHTTPResponse(rsp *http.Response) (*PutJobWithLeaseHTTPResponse, error)

ParsePutJobWithLeaseHTTPResponse parses an HTTP response from a PutJobWithLeaseWithResponse call

func (PutJobWithLeaseHTTPResponse) Status added in v0.0.13

Status returns HTTPResponse.Status

func (PutJobWithLeaseHTTPResponse) StatusCode added in v0.0.13

func (r PutJobWithLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutJobWithLeaseJSONRequestBody added in v0.0.13

type PutJobWithLeaseJSONRequestBody = SubmitJobRequest

PutJobWithLeaseJSONRequestBody defines body for PutJobWithLease for application/json ContentType.

type PutJobWithLeaseParams added in v0.0.13

type PutJobWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

PutJobWithLeaseParams defines parameters for PutJobWithLease.

type PutJobWithLeaseRequestObject added in v0.0.13

type PutJobWithLeaseRequestObject struct {
	TenantId    TenantId    `json:"tenantId"`
	ParentJobId ParentJobId `json:"parentJobId"`
	LeaseId     LeaseId     `json:"leaseId"`
	ChildJobId  ChildJobId  `json:"childJobId"`
	Params      PutJobWithLeaseParams
	Body        *PutJobWithLeaseJSONRequestBody
}

type PutJobWithLeaseResponseObject added in v0.0.13

type PutJobWithLeaseResponseObject interface {
	VisitPutJobWithLeaseResponse(w http.ResponseWriter) error
}

type PutRestartJob200JSONResponse

type PutRestartJob200JSONResponse JobHandle

func (PutRestartJob200JSONResponse) VisitPutRestartJobResponse

func (response PutRestartJob200JSONResponse) VisitPutRestartJobResponse(w http.ResponseWriter) error

type PutRestartJob409JSONResponse

type PutRestartJob409JSONResponse ErrorResponse

func (PutRestartJob409JSONResponse) VisitPutRestartJobResponse

func (response PutRestartJob409JSONResponse) VisitPutRestartJobResponse(w http.ResponseWriter) error

type PutRestartJobHTTPResponse

type PutRestartJobHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
	JSON409      *ErrorResponse
}

func ParsePutRestartJobHTTPResponse

func ParsePutRestartJobHTTPResponse(rsp *http.Response) (*PutRestartJobHTTPResponse, error)

ParsePutRestartJobHTTPResponse parses an HTTP response from a PutRestartJobWithResponse call

func (PutRestartJobHTTPResponse) Status

func (r PutRestartJobHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (PutRestartJobHTTPResponse) StatusCode

func (r PutRestartJobHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutRestartJobJSONRequestBody

type PutRestartJobJSONRequestBody = SubmitRestartJobRequest

PutRestartJobJSONRequestBody defines body for PutRestartJob for application/json ContentType.

type PutRestartJobRequestObject

type PutRestartJobRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	Body     *PutRestartJobJSONRequestBody
}

type PutRestartJobResponseObject

type PutRestartJobResponseObject interface {
	VisitPutRestartJobResponse(w http.ResponseWriter) error
}

type PutRestartJobWithLease200JSONResponse added in v0.0.13

type PutRestartJobWithLease200JSONResponse JobHandle

func (PutRestartJobWithLease200JSONResponse) VisitPutRestartJobWithLeaseResponse added in v0.0.13

func (response PutRestartJobWithLease200JSONResponse) VisitPutRestartJobWithLeaseResponse(w http.ResponseWriter) error

type PutRestartJobWithLease409JSONResponse added in v0.0.13

type PutRestartJobWithLease409JSONResponse ErrorResponse

func (PutRestartJobWithLease409JSONResponse) VisitPutRestartJobWithLeaseResponse added in v0.0.13

func (response PutRestartJobWithLease409JSONResponse) VisitPutRestartJobWithLeaseResponse(w http.ResponseWriter) error

type PutRestartJobWithLeaseHTTPResponse added in v0.0.13

type PutRestartJobWithLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
	JSON409      *ErrorResponse
}

func ParsePutRestartJobWithLeaseHTTPResponse added in v0.0.13

func ParsePutRestartJobWithLeaseHTTPResponse(rsp *http.Response) (*PutRestartJobWithLeaseHTTPResponse, error)

ParsePutRestartJobWithLeaseHTTPResponse parses an HTTP response from a PutRestartJobWithLeaseWithResponse call

func (PutRestartJobWithLeaseHTTPResponse) Status added in v0.0.13

Status returns HTTPResponse.Status

func (PutRestartJobWithLeaseHTTPResponse) StatusCode added in v0.0.13

func (r PutRestartJobWithLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PutRestartJobWithLeaseJSONRequestBody added in v0.0.13

type PutRestartJobWithLeaseJSONRequestBody = SubmitRestartJobRequest

PutRestartJobWithLeaseJSONRequestBody defines body for PutRestartJobWithLease for application/json ContentType.

type PutRestartJobWithLeaseParams added in v0.0.13

type PutRestartJobWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

PutRestartJobWithLeaseParams defines parameters for PutRestartJobWithLease.

type PutRestartJobWithLeaseRequestObject added in v0.0.13

type PutRestartJobWithLeaseRequestObject struct {
	TenantId    TenantId    `json:"tenantId"`
	ParentJobId ParentJobId `json:"parentJobId"`
	LeaseId     LeaseId     `json:"leaseId"`
	ChildJobId  ChildJobId  `json:"childJobId"`
	Params      PutRestartJobWithLeaseParams
	Body        *PutRestartJobWithLeaseJSONRequestBody
}

type PutRestartJobWithLeaseResponseObject added in v0.0.13

type PutRestartJobWithLeaseResponseObject interface {
	VisitPutRestartJobWithLeaseResponse(w http.ResponseWriter) error
}

type RegisterJobSchema200JSONResponse added in v0.0.9

type RegisterJobSchema200JSONResponse JobSchemaInfo

func (RegisterJobSchema200JSONResponse) VisitRegisterJobSchemaResponse added in v0.0.9

func (response RegisterJobSchema200JSONResponse) VisitRegisterJobSchemaResponse(w http.ResponseWriter) error

type RegisterJobSchema409JSONResponse added in v0.0.9

type RegisterJobSchema409JSONResponse ErrorResponse

func (RegisterJobSchema409JSONResponse) VisitRegisterJobSchemaResponse added in v0.0.9

func (response RegisterJobSchema409JSONResponse) VisitRegisterJobSchemaResponse(w http.ResponseWriter) error

type RegisterJobSchemaHTTPResponse added in v0.0.9

type RegisterJobSchemaHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobSchemaInfo
	JSON409      *ErrorResponse
}

func ParseRegisterJobSchemaHTTPResponse added in v0.0.9

func ParseRegisterJobSchemaHTTPResponse(rsp *http.Response) (*RegisterJobSchemaHTTPResponse, error)

ParseRegisterJobSchemaHTTPResponse parses an HTTP response from a RegisterJobSchemaWithResponse call

func (RegisterJobSchemaHTTPResponse) Status added in v0.0.9

Status returns HTTPResponse.Status

func (RegisterJobSchemaHTTPResponse) StatusCode added in v0.0.9

func (r RegisterJobSchemaHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RegisterJobSchemaJSONRequestBody added in v0.0.9

type RegisterJobSchemaJSONRequestBody = RegisterJobSchemaRequest

RegisterJobSchemaJSONRequestBody defines body for RegisterJobSchema for application/json ContentType.

type RegisterJobSchemaRequest added in v0.0.9

type RegisterJobSchemaRequest struct {
	// Schema JobDB schema envelope. Each shape is a JSON Schema draft 2020-12 schema fragment that validates a visible chapter record.
	Schema JobSchemaDocument `json:"schema"`
}

RegisterJobSchemaRequest defines model for RegisterJobSchemaRequest.

type RegisterJobSchemaRequestObject added in v0.0.9

type RegisterJobSchemaRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Body     *RegisterJobSchemaJSONRequestBody
}

type RegisterJobSchemaResponseObject added in v0.0.9

type RegisterJobSchemaResponseObject interface {
	VisitRegisterJobSchemaResponse(w http.ResponseWriter) error
}

type RemoveConfigurationBody added in v0.0.33

type RemoveConfigurationBody struct {
	Name string `json:"name"`
}

RemoveConfigurationBody defines model for RemoveConfigurationBody.

type RemoveTenantConfigurationValue204Response added in v0.0.33

type RemoveTenantConfigurationValue204Response struct {
	Headers RemoveTenantConfigurationValue204ResponseHeaders
}

func (RemoveTenantConfigurationValue204Response) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue204Response) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue204ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue204ResponseHeaders struct {
	CacheControl string
	ETag         string
}

type RemoveTenantConfigurationValue400JSONResponse added in v0.0.33

type RemoveTenantConfigurationValue400JSONResponse struct {
	Body    ErrorResponse
	Headers RemoveTenantConfigurationValue400ResponseHeaders
}

func (RemoveTenantConfigurationValue400JSONResponse) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue400JSONResponse) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue400ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue400ResponseHeaders struct {
	CacheControl string
}

type RemoveTenantConfigurationValue401JSONResponse added in v0.0.33

type RemoveTenantConfigurationValue401JSONResponse struct {
	Body    ErrorResponse
	Headers RemoveTenantConfigurationValue401ResponseHeaders
}

func (RemoveTenantConfigurationValue401JSONResponse) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue401JSONResponse) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue401ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue401ResponseHeaders struct {
	CacheControl string
}

type RemoveTenantConfigurationValue403JSONResponse added in v0.0.33

type RemoveTenantConfigurationValue403JSONResponse struct {
	Body    ErrorResponse
	Headers RemoveTenantConfigurationValue403ResponseHeaders
}

func (RemoveTenantConfigurationValue403JSONResponse) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue403JSONResponse) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue403ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue403ResponseHeaders struct {
	CacheControl string
}

type RemoveTenantConfigurationValue412JSONResponse added in v0.0.33

type RemoveTenantConfigurationValue412JSONResponse struct {
	Body    ErrorResponse
	Headers RemoveTenantConfigurationValue412ResponseHeaders
}

func (RemoveTenantConfigurationValue412JSONResponse) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue412JSONResponse) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue412ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue412ResponseHeaders struct {
	CacheControl string
}

type RemoveTenantConfigurationValue413JSONResponse added in v0.0.33

type RemoveTenantConfigurationValue413JSONResponse struct {
	Body    ErrorResponse
	Headers RemoveTenantConfigurationValue413ResponseHeaders
}

func (RemoveTenantConfigurationValue413JSONResponse) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue413JSONResponse) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue413ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue413ResponseHeaders struct {
	CacheControl string
}

type RemoveTenantConfigurationValue500JSONResponse added in v0.0.33

type RemoveTenantConfigurationValue500JSONResponse struct {
	Body    ErrorResponse
	Headers RemoveTenantConfigurationValue500ResponseHeaders
}

func (RemoveTenantConfigurationValue500JSONResponse) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue500JSONResponse) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue500ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue500ResponseHeaders struct {
	CacheControl string
}

type RemoveTenantConfigurationValue503JSONResponse added in v0.0.33

type RemoveTenantConfigurationValue503JSONResponse struct {
	Body    ErrorResponse
	Headers RemoveTenantConfigurationValue503ResponseHeaders
}

func (RemoveTenantConfigurationValue503JSONResponse) VisitRemoveTenantConfigurationValueResponse added in v0.0.33

func (response RemoveTenantConfigurationValue503JSONResponse) VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error

type RemoveTenantConfigurationValue503ResponseHeaders added in v0.0.33

type RemoveTenantConfigurationValue503ResponseHeaders struct {
	CacheControl string
}

type RemoveTenantConfigurationValueHTTPResponse added in v0.0.33

type RemoveTenantConfigurationValueHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorResponse
	JSON401      *ErrorResponse
	JSON403      *ErrorResponse
	JSON412      *ErrorResponse
	JSON413      *ErrorResponse
	JSON500      *ErrorResponse
	JSON503      *ErrorResponse
}

func ParseRemoveTenantConfigurationValueHTTPResponse added in v0.0.33

func ParseRemoveTenantConfigurationValueHTTPResponse(rsp *http.Response) (*RemoveTenantConfigurationValueHTTPResponse, error)

ParseRemoveTenantConfigurationValueHTTPResponse parses an HTTP response from a RemoveTenantConfigurationValueWithResponse call

func (RemoveTenantConfigurationValueHTTPResponse) Status added in v0.0.33

Status returns HTTPResponse.Status

func (RemoveTenantConfigurationValueHTTPResponse) StatusCode added in v0.0.33

StatusCode returns HTTPResponse.StatusCode

type RemoveTenantConfigurationValueJSONRequestBody added in v0.0.33

type RemoveTenantConfigurationValueJSONRequestBody = RemoveConfigurationBody

RemoveTenantConfigurationValueJSONRequestBody defines body for RemoveTenantConfigurationValue for application/json ContentType.

type RemoveTenantConfigurationValueParams added in v0.0.33

type RemoveTenantConfigurationValueParams struct {
	// IfMatch One quoted revision ETag; weak tags, lists and wildcard are invalid.
	IfMatch *string `json:"If-Match,omitempty"`
}

RemoveTenantConfigurationValueParams defines parameters for RemoveTenantConfigurationValue.

type RemoveTenantConfigurationValueRequestObject added in v0.0.33

type RemoveTenantConfigurationValueRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Params   RemoveTenantConfigurationValueParams
	Body     *RemoveTenantConfigurationValueJSONRequestBody
}

type RemoveTenantConfigurationValueResponseObject added in v0.0.33

type RemoveTenantConfigurationValueResponseObject interface {
	VisitRemoveTenantConfigurationValueResponse(w http.ResponseWriter) error
}

type RequestEditorFn

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

RequestEditorFn is the function signature for the RequestEditor callback function

type RequiredHeaderError

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

func (*RequiredHeaderError) Error

func (e *RequiredHeaderError) Error() string

func (*RequiredHeaderError) Unwrap

func (e *RequiredHeaderError) Unwrap() error

type RequiredParamError

type RequiredParamError struct {
	ParamName string
}

func (*RequiredParamError) Error

func (e *RequiredParamError) Error() string

type RescheduleExecutionRequest

type RescheduleExecutionRequest struct {
	// AlternateAfter Duration string.
	AlternateAfter      *string              `json:"alternateAfter,omitempty"`
	AlternateRoute      *Route               `json:"alternateRoute,omitempty"`
	ClientPayloadUpdate *ClientPayloadUpdate `json:"clientPayloadUpdate,omitempty"`
	NextRoute           Route                `json:"nextRoute"`
	TaskWait            *TaskWait            `json:"taskWait,omitempty"`
	WaitForJobIds       *[]string            `json:"waitForJobIds,omitempty"`

	// WaitUntil Without waitForJobIds, delays eligibility until this time. With waitForJobIds, resumes when all listed jobs terminate or this deadline arrives.
	WaitUntil *time.Time `json:"waitUntil,omitempty"`
}

RescheduleExecutionRequest defines model for RescheduleExecutionRequest.

type RescheduleJobWithLease204Response

type RescheduleJobWithLease204Response struct {
}

func (RescheduleJobWithLease204Response) VisitRescheduleJobWithLeaseResponse

func (response RescheduleJobWithLease204Response) VisitRescheduleJobWithLeaseResponse(w http.ResponseWriter) error

type RescheduleJobWithLeaseHTTPResponse

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

func ParseRescheduleJobWithLeaseHTTPResponse

func ParseRescheduleJobWithLeaseHTTPResponse(rsp *http.Response) (*RescheduleJobWithLeaseHTTPResponse, error)

ParseRescheduleJobWithLeaseHTTPResponse parses an HTTP response from a RescheduleJobWithLeaseWithResponse call

func (RescheduleJobWithLeaseHTTPResponse) Status

Status returns HTTPResponse.Status

func (RescheduleJobWithLeaseHTTPResponse) StatusCode

func (r RescheduleJobWithLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RescheduleJobWithLeaseJSONRequestBody

type RescheduleJobWithLeaseJSONRequestBody = RescheduleExecutionRequest

RescheduleJobWithLeaseJSONRequestBody defines body for RescheduleJobWithLease for application/json ContentType.

type RescheduleJobWithLeaseParams

type RescheduleJobWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

RescheduleJobWithLeaseParams defines parameters for RescheduleJobWithLease.

type RescheduleJobWithLeaseRequestObject

type RescheduleJobWithLeaseRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	LeaseId  LeaseId  `json:"leaseId"`
	Params   RescheduleJobWithLeaseParams
	Body     *RescheduleJobWithLeaseJSONRequestBody
}

type RescheduleJobWithLeaseResponseObject

type RescheduleJobWithLeaseResponseObject interface {
	VisitRescheduleJobWithLeaseResponse(w http.ResponseWriter) error
}

type ResolveSecretsBody added in v0.0.29

type ResolveSecretsBody struct {
	Names []string `json:"names"`
}

ResolveSecretsBody defines model for ResolveSecretsBody.

type ResolveSecretsWithLease200JSONResponse added in v0.0.29

type ResolveSecretsWithLease200JSONResponse struct {
	Body    SecretResolveResult
	Headers ResolveSecretsWithLease200ResponseHeaders
}

func (ResolveSecretsWithLease200JSONResponse) VisitResolveSecretsWithLeaseResponse added in v0.0.29

func (response ResolveSecretsWithLease200JSONResponse) VisitResolveSecretsWithLeaseResponse(w http.ResponseWriter) error

type ResolveSecretsWithLease200ResponseHeaders added in v0.0.29

type ResolveSecretsWithLease200ResponseHeaders struct {
	CacheControl string
}

type ResolveSecretsWithLeaseHTTPResponse added in v0.0.29

type ResolveSecretsWithLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *SecretResolveResult
	JSONDefault  *SecretError
}

func ParseResolveSecretsWithLeaseHTTPResponse added in v0.0.29

func ParseResolveSecretsWithLeaseHTTPResponse(rsp *http.Response) (*ResolveSecretsWithLeaseHTTPResponse, error)

ParseResolveSecretsWithLeaseHTTPResponse parses an HTTP response from a ResolveSecretsWithLeaseWithResponse call

func (ResolveSecretsWithLeaseHTTPResponse) Status added in v0.0.29

Status returns HTTPResponse.Status

func (ResolveSecretsWithLeaseHTTPResponse) StatusCode added in v0.0.29

StatusCode returns HTTPResponse.StatusCode

type ResolveSecretsWithLeaseJSONRequestBody added in v0.0.29

type ResolveSecretsWithLeaseJSONRequestBody = ResolveSecretsBody

ResolveSecretsWithLeaseJSONRequestBody defines body for ResolveSecretsWithLease for application/json ContentType.

type ResolveSecretsWithLeaseParams added in v0.0.29

type ResolveSecretsWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

ResolveSecretsWithLeaseParams defines parameters for ResolveSecretsWithLease.

type ResolveSecretsWithLeaseRequestObject added in v0.0.29

type ResolveSecretsWithLeaseRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	JobId    JobId    `json:"jobId"`
	LeaseId  LeaseId  `json:"leaseId"`
	Params   ResolveSecretsWithLeaseParams
	Body     *ResolveSecretsWithLeaseJSONRequestBody
}

type ResolveSecretsWithLeaseResponseObject added in v0.0.29

type ResolveSecretsWithLeaseResponseObject interface {
	VisitResolveSecretsWithLeaseResponse(w http.ResponseWriter) error
}

type ResolveSecretsWithLeasedefaultJSONResponse added in v0.0.29

type ResolveSecretsWithLeasedefaultJSONResponse struct {
	Body       SecretError
	Headers    ResolveSecretsWithLeasedefaultResponseHeaders
	StatusCode int
}

func (ResolveSecretsWithLeasedefaultJSONResponse) VisitResolveSecretsWithLeaseResponse added in v0.0.29

func (response ResolveSecretsWithLeasedefaultJSONResponse) VisitResolveSecretsWithLeaseResponse(w http.ResponseWriter) error

type ResolveSecretsWithLeasedefaultResponseHeaders added in v0.0.29

type ResolveSecretsWithLeasedefaultResponseHeaders struct {
	CacheControl string
}

type RestartExtraChapter

type RestartExtraChapter struct {
	Kind RestartExtraChapterKind `json:"kind"`

	// Output Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Output ApplicationPayload `json:"output"`
}

RestartExtraChapter defines model for RestartExtraChapter.

type RestartExtraChapterKind

type RestartExtraChapterKind string

RestartExtraChapterKind defines model for RestartExtraChapter.Kind.

const (
	RestartExtra RestartExtraChapterKind = "restartExtra"
)

Defines values for RestartExtraChapterKind.

type ResumeSchedule200JSONResponse

type ResumeSchedule200JSONResponse ScheduleInfo

func (ResumeSchedule200JSONResponse) VisitResumeScheduleResponse

func (response ResumeSchedule200JSONResponse) VisitResumeScheduleResponse(w http.ResponseWriter) error

type ResumeScheduleHTTPResponse

type ResumeScheduleHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ScheduleInfo
}

func ParseResumeScheduleHTTPResponse

func ParseResumeScheduleHTTPResponse(rsp *http.Response) (*ResumeScheduleHTTPResponse, error)

ParseResumeScheduleHTTPResponse parses an HTTP response from a ResumeScheduleWithResponse call

func (ResumeScheduleHTTPResponse) Status

Status returns HTTPResponse.Status

func (ResumeScheduleHTTPResponse) StatusCode

func (r ResumeScheduleHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type ResumeScheduleJSONRequestBody

type ResumeScheduleJSONRequestBody = ScheduleMutationRequest

ResumeScheduleJSONRequestBody defines body for ResumeSchedule for application/json ContentType.

type ResumeScheduleRequestObject

type ResumeScheduleRequestObject struct {
	TenantId   TenantId   `json:"tenantId"`
	ScheduleId ScheduleId `json:"scheduleId"`
	Body       *ResumeScheduleJSONRequestBody
}

type ResumeScheduleResponseObject

type ResumeScheduleResponseObject interface {
	VisitResumeScheduleResponse(w http.ResponseWriter) error
}

type RetryPolicy

type RetryPolicy struct {
	BackoffCoefficient     *float64  `json:"backoffCoefficient,omitempty"`
	InitialInterval        *string   `json:"initialInterval,omitempty"`
	MaximumAttempts        *int32    `json:"maximumAttempts,omitempty"`
	MaximumInterval        *string   `json:"maximumInterval,omitempty"`
	NonRetryableErrorTypes *[]string `json:"nonRetryableErrorTypes,omitempty"`
}

RetryPolicy defines model for RetryPolicy.

type Route added in v0.0.19

type Route struct {
	// JobType Opaque job identifier; punctuation has no routing meaning.
	JobType string `json:"jobType"`

	// TaskType Opaque task identifier; omitted or empty selects job work.
	TaskType string `json:"taskType,omitempty"`
}

Route defines model for Route.

type RunPolicy

type RunPolicy struct {
	InvocationTimeout *string      `json:"invocationTimeout,omitempty"`
	Retry             *RetryPolicy `json:"retry,omitempty"`
	TotalTimeout      *string      `json:"totalTimeout,omitempty"`
}

RunPolicy defines model for RunPolicy.

type ScheduleFailurePolicy

type ScheduleFailurePolicy struct {
	MaxSequentialFailures *int32 `json:"maxSequentialFailures,omitempty"`
	MinSuccessPercent     *int32 `json:"minSuccessPercent,omitempty"`
	WindowSize            *int32 `json:"windowSize,omitempty"`
}

ScheduleFailurePolicy defines model for ScheduleFailurePolicy.

type ScheduleId

type ScheduleId = string

ScheduleId defines model for ScheduleId.

type ScheduleInfo

type ScheduleInfo struct {
	CreatedAt      time.Time             `json:"createdAt"`
	EffectiveState ScheduleState         `json:"effectiveState"`
	FailurePolicy  ScheduleFailurePolicy `json:"failurePolicy"`
	Generation     int64                 `json:"generation"`
	NextFireAt     *time.Time            `json:"nextFireAt,omitempty"`
	NextJobKey     *JobKey               `json:"nextJobKey,omitempty"`
	OverlapPolicy  ScheduleOverlapPolicy `json:"overlapPolicy"`
	ScheduleId     string                `json:"scheduleId"`
	ScheduleKey    ScheduleKey           `json:"scheduleKey"`
	SpecHash       string                `json:"specHash"`
	State          ScheduleState         `json:"state"`
	Target         ScheduleTarget        `json:"target"`
	TenantId       string                `json:"tenantId"`
	Trigger        ScheduleTrigger       `json:"trigger"`
	UpdatedAt      time.Time             `json:"updatedAt"`
}

ScheduleInfo defines model for ScheduleInfo.

type ScheduleKey

type ScheduleKey struct {
	ScheduleId string `json:"scheduleId"`
	TenantId   string `json:"tenantId"`
}

ScheduleKey defines model for ScheduleKey.

type ScheduleMutationRequest

type ScheduleMutationRequest struct {
	ExpectedGeneration *int64     `json:"expectedGeneration,omitempty"`
	RequestTime        *time.Time `json:"requestTime,omitempty"`
	WorkerId           *string    `json:"workerId,omitempty"`
}

ScheduleMutationRequest defines model for ScheduleMutationRequest.

type ScheduleOverlapPolicy

type ScheduleOverlapPolicy string

ScheduleOverlapPolicy defines model for ScheduleOverlapPolicy.

const (
	Serial ScheduleOverlapPolicy = "serial"
)

Defines values for ScheduleOverlapPolicy.

type ScheduleRunSummary

type ScheduleRunSummary struct {
	Job         JobSummary `json:"job"`
	ReasonCode  *string    `json:"reasonCode,omitempty"`
	ScheduleId  string     `json:"scheduleId"`
	ScheduledAt time.Time  `json:"scheduledAt"`
}

ScheduleRunSummary defines model for ScheduleRunSummary.

type ScheduleState

type ScheduleState string

ScheduleState defines model for ScheduleState.

const (
	ACTIVE        ScheduleState = "ACTIVE"
	ARCHIVED      ScheduleState = "ARCHIVED"
	FAILUREPAUSED ScheduleState = "FAILURE_PAUSED"
	PAUSED        ScheduleState = "PAUSED"
)

Defines values for ScheduleState.

type ScheduleTarget

type ScheduleTarget struct {
	ClientPayloadUpdate *ClientPayloadUpdate `json:"clientPayloadUpdate,omitempty"`
	Data                TaskDataWrite        `json:"data"`
	JobType             string               `json:"jobType"`
	Metadata            *Metadata            `json:"metadata,omitempty"`
	RunPolicy           *RunPolicy           `json:"runPolicy,omitempty"`
}

ScheduleTarget defines model for ScheduleTarget.

type ScheduleTrigger

type ScheduleTrigger struct {
	EndAt      *time.Time `json:"endAt,omitempty"`
	Expression *string    `json:"expression,omitempty"`

	// Interval Duration string for interval schedules.
	Interval *string             `json:"interval,omitempty"`
	Kind     ScheduleTriggerKind `json:"kind"`
	StartAt  *time.Time          `json:"startAt,omitempty"`
	Timezone *string             `json:"timezone,omitempty"`
}

ScheduleTrigger defines model for ScheduleTrigger.

type ScheduleTriggerKind

type ScheduleTriggerKind string

ScheduleTriggerKind defines model for ScheduleTriggerKind.

const (
	Cron     ScheduleTriggerKind = "cron"
	Interval ScheduleTriggerKind = "interval"
)

Defines values for ScheduleTriggerKind.

type SecretError added in v0.0.29

type SecretError struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

SecretError defines model for SecretError.

type SecretResolveResult added in v0.0.29

type SecretResolveResult struct {
	Secrets map[string]SecretValue `json:"secrets"`
}

SecretResolveResult defines model for SecretResolveResult.

type SecretValue added in v0.0.29

type SecretValue struct {
	ExpiresAt *time.Time `json:"expiresAt,omitempty"`
	Value     string     `json:"value"`
	Version   *string    `json:"version,omitempty"`
}

SecretValue defines model for SecretValue.

type ServerInterface

type ServerInterface interface {
	// Poll work
	// (POST /v1/jobs/poll)
	PollWork(w http.ResponseWriter, r *http.Request)
	// Read the complete tenant configuration
	// (GET /v1/tenants/{tenantId}/configuration)
	GetTenantConfiguration(w http.ResponseWriter, r *http.Request, tenantId TenantId)
	// Remove one tenant configuration value
	// (POST /v1/tenants/{tenantId}/configuration/remove)
	RemoveTenantConfigurationValue(w http.ResponseWriter, r *http.Request, tenantId TenantId, params RemoveTenantConfigurationValueParams)
	// Set one tenant configuration value
	// (POST /v1/tenants/{tenantId}/configuration/set)
	SetTenantConfigurationValue(w http.ResponseWriter, r *http.Request, tenantId TenantId, params SetTenantConfigurationValueParams)
	// Submit job
	// (POST /v1/tenants/{tenantId}/jobs)
	SubmitJob(w http.ResponseWriter, r *http.Request, tenantId TenantId)
	// List jobs
	// (POST /v1/tenants/{tenantId}/jobs/query)
	ListJobs(w http.ResponseWriter, r *http.Request, tenantId TenantId)
	// Submit restart job
	// (POST /v1/tenants/{tenantId}/jobs/restarts)
	SubmitRestartJob(w http.ResponseWriter, r *http.Request, tenantId TenantId)
	// Get job
	// (GET /v1/tenants/{tenantId}/jobs/{jobId})
	GetJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
	// Submit job with explicit job ID
	// (PUT /v1/tenants/{tenantId}/jobs/{jobId})
	PutJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
	// Cancel job
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/cancel)
	CancelJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
	// List chapters
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters)
	ListChapters(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, params ListChaptersParams)
	// Get chapter
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal})
	GetChapter(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ordinal Ordinal)
	// Open artifact
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal}/artifacts/{name})
	OpenArtifact(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ordinal Ordinal, name ArtifactName)
	// Commit chapter if waiting
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal}/commit-if-waiting)
	CommitChapterIfWaiting(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ordinal Ordinal)
	// Get job lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/lease)
	GetJobLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
	// Add chapter with lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/add_chapter)
	AddChapterWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params AddChapterWithLeaseParams)
	// Complete job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/complete)
	CompleteJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params CompleteJobWithLeaseParams)
	// Read current tenant configuration using a live lease
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/configuration)
	GetConfigurationWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params GetConfigurationWithLeaseParams)
	// Keep lease alive
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/keepalive)
	KeepAliveLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params KeepAliveLeaseParams)
	// Reschedule job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/reschedule)
	RescheduleJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params RescheduleJobWithLeaseParams)
	// Resolve the allowed subset of requested job secrets
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/secrets/resolve)
	ResolveSecretsWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params ResolveSecretsWithLeaseParams)
	// Submit restart job with explicit job ID
	// (PUT /v1/tenants/{tenantId}/jobs/{jobId}/restart)
	PutRestartJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
	// Submit child job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs)
	SubmitJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params SubmitJobWithLeaseParams)
	// Submit child restart job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/restarts)
	SubmitRestartJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params SubmitRestartJobWithLeaseParams)
	// Submit child job with explicit job ID and lease
	// (PUT /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/{childJobId})
	PutJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params PutJobWithLeaseParams)
	// Submit child restart job with explicit job ID and lease
	// (PUT /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/{childJobId}/restart)
	PutRestartJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params PutRestartJobWithLeaseParams)
	// List schedules
	// (POST /v1/tenants/{tenantId}/schedules/query)
	ListSchedules(w http.ResponseWriter, r *http.Request, tenantId TenantId)
	// Get schedule
	// (GET /v1/tenants/{tenantId}/schedules/{scheduleId})
	GetSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)
	// Upsert schedule
	// (PUT /v1/tenants/{tenantId}/schedules/{scheduleId})
	UpsertSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)
	// Archive schedule
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/archive)
	ArchiveSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)
	// Pause schedule
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/pause)
	PauseSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)
	// Resume schedule
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/resume)
	ResumeSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)
	// List schedule runs
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/runs/query)
	ListScheduleRuns(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)
	// Trigger schedule now
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/trigger)
	TriggerSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)
	// List job schemas
	// (GET /v1/tenants/{tenantId}/schemas)
	ListJobSchemas(w http.ResponseWriter, r *http.Request, tenantId TenantId, params ListJobSchemasParams)
	// Register job schema
	// (POST /v1/tenants/{tenantId}/schemas)
	RegisterJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId)
	// Get job schema
	// (GET /v1/tenants/{tenantId}/schemas/{schemaHash})
	GetJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId, schemaHash JobSchemaHash)
	// Archive job schema
	// (POST /v1/tenants/{tenantId}/schemas/{schemaHash}/archive)
	ArchiveJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId, schemaHash JobSchemaHash)
}

ServerInterface represents all server handlers.

func NewStrictHandler

func NewStrictHandler(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc) ServerInterface

func NewStrictHandlerWithOptions

func NewStrictHandlerWithOptions(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc, options StrictHTTPServerOptions) ServerInterface

type ServerInterfaceWrapper

type ServerInterfaceWrapper struct {
	Handler            ServerInterface
	HandlerMiddlewares []MiddlewareFunc
	ErrorHandlerFunc   func(w http.ResponseWriter, r *http.Request, err error)
}

ServerInterfaceWrapper converts contexts to parameters.

func (*ServerInterfaceWrapper) AddChapterWithLease

func (siw *ServerInterfaceWrapper) AddChapterWithLease(w http.ResponseWriter, r *http.Request)

AddChapterWithLease operation middleware

func (*ServerInterfaceWrapper) ArchiveJobSchema added in v0.0.9

func (siw *ServerInterfaceWrapper) ArchiveJobSchema(w http.ResponseWriter, r *http.Request)

ArchiveJobSchema operation middleware

func (*ServerInterfaceWrapper) ArchiveSchedule

func (siw *ServerInterfaceWrapper) ArchiveSchedule(w http.ResponseWriter, r *http.Request)

ArchiveSchedule operation middleware

func (*ServerInterfaceWrapper) CancelJob

func (siw *ServerInterfaceWrapper) CancelJob(w http.ResponseWriter, r *http.Request)

CancelJob operation middleware

func (*ServerInterfaceWrapper) CommitChapterIfWaiting

func (siw *ServerInterfaceWrapper) CommitChapterIfWaiting(w http.ResponseWriter, r *http.Request)

CommitChapterIfWaiting operation middleware

func (*ServerInterfaceWrapper) CompleteJobWithLease

func (siw *ServerInterfaceWrapper) CompleteJobWithLease(w http.ResponseWriter, r *http.Request)

CompleteJobWithLease operation middleware

func (*ServerInterfaceWrapper) GetChapter

func (siw *ServerInterfaceWrapper) GetChapter(w http.ResponseWriter, r *http.Request)

GetChapter operation middleware

func (*ServerInterfaceWrapper) GetConfigurationWithLease added in v0.0.33

func (siw *ServerInterfaceWrapper) GetConfigurationWithLease(w http.ResponseWriter, r *http.Request)

GetConfigurationWithLease operation middleware

func (*ServerInterfaceWrapper) GetJob

GetJob operation middleware

func (*ServerInterfaceWrapper) GetJobLease

func (siw *ServerInterfaceWrapper) GetJobLease(w http.ResponseWriter, r *http.Request)

GetJobLease operation middleware

func (*ServerInterfaceWrapper) GetJobSchema added in v0.0.9

func (siw *ServerInterfaceWrapper) GetJobSchema(w http.ResponseWriter, r *http.Request)

GetJobSchema operation middleware

func (*ServerInterfaceWrapper) GetSchedule

func (siw *ServerInterfaceWrapper) GetSchedule(w http.ResponseWriter, r *http.Request)

GetSchedule operation middleware

func (*ServerInterfaceWrapper) GetTenantConfiguration added in v0.0.33

func (siw *ServerInterfaceWrapper) GetTenantConfiguration(w http.ResponseWriter, r *http.Request)

GetTenantConfiguration operation middleware

func (*ServerInterfaceWrapper) KeepAliveLease

func (siw *ServerInterfaceWrapper) KeepAliveLease(w http.ResponseWriter, r *http.Request)

KeepAliveLease operation middleware

func (*ServerInterfaceWrapper) ListChapters

func (siw *ServerInterfaceWrapper) ListChapters(w http.ResponseWriter, r *http.Request)

ListChapters operation middleware

func (*ServerInterfaceWrapper) ListJobSchemas added in v0.0.9

func (siw *ServerInterfaceWrapper) ListJobSchemas(w http.ResponseWriter, r *http.Request)

ListJobSchemas operation middleware

func (*ServerInterfaceWrapper) ListJobs

func (siw *ServerInterfaceWrapper) ListJobs(w http.ResponseWriter, r *http.Request)

ListJobs operation middleware

func (*ServerInterfaceWrapper) ListScheduleRuns

func (siw *ServerInterfaceWrapper) ListScheduleRuns(w http.ResponseWriter, r *http.Request)

ListScheduleRuns operation middleware

func (*ServerInterfaceWrapper) ListSchedules

func (siw *ServerInterfaceWrapper) ListSchedules(w http.ResponseWriter, r *http.Request)

ListSchedules operation middleware

func (*ServerInterfaceWrapper) OpenArtifact

func (siw *ServerInterfaceWrapper) OpenArtifact(w http.ResponseWriter, r *http.Request)

OpenArtifact operation middleware

func (*ServerInterfaceWrapper) PauseSchedule

func (siw *ServerInterfaceWrapper) PauseSchedule(w http.ResponseWriter, r *http.Request)

PauseSchedule operation middleware

func (*ServerInterfaceWrapper) PollWork

func (siw *ServerInterfaceWrapper) PollWork(w http.ResponseWriter, r *http.Request)

PollWork operation middleware

func (*ServerInterfaceWrapper) PutJob

PutJob operation middleware

func (*ServerInterfaceWrapper) PutJobWithLease added in v0.0.13

func (siw *ServerInterfaceWrapper) PutJobWithLease(w http.ResponseWriter, r *http.Request)

PutJobWithLease operation middleware

func (*ServerInterfaceWrapper) PutRestartJob

func (siw *ServerInterfaceWrapper) PutRestartJob(w http.ResponseWriter, r *http.Request)

PutRestartJob operation middleware

func (*ServerInterfaceWrapper) PutRestartJobWithLease added in v0.0.13

func (siw *ServerInterfaceWrapper) PutRestartJobWithLease(w http.ResponseWriter, r *http.Request)

PutRestartJobWithLease operation middleware

func (*ServerInterfaceWrapper) RegisterJobSchema added in v0.0.9

func (siw *ServerInterfaceWrapper) RegisterJobSchema(w http.ResponseWriter, r *http.Request)

RegisterJobSchema operation middleware

func (*ServerInterfaceWrapper) RemoveTenantConfigurationValue added in v0.0.33

func (siw *ServerInterfaceWrapper) RemoveTenantConfigurationValue(w http.ResponseWriter, r *http.Request)

RemoveTenantConfigurationValue operation middleware

func (*ServerInterfaceWrapper) RescheduleJobWithLease

func (siw *ServerInterfaceWrapper) RescheduleJobWithLease(w http.ResponseWriter, r *http.Request)

RescheduleJobWithLease operation middleware

func (*ServerInterfaceWrapper) ResolveSecretsWithLease added in v0.0.29

func (siw *ServerInterfaceWrapper) ResolveSecretsWithLease(w http.ResponseWriter, r *http.Request)

ResolveSecretsWithLease operation middleware

func (*ServerInterfaceWrapper) ResumeSchedule

func (siw *ServerInterfaceWrapper) ResumeSchedule(w http.ResponseWriter, r *http.Request)

ResumeSchedule operation middleware

func (*ServerInterfaceWrapper) SetTenantConfigurationValue added in v0.0.33

func (siw *ServerInterfaceWrapper) SetTenantConfigurationValue(w http.ResponseWriter, r *http.Request)

SetTenantConfigurationValue operation middleware

func (*ServerInterfaceWrapper) SubmitJob

func (siw *ServerInterfaceWrapper) SubmitJob(w http.ResponseWriter, r *http.Request)

SubmitJob operation middleware

func (*ServerInterfaceWrapper) SubmitJobWithLease added in v0.0.13

func (siw *ServerInterfaceWrapper) SubmitJobWithLease(w http.ResponseWriter, r *http.Request)

SubmitJobWithLease operation middleware

func (*ServerInterfaceWrapper) SubmitRestartJob

func (siw *ServerInterfaceWrapper) SubmitRestartJob(w http.ResponseWriter, r *http.Request)

SubmitRestartJob operation middleware

func (*ServerInterfaceWrapper) SubmitRestartJobWithLease added in v0.0.13

func (siw *ServerInterfaceWrapper) SubmitRestartJobWithLease(w http.ResponseWriter, r *http.Request)

SubmitRestartJobWithLease operation middleware

func (*ServerInterfaceWrapper) TriggerSchedule

func (siw *ServerInterfaceWrapper) TriggerSchedule(w http.ResponseWriter, r *http.Request)

TriggerSchedule operation middleware

func (*ServerInterfaceWrapper) UpsertSchedule

func (siw *ServerInterfaceWrapper) UpsertSchedule(w http.ResponseWriter, r *http.Request)

UpsertSchedule operation middleware

type SetConfigurationBody added in v0.0.33

type SetConfigurationBody struct {
	Name string `json:"name"`

	// Value Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Value ApplicationPayload `json:"value"`
}

SetConfigurationBody defines model for SetConfigurationBody.

type SetTenantConfigurationValue204Response added in v0.0.33

type SetTenantConfigurationValue204Response struct {
	Headers SetTenantConfigurationValue204ResponseHeaders
}

func (SetTenantConfigurationValue204Response) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue204Response) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue204ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue204ResponseHeaders struct {
	CacheControl string
	ETag         string
}

type SetTenantConfigurationValue400JSONResponse added in v0.0.33

type SetTenantConfigurationValue400JSONResponse struct {
	Body    ErrorResponse
	Headers SetTenantConfigurationValue400ResponseHeaders
}

func (SetTenantConfigurationValue400JSONResponse) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue400JSONResponse) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue400ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue400ResponseHeaders struct {
	CacheControl string
}

type SetTenantConfigurationValue401JSONResponse added in v0.0.33

type SetTenantConfigurationValue401JSONResponse struct {
	Body    ErrorResponse
	Headers SetTenantConfigurationValue401ResponseHeaders
}

func (SetTenantConfigurationValue401JSONResponse) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue401JSONResponse) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue401ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue401ResponseHeaders struct {
	CacheControl string
}

type SetTenantConfigurationValue403JSONResponse added in v0.0.33

type SetTenantConfigurationValue403JSONResponse struct {
	Body    ErrorResponse
	Headers SetTenantConfigurationValue403ResponseHeaders
}

func (SetTenantConfigurationValue403JSONResponse) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue403JSONResponse) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue403ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue403ResponseHeaders struct {
	CacheControl string
}

type SetTenantConfigurationValue412JSONResponse added in v0.0.33

type SetTenantConfigurationValue412JSONResponse struct {
	Body    ErrorResponse
	Headers SetTenantConfigurationValue412ResponseHeaders
}

func (SetTenantConfigurationValue412JSONResponse) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue412JSONResponse) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue412ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue412ResponseHeaders struct {
	CacheControl string
}

type SetTenantConfigurationValue413JSONResponse added in v0.0.33

type SetTenantConfigurationValue413JSONResponse struct {
	Body    ErrorResponse
	Headers SetTenantConfigurationValue413ResponseHeaders
}

func (SetTenantConfigurationValue413JSONResponse) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue413JSONResponse) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue413ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue413ResponseHeaders struct {
	CacheControl string
}

type SetTenantConfigurationValue500JSONResponse added in v0.0.33

type SetTenantConfigurationValue500JSONResponse struct {
	Body    ErrorResponse
	Headers SetTenantConfigurationValue500ResponseHeaders
}

func (SetTenantConfigurationValue500JSONResponse) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue500JSONResponse) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue500ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue500ResponseHeaders struct {
	CacheControl string
}

type SetTenantConfigurationValue503JSONResponse added in v0.0.33

type SetTenantConfigurationValue503JSONResponse struct {
	Body    ErrorResponse
	Headers SetTenantConfigurationValue503ResponseHeaders
}

func (SetTenantConfigurationValue503JSONResponse) VisitSetTenantConfigurationValueResponse added in v0.0.33

func (response SetTenantConfigurationValue503JSONResponse) VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error

type SetTenantConfigurationValue503ResponseHeaders added in v0.0.33

type SetTenantConfigurationValue503ResponseHeaders struct {
	CacheControl string
}

type SetTenantConfigurationValueHTTPResponse added in v0.0.33

type SetTenantConfigurationValueHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON400      *ErrorResponse
	JSON401      *ErrorResponse
	JSON403      *ErrorResponse
	JSON412      *ErrorResponse
	JSON413      *ErrorResponse
	JSON500      *ErrorResponse
	JSON503      *ErrorResponse
}

func ParseSetTenantConfigurationValueHTTPResponse added in v0.0.33

func ParseSetTenantConfigurationValueHTTPResponse(rsp *http.Response) (*SetTenantConfigurationValueHTTPResponse, error)

ParseSetTenantConfigurationValueHTTPResponse parses an HTTP response from a SetTenantConfigurationValueWithResponse call

func (SetTenantConfigurationValueHTTPResponse) Status added in v0.0.33

Status returns HTTPResponse.Status

func (SetTenantConfigurationValueHTTPResponse) StatusCode added in v0.0.33

StatusCode returns HTTPResponse.StatusCode

type SetTenantConfigurationValueJSONRequestBody added in v0.0.33

type SetTenantConfigurationValueJSONRequestBody = SetConfigurationBody

SetTenantConfigurationValueJSONRequestBody defines body for SetTenantConfigurationValue for application/json ContentType.

type SetTenantConfigurationValueParams added in v0.0.33

type SetTenantConfigurationValueParams struct {
	// IfMatch One quoted revision ETag; weak tags, lists and wildcard are invalid.
	IfMatch *string `json:"If-Match,omitempty"`
}

SetTenantConfigurationValueParams defines parameters for SetTenantConfigurationValue.

type SetTenantConfigurationValueRequestObject added in v0.0.33

type SetTenantConfigurationValueRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Params   SetTenantConfigurationValueParams
	Body     *SetTenantConfigurationValueJSONRequestBody
}

type SetTenantConfigurationValueResponseObject added in v0.0.33

type SetTenantConfigurationValueResponseObject interface {
	VisitSetTenantConfigurationValueResponse(w http.ResponseWriter) error
}

type StartOrdinal

type StartOrdinal = int64

StartOrdinal defines model for StartOrdinal.

type StoredArtifact

type StoredArtifact struct {
	Digest string `json:"digest"`
	Name   string `json:"name"`
	Size   int64  `json:"size"`
}

StoredArtifact defines model for StoredArtifact.

type StoredTaskData

type StoredTaskData struct {
	Artifacts []StoredArtifact `json:"artifacts"`
	Outcome   TaskOutcome      `json:"outcome"`
}

StoredTaskData defines model for StoredTaskData.

type StrictHTTPServerOptions

type StrictHTTPServerOptions struct {
	RequestErrorHandlerFunc  func(w http.ResponseWriter, r *http.Request, err error)
	ResponseErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)
}

type StrictServerInterface

type StrictServerInterface interface {
	// Poll work
	// (POST /v1/jobs/poll)
	PollWork(ctx context.Context, request PollWorkRequestObject) (PollWorkResponseObject, error)
	// Read the complete tenant configuration
	// (GET /v1/tenants/{tenantId}/configuration)
	GetTenantConfiguration(ctx context.Context, request GetTenantConfigurationRequestObject) (GetTenantConfigurationResponseObject, error)
	// Remove one tenant configuration value
	// (POST /v1/tenants/{tenantId}/configuration/remove)
	RemoveTenantConfigurationValue(ctx context.Context, request RemoveTenantConfigurationValueRequestObject) (RemoveTenantConfigurationValueResponseObject, error)
	// Set one tenant configuration value
	// (POST /v1/tenants/{tenantId}/configuration/set)
	SetTenantConfigurationValue(ctx context.Context, request SetTenantConfigurationValueRequestObject) (SetTenantConfigurationValueResponseObject, error)
	// Submit job
	// (POST /v1/tenants/{tenantId}/jobs)
	SubmitJob(ctx context.Context, request SubmitJobRequestObject) (SubmitJobResponseObject, error)
	// List jobs
	// (POST /v1/tenants/{tenantId}/jobs/query)
	ListJobs(ctx context.Context, request ListJobsRequestObject) (ListJobsResponseObject, error)
	// Submit restart job
	// (POST /v1/tenants/{tenantId}/jobs/restarts)
	SubmitRestartJob(ctx context.Context, request SubmitRestartJobRequestObject) (SubmitRestartJobResponseObject, error)
	// Get job
	// (GET /v1/tenants/{tenantId}/jobs/{jobId})
	GetJob(ctx context.Context, request GetJobRequestObject) (GetJobResponseObject, error)
	// Submit job with explicit job ID
	// (PUT /v1/tenants/{tenantId}/jobs/{jobId})
	PutJob(ctx context.Context, request PutJobRequestObject) (PutJobResponseObject, error)
	// Cancel job
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/cancel)
	CancelJob(ctx context.Context, request CancelJobRequestObject) (CancelJobResponseObject, error)
	// List chapters
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters)
	ListChapters(ctx context.Context, request ListChaptersRequestObject) (ListChaptersResponseObject, error)
	// Get chapter
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal})
	GetChapter(ctx context.Context, request GetChapterRequestObject) (GetChapterResponseObject, error)
	// Open artifact
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal}/artifacts/{name})
	OpenArtifact(ctx context.Context, request OpenArtifactRequestObject) (OpenArtifactResponseObject, error)
	// Commit chapter if waiting
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal}/commit-if-waiting)
	CommitChapterIfWaiting(ctx context.Context, request CommitChapterIfWaitingRequestObject) (CommitChapterIfWaitingResponseObject, error)
	// Get job lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/lease)
	GetJobLease(ctx context.Context, request GetJobLeaseRequestObject) (GetJobLeaseResponseObject, error)
	// Add chapter with lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/add_chapter)
	AddChapterWithLease(ctx context.Context, request AddChapterWithLeaseRequestObject) (AddChapterWithLeaseResponseObject, error)
	// Complete job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/complete)
	CompleteJobWithLease(ctx context.Context, request CompleteJobWithLeaseRequestObject) (CompleteJobWithLeaseResponseObject, error)
	// Read current tenant configuration using a live lease
	// (GET /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/configuration)
	GetConfigurationWithLease(ctx context.Context, request GetConfigurationWithLeaseRequestObject) (GetConfigurationWithLeaseResponseObject, error)
	// Keep lease alive
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/keepalive)
	KeepAliveLease(ctx context.Context, request KeepAliveLeaseRequestObject) (KeepAliveLeaseResponseObject, error)
	// Reschedule job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/reschedule)
	RescheduleJobWithLease(ctx context.Context, request RescheduleJobWithLeaseRequestObject) (RescheduleJobWithLeaseResponseObject, error)
	// Resolve the allowed subset of requested job secrets
	// (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/secrets/resolve)
	ResolveSecretsWithLease(ctx context.Context, request ResolveSecretsWithLeaseRequestObject) (ResolveSecretsWithLeaseResponseObject, error)
	// Submit restart job with explicit job ID
	// (PUT /v1/tenants/{tenantId}/jobs/{jobId}/restart)
	PutRestartJob(ctx context.Context, request PutRestartJobRequestObject) (PutRestartJobResponseObject, error)
	// Submit child job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs)
	SubmitJobWithLease(ctx context.Context, request SubmitJobWithLeaseRequestObject) (SubmitJobWithLeaseResponseObject, error)
	// Submit child restart job with lease
	// (POST /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/restarts)
	SubmitRestartJobWithLease(ctx context.Context, request SubmitRestartJobWithLeaseRequestObject) (SubmitRestartJobWithLeaseResponseObject, error)
	// Submit child job with explicit job ID and lease
	// (PUT /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/{childJobId})
	PutJobWithLease(ctx context.Context, request PutJobWithLeaseRequestObject) (PutJobWithLeaseResponseObject, error)
	// Submit child restart job with explicit job ID and lease
	// (PUT /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/{childJobId}/restart)
	PutRestartJobWithLease(ctx context.Context, request PutRestartJobWithLeaseRequestObject) (PutRestartJobWithLeaseResponseObject, error)
	// List schedules
	// (POST /v1/tenants/{tenantId}/schedules/query)
	ListSchedules(ctx context.Context, request ListSchedulesRequestObject) (ListSchedulesResponseObject, error)
	// Get schedule
	// (GET /v1/tenants/{tenantId}/schedules/{scheduleId})
	GetSchedule(ctx context.Context, request GetScheduleRequestObject) (GetScheduleResponseObject, error)
	// Upsert schedule
	// (PUT /v1/tenants/{tenantId}/schedules/{scheduleId})
	UpsertSchedule(ctx context.Context, request UpsertScheduleRequestObject) (UpsertScheduleResponseObject, error)
	// Archive schedule
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/archive)
	ArchiveSchedule(ctx context.Context, request ArchiveScheduleRequestObject) (ArchiveScheduleResponseObject, error)
	// Pause schedule
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/pause)
	PauseSchedule(ctx context.Context, request PauseScheduleRequestObject) (PauseScheduleResponseObject, error)
	// Resume schedule
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/resume)
	ResumeSchedule(ctx context.Context, request ResumeScheduleRequestObject) (ResumeScheduleResponseObject, error)
	// List schedule runs
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/runs/query)
	ListScheduleRuns(ctx context.Context, request ListScheduleRunsRequestObject) (ListScheduleRunsResponseObject, error)
	// Trigger schedule now
	// (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/trigger)
	TriggerSchedule(ctx context.Context, request TriggerScheduleRequestObject) (TriggerScheduleResponseObject, error)
	// List job schemas
	// (GET /v1/tenants/{tenantId}/schemas)
	ListJobSchemas(ctx context.Context, request ListJobSchemasRequestObject) (ListJobSchemasResponseObject, error)
	// Register job schema
	// (POST /v1/tenants/{tenantId}/schemas)
	RegisterJobSchema(ctx context.Context, request RegisterJobSchemaRequestObject) (RegisterJobSchemaResponseObject, error)
	// Get job schema
	// (GET /v1/tenants/{tenantId}/schemas/{schemaHash})
	GetJobSchema(ctx context.Context, request GetJobSchemaRequestObject) (GetJobSchemaResponseObject, error)
	// Archive job schema
	// (POST /v1/tenants/{tenantId}/schemas/{schemaHash}/archive)
	ArchiveJobSchema(ctx context.Context, request ArchiveJobSchemaRequestObject) (ArchiveJobSchemaResponseObject, error)
}

StrictServerInterface represents all server handlers.

type SubmitJob

type SubmitJob struct {
	AvailableAt         *time.Time           `json:"availableAt,omitempty"`
	ClientPayloadUpdate *ClientPayloadUpdate `json:"clientPayloadUpdate,omitempty"`
	Data                TaskDataWrite        `json:"data"`
	JobType             string               `json:"jobType"`
	Metadata            *Metadata            `json:"metadata,omitempty"`
	Prerequisites       *[]JobPrerequisite   `json:"prerequisites,omitempty"`
	RunPolicy           *RunPolicy           `json:"runPolicy,omitempty"`
	Schema              *JobSchemaSelector   `json:"schema,omitempty"`
}

SubmitJob defines model for SubmitJob.

type SubmitJob200JSONResponse

type SubmitJob200JSONResponse JobHandle

func (SubmitJob200JSONResponse) VisitSubmitJobResponse

func (response SubmitJob200JSONResponse) VisitSubmitJobResponse(w http.ResponseWriter) error

type SubmitJobHTTPResponse

type SubmitJobHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
}

func ParseSubmitJobHTTPResponse

func ParseSubmitJobHTTPResponse(rsp *http.Response) (*SubmitJobHTTPResponse, error)

ParseSubmitJobHTTPResponse parses an HTTP response from a SubmitJobWithResponse call

func (SubmitJobHTTPResponse) Status

func (r SubmitJobHTTPResponse) Status() string

Status returns HTTPResponse.Status

func (SubmitJobHTTPResponse) StatusCode

func (r SubmitJobHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type SubmitJobJSONRequestBody

type SubmitJobJSONRequestBody = SubmitJobRequest

SubmitJobJSONRequestBody defines body for SubmitJob for application/json ContentType.

type SubmitJobRequest

type SubmitJobRequest struct {
	Job         SubmitJob  `json:"job"`
	RequestTime *time.Time `json:"requestTime,omitempty"`
	WorkerId    *string    `json:"workerId,omitempty"`
}

SubmitJobRequest defines model for SubmitJobRequest.

type SubmitJobRequestObject

type SubmitJobRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Body     *SubmitJobJSONRequestBody
}

type SubmitJobResponseObject

type SubmitJobResponseObject interface {
	VisitSubmitJobResponse(w http.ResponseWriter) error
}

type SubmitJobWithLease200JSONResponse added in v0.0.13

type SubmitJobWithLease200JSONResponse JobHandle

func (SubmitJobWithLease200JSONResponse) VisitSubmitJobWithLeaseResponse added in v0.0.13

func (response SubmitJobWithLease200JSONResponse) VisitSubmitJobWithLeaseResponse(w http.ResponseWriter) error

type SubmitJobWithLeaseHTTPResponse added in v0.0.13

type SubmitJobWithLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
}

func ParseSubmitJobWithLeaseHTTPResponse added in v0.0.13

func ParseSubmitJobWithLeaseHTTPResponse(rsp *http.Response) (*SubmitJobWithLeaseHTTPResponse, error)

ParseSubmitJobWithLeaseHTTPResponse parses an HTTP response from a SubmitJobWithLeaseWithResponse call

func (SubmitJobWithLeaseHTTPResponse) Status added in v0.0.13

Status returns HTTPResponse.Status

func (SubmitJobWithLeaseHTTPResponse) StatusCode added in v0.0.13

func (r SubmitJobWithLeaseHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type SubmitJobWithLeaseJSONRequestBody added in v0.0.13

type SubmitJobWithLeaseJSONRequestBody = SubmitJobRequest

SubmitJobWithLeaseJSONRequestBody defines body for SubmitJobWithLease for application/json ContentType.

type SubmitJobWithLeaseParams added in v0.0.13

type SubmitJobWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

SubmitJobWithLeaseParams defines parameters for SubmitJobWithLease.

type SubmitJobWithLeaseRequestObject added in v0.0.13

type SubmitJobWithLeaseRequestObject struct {
	TenantId    TenantId    `json:"tenantId"`
	ParentJobId ParentJobId `json:"parentJobId"`
	LeaseId     LeaseId     `json:"leaseId"`
	Params      SubmitJobWithLeaseParams
	Body        *SubmitJobWithLeaseJSONRequestBody
}

type SubmitJobWithLeaseResponseObject added in v0.0.13

type SubmitJobWithLeaseResponseObject interface {
	VisitSubmitJobWithLeaseResponse(w http.ResponseWriter) error
}

type SubmitRestartJob

type SubmitRestartJob struct {
	ClientPayloadUpdate *ClientPayloadUpdate `json:"clientPayloadUpdate,omitempty"`
	ExecutionRestart    *ExecutionRestart    `json:"executionRestart,omitempty"`
	ExtraTaskInput      *TaskDataWrite       `json:"extraTaskInput,omitempty"`
	ExtraTaskOutput     *TaskDataWrite       `json:"extraTaskOutput,omitempty"`
	LastStepToKeep      int64                `json:"lastStepToKeep"`
	Prerequisites       *[]JobPrerequisite   `json:"prerequisites,omitempty"`
	PriorJobKey         JobKey               `json:"priorJobKey"`
	Schema              *JobSchemaSelector   `json:"schema,omitempty"`
}

SubmitRestartJob defines model for SubmitRestartJob.

type SubmitRestartJob200JSONResponse

type SubmitRestartJob200JSONResponse JobHandle

func (SubmitRestartJob200JSONResponse) VisitSubmitRestartJobResponse

func (response SubmitRestartJob200JSONResponse) VisitSubmitRestartJobResponse(w http.ResponseWriter) error

type SubmitRestartJobHTTPResponse

type SubmitRestartJobHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
}

func ParseSubmitRestartJobHTTPResponse

func ParseSubmitRestartJobHTTPResponse(rsp *http.Response) (*SubmitRestartJobHTTPResponse, error)

ParseSubmitRestartJobHTTPResponse parses an HTTP response from a SubmitRestartJobWithResponse call

func (SubmitRestartJobHTTPResponse) Status

Status returns HTTPResponse.Status

func (SubmitRestartJobHTTPResponse) StatusCode

func (r SubmitRestartJobHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type SubmitRestartJobJSONRequestBody

type SubmitRestartJobJSONRequestBody = SubmitRestartJobRequest

SubmitRestartJobJSONRequestBody defines body for SubmitRestartJob for application/json ContentType.

type SubmitRestartJobRequest

type SubmitRestartJobRequest struct {
	Job         SubmitRestartJob `json:"job"`
	RequestTime *time.Time       `json:"requestTime,omitempty"`
	WorkerId    *string          `json:"workerId,omitempty"`
}

SubmitRestartJobRequest defines model for SubmitRestartJobRequest.

type SubmitRestartJobRequestObject

type SubmitRestartJobRequestObject struct {
	TenantId TenantId `json:"tenantId"`
	Body     *SubmitRestartJobJSONRequestBody
}

type SubmitRestartJobResponseObject

type SubmitRestartJobResponseObject interface {
	VisitSubmitRestartJobResponse(w http.ResponseWriter) error
}

type SubmitRestartJobWithLease200JSONResponse added in v0.0.13

type SubmitRestartJobWithLease200JSONResponse JobHandle

func (SubmitRestartJobWithLease200JSONResponse) VisitSubmitRestartJobWithLeaseResponse added in v0.0.13

func (response SubmitRestartJobWithLease200JSONResponse) VisitSubmitRestartJobWithLeaseResponse(w http.ResponseWriter) error

type SubmitRestartJobWithLeaseHTTPResponse added in v0.0.13

type SubmitRestartJobWithLeaseHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
}

func ParseSubmitRestartJobWithLeaseHTTPResponse added in v0.0.13

func ParseSubmitRestartJobWithLeaseHTTPResponse(rsp *http.Response) (*SubmitRestartJobWithLeaseHTTPResponse, error)

ParseSubmitRestartJobWithLeaseHTTPResponse parses an HTTP response from a SubmitRestartJobWithLeaseWithResponse call

func (SubmitRestartJobWithLeaseHTTPResponse) Status added in v0.0.13

Status returns HTTPResponse.Status

func (SubmitRestartJobWithLeaseHTTPResponse) StatusCode added in v0.0.13

StatusCode returns HTTPResponse.StatusCode

type SubmitRestartJobWithLeaseJSONRequestBody added in v0.0.13

type SubmitRestartJobWithLeaseJSONRequestBody = SubmitRestartJobRequest

SubmitRestartJobWithLeaseJSONRequestBody defines body for SubmitRestartJobWithLease for application/json ContentType.

type SubmitRestartJobWithLeaseParams added in v0.0.13

type SubmitRestartJobWithLeaseParams struct {
	XJobDBLeaseToken LeaseTokenHeader `json:"X-JobDB-Lease-Token"`
}

SubmitRestartJobWithLeaseParams defines parameters for SubmitRestartJobWithLease.

type SubmitRestartJobWithLeaseRequestObject added in v0.0.13

type SubmitRestartJobWithLeaseRequestObject struct {
	TenantId    TenantId    `json:"tenantId"`
	ParentJobId ParentJobId `json:"parentJobId"`
	LeaseId     LeaseId     `json:"leaseId"`
	Params      SubmitRestartJobWithLeaseParams
	Body        *SubmitRestartJobWithLeaseJSONRequestBody
}

type SubmitRestartJobWithLeaseResponseObject added in v0.0.13

type SubmitRestartJobWithLeaseResponseObject interface {
	VisitSubmitRestartJobWithLeaseResponse(w http.ResponseWriter) error
}

type SystemErrorPayload

type SystemErrorPayload struct {
	Code       *string         `json:"code,omitempty"`
	Component  *string         `json:"component,omitempty"`
	InputRef   *InputReference `json:"inputRef,omitempty"`
	Message    string          `json:"message"`
	Retryable  *bool           `json:"retryable,omitempty"`
	Stacktrace *[]string       `json:"stacktrace,omitempty"`
}

SystemErrorPayload defines model for SystemErrorPayload.

type TaskAttemptOutcomeChapter

type TaskAttemptOutcomeChapter struct {
	Kind    TaskAttemptOutcomeChapterKind `json:"kind"`
	Outcome TaskOutcome                   `json:"outcome"`
}

TaskAttemptOutcomeChapter defines model for TaskAttemptOutcomeChapter.

type TaskAttemptOutcomeChapterKind

type TaskAttemptOutcomeChapterKind string

TaskAttemptOutcomeChapterKind defines model for TaskAttemptOutcomeChapter.Kind.

const (
	TaskAttemptOutcome TaskAttemptOutcomeChapterKind = "taskAttemptOutcome"
)

Defines values for TaskAttemptOutcomeChapterKind.

type TaskDataWrite

type TaskDataWrite struct {
	Artifacts []ArtifactWrite `json:"artifacts"`

	// Data Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Data ApplicationPayload `json:"data"`
}

TaskDataWrite defines model for TaskDataWrite.

type TaskOutcome

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

TaskOutcome defines model for TaskOutcome.

func (TaskOutcome) AsTaskOutcomeAppError

func (t TaskOutcome) AsTaskOutcomeAppError() (TaskOutcomeAppError, error)

AsTaskOutcomeAppError returns the union data inside the TaskOutcome as a TaskOutcomeAppError

func (TaskOutcome) AsTaskOutcomeSuccess

func (t TaskOutcome) AsTaskOutcomeSuccess() (TaskOutcomeSuccess, error)

AsTaskOutcomeSuccess returns the union data inside the TaskOutcome as a TaskOutcomeSuccess

func (TaskOutcome) AsTaskOutcomeSystemError

func (t TaskOutcome) AsTaskOutcomeSystemError() (TaskOutcomeSystemError, error)

AsTaskOutcomeSystemError returns the union data inside the TaskOutcome as a TaskOutcomeSystemError

func (TaskOutcome) AsTaskOutcomeTimeout

func (t TaskOutcome) AsTaskOutcomeTimeout() (TaskOutcomeTimeout, error)

AsTaskOutcomeTimeout returns the union data inside the TaskOutcome as a TaskOutcomeTimeout

func (TaskOutcome) Discriminator

func (t TaskOutcome) Discriminator() (string, error)

func (*TaskOutcome) FromTaskOutcomeAppError

func (t *TaskOutcome) FromTaskOutcomeAppError(v TaskOutcomeAppError) error

FromTaskOutcomeAppError overwrites any union data inside the TaskOutcome as the provided TaskOutcomeAppError

func (*TaskOutcome) FromTaskOutcomeSuccess

func (t *TaskOutcome) FromTaskOutcomeSuccess(v TaskOutcomeSuccess) error

FromTaskOutcomeSuccess overwrites any union data inside the TaskOutcome as the provided TaskOutcomeSuccess

func (*TaskOutcome) FromTaskOutcomeSystemError

func (t *TaskOutcome) FromTaskOutcomeSystemError(v TaskOutcomeSystemError) error

FromTaskOutcomeSystemError overwrites any union data inside the TaskOutcome as the provided TaskOutcomeSystemError

func (*TaskOutcome) FromTaskOutcomeTimeout

func (t *TaskOutcome) FromTaskOutcomeTimeout(v TaskOutcomeTimeout) error

FromTaskOutcomeTimeout overwrites any union data inside the TaskOutcome as the provided TaskOutcomeTimeout

func (TaskOutcome) MarshalJSON

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

func (*TaskOutcome) MergeTaskOutcomeAppError

func (t *TaskOutcome) MergeTaskOutcomeAppError(v TaskOutcomeAppError) error

MergeTaskOutcomeAppError performs a merge with any union data inside the TaskOutcome, using the provided TaskOutcomeAppError

func (*TaskOutcome) MergeTaskOutcomeSuccess

func (t *TaskOutcome) MergeTaskOutcomeSuccess(v TaskOutcomeSuccess) error

MergeTaskOutcomeSuccess performs a merge with any union data inside the TaskOutcome, using the provided TaskOutcomeSuccess

func (*TaskOutcome) MergeTaskOutcomeSystemError

func (t *TaskOutcome) MergeTaskOutcomeSystemError(v TaskOutcomeSystemError) error

MergeTaskOutcomeSystemError performs a merge with any union data inside the TaskOutcome, using the provided TaskOutcomeSystemError

func (*TaskOutcome) MergeTaskOutcomeTimeout

func (t *TaskOutcome) MergeTaskOutcomeTimeout(v TaskOutcomeTimeout) error

MergeTaskOutcomeTimeout performs a merge with any union data inside the TaskOutcome, using the provided TaskOutcomeTimeout

func (*TaskOutcome) UnmarshalJSON

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

func (TaskOutcome) ValueByDiscriminator

func (t TaskOutcome) ValueByDiscriminator() (interface{}, error)

type TaskOutcomeAppError

type TaskOutcomeAppError struct {
	Error AppErrorPayload         `json:"error"`
	Kind  TaskOutcomeAppErrorKind `json:"kind"`
}

TaskOutcomeAppError defines model for TaskOutcomeAppError.

type TaskOutcomeAppErrorKind

type TaskOutcomeAppErrorKind string

TaskOutcomeAppErrorKind defines model for TaskOutcomeAppError.Kind.

const (
	AppError TaskOutcomeAppErrorKind = "appError"
)

Defines values for TaskOutcomeAppErrorKind.

type TaskOutcomeSuccess

type TaskOutcomeSuccess struct {
	Kind TaskOutcomeSuccessKind `json:"kind"`

	// Output Caller-owned application JSON payload embedded directly in REST
	// requests and responses. This value is any valid JSON value: object,
	// array, string, number, boolean, or null. It is never base64-encoded and
	// never wrapped in a protobuf `Any`-style envelope on the REST boundary.
	Output ApplicationPayload `json:"output"`
}

TaskOutcomeSuccess defines model for TaskOutcomeSuccess.

type TaskOutcomeSuccessKind

type TaskOutcomeSuccessKind string

TaskOutcomeSuccessKind defines model for TaskOutcomeSuccess.Kind.

const (
	TaskOutcomeSuccessKindSuccess TaskOutcomeSuccessKind = "success"
)

Defines values for TaskOutcomeSuccessKind.

type TaskOutcomeSystemError

type TaskOutcomeSystemError struct {
	Error SystemErrorPayload         `json:"error"`
	Kind  TaskOutcomeSystemErrorKind `json:"kind"`
}

TaskOutcomeSystemError defines model for TaskOutcomeSystemError.

type TaskOutcomeSystemErrorKind

type TaskOutcomeSystemErrorKind string

TaskOutcomeSystemErrorKind defines model for TaskOutcomeSystemError.Kind.

const (
	SystemError TaskOutcomeSystemErrorKind = "systemError"
)

Defines values for TaskOutcomeSystemErrorKind.

type TaskOutcomeTimeout

type TaskOutcomeTimeout struct {
	Kind    TaskOutcomeTimeoutKind `json:"kind"`
	Timeout TimeoutPayload         `json:"timeout"`
}

TaskOutcomeTimeout defines model for TaskOutcomeTimeout.

type TaskOutcomeTimeoutKind

type TaskOutcomeTimeoutKind string

TaskOutcomeTimeoutKind defines model for TaskOutcomeTimeout.Kind.

const (
	Timeout TaskOutcomeTimeoutKind = "timeout"
)

Defines values for TaskOutcomeTimeoutKind.

type TaskWait

type TaskWait struct {
	InputHash     string `json:"inputHash"`
	InputOrdinal  int64  `json:"inputOrdinal"`
	OutputOrdinal int64  `json:"outputOrdinal"`
	ResumeJobType string `json:"resumeJobType"`
}

TaskWait defines model for TaskWait.

type TenantId

type TenantId = string

TenantId defines model for TenantId.

type TimeoutPayload

type TimeoutPayload struct {
	After     string          `json:"after"`
	Code      *string         `json:"code,omitempty"`
	Component *string         `json:"component,omitempty"`
	InputRef  *InputReference `json:"inputRef,omitempty"`
	Kind      *string         `json:"kind,omitempty"`
	Message   *string         `json:"message,omitempty"`
	Retryable bool            `json:"retryable"`
	Scope     string          `json:"scope"`
}

TimeoutPayload defines model for TimeoutPayload.

type TooManyValuesForParamError

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

func (*TooManyValuesForParamError) Error

type TriggerSchedule200JSONResponse

type TriggerSchedule200JSONResponse JobHandle

func (TriggerSchedule200JSONResponse) VisitTriggerScheduleResponse

func (response TriggerSchedule200JSONResponse) VisitTriggerScheduleResponse(w http.ResponseWriter) error

type TriggerScheduleHTTPResponse

type TriggerScheduleHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *JobHandle
}

func ParseTriggerScheduleHTTPResponse

func ParseTriggerScheduleHTTPResponse(rsp *http.Response) (*TriggerScheduleHTTPResponse, error)

ParseTriggerScheduleHTTPResponse parses an HTTP response from a TriggerScheduleWithResponse call

func (TriggerScheduleHTTPResponse) Status

Status returns HTTPResponse.Status

func (TriggerScheduleHTTPResponse) StatusCode

func (r TriggerScheduleHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type TriggerScheduleJSONRequestBody

type TriggerScheduleJSONRequestBody = TriggerScheduleRequest

TriggerScheduleJSONRequestBody defines body for TriggerSchedule for application/json ContentType.

type TriggerScheduleRequest

type TriggerScheduleRequest struct {
	RequestId   *string    `json:"requestId,omitempty"`
	RequestTime *time.Time `json:"requestTime,omitempty"`
	WorkerId    *string    `json:"workerId,omitempty"`
}

TriggerScheduleRequest defines model for TriggerScheduleRequest.

type TriggerScheduleRequestObject

type TriggerScheduleRequestObject struct {
	TenantId   TenantId   `json:"tenantId"`
	ScheduleId ScheduleId `json:"scheduleId"`
	Body       *TriggerScheduleJSONRequestBody
}

type TriggerScheduleResponseObject

type TriggerScheduleResponseObject interface {
	VisitTriggerScheduleResponse(w http.ResponseWriter) error
}

type UnescapedCookieParamError

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

func (*UnescapedCookieParamError) Error

func (e *UnescapedCookieParamError) Error() string

func (*UnescapedCookieParamError) Unwrap

func (e *UnescapedCookieParamError) Unwrap() error

type Unimplemented

type Unimplemented struct{}

func (Unimplemented) AddChapterWithLease

func (_ Unimplemented) AddChapterWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params AddChapterWithLeaseParams)

Add chapter with lease (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/add_chapter)

func (Unimplemented) ArchiveJobSchema added in v0.0.9

func (_ Unimplemented) ArchiveJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId, schemaHash JobSchemaHash)

Archive job schema (POST /v1/tenants/{tenantId}/schemas/{schemaHash}/archive)

func (Unimplemented) ArchiveSchedule

func (_ Unimplemented) ArchiveSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)

Archive schedule (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/archive)

func (Unimplemented) CancelJob

func (_ Unimplemented) CancelJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)

Cancel job (POST /v1/tenants/{tenantId}/jobs/{jobId}/cancel)

func (Unimplemented) CommitChapterIfWaiting

func (_ Unimplemented) CommitChapterIfWaiting(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ordinal Ordinal)

Commit chapter if waiting (POST /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal}/commit-if-waiting)

func (Unimplemented) CompleteJobWithLease

func (_ Unimplemented) CompleteJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params CompleteJobWithLeaseParams)

Complete job with lease (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/complete)

func (Unimplemented) GetChapter

func (_ Unimplemented) GetChapter(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ordinal Ordinal)

Get chapter (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal})

func (Unimplemented) GetConfigurationWithLease added in v0.0.33

func (_ Unimplemented) GetConfigurationWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params GetConfigurationWithLeaseParams)

Read current tenant configuration using a live lease (GET /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/configuration)

func (Unimplemented) GetJob

func (_ Unimplemented) GetJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)

Get job (GET /v1/tenants/{tenantId}/jobs/{jobId})

func (Unimplemented) GetJobLease

func (_ Unimplemented) GetJobLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)

Get job lease (POST /v1/tenants/{tenantId}/jobs/{jobId}/lease)

func (Unimplemented) GetJobSchema added in v0.0.9

func (_ Unimplemented) GetJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId, schemaHash JobSchemaHash)

Get job schema (GET /v1/tenants/{tenantId}/schemas/{schemaHash})

func (Unimplemented) GetSchedule

func (_ Unimplemented) GetSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)

Get schedule (GET /v1/tenants/{tenantId}/schedules/{scheduleId})

func (Unimplemented) GetTenantConfiguration added in v0.0.33

func (_ Unimplemented) GetTenantConfiguration(w http.ResponseWriter, r *http.Request, tenantId TenantId)

Read the complete tenant configuration (GET /v1/tenants/{tenantId}/configuration)

func (Unimplemented) KeepAliveLease

func (_ Unimplemented) KeepAliveLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params KeepAliveLeaseParams)

Keep lease alive (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/keepalive)

func (Unimplemented) ListChapters

func (_ Unimplemented) ListChapters(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, params ListChaptersParams)

List chapters (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters)

func (Unimplemented) ListJobSchemas added in v0.0.9

func (_ Unimplemented) ListJobSchemas(w http.ResponseWriter, r *http.Request, tenantId TenantId, params ListJobSchemasParams)

List job schemas (GET /v1/tenants/{tenantId}/schemas)

func (Unimplemented) ListJobs

func (_ Unimplemented) ListJobs(w http.ResponseWriter, r *http.Request, tenantId TenantId)

List jobs (POST /v1/tenants/{tenantId}/jobs/query)

func (Unimplemented) ListScheduleRuns

func (_ Unimplemented) ListScheduleRuns(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)

List schedule runs (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/runs/query)

func (Unimplemented) ListSchedules

func (_ Unimplemented) ListSchedules(w http.ResponseWriter, r *http.Request, tenantId TenantId)

List schedules (POST /v1/tenants/{tenantId}/schedules/query)

func (Unimplemented) OpenArtifact

func (_ Unimplemented) OpenArtifact(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ordinal Ordinal, name ArtifactName)

Open artifact (GET /v1/tenants/{tenantId}/jobs/{jobId}/chapters/{ordinal}/artifacts/{name})

func (Unimplemented) PauseSchedule

func (_ Unimplemented) PauseSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)

Pause schedule (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/pause)

func (Unimplemented) PollWork

func (_ Unimplemented) PollWork(w http.ResponseWriter, r *http.Request)

Poll work (POST /v1/jobs/poll)

func (Unimplemented) PutJob

func (_ Unimplemented) PutJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)

Submit job with explicit job ID (PUT /v1/tenants/{tenantId}/jobs/{jobId})

func (Unimplemented) PutJobWithLease added in v0.0.13

func (_ Unimplemented) PutJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params PutJobWithLeaseParams)

Submit child job with explicit job ID and lease (PUT /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/{childJobId})

func (Unimplemented) PutRestartJob

func (_ Unimplemented) PutRestartJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)

Submit restart job with explicit job ID (PUT /v1/tenants/{tenantId}/jobs/{jobId}/restart)

func (Unimplemented) PutRestartJobWithLease added in v0.0.13

func (_ Unimplemented) PutRestartJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, childJobId ChildJobId, params PutRestartJobWithLeaseParams)

Submit child restart job with explicit job ID and lease (PUT /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/{childJobId}/restart)

func (Unimplemented) RegisterJobSchema added in v0.0.9

func (_ Unimplemented) RegisterJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId)

Register job schema (POST /v1/tenants/{tenantId}/schemas)

func (Unimplemented) RemoveTenantConfigurationValue added in v0.0.33

func (_ Unimplemented) RemoveTenantConfigurationValue(w http.ResponseWriter, r *http.Request, tenantId TenantId, params RemoveTenantConfigurationValueParams)

Remove one tenant configuration value (POST /v1/tenants/{tenantId}/configuration/remove)

func (Unimplemented) RescheduleJobWithLease

func (_ Unimplemented) RescheduleJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params RescheduleJobWithLeaseParams)

Reschedule job with lease (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/reschedule)

func (Unimplemented) ResolveSecretsWithLease added in v0.0.29

func (_ Unimplemented) ResolveSecretsWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, leaseId LeaseId, params ResolveSecretsWithLeaseParams)

Resolve the allowed subset of requested job secrets (POST /v1/tenants/{tenantId}/jobs/{jobId}/leases/{leaseId}/secrets/resolve)

func (Unimplemented) ResumeSchedule

func (_ Unimplemented) ResumeSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)

Resume schedule (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/resume)

func (Unimplemented) SetTenantConfigurationValue added in v0.0.33

func (_ Unimplemented) SetTenantConfigurationValue(w http.ResponseWriter, r *http.Request, tenantId TenantId, params SetTenantConfigurationValueParams)

Set one tenant configuration value (POST /v1/tenants/{tenantId}/configuration/set)

func (Unimplemented) SubmitJob

func (_ Unimplemented) SubmitJob(w http.ResponseWriter, r *http.Request, tenantId TenantId)

Submit job (POST /v1/tenants/{tenantId}/jobs)

func (Unimplemented) SubmitJobWithLease added in v0.0.13

func (_ Unimplemented) SubmitJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params SubmitJobWithLeaseParams)

Submit child job with lease (POST /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs)

func (Unimplemented) SubmitRestartJob

func (_ Unimplemented) SubmitRestartJob(w http.ResponseWriter, r *http.Request, tenantId TenantId)

Submit restart job (POST /v1/tenants/{tenantId}/jobs/restarts)

func (Unimplemented) SubmitRestartJobWithLease added in v0.0.13

func (_ Unimplemented) SubmitRestartJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, params SubmitRestartJobWithLeaseParams)

Submit child restart job with lease (POST /v1/tenants/{tenantId}/jobs/{parentJobId}/leases/{leaseId}/jobs/restarts)

func (Unimplemented) TriggerSchedule

func (_ Unimplemented) TriggerSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)

Trigger schedule now (POST /v1/tenants/{tenantId}/schedules/{scheduleId}/trigger)

func (Unimplemented) UpsertSchedule

func (_ Unimplemented) UpsertSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, scheduleId ScheduleId)

Upsert schedule (PUT /v1/tenants/{tenantId}/schedules/{scheduleId})

type UnmarshalingParamError

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}

func (*UnmarshalingParamError) Error

func (e *UnmarshalingParamError) Error() string

func (*UnmarshalingParamError) Unwrap

func (e *UnmarshalingParamError) Unwrap() error

type UpsertSchedule200JSONResponse

type UpsertSchedule200JSONResponse ScheduleInfo

func (UpsertSchedule200JSONResponse) VisitUpsertScheduleResponse

func (response UpsertSchedule200JSONResponse) VisitUpsertScheduleResponse(w http.ResponseWriter) error

type UpsertSchedule409Response

type UpsertSchedule409Response struct {
}

func (UpsertSchedule409Response) VisitUpsertScheduleResponse

func (response UpsertSchedule409Response) VisitUpsertScheduleResponse(w http.ResponseWriter) error

type UpsertScheduleHTTPResponse

type UpsertScheduleHTTPResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *ScheduleInfo
}

func ParseUpsertScheduleHTTPResponse

func ParseUpsertScheduleHTTPResponse(rsp *http.Response) (*UpsertScheduleHTTPResponse, error)

ParseUpsertScheduleHTTPResponse parses an HTTP response from a UpsertScheduleWithResponse call

func (UpsertScheduleHTTPResponse) Status

Status returns HTTPResponse.Status

func (UpsertScheduleHTTPResponse) StatusCode

func (r UpsertScheduleHTTPResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpsertScheduleJSONRequestBody

type UpsertScheduleJSONRequestBody = UpsertScheduleRequest

UpsertScheduleJSONRequestBody defines body for UpsertSchedule for application/json ContentType.

type UpsertScheduleRequest

type UpsertScheduleRequest struct {
	ExpectedGeneration *int64                 `json:"expectedGeneration,omitempty"`
	FailurePolicy      *ScheduleFailurePolicy `json:"failurePolicy,omitempty"`
	OverlapPolicy      *ScheduleOverlapPolicy `json:"overlapPolicy,omitempty"`
	Paused             *bool                  `json:"paused,omitempty"`
	RequestTime        *time.Time             `json:"requestTime,omitempty"`
	Target             ScheduleTarget         `json:"target"`
	Trigger            ScheduleTrigger        `json:"trigger"`
	WorkerId           *string                `json:"workerId,omitempty"`
}

UpsertScheduleRequest defines model for UpsertScheduleRequest.

type UpsertScheduleRequestObject

type UpsertScheduleRequestObject struct {
	TenantId   TenantId   `json:"tenantId"`
	ScheduleId ScheduleId `json:"scheduleId"`
	Body       *UpsertScheduleJSONRequestBody
}

type UpsertScheduleResponseObject

type UpsertScheduleResponseObject interface {
	VisitUpsertScheduleResponse(w http.ResponseWriter) error
}

Jump to

Keyboard shortcuts

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