api

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

type AgentCheckinInput struct {
	AgentID      *string `json:"agentID,omitempty"`
	AgentVersion *string `json:"agentVersion,omitempty"`

	// Paused Self-reported quiesced acknowledgement. A pause-aware agent sets
	// this to true only once it has observed the pause and its in-flight
	// worker has exited (it is in the paused sleep loop). It is
	// level-triggered — sent on every checkin while quiesced — and the
	// server records it only while the agent is actually paused, so a
	// stale ack racing an unpause is ignored. Optional: absent means the
	// agent has not acknowledged quiescing.
	Paused     *bool        `json:"paused,omitempty"`
	PoolLabels *[]PoolLabel `json:"poolLabels,omitempty"`
}

type AgentCheckinJSONRequestBody = AgentCheckinInput

type AgentCheckinOutput struct {
	AuthToken *string `json:"authToken,omitempty"`

	// PauseReason The reason recorded with the pause, for the host operator's logs. Present only when paused and a reason was given.
	PauseReason *string `json:"pauseReason,omitempty"`

	// Paused True when the agent is paused and must not launch workers: it
	// should log the pause, skip launching, and keep checking in on its
	// existing cadence until this clears. A paused checkin is still a
	// successful checkin and must not count toward the agent's max-error
	// process exit. Optional — absent or false means run normally, so an
	// older agent binary talking to this API (or a newer agent talking
	// to an older API) safely defaults to running.
	Paused *bool `json:"paused,omitempty"`

	// PausedAt When the pause was set. Present only when paused.
	PausedAt *time.Time `json:"pausedAt,omitempty"`

	// PausedBy Who set the pause (email, or client identity for machine tokens). Present only when paused.
	PausedBy                   *string                `json:"pausedBy,omitempty"`
	RequiredAgentVersion       *string                `json:"requiredAgentVersion,omitempty"`
	WorkerEnvironmentVariables *[]EnvironmentVariable `json:"workerEnvironmentVariables,omitempty"`
	WorkerImageURI             *string                `json:"workerImageURI,omitempty"`
}

type AgentCheckinResponse struct {
	Body         []byte
	HTTPResponse *http.Response
	// JSON200 the response for an HTTP 200 `application/json` response
	JSON200 *AgentCheckinOutput
}

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 {

	// AgentCheckinWithBody performs a POST /agent/checkin (the `AgentCheckin` operationId) request,
	// with any type of body and a specified content type.
	//
	// Startup endpoint for agents.
	AgentCheckinWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AgentCheckin performs a POST /agent/checkin (the `AgentCheckin` operationId) request.
	// Takes a body of the `application/json` content type.
	//
	// Startup endpoint for agents.
	AgentCheckin(ctx context.Context, body AgentCheckinJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

	// AgentAPIPing performs a GET /agentapiping (the `AgentAPIPing` operationId) request.
	//
	// Used for testing, to validate the specific existence of the Agent API
	AgentAPIPing(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// Health performs a GET /health (the `Health` operationId) request.
	//
	// Returns whether the service is healthy or not.
	Health(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)
}

type ClientOption func(*Client) error

type ClientWithResponses struct {
	ClientInterface
}

type ClientWithResponsesInterface interface {

	// AgentCheckinWithBodyWithResponse performs a POST /agent/checkin (the `AgentCheckin` operationId) request,
	// with any type of body and a specified content type.
	//
	// Startup endpoint for agents.
	//
	// Returns a wrapper object for the known response body format(s).
	AgentCheckinWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*AgentCheckinResponse, error)

	// AgentCheckinWithResponse performs a POST /agent/checkin (the `AgentCheckin` operationId) request.
	// Takes a body of the `application/json` content type, and returns a wrapper object for the known response body format(s).
	//
	// Startup endpoint for agents.
	AgentCheckinWithResponse(ctx context.Context, body AgentCheckinJSONRequestBody, reqEditors ...RequestEditorFn) (*AgentCheckinResponse, error)

	// AgentAPIPingWithResponse performs a GET /agentapiping (the `AgentAPIPing` operationId) request.
	//
	// Used for testing, to validate the specific existence of the Agent API
	//
	// Returns a wrapper object for the known response body format(s).
	AgentAPIPingWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*AgentAPIPingResponse, error)

	// HealthWithResponse performs a GET /health (the `Health` operationId) request.
	//
	// Returns whether the service is healthy or not.
	//
	// Returns a wrapper object for the known response body format(s).
	HealthWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthResponse, error)
}

type EnvironmentVariable = []string

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

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

type PoolLabel = string

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