callbackapi

type CallbackRequest struct {
	Complete *TaskComplete `json:"complete,omitempty"`
	Error    *TaskError    `json:"error,omitempty"`
}

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

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
}

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

	PostCallback(ctx context.Context, body PostCallbackJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	PostGetSubtaskResult(ctx context.Context, body PostGetSubtaskResultJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// GetInput request
	GetInput(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	PostRegisterTasks(ctx context.Context, body PostRegisterTasksJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	PostRunSubtask(ctx context.Context, body PostRunSubtaskJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)
}

type ClientOption func(*Client) error

type ClientWithResponses struct {
	ClientInterface
}

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

	PostCallbackWithResponse(ctx context.Context, body PostCallbackJSONRequestBody, reqEditors ...RequestEditorFn) (*PostCallbackResponse, error)

	// PostGetSubtaskResultWithBodyWithResponse request with any body
	PostGetSubtaskResultWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PostGetSubtaskResultResponse, error)

	PostGetSubtaskResultWithResponse(ctx context.Context, body PostGetSubtaskResultJSONRequestBody, reqEditors ...RequestEditorFn) (*PostGetSubtaskResultResponse, error)

	// GetInputWithResponse request
	GetInputWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetInputResponse, error)

	// PostRegisterTasksWithBodyWithResponse request with any body
	PostRegisterTasksWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PostRegisterTasksResponse, error)

	PostRegisterTasksWithResponse(ctx context.Context, body PostRegisterTasksJSONRequestBody, reqEditors ...RequestEditorFn) (*PostRegisterTasksResponse, error)

	// PostRunSubtaskWithBodyWithResponse request with any body
	PostRunSubtaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*PostRunSubtaskResponse, error)

	PostRunSubtaskWithResponse(ctx context.Context, body PostRunSubtaskJSONRequestBody, reqEditors ...RequestEditorFn) (*PostRunSubtaskResponse, error)
}

type GetInput200JSONResponse InputResponse

type GetInput500Response struct {
}

type GetInputRequestObject struct {
}

type GetInputResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *InputResponse
}

type GetInputResponseObject interface {
	VisitGetInputResponse(w http.ResponseWriter) error
}

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

type InputResponse struct {
	Input    []byte `json:"input"`
	TaskName string `json:"task_name"`
}

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

type MiddlewareFunc func(http.Handler) http.Handler

type PostCallback200Response struct {
}

type PostCallback400Response struct {
}

type PostCallback401Response struct {
}

type PostCallback403Response struct {
}

type PostCallback500Response struct {
}

type PostCallbackJSONRequestBody = CallbackRequest

type PostCallbackRequestObject struct {
	Body *PostCallbackJSONRequestBody
}

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

type PostCallbackResponseObject interface {
	VisitPostCallbackResponse(w http.ResponseWriter) error
}

type PostGetSubtaskResult200JSONResponse SubtaskResultResponse

type PostGetSubtaskResult500Response struct {
}

type PostGetSubtaskResultJSONRequestBody = SubtaskResultRequest

type PostGetSubtaskResultRequestObject struct {
	Body *PostGetSubtaskResultJSONRequestBody
}

type PostGetSubtaskResultResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *SubtaskResultResponse
}

type PostGetSubtaskResultResponseObject interface {
	VisitPostGetSubtaskResultResponse(w http.ResponseWriter) error
}

type PostRegisterTasks200Response struct {
}

type PostRegisterTasks400Response struct {
}

type PostRegisterTasks500Response struct {
}

type PostRegisterTasksJSONRequestBody = Tasks

type PostRegisterTasksRequestObject struct {
	Body *PostRegisterTasksJSONRequestBody
}

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

type PostRegisterTasksResponseObject interface {
	VisitPostRegisterTasksResponse(w http.ResponseWriter) error
}

type PostRunSubtask200JSONResponse RunSubtaskResponse

type PostRunSubtask500Response struct {
}

type PostRunSubtaskJSONRequestBody = RunSubtaskRequest

type PostRunSubtaskRequestObject struct {
	Body *PostRunSubtaskJSONRequestBody
}

type PostRunSubtaskResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	JSON200      *RunSubtaskResponse
}

type PostRunSubtaskResponseObject interface {
	VisitPostRunSubtaskResponse(w http.ResponseWriter) error
}

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

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

type RequiredParamError struct {
	ParamName string
}

type RetryConfig struct {
	// Factor Backoff factor for exponential retry
	Factor *float32 `json:"factor,omitempty"`

	// MaxRetries Maximum number of retry attempts
	MaxRetries *int `json:"max_retries,omitempty"`

	// WaitDurationMs Initial wait duration between retries (in milliseconds)
	WaitDurationMs *int64 `json:"wait_duration_ms,omitempty"`
}

type RunSubtaskRequest struct {
	Input    *[]byte `json:"input,omitempty"`
	TaskName string  `json:"task_name"`
}

type RunSubtaskResponse struct {
	TaskRunId string `json:"task_run_id"`
}

type ServerInterface interface {
	// Receive a callback from a workflow
	// (POST /callback)
	PostCallback(w http.ResponseWriter, r *http.Request)
	// Fetch the results for a subtask
	// (POST /get-subtask-result)
	PostGetSubtaskResult(w http.ResponseWriter, r *http.Request)
	// Get the task name and input for a task run
	// (GET /input)
	GetInput(w http.ResponseWriter, r *http.Request)
	// Publish registered tasks
	// (POST /register-tasks)
	PostRegisterTasks(w http.ResponseWriter, r *http.Request)
	// Trigger a subtask
	// (POST /run-subtask)
	PostRunSubtask(w http.ResponseWriter, r *http.Request)
}

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

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 = strictnethttp.StrictHTTPHandlerFunc

type StrictMiddlewareFunc = strictnethttp.StrictHTTPMiddlewareFunc

type StrictServerInterface interface {
	// Receive a callback from a workflow
	// (POST /callback)
	PostCallback(ctx context.Context, request PostCallbackRequestObject) (PostCallbackResponseObject, error)
	// Fetch the results for a subtask
	// (POST /get-subtask-result)
	PostGetSubtaskResult(ctx context.Context, request PostGetSubtaskResultRequestObject) (PostGetSubtaskResultResponseObject, error)
	// Get the task name and input for a task run
	// (GET /input)
	GetInput(ctx context.Context, request GetInputRequestObject) (GetInputResponseObject, error)
	// Publish registered tasks
	// (POST /register-tasks)
	PostRegisterTasks(ctx context.Context, request PostRegisterTasksRequestObject) (PostRegisterTasksResponseObject, error)
	// Trigger a subtask
	// (POST /run-subtask)
	PostRunSubtask(ctx context.Context, request PostRunSubtaskRequestObject) (PostRunSubtaskResponseObject, error)
}

type SubtaskResultRequest struct {
	TaskRunId string `json:"task_run_id"`
}

type SubtaskResultResponse struct {
	Complete     *TaskComplete `json:"complete,omitempty"`
	Error        *TaskError    `json:"error,omitempty"`
	StillRunning bool          `json:"still_running"`
}

type Task struct {
	Name    string       `json:"name"`
	Options *TaskOptions `json:"options,omitempty"`
}

type TaskComplete struct {
	Output []byte `json:"output"`
}

type TaskError struct {
	Details    string  `json:"details"`
	StackTrace *string `json:"stack_trace,omitempty"`
}

type TaskOptions struct {
	Retry *RetryConfig `json:"retry,omitempty"`
}

type Tasks struct {
	Tasks []Task `json:"tasks"`
}

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

type Unimplemented struct{}

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}