api

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

type CancelJobRequest struct {
	JobID string `path:"jobId" description:"Job ID"`
}

type CompleteDurableActivityRequest operator.CompletionInput

type DLQCountResponse struct {
	Count int64 `json:"count"`
}

type DeleteCronRequest struct {
	CronID string `path:"cronId" description:"Cron entry ID"`
}

type DeleteDLQRequest struct {
	EntryID string `path:"entryId" description:"DLQ entry ID"`
}

type DisableCronRequest struct {
	CronID string `path:"cronId" description:"Cron entry ID"`
}

type EnableCronRequest struct {
	CronID string `path:"cronId" description:"Cron entry ID"`
}

type ErrorResponse struct {
	Code  int    `json:"code"`
	Error string `json:"error"`
}

type GetCronRequest struct {
	CronID string `path:"cronId" description:"Cron entry ID"`
}

type GetDLQRequest struct {
	EntryID string `path:"entryId" description:"DLQ entry ID"`
}

type GetJobRequest struct {
	JobID string `path:"jobId" description:"Job ID"`
}

type GetWorkflowRunRequest struct {
	RunID string `path:"runId" description:"Workflow run ID"`
}

type HeartbeatDurableActivityRequest operator.HeartbeatInput

type JobCountsResponse struct {
	Pending   int64 `json:"pending"`
	Running   int64 `json:"running"`
	Completed int64 `json:"completed"`
	Failed    int64 `json:"failed"`
	Retrying  int64 `json:"retrying"`
	Cancelled int64 `json:"cancelled"`
}

type ListCronsRequest struct {
	Limit  int `query:"limit" optional:"true" description:"Maximum number of results (default: 50, max: 1000)"`
	Offset int `query:"offset" optional:"true" description:"Number of results to skip"`
}

type ListCronsResponse struct {
	Entries []*cron.Entry `body:""`
}

type ListDLQRequest struct {
	Queue  string `query:"queue" optional:"true" description:"Filter by queue name"`
	Limit  int    `query:"limit" optional:"true" description:"Maximum number of results (default: 50, max: 1000)"`
	Offset int    `query:"offset" optional:"true" description:"Number of results to skip"`
}

type ListDLQResponse struct {
	Entries []*dlq.Entry `body:""`
}

type ListJobsRequest struct {
	State  string `` /* 144-byte string literal not displayed */
	Queue  string `query:"queue" optional:"true" description:"Filter by queue name"`
	Limit  int    `query:"limit" optional:"true" description:"Maximum number of results (default: 50, max: 1000)"`
	Offset int    `query:"offset" optional:"true" description:"Number of results to skip"`
}

type ListJobsResponse struct {
	Jobs []*job.Job `body:""`
}

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

type ListWorkflowRunsRequest struct {
	State  string `query:"state" optional:"true" description:"Filter by run state (running, completed, failed; default: every state)"`
	Limit  int    `query:"limit" optional:"true" description:"Maximum number of results (default: 50, max: 1000)"`
	Offset int    `query:"offset" optional:"true" description:"Number of results to skip"`
}

type ListWorkflowRunsResponse struct {
	Runs []*workflow.Run `body:""`
}

type Option func(*API)

type PlanWorkflowReplayRequest struct {
	RunID string `path:"runId" description:"Workflow run ID"`
	Step  string `query:"step" required:"true" description:"Checkpointed step to replay from"`
}

type PurgeDLQRequest struct {
	Before    string `query:"before" optional:"true" description:"Purge entries that failed before this RFC 3339 time"`
	OlderThan string `query:"older_than" optional:"true" description:"Purge entries that failed longer ago than this Go duration, e.g. 72h"`
	DryRun    bool   `query:"dry_run" optional:"true" description:"Count the entries the cutoff matches without deleting any"`
}

type PurgeDLQResponse struct {
	Purged  int64     `json:"purged"`
	Matched int64     `json:"matched"`
	DryRun  bool      `json:"dry_run"`
	Before  time.Time `json:"before"`
}

type ReplayAllDLQRequest struct {
	Queue string `query:"queue" optional:"true" description:"Replay only entries from this queue (default: every queue)"`
	Limit int    `query:"limit" optional:"true" description:"Maximum number of entries to try, 1 to 1000 (default: 1000)"`
}

type ReplayAllDLQResponse struct {
	Replayed      int64    `json:"replayed"`
	Conflicts     int64    `json:"conflicts"`
	Errors        int64    `json:"errors"`
	ErrorMessages []string `json:"error_messages"`
}

type ReplayDLQRequest struct {
	EntryID string `path:"entryId" description:"DLQ entry ID"`
}

type ReplayWorkflowRequest struct {
	RunID string `path:"runId" description:"Workflow run ID"`
	Step  string `json:"step" description:"Checkpointed step to replay from; it and every step before it are kept"`
}

type RetryJobRequest struct {
	JobID string `path:"jobId" description:"Job ID"`
}

type StatsResponse struct {
	Jobs      JobCountsResponse `json:"jobs"`
	DLQCount  int64             `json:"dlq_count"`
	Workflows WorkflowCounts    `json:"workflows"`
}

type TriggerCronRequest struct {
	CronID string `path:"cronId" description:"Cron entry ID"`
}

type WorkflowCounts struct {
	Running   int `json:"running"`
	Completed int `json:"completed"`
	Failed    int `json:"failed"`
}