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
- func Handler(si ServerInterface) http.Handler
- func HandlerFromMux(si ServerInterface, r chi.Router) http.Handler
- func HandlerFromMuxWithBaseURL(si ServerInterface, r chi.Router, baseURL string) http.Handler
- func HandlerWithOptions(si ServerInterface, options ChiServerOptions) http.Handler
- func NewAddChapterWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewAddChapterWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewArchiveJobSchemaRequest(server string, tenantId TenantId, schemaHash JobSchemaHash) (*http.Request, error)
- func NewArchiveScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Request, error)
- func NewArchiveScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, ...) (*http.Request, error)
- func NewCancelJobRequest(server string, tenantId TenantId, jobId JobId, body CancelJobJSONRequestBody) (*http.Request, error)
- func NewCancelJobRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Request, error)
- func NewCommitChapterIfWaitingRequest(server string, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*http.Request, error)
- func NewCommitChapterIfWaitingRequestWithBody(server string, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*http.Request, error)
- func NewCompleteJobWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewCompleteJobWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewGetChapterRequest(server string, tenantId TenantId, jobId JobId, ordinal Ordinal) (*http.Request, error)
- func NewGetConfigurationWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewGetJobLeaseRequest(server string, tenantId TenantId, jobId JobId, body GetJobLeaseJSONRequestBody) (*http.Request, error)
- func NewGetJobLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Request, error)
- func NewGetJobRequest(server string, tenantId TenantId, jobId JobId) (*http.Request, error)
- func NewGetJobSchemaRequest(server string, tenantId TenantId, schemaHash JobSchemaHash) (*http.Request, error)
- func NewGetScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId) (*http.Request, error)
- func NewGetTenantConfigurationRequest(server string, tenantId TenantId) (*http.Request, error)
- func NewKeepAliveLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewListChaptersRequest(server string, tenantId TenantId, jobId JobId, params *ListChaptersParams) (*http.Request, error)
- func NewListJobSchemasRequest(server string, tenantId TenantId, params *ListJobSchemasParams) (*http.Request, error)
- func NewListJobsRequest(server string, tenantId TenantId, body ListJobsJSONRequestBody) (*http.Request, error)
- func NewListJobsRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)
- func NewListScheduleRunsRequest(server string, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Request, error)
- func NewListScheduleRunsRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, ...) (*http.Request, error)
- func NewListSchedulesRequest(server string, tenantId TenantId, body ListSchedulesJSONRequestBody) (*http.Request, error)
- func NewListSchedulesRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)
- func NewOpenArtifactRequest(server string, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*http.Request, error)
- func NewPauseScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Request, error)
- func NewPauseScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, ...) (*http.Request, error)
- func NewPollWorkRequest(server string, body PollWorkJSONRequestBody) (*http.Request, error)
- func NewPollWorkRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)
- func NewPutJobRequest(server string, tenantId TenantId, jobId JobId, body PutJobJSONRequestBody) (*http.Request, error)
- func NewPutJobRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Request, error)
- func NewPutJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewPutJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewPutRestartJobRequest(server string, tenantId TenantId, jobId JobId, ...) (*http.Request, error)
- func NewPutRestartJobRequestWithBody(server string, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Request, error)
- func NewPutRestartJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewPutRestartJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewRegisterJobSchemaRequest(server string, tenantId TenantId, body RegisterJobSchemaJSONRequestBody) (*http.Request, error)
- func NewRegisterJobSchemaRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)
- func NewRemoveTenantConfigurationValueRequest(server string, tenantId TenantId, params *RemoveTenantConfigurationValueParams, ...) (*http.Request, error)
- func NewRemoveTenantConfigurationValueRequestWithBody(server string, tenantId TenantId, params *RemoveTenantConfigurationValueParams, ...) (*http.Request, error)
- func NewRescheduleJobWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewRescheduleJobWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewResolveSecretsWithLeaseRequest(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewResolveSecretsWithLeaseRequestWithBody(server string, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewResumeScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Request, error)
- func NewResumeScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, ...) (*http.Request, error)
- func NewSetTenantConfigurationValueRequest(server string, tenantId TenantId, params *SetTenantConfigurationValueParams, ...) (*http.Request, error)
- func NewSetTenantConfigurationValueRequestWithBody(server string, tenantId TenantId, params *SetTenantConfigurationValueParams, ...) (*http.Request, error)
- func NewSubmitJobRequest(server string, tenantId TenantId, body SubmitJobJSONRequestBody) (*http.Request, error)
- func NewSubmitJobRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)
- func NewSubmitJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewSubmitJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewSubmitRestartJobRequest(server string, tenantId TenantId, body SubmitRestartJobJSONRequestBody) (*http.Request, error)
- func NewSubmitRestartJobRequestWithBody(server string, tenantId TenantId, contentType string, body io.Reader) (*http.Request, error)
- func NewSubmitRestartJobWithLeaseRequest(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewSubmitRestartJobWithLeaseRequestWithBody(server string, tenantId TenantId, parentJobId ParentJobId, leaseId LeaseId, ...) (*http.Request, error)
- func NewTriggerScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Request, error)
- func NewTriggerScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, ...) (*http.Request, error)
- func NewUpsertScheduleRequest(server string, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Request, error)
- func NewUpsertScheduleRequestWithBody(server string, tenantId TenantId, scheduleId ScheduleId, contentType string, ...) (*http.Request, error)
- type AddChapterRequest
- type AddChapterWithLease204Response
- type AddChapterWithLease409Response
- type AddChapterWithLeaseHTTPResponse
- type AddChapterWithLeaseJSONRequestBody
- type AddChapterWithLeaseParams
- type AddChapterWithLeaseRequestObject
- type AddChapterWithLeaseResponseObject
- type AppErrorPayload
- type ApplicationPayload
- type ArchiveJobSchema200JSONResponse
- type ArchiveJobSchemaHTTPResponse
- type ArchiveJobSchemaRequestObject
- type ArchiveJobSchemaResponseObject
- type ArchiveSchedule200JSONResponse
- type ArchiveScheduleHTTPResponse
- type ArchiveScheduleJSONRequestBody
- type ArchiveScheduleRequestObject
- type ArchiveScheduleResponseObject
- type ArtifactName
- type ArtifactUpload
- type ArtifactWrite
- type CancelJob204Response
- type CancelJobHTTPResponse
- type CancelJobJSONRequestBody
- type CancelJobRequest
- type CancelJobRequestObject
- type CancelJobResponseObject
- type ChapterBody
- func (t ChapterBody) AsExecutionChapter() (ExecutionChapter, error)
- func (t ChapterBody) AsJobAttemptOutcomeChapter() (JobAttemptOutcomeChapter, error)
- func (t ChapterBody) AsJobStartChapter() (JobStartChapter, error)
- func (t ChapterBody) AsRestartExtraChapter() (RestartExtraChapter, error)
- func (t ChapterBody) AsTaskAttemptOutcomeChapter() (TaskAttemptOutcomeChapter, error)
- func (t ChapterBody) Discriminator() (string, error)
- func (t *ChapterBody) FromExecutionChapter(v ExecutionChapter) error
- func (t *ChapterBody) FromJobAttemptOutcomeChapter(v JobAttemptOutcomeChapter) error
- func (t *ChapterBody) FromJobStartChapter(v JobStartChapter) error
- func (t *ChapterBody) FromRestartExtraChapter(v RestartExtraChapter) error
- func (t *ChapterBody) FromTaskAttemptOutcomeChapter(v TaskAttemptOutcomeChapter) error
- func (t ChapterBody) MarshalJSON() ([]byte, error)
- func (t *ChapterBody) MergeExecutionChapter(v ExecutionChapter) error
- func (t *ChapterBody) MergeJobAttemptOutcomeChapter(v JobAttemptOutcomeChapter) error
- func (t *ChapterBody) MergeJobStartChapter(v JobStartChapter) error
- func (t *ChapterBody) MergeRestartExtraChapter(v RestartExtraChapter) error
- func (t *ChapterBody) MergeTaskAttemptOutcomeChapter(v TaskAttemptOutcomeChapter) error
- func (t *ChapterBody) UnmarshalJSON(b []byte) error
- func (t ChapterBody) ValueByDiscriminator() (interface{}, error)
- type ChapterRecord
- type ChiServerOptions
- type ChildJobId
- type Client
- func (c *Client) AddChapterWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) AddChapterWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) ArchiveJobSchema(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, ...) (*http.Response, error)
- func (c *Client) ArchiveSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) ArchiveScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) CancelJob(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*http.Response, error)
- func (c *Client) CancelJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Response, error)
- func (c *Client) CommitChapterIfWaiting(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*http.Response, error)
- func (c *Client) CommitChapterIfWaitingWithBody(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*http.Response, error)
- func (c *Client) CompleteJobWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) CompleteJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) GetChapter(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*http.Response, error)
- func (c *Client) GetConfigurationWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) GetJob(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*http.Response, error)
- func (c *Client) GetJobLease(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*http.Response, error)
- func (c *Client) GetJobLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Response, error)
- func (c *Client) GetJobSchema(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, ...) (*http.Response, error)
- func (c *Client) GetSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) GetTenantConfiguration(ctx context.Context, tenantId TenantId, reqEditors ...RequestEditorFn) (*http.Response, error)
- func (c *Client) KeepAliveLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) ListChapters(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*http.Response, error)
- func (c *Client) ListJobSchemas(ctx context.Context, tenantId TenantId, params *ListJobSchemasParams, ...) (*http.Response, error)
- func (c *Client) ListJobs(ctx context.Context, tenantId TenantId, body ListJobsJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) ListJobsWithBody(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) ListScheduleRuns(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) ListScheduleRunsWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) ListSchedules(ctx context.Context, tenantId TenantId, body ListSchedulesJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) ListSchedulesWithBody(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) OpenArtifact(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*http.Response, error)
- func (c *Client) PauseSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) PauseScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) PollWork(ctx context.Context, body PollWorkJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) PollWorkWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) PutJob(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*http.Response, error)
- func (c *Client) PutJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Response, error)
- func (c *Client) PutJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) PutJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) PutRestartJob(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*http.Response, error)
- func (c *Client) PutRestartJobWithBody(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*http.Response, error)
- func (c *Client) PutRestartJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) PutRestartJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) RegisterJobSchema(ctx context.Context, tenantId TenantId, body RegisterJobSchemaJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) RegisterJobSchemaWithBody(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) RemoveTenantConfigurationValue(ctx context.Context, tenantId TenantId, ...) (*http.Response, error)
- func (c *Client) RemoveTenantConfigurationValueWithBody(ctx context.Context, tenantId TenantId, ...) (*http.Response, error)
- func (c *Client) RescheduleJobWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) RescheduleJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) ResolveSecretsWithLease(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) ResolveSecretsWithLeaseWithBody(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*http.Response, error)
- func (c *Client) ResumeSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) ResumeScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) SetTenantConfigurationValue(ctx context.Context, tenantId TenantId, ...) (*http.Response, error)
- func (c *Client) SetTenantConfigurationValueWithBody(ctx context.Context, tenantId TenantId, ...) (*http.Response, error)
- func (c *Client) SubmitJob(ctx context.Context, tenantId TenantId, body SubmitJobJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) SubmitJobWithBody(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) SubmitJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) SubmitJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) SubmitRestartJob(ctx context.Context, tenantId TenantId, body SubmitRestartJobJSONRequestBody, ...) (*http.Response, error)
- func (c *Client) SubmitRestartJobWithBody(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*http.Response, error)
- func (c *Client) SubmitRestartJobWithLease(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) SubmitRestartJobWithLeaseWithBody(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*http.Response, error)
- func (c *Client) TriggerSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) TriggerScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) UpsertSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- func (c *Client) UpsertScheduleWithBody(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*http.Response, error)
- type ClientInterface
- type ClientOption
- type ClientPayloadUpdate
- type ClientWithResponses
- func (c *ClientWithResponses) AddChapterWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*AddChapterWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) AddChapterWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*AddChapterWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) ArchiveJobSchemaWithResponse(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, ...) (*ArchiveJobSchemaHTTPResponse, error)
- func (c *ClientWithResponses) ArchiveScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*ArchiveScheduleHTTPResponse, error)
- func (c *ClientWithResponses) ArchiveScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*ArchiveScheduleHTTPResponse, error)
- func (c *ClientWithResponses) CancelJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*CancelJobHTTPResponse, error)
- func (c *ClientWithResponses) CancelJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*CancelJobHTTPResponse, error)
- func (c *ClientWithResponses) CommitChapterIfWaitingWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*CommitChapterIfWaitingHTTPResponse, error)
- func (c *ClientWithResponses) CommitChapterIfWaitingWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*CommitChapterIfWaitingHTTPResponse, error)
- func (c *ClientWithResponses) CompleteJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*CompleteJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) CompleteJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*CompleteJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) GetChapterWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*GetChapterHTTPResponse, error)
- func (c *ClientWithResponses) GetConfigurationWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*GetConfigurationWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) GetJobLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*GetJobLeaseHTTPResponse, error)
- func (c *ClientWithResponses) GetJobLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*GetJobLeaseHTTPResponse, error)
- func (c *ClientWithResponses) GetJobSchemaWithResponse(ctx context.Context, tenantId TenantId, schemaHash JobSchemaHash, ...) (*GetJobSchemaHTTPResponse, error)
- func (c *ClientWithResponses) GetJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*GetJobHTTPResponse, error)
- func (c *ClientWithResponses) GetScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*GetScheduleHTTPResponse, error)
- func (c *ClientWithResponses) GetTenantConfigurationWithResponse(ctx context.Context, tenantId TenantId, reqEditors ...RequestEditorFn) (*GetTenantConfigurationHTTPResponse, error)
- func (c *ClientWithResponses) KeepAliveLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*KeepAliveLeaseHTTPResponse, error)
- func (c *ClientWithResponses) ListChaptersWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*ListChaptersHTTPResponse, error)
- func (c *ClientWithResponses) ListJobSchemasWithResponse(ctx context.Context, tenantId TenantId, params *ListJobSchemasParams, ...) (*ListJobSchemasHTTPResponse, error)
- func (c *ClientWithResponses) ListJobsWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*ListJobsHTTPResponse, error)
- func (c *ClientWithResponses) ListJobsWithResponse(ctx context.Context, tenantId TenantId, body ListJobsJSONRequestBody, ...) (*ListJobsHTTPResponse, error)
- func (c *ClientWithResponses) ListScheduleRunsWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*ListScheduleRunsHTTPResponse, error)
- func (c *ClientWithResponses) ListScheduleRunsWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*ListScheduleRunsHTTPResponse, error)
- func (c *ClientWithResponses) ListSchedulesWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*ListSchedulesHTTPResponse, error)
- func (c *ClientWithResponses) ListSchedulesWithResponse(ctx context.Context, tenantId TenantId, body ListSchedulesJSONRequestBody, ...) (*ListSchedulesHTTPResponse, error)
- func (c *ClientWithResponses) OpenArtifactWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ordinal Ordinal, ...) (*OpenArtifactHTTPResponse, error)
- func (c *ClientWithResponses) PauseScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*PauseScheduleHTTPResponse, error)
- func (c *ClientWithResponses) PauseScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*PauseScheduleHTTPResponse, error)
- func (c *ClientWithResponses) PollWorkWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*PollWorkHTTPResponse, error)
- func (c *ClientWithResponses) PollWorkWithResponse(ctx context.Context, body PollWorkJSONRequestBody, ...) (*PollWorkHTTPResponse, error)
- func (c *ClientWithResponses) PutJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*PutJobHTTPResponse, error)
- func (c *ClientWithResponses) PutJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*PutJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) PutJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*PutJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) PutJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*PutJobHTTPResponse, error)
- func (c *ClientWithResponses) PutRestartJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, contentType string, ...) (*PutRestartJobHTTPResponse, error)
- func (c *ClientWithResponses) PutRestartJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*PutRestartJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) PutRestartJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*PutRestartJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) PutRestartJobWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, ...) (*PutRestartJobHTTPResponse, error)
- func (c *ClientWithResponses) RegisterJobSchemaWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*RegisterJobSchemaHTTPResponse, error)
- func (c *ClientWithResponses) RegisterJobSchemaWithResponse(ctx context.Context, tenantId TenantId, body RegisterJobSchemaJSONRequestBody, ...) (*RegisterJobSchemaHTTPResponse, error)
- func (c *ClientWithResponses) RemoveTenantConfigurationValueWithBodyWithResponse(ctx context.Context, tenantId TenantId, ...) (*RemoveTenantConfigurationValueHTTPResponse, error)
- func (c *ClientWithResponses) RemoveTenantConfigurationValueWithResponse(ctx context.Context, tenantId TenantId, ...) (*RemoveTenantConfigurationValueHTTPResponse, error)
- func (c *ClientWithResponses) RescheduleJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*RescheduleJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) RescheduleJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*RescheduleJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) ResolveSecretsWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*ResolveSecretsWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) ResolveSecretsWithLeaseWithResponse(ctx context.Context, tenantId TenantId, jobId JobId, leaseId LeaseId, ...) (*ResolveSecretsWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) ResumeScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*ResumeScheduleHTTPResponse, error)
- func (c *ClientWithResponses) ResumeScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*ResumeScheduleHTTPResponse, error)
- func (c *ClientWithResponses) SetTenantConfigurationValueWithBodyWithResponse(ctx context.Context, tenantId TenantId, ...) (*SetTenantConfigurationValueHTTPResponse, error)
- func (c *ClientWithResponses) SetTenantConfigurationValueWithResponse(ctx context.Context, tenantId TenantId, ...) (*SetTenantConfigurationValueHTTPResponse, error)
- func (c *ClientWithResponses) SubmitJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*SubmitJobHTTPResponse, error)
- func (c *ClientWithResponses) SubmitJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*SubmitJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) SubmitJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*SubmitJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) SubmitJobWithResponse(ctx context.Context, tenantId TenantId, body SubmitJobJSONRequestBody, ...) (*SubmitJobHTTPResponse, error)
- func (c *ClientWithResponses) SubmitRestartJobWithBodyWithResponse(ctx context.Context, tenantId TenantId, contentType string, body io.Reader, ...) (*SubmitRestartJobHTTPResponse, error)
- func (c *ClientWithResponses) SubmitRestartJobWithLeaseWithBodyWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*SubmitRestartJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) SubmitRestartJobWithLeaseWithResponse(ctx context.Context, tenantId TenantId, parentJobId ParentJobId, ...) (*SubmitRestartJobWithLeaseHTTPResponse, error)
- func (c *ClientWithResponses) SubmitRestartJobWithResponse(ctx context.Context, tenantId TenantId, body SubmitRestartJobJSONRequestBody, ...) (*SubmitRestartJobHTTPResponse, error)
- func (c *ClientWithResponses) TriggerScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*TriggerScheduleHTTPResponse, error)
- func (c *ClientWithResponses) TriggerScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*TriggerScheduleHTTPResponse, error)
- func (c *ClientWithResponses) UpsertScheduleWithBodyWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*UpsertScheduleHTTPResponse, error)
- func (c *ClientWithResponses) UpsertScheduleWithResponse(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, ...) (*UpsertScheduleHTTPResponse, error)
- type ClientWithResponsesInterface
- type CommitChapterIfWaiting204Response
- type CommitChapterIfWaiting409Response
- type CommitChapterIfWaitingHTTPResponse
- type CommitChapterIfWaitingJSONRequestBody
- type CommitChapterIfWaitingRequest
- type CommitChapterIfWaitingRequestObject
- type CommitChapterIfWaitingResponseObject
- type CompleteExecutionRequest
- type CompleteJobWithLease204Response
- type CompleteJobWithLeaseHTTPResponse
- type CompleteJobWithLeaseJSONRequestBody
- type CompleteJobWithLeaseParams
- type CompleteJobWithLeaseRequestObject
- type CompleteJobWithLeaseResponseObject
- type ConfigurationSnapshot
- type EndOrdinal
- type ErrorCode
- type ErrorResponse
- type ExecutionChapter
- type ExecutionChapterKind
- type ExecutionLease
- type ExecutionRestart
- type ExecutionState
- type GetChapter200JSONResponse
- type GetChapterHTTPResponse
- type GetChapterRequestObject
- type GetChapterResponseObject
- type GetConfigurationWithLease200JSONResponse
- type GetConfigurationWithLease200ResponseHeaders
- type GetConfigurationWithLease400JSONResponse
- type GetConfigurationWithLease400ResponseHeaders
- type GetConfigurationWithLease401JSONResponse
- type GetConfigurationWithLease401ResponseHeaders
- type GetConfigurationWithLease403JSONResponse
- type GetConfigurationWithLease403ResponseHeaders
- type GetConfigurationWithLease409JSONResponse
- type GetConfigurationWithLease409ResponseHeaders
- type GetConfigurationWithLease413JSONResponse
- type GetConfigurationWithLease413ResponseHeaders
- type GetConfigurationWithLease500JSONResponse
- type GetConfigurationWithLease500ResponseHeaders
- type GetConfigurationWithLease503JSONResponse
- type GetConfigurationWithLease503ResponseHeaders
- type GetConfigurationWithLeaseHTTPResponse
- type GetConfigurationWithLeaseParams
- type GetConfigurationWithLeaseRequestObject
- type GetConfigurationWithLeaseResponseObject
- type GetJob200JSONResponse
- type GetJobHTTPResponse
- type GetJobLease200JSONResponse
- type GetJobLeaseHTTPResponse
- type GetJobLeaseJSONRequestBody
- type GetJobLeaseRequest
- type GetJobLeaseRequestObject
- type GetJobLeaseResponse
- type GetJobLeaseResponseObject
- type GetJobRequestObject
- type GetJobResponseObject
- type GetJobSchema200JSONResponse
- type GetJobSchemaHTTPResponse
- type GetJobSchemaRequestObject
- type GetJobSchemaResponseObject
- type GetSchedule200JSONResponse
- type GetScheduleHTTPResponse
- type GetScheduleRequestObject
- type GetScheduleResponseObject
- type GetTenantConfiguration200JSONResponse
- type GetTenantConfiguration200ResponseHeaders
- type GetTenantConfiguration400JSONResponse
- type GetTenantConfiguration400ResponseHeaders
- type GetTenantConfiguration401JSONResponse
- type GetTenantConfiguration401ResponseHeaders
- type GetTenantConfiguration403JSONResponse
- type GetTenantConfiguration403ResponseHeaders
- type GetTenantConfiguration413JSONResponse
- type GetTenantConfiguration413ResponseHeaders
- type GetTenantConfiguration500JSONResponse
- type GetTenantConfiguration500ResponseHeaders
- type GetTenantConfiguration503JSONResponse
- type GetTenantConfiguration503ResponseHeaders
- type GetTenantConfigurationHTTPResponse
- type GetTenantConfigurationRequestObject
- type GetTenantConfigurationResponseObject
- type HttpRequestDoer
- type InputReference
- type InvalidParamFormatError
- type JobAttemptOutcomeChapter
- type JobAttemptOutcomeChapterKind
- type JobHandle
- type JobId
- type JobInfo
- type JobKey
- type JobPrerequisite
- type JobPrerequisiteCondition
- type JobSchemaDocument
- type JobSchemaHash
- type JobSchemaInfo
- type JobSchemaListState
- type JobSchemaSelector
- type JobSchemaState
- type JobStartChapter
- type JobStartChapterKind
- type JobStatus
- type JobStore
- type JobSummary
- type JobTaskFilter
- type JsonSchemaFragment
- type KeepAliveLease200JSONResponse
- type KeepAliveLeaseHTTPResponse
- type KeepAliveLeaseParams
- type KeepAliveLeaseRequestObject
- type KeepAliveLeaseResponse
- type KeepAliveLeaseResponseObject
- type LeaseId
- type LeaseTokenHeader
- type ListChapters200JSONResponse
- type ListChaptersHTTPResponse
- type ListChaptersParams
- type ListChaptersRequestObject
- type ListChaptersResponse
- type ListChaptersResponseObject
- type ListJobSchemas200JSONResponse
- type ListJobSchemasHTTPResponse
- type ListJobSchemasParams
- type ListJobSchemasRequestObject
- type ListJobSchemasResponse
- type ListJobSchemasResponseObject
- type ListJobs200JSONResponse
- type ListJobsHTTPResponse
- type ListJobsJSONRequestBody
- type ListJobsRequest
- type ListJobsRequestObject
- type ListJobsResponse
- type ListJobsResponseObject
- type ListScheduleRuns200JSONResponse
- type ListScheduleRunsHTTPResponse
- type ListScheduleRunsJSONRequestBody
- type ListScheduleRunsRequest
- type ListScheduleRunsRequestObject
- type ListScheduleRunsResponse
- type ListScheduleRunsResponseObject
- type ListSchedules200JSONResponse
- type ListSchedulesHTTPResponse
- type ListSchedulesJSONRequestBody
- type ListSchedulesRequest
- type ListSchedulesRequestObject
- type ListSchedulesResponse
- type ListSchedulesResponseObject
- type Metadata
- type MetadataBool
- type MetadataBoolKind
- type MetadataDouble
- type MetadataDoubleKind
- type MetadataInt
- type MetadataIntKind
- type MetadataList
- type MetadataListKind
- type MetadataMap
- type MetadataMapKind
- type MetadataNull
- type MetadataNullKind
- type MetadataPredicate
- type MetadataString
- type MetadataStringKind
- type MetadataValue
- func (t MetadataValue) AsMetadataBool() (MetadataBool, error)
- func (t MetadataValue) AsMetadataDouble() (MetadataDouble, error)
- func (t MetadataValue) AsMetadataInt() (MetadataInt, error)
- func (t MetadataValue) AsMetadataList() (MetadataList, error)
- func (t MetadataValue) AsMetadataMap() (MetadataMap, error)
- func (t MetadataValue) AsMetadataNull() (MetadataNull, error)
- func (t MetadataValue) AsMetadataString() (MetadataString, error)
- func (t MetadataValue) Discriminator() (string, error)
- func (t *MetadataValue) FromMetadataBool(v MetadataBool) error
- func (t *MetadataValue) FromMetadataDouble(v MetadataDouble) error
- func (t *MetadataValue) FromMetadataInt(v MetadataInt) error
- func (t *MetadataValue) FromMetadataList(v MetadataList) error
- func (t *MetadataValue) FromMetadataMap(v MetadataMap) error
- func (t *MetadataValue) FromMetadataNull(v MetadataNull) error
- func (t *MetadataValue) FromMetadataString(v MetadataString) error
- func (t MetadataValue) MarshalJSON() ([]byte, error)
- func (t *MetadataValue) MergeMetadataBool(v MetadataBool) error
- func (t *MetadataValue) MergeMetadataDouble(v MetadataDouble) error
- func (t *MetadataValue) MergeMetadataInt(v MetadataInt) error
- func (t *MetadataValue) MergeMetadataList(v MetadataList) error
- func (t *MetadataValue) MergeMetadataMap(v MetadataMap) error
- func (t *MetadataValue) MergeMetadataNull(v MetadataNull) error
- func (t *MetadataValue) MergeMetadataString(v MetadataString) error
- func (t *MetadataValue) UnmarshalJSON(b []byte) error
- func (t MetadataValue) ValueByDiscriminator() (interface{}, error)
- type MiddlewareFunc
- type OpenArtifact200ApplicationoctetStreamResponse
- type OpenArtifactHTTPResponse
- type OpenArtifactRequestObject
- type OpenArtifactResponseObject
- type Ordinal
- type ParentJobId
- type PauseSchedule200JSONResponse
- type PauseScheduleHTTPResponse
- type PauseScheduleJSONRequestBody
- type PauseScheduleRequestObject
- type PauseScheduleResponseObject
- type PollWork200JSONResponse
- type PollWorkHTTPResponse
- type PollWorkJSONRequestBody
- type PollWorkRequest
- type PollWorkRequestObject
- type PollWorkResponseObject
- type PutJob200JSONResponse
- type PutJob409JSONResponse
- type PutJobHTTPResponse
- type PutJobJSONRequestBody
- type PutJobRequestObject
- type PutJobResponseObject
- type PutJobWithLease200JSONResponse
- type PutJobWithLease409JSONResponse
- type PutJobWithLeaseHTTPResponse
- type PutJobWithLeaseJSONRequestBody
- type PutJobWithLeaseParams
- type PutJobWithLeaseRequestObject
- type PutJobWithLeaseResponseObject
- type PutRestartJob200JSONResponse
- type PutRestartJob409JSONResponse
- type PutRestartJobHTTPResponse
- type PutRestartJobJSONRequestBody
- type PutRestartJobRequestObject
- type PutRestartJobResponseObject
- type PutRestartJobWithLease200JSONResponse
- type PutRestartJobWithLease409JSONResponse
- type PutRestartJobWithLeaseHTTPResponse
- type PutRestartJobWithLeaseJSONRequestBody
- type PutRestartJobWithLeaseParams
- type PutRestartJobWithLeaseRequestObject
- type PutRestartJobWithLeaseResponseObject
- type RegisterJobSchema200JSONResponse
- type RegisterJobSchema409JSONResponse
- type RegisterJobSchemaHTTPResponse
- type RegisterJobSchemaJSONRequestBody
- type RegisterJobSchemaRequest
- type RegisterJobSchemaRequestObject
- type RegisterJobSchemaResponseObject
- type RemoveConfigurationBody
- type RemoveTenantConfigurationValue204Response
- type RemoveTenantConfigurationValue204ResponseHeaders
- type RemoveTenantConfigurationValue400JSONResponse
- type RemoveTenantConfigurationValue400ResponseHeaders
- type RemoveTenantConfigurationValue401JSONResponse
- type RemoveTenantConfigurationValue401ResponseHeaders
- type RemoveTenantConfigurationValue403JSONResponse
- type RemoveTenantConfigurationValue403ResponseHeaders
- type RemoveTenantConfigurationValue412JSONResponse
- type RemoveTenantConfigurationValue412ResponseHeaders
- type RemoveTenantConfigurationValue413JSONResponse
- type RemoveTenantConfigurationValue413ResponseHeaders
- type RemoveTenantConfigurationValue500JSONResponse
- type RemoveTenantConfigurationValue500ResponseHeaders
- type RemoveTenantConfigurationValue503JSONResponse
- type RemoveTenantConfigurationValue503ResponseHeaders
- type RemoveTenantConfigurationValueHTTPResponse
- type RemoveTenantConfigurationValueJSONRequestBody
- type RemoveTenantConfigurationValueParams
- type RemoveTenantConfigurationValueRequestObject
- type RemoveTenantConfigurationValueResponseObject
- type RequestEditorFn
- type RequiredHeaderError
- type RequiredParamError
- type RescheduleExecutionRequest
- type RescheduleJobWithLease204Response
- type RescheduleJobWithLeaseHTTPResponse
- type RescheduleJobWithLeaseJSONRequestBody
- type RescheduleJobWithLeaseParams
- type RescheduleJobWithLeaseRequestObject
- type RescheduleJobWithLeaseResponseObject
- type ResolveSecretsBody
- type ResolveSecretsWithLease200JSONResponse
- type ResolveSecretsWithLease200ResponseHeaders
- type ResolveSecretsWithLeaseHTTPResponse
- type ResolveSecretsWithLeaseJSONRequestBody
- type ResolveSecretsWithLeaseParams
- type ResolveSecretsWithLeaseRequestObject
- type ResolveSecretsWithLeaseResponseObject
- type ResolveSecretsWithLeasedefaultJSONResponse
- type ResolveSecretsWithLeasedefaultResponseHeaders
- type RestartExtraChapter
- type RestartExtraChapterKind
- type ResumeSchedule200JSONResponse
- type ResumeScheduleHTTPResponse
- type ResumeScheduleJSONRequestBody
- type ResumeScheduleRequestObject
- type ResumeScheduleResponseObject
- type RetryPolicy
- type Route
- type RunPolicy
- type ScheduleFailurePolicy
- type ScheduleId
- type ScheduleInfo
- type ScheduleKey
- type ScheduleMutationRequest
- type ScheduleOverlapPolicy
- type ScheduleRunSummary
- type ScheduleState
- type ScheduleTarget
- type ScheduleTrigger
- type ScheduleTriggerKind
- type SecretError
- type SecretResolveResult
- type SecretValue
- type ServerInterface
- type ServerInterfaceWrapper
- func (siw *ServerInterfaceWrapper) AddChapterWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ArchiveJobSchema(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ArchiveSchedule(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CancelJob(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CommitChapterIfWaiting(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) CompleteJobWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetChapter(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetConfigurationWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetJob(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetJobLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetJobSchema(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetSchedule(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) GetTenantConfiguration(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) KeepAliveLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListChapters(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListJobSchemas(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListJobs(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListScheduleRuns(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ListSchedules(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) OpenArtifact(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) PauseSchedule(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) PollWork(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) PutJob(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) PutJobWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) PutRestartJob(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) PutRestartJobWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) RegisterJobSchema(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) RemoveTenantConfigurationValue(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) RescheduleJobWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ResolveSecretsWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) ResumeSchedule(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) SetTenantConfigurationValue(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) SubmitJob(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) SubmitJobWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) SubmitRestartJob(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) SubmitRestartJobWithLease(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) TriggerSchedule(w http.ResponseWriter, r *http.Request)
- func (siw *ServerInterfaceWrapper) UpsertSchedule(w http.ResponseWriter, r *http.Request)
- type SetConfigurationBody
- type SetTenantConfigurationValue204Response
- type SetTenantConfigurationValue204ResponseHeaders
- type SetTenantConfigurationValue400JSONResponse
- type SetTenantConfigurationValue400ResponseHeaders
- type SetTenantConfigurationValue401JSONResponse
- type SetTenantConfigurationValue401ResponseHeaders
- type SetTenantConfigurationValue403JSONResponse
- type SetTenantConfigurationValue403ResponseHeaders
- type SetTenantConfigurationValue412JSONResponse
- type SetTenantConfigurationValue412ResponseHeaders
- type SetTenantConfigurationValue413JSONResponse
- type SetTenantConfigurationValue413ResponseHeaders
- type SetTenantConfigurationValue500JSONResponse
- type SetTenantConfigurationValue500ResponseHeaders
- type SetTenantConfigurationValue503JSONResponse
- type SetTenantConfigurationValue503ResponseHeaders
- type SetTenantConfigurationValueHTTPResponse
- type SetTenantConfigurationValueJSONRequestBody
- type SetTenantConfigurationValueParams
- type SetTenantConfigurationValueRequestObject
- type SetTenantConfigurationValueResponseObject
- type StartOrdinal
- type StoredArtifact
- type StoredTaskData
- type StrictHTTPServerOptions
- type StrictHandlerFunc
- type StrictMiddlewareFunc
- type StrictServerInterface
- type SubmitJob
- type SubmitJob200JSONResponse
- type SubmitJobHTTPResponse
- type SubmitJobJSONRequestBody
- type SubmitJobRequest
- type SubmitJobRequestObject
- type SubmitJobResponseObject
- type SubmitJobWithLease200JSONResponse
- type SubmitJobWithLeaseHTTPResponse
- type SubmitJobWithLeaseJSONRequestBody
- type SubmitJobWithLeaseParams
- type SubmitJobWithLeaseRequestObject
- type SubmitJobWithLeaseResponseObject
- type SubmitRestartJob
- type SubmitRestartJob200JSONResponse
- type SubmitRestartJobHTTPResponse
- type SubmitRestartJobJSONRequestBody
- type SubmitRestartJobRequest
- type SubmitRestartJobRequestObject
- type SubmitRestartJobResponseObject
- type SubmitRestartJobWithLease200JSONResponse
- type SubmitRestartJobWithLeaseHTTPResponse
- type SubmitRestartJobWithLeaseJSONRequestBody
- type SubmitRestartJobWithLeaseParams
- type SubmitRestartJobWithLeaseRequestObject
- type SubmitRestartJobWithLeaseResponseObject
- type SystemErrorPayload
- type TaskAttemptOutcomeChapter
- type TaskAttemptOutcomeChapterKind
- type TaskDataWrite
- type TaskOutcome
- func (t TaskOutcome) AsTaskOutcomeAppError() (TaskOutcomeAppError, error)
- func (t TaskOutcome) AsTaskOutcomeSuccess() (TaskOutcomeSuccess, error)
- func (t TaskOutcome) AsTaskOutcomeSystemError() (TaskOutcomeSystemError, error)
- func (t TaskOutcome) AsTaskOutcomeTimeout() (TaskOutcomeTimeout, error)
- func (t TaskOutcome) Discriminator() (string, error)
- func (t *TaskOutcome) FromTaskOutcomeAppError(v TaskOutcomeAppError) error
- func (t *TaskOutcome) FromTaskOutcomeSuccess(v TaskOutcomeSuccess) error
- func (t *TaskOutcome) FromTaskOutcomeSystemError(v TaskOutcomeSystemError) error
- func (t *TaskOutcome) FromTaskOutcomeTimeout(v TaskOutcomeTimeout) error
- func (t TaskOutcome) MarshalJSON() ([]byte, error)
- func (t *TaskOutcome) MergeTaskOutcomeAppError(v TaskOutcomeAppError) error
- func (t *TaskOutcome) MergeTaskOutcomeSuccess(v TaskOutcomeSuccess) error
- func (t *TaskOutcome) MergeTaskOutcomeSystemError(v TaskOutcomeSystemError) error
- func (t *TaskOutcome) MergeTaskOutcomeTimeout(v TaskOutcomeTimeout) error
- func (t *TaskOutcome) UnmarshalJSON(b []byte) error
- func (t TaskOutcome) ValueByDiscriminator() (interface{}, error)
- type TaskOutcomeAppError
- type TaskOutcomeAppErrorKind
- type TaskOutcomeSuccess
- type TaskOutcomeSuccessKind
- type TaskOutcomeSystemError
- type TaskOutcomeSystemErrorKind
- type TaskOutcomeTimeout
- type TaskOutcomeTimeoutKind
- type TaskWait
- type TenantId
- type TimeoutPayload
- type TooManyValuesForParamError
- type TriggerSchedule200JSONResponse
- type TriggerScheduleHTTPResponse
- type TriggerScheduleJSONRequestBody
- type TriggerScheduleRequest
- type TriggerScheduleRequestObject
- type TriggerScheduleResponseObject
- type UnescapedCookieParamError
- type Unimplemented
- func (_ Unimplemented) AddChapterWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) ArchiveJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) ArchiveSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) CancelJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
- func (_ Unimplemented) CommitChapterIfWaiting(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) CompleteJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) GetChapter(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) GetConfigurationWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) GetJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
- func (_ Unimplemented) GetJobLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
- func (_ Unimplemented) GetJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) GetSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) GetTenantConfiguration(w http.ResponseWriter, r *http.Request, tenantId TenantId)
- func (_ Unimplemented) KeepAliveLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) ListChapters(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) ListJobSchemas(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) ListJobs(w http.ResponseWriter, r *http.Request, tenantId TenantId)
- func (_ Unimplemented) ListScheduleRuns(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) ListSchedules(w http.ResponseWriter, r *http.Request, tenantId TenantId)
- func (_ Unimplemented) OpenArtifact(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) PauseSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) PollWork(w http.ResponseWriter, r *http.Request)
- func (_ Unimplemented) PutJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
- func (_ Unimplemented) PutJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) PutRestartJob(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId)
- func (_ Unimplemented) PutRestartJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) RegisterJobSchema(w http.ResponseWriter, r *http.Request, tenantId TenantId)
- func (_ Unimplemented) RemoveTenantConfigurationValue(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) RescheduleJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) ResolveSecretsWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, jobId JobId, ...)
- func (_ Unimplemented) ResumeSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) SetTenantConfigurationValue(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) SubmitJob(w http.ResponseWriter, r *http.Request, tenantId TenantId)
- func (_ Unimplemented) SubmitJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) SubmitRestartJob(w http.ResponseWriter, r *http.Request, tenantId TenantId)
- func (_ Unimplemented) SubmitRestartJobWithLease(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) TriggerSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- func (_ Unimplemented) UpsertSchedule(w http.ResponseWriter, r *http.Request, tenantId TenantId, ...)
- type UnmarshalingParamError
- type UpsertSchedule200JSONResponse
- type UpsertSchedule409Response
- type UpsertScheduleHTTPResponse
- type UpsertScheduleJSONRequestBody
- type UpsertScheduleRequest
- type UpsertScheduleRequestObject
- type UpsertScheduleResponseObject
Constants ¶
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 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 ¶
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
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
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 ¶
func ParseAddChapterWithLeaseHTTPResponse ¶
func ParseAddChapterWithLeaseHTTPResponse(rsp *http.Response) (*AddChapterWithLeaseHTTPResponse, error)
ParseAddChapterWithLeaseHTTPResponse parses an HTTP response from a AddChapterWithLeaseWithResponse call
func (AddChapterWithLeaseHTTPResponse) Status ¶
func (r AddChapterWithLeaseHTTPResponse) Status() string
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
func (r ArchiveJobSchemaHTTPResponse) Status() string
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 ¶
func (r ArchiveScheduleHTTPResponse) Status() string
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 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 ¶
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 (*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 (*Client) CancelJob ¶
func (c *Client) CancelJob(ctx context.Context, tenantId TenantId, jobId JobId, body CancelJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) CancelJobWithBody ¶
func (*Client) CommitChapterIfWaiting ¶
func (*Client) CommitChapterIfWaitingWithBody ¶
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 (*Client) GetChapter ¶
func (*Client) GetConfigurationWithLease ¶ added in v0.0.33
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 (*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 (*Client) KeepAliveLease ¶
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 (*Client) ListScheduleRuns ¶
func (c *Client) ListScheduleRuns(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ListScheduleRunsJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) ListScheduleRunsWithBody ¶
func (*Client) ListSchedules ¶
func (c *Client) ListSchedules(ctx context.Context, tenantId TenantId, body ListSchedulesJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) ListSchedulesWithBody ¶
func (*Client) OpenArtifact ¶
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 (*Client) PollWork ¶
func (c *Client) PollWork(ctx context.Context, body PollWorkJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) PollWorkWithBody ¶
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 (*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 (*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 (*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 (*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 (*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 (*Client) ResumeSchedule ¶
func (c *Client) ResumeSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body ResumeScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) ResumeScheduleWithBody ¶
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 (*Client) SubmitJob ¶
func (c *Client) SubmitJob(ctx context.Context, tenantId TenantId, body SubmitJobJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) SubmitJobWithBody ¶
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 (*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 (*Client) UpsertSchedule ¶
func (c *Client) UpsertSchedule(ctx context.Context, tenantId TenantId, scheduleId ScheduleId, body UpsertScheduleJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
func (*Client) UpsertScheduleWithBody ¶
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 ¶
ClientOption allows setting custom parameters during construction
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 (c *ClientWithResponses) RemoveTenantConfigurationValueWithResponse(ctx context.Context, tenantId TenantId, params *RemoveTenantConfigurationValueParams, body RemoveTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*RemoveTenantConfigurationValueHTTPResponse, error)
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 (c *ClientWithResponses) SetTenantConfigurationValueWithResponse(ctx context.Context, tenantId TenantId, params *SetTenantConfigurationValueParams, body SetTenantConfigurationValueJSONRequestBody, reqEditors ...RequestEditorFn) (*SetTenantConfigurationValueHTTPResponse, error)
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 ¶
func ParseCommitChapterIfWaitingHTTPResponse ¶
func ParseCommitChapterIfWaitingHTTPResponse(rsp *http.Response) (*CommitChapterIfWaitingHTTPResponse, error)
ParseCommitChapterIfWaitingHTTPResponse parses an HTTP response from a CommitChapterIfWaitingWithResponse call
func (CommitChapterIfWaitingHTTPResponse) Status ¶
func (r CommitChapterIfWaitingHTTPResponse) Status() string
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 ¶
func ParseCompleteJobWithLeaseHTTPResponse ¶
func ParseCompleteJobWithLeaseHTTPResponse(rsp *http.Response) (*CompleteJobWithLeaseHTTPResponse, error)
ParseCompleteJobWithLeaseHTTPResponse parses an HTTP response from a CompleteJobWithLeaseWithResponse call
func (CompleteJobWithLeaseHTTPResponse) Status ¶
func (r CompleteJobWithLeaseHTTPResponse) Status() string
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 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" 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 ¶
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 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 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
func (r GetConfigurationWithLeaseHTTPResponse) Status() string
Status returns HTTPResponse.Status
func (GetConfigurationWithLeaseHTTPResponse) StatusCode ¶ added in v0.0.33
func (r GetConfigurationWithLeaseHTTPResponse) StatusCode() int
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 ¶
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 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 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
func (r GetTenantConfigurationHTTPResponse) Status() string
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 ¶
Doer performs HTTP requests.
The standard http.Client implements this interface.
type InputReference ¶
InputReference defines model for InputReference.
type InvalidParamFormatError ¶
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 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 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 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 ¶
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 ¶
func (r KeepAliveLeaseHTTPResponse) Status() string
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 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
func (r ListJobSchemasHTTPResponse) Status() string
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 ¶
func (r ListScheduleRunsHTTPResponse) Status() string
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 OpenArtifact200ApplicationoctetStreamResponse ¶
func (OpenArtifact200ApplicationoctetStreamResponse) VisitOpenArtifactResponse ¶
func (response OpenArtifact200ApplicationoctetStreamResponse) VisitOpenArtifactResponse(w http.ResponseWriter) error
type OpenArtifactHTTPResponse ¶
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 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
func (r PutJobWithLeaseHTTPResponse) Status() string
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
func (r PutRestartJobWithLeaseHTTPResponse) Status() string
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
func (r RegisterJobSchemaHTTPResponse) Status() string
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 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
func (r RemoveTenantConfigurationValueHTTPResponse) Status() string
Status returns HTTPResponse.Status
func (RemoveTenantConfigurationValueHTTPResponse) StatusCode ¶ added in v0.0.33
func (r RemoveTenantConfigurationValueHTTPResponse) StatusCode() int
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 ¶
RequestEditorFn is the function signature for the RequestEditor callback function
type RequiredHeaderError ¶
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 ¶
func ParseRescheduleJobWithLeaseHTTPResponse ¶
func ParseRescheduleJobWithLeaseHTTPResponse(rsp *http.Response) (*RescheduleJobWithLeaseHTTPResponse, error)
ParseRescheduleJobWithLeaseHTTPResponse parses an HTTP response from a RescheduleJobWithLeaseWithResponse call
func (RescheduleJobWithLeaseHTTPResponse) Status ¶
func (r RescheduleJobWithLeaseHTTPResponse) Status() string
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
func (r ResolveSecretsWithLeaseHTTPResponse) Status() string
Status returns HTTPResponse.Status
func (ResolveSecretsWithLeaseHTTPResponse) StatusCode ¶ added in v0.0.29
func (r ResolveSecretsWithLeaseHTTPResponse) StatusCode() int
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 ¶
func (r ResumeScheduleHTTPResponse) Status() string
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 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 ¶
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
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 ¶
func (siw *ServerInterfaceWrapper) GetJob(w http.ResponseWriter, r *http.Request)
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 ¶
func (siw *ServerInterfaceWrapper) PutJob(w http.ResponseWriter, r *http.Request)
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 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
func (r SetTenantConfigurationValueHTTPResponse) Status() string
Status returns HTTPResponse.Status
func (SetTenantConfigurationValueHTTPResponse) StatusCode ¶ added in v0.0.33
func (r SetTenantConfigurationValueHTTPResponse) StatusCode() int
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 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 StrictHandlerFunc ¶
type StrictHandlerFunc = strictnethttp.StrictHTTPHandlerFunc
type StrictMiddlewareFunc ¶
type StrictMiddlewareFunc = strictnethttp.StrictHTTPMiddlewareFunc
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 ¶
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
func (r SubmitJobWithLeaseHTTPResponse) Status() string
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 ¶
func (r SubmitRestartJobHTTPResponse) Status() string
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
func (r SubmitRestartJobWithLeaseHTTPResponse) Status() string
Status returns HTTPResponse.Status
func (SubmitRestartJobWithLeaseHTTPResponse) StatusCode ¶ added in v0.0.13
func (r SubmitRestartJobWithLeaseHTTPResponse) StatusCode() int
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 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 ¶
func (*TooManyValuesForParamError) Error ¶
func (e *TooManyValuesForParamError) Error() string
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 ¶
func (r TriggerScheduleHTTPResponse) Status() string
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 ¶
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 ¶
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 ¶
func (r UpsertScheduleHTTPResponse) Status() string
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
}