httpapi

package
v0.5.4 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2026 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Overview

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

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

Index

Constants

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

Variables

View Source 
var OpenAPIJSON = string(openAPIJSON)

Functions

func Handler added in v0.4.0 

func Handler(si ServerInterface) http.Handler

Handler creates http.Handler with routing matching OpenAPI spec.

func HandlerForSQLite 

func HandlerForSQLite(ctx context.Context, dsn string, offer []domain.OfferSnapshot, options ...Option) (http.Handler, func() error, error)

HandlerForSQLite builds a fully-wired handler over a SQLite event log with the fake adapter serving the given offers. Used for evaluation and tests.

func HandlerFromMux added in v0.4.0 

func HandlerFromMux(si ServerInterface, m ServeMux) http.Handler

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

func HandlerFromMuxWithBaseURL added in v0.4.0 

func HandlerFromMuxWithBaseURL(si ServerInterface, m ServeMux, baseURL string) http.Handler

func HandlerWithOptions added in v0.4.0 

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

HandlerWithOptions creates http.Handler with additional options

func New 

func New(deps Deps, options ...Option) http.Handler

Types

type AcceleratorInventory added in v0.4.0 

type AcceleratorInventory struct {
	CanonicalModel string `json:"canonical_model,omitempty"`
	Count          int    `json:"count"`
	MemoryBytes    int64  `json:"memory_bytes"`
	Model          string `json:"model"`
	Vendor         string `json:"vendor"`
}

AcceleratorInventory defines model for AcceleratorInventory.

type AcceleratorRequirement added in v0.4.0 

type AcceleratorRequirement struct {
	Count          int      `json:"count"`
	MemoryMinBytes int64    `json:"memory_min_bytes"`
	ModelAnyOf     []string `json:"model_any_of,omitempty"`
	Vendor         string   `json:"vendor"`
}

AcceleratorRequirement defines model for AcceleratorRequirement.

type AdapterListResponse added in v0.4.0 

type AdapterListResponse struct {
	Adapters []AdapterManifest `json:"adapters"`
}

AdapterListResponse defines model for AdapterListResponse.

type AdapterManifest added in v0.4.0 

type AdapterManifest = adapter.Manifest

AdapterManifest An adapter's self-description for onboarding surfaces. Lives next to the adapter's code; carries no per-connection state and never any secret material.

type ArchiveWorkspace200JSONResponse added in v0.4.5 

type ArchiveWorkspace200JSONResponse WorkspaceResponse

func (ArchiveWorkspace200JSONResponse) VisitArchiveWorkspaceResponse added in v0.4.5 

func (response ArchiveWorkspace200JSONResponse) VisitArchiveWorkspaceResponse(w http.ResponseWriter) error

type ArchiveWorkspace400JSONResponse added in v0.4.5 

type ArchiveWorkspace400JSONResponse ErrorResponse

func (ArchiveWorkspace400JSONResponse) VisitArchiveWorkspaceResponse added in v0.4.5 

func (response ArchiveWorkspace400JSONResponse) VisitArchiveWorkspaceResponse(w http.ResponseWriter) error

type ArchiveWorkspace401JSONResponse added in v0.4.5 

type ArchiveWorkspace401JSONResponse ErrorResponse

func (ArchiveWorkspace401JSONResponse) VisitArchiveWorkspaceResponse added in v0.4.5 

func (response ArchiveWorkspace401JSONResponse) VisitArchiveWorkspaceResponse(w http.ResponseWriter) error

type ArchiveWorkspace404JSONResponse added in v0.4.5 

type ArchiveWorkspace404JSONResponse ErrorResponse

func (ArchiveWorkspace404JSONResponse) VisitArchiveWorkspaceResponse added in v0.4.5 

func (response ArchiveWorkspace404JSONResponse) VisitArchiveWorkspaceResponse(w http.ResponseWriter) error

type ArchiveWorkspace500JSONResponse added in v0.4.5 

type ArchiveWorkspace500JSONResponse ErrorResponse

func (ArchiveWorkspace500JSONResponse) VisitArchiveWorkspaceResponse added in v0.4.5 

func (response ArchiveWorkspace500JSONResponse) VisitArchiveWorkspaceResponse(w http.ResponseWriter) error

type ArchiveWorkspaceRequestObject added in v0.4.5 

type ArchiveWorkspaceRequestObject struct {
	WorkspaceId string `json:"workspace_id"`
}

type ArchiveWorkspaceResponseObject added in v0.4.5 

type ArchiveWorkspaceResponseObject interface {
	VisitArchiveWorkspaceResponse(w http.ResponseWriter) error
}

type AuthorizeConnection200JSONResponse added in v0.4.0 

type AuthorizeConnection200JSONResponse ConnectionResponse

func (AuthorizeConnection200JSONResponse) VisitAuthorizeConnectionResponse added in v0.4.0 

func (response AuthorizeConnection200JSONResponse) VisitAuthorizeConnectionResponse(w http.ResponseWriter) error

type AuthorizeConnection400JSONResponse added in v0.4.0 

type AuthorizeConnection400JSONResponse ErrorResponse

func (AuthorizeConnection400JSONResponse) VisitAuthorizeConnectionResponse added in v0.4.0 

func (response AuthorizeConnection400JSONResponse) VisitAuthorizeConnectionResponse(w http.ResponseWriter) error

type AuthorizeConnection401JSONResponse added in v0.4.0 

type AuthorizeConnection401JSONResponse ErrorResponse

func (AuthorizeConnection401JSONResponse) VisitAuthorizeConnectionResponse added in v0.4.0 

func (response AuthorizeConnection401JSONResponse) VisitAuthorizeConnectionResponse(w http.ResponseWriter) error

type AuthorizeConnection403JSONResponse added in v0.4.0 

type AuthorizeConnection403JSONResponse ErrorResponse

func (AuthorizeConnection403JSONResponse) VisitAuthorizeConnectionResponse added in v0.4.0 

func (response AuthorizeConnection403JSONResponse) VisitAuthorizeConnectionResponse(w http.ResponseWriter) error

type AuthorizeConnection500JSONResponse added in v0.4.0 

type AuthorizeConnection500JSONResponse ErrorResponse

func (AuthorizeConnection500JSONResponse) VisitAuthorizeConnectionResponse added in v0.4.0 

func (response AuthorizeConnection500JSONResponse) VisitAuthorizeConnectionResponse(w http.ResponseWriter) error

type AuthorizeConnection501JSONResponse added in v0.4.0 

type AuthorizeConnection501JSONResponse ErrorResponse

func (AuthorizeConnection501JSONResponse) VisitAuthorizeConnectionResponse added in v0.4.0 

func (response AuthorizeConnection501JSONResponse) VisitAuthorizeConnectionResponse(w http.ResponseWriter) error

type AuthorizeConnection502JSONResponse added in v0.4.0 

type AuthorizeConnection502JSONResponse ErrorResponse

func (AuthorizeConnection502JSONResponse) VisitAuthorizeConnectionResponse added in v0.4.0 

func (response AuthorizeConnection502JSONResponse) VisitAuthorizeConnectionResponse(w http.ResponseWriter) error

type AuthorizeConnectionParams added in v0.4.0 

type AuthorizeConnectionParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

AuthorizeConnectionParams defines parameters for AuthorizeConnection.

type AuthorizeConnectionRequestObject added in v0.4.0 

type AuthorizeConnectionRequestObject struct {
	ConnectionId string `json:"connection_id"`
	Params       AuthorizeConnectionParams
}

type AuthorizeConnectionResponseObject added in v0.4.0 

type AuthorizeConnectionResponseObject interface {
	VisitAuthorizeConnectionResponse(w http.ResponseWriter) error
}

type Booking added in v0.5.0 

type Booking = domain.Booking

Booking defines model for Booking.

type BookingDecision added in v0.5.0 

type BookingDecision = domain.BookingDecision

BookingDecision defines model for BookingDecision.

type BookingDecisionResponse added in v0.5.0 

type BookingDecisionResponse struct {
	Decision BookingDecision `json:"decision"`
}

BookingDecisionResponse defines model for BookingDecisionResponse.

type CPURequirement added in v0.4.0 

type CPURequirement struct {
	MinMillis int64 `json:"min_millis"`
}

CPURequirement defines model for CPURequirement.

type CancelRun200JSONResponse added in v0.4.0 

type CancelRun200JSONResponse RunResponse

func (CancelRun200JSONResponse) VisitCancelRunResponse added in v0.4.0 

func (response CancelRun200JSONResponse) VisitCancelRunResponse(w http.ResponseWriter) error

type CancelRun400JSONResponse added in v0.4.0 

type CancelRun400JSONResponse ErrorResponse

func (CancelRun400JSONResponse) VisitCancelRunResponse added in v0.4.0 

func (response CancelRun400JSONResponse) VisitCancelRunResponse(w http.ResponseWriter) error

type CancelRun401JSONResponse added in v0.4.0 

type CancelRun401JSONResponse ErrorResponse

func (CancelRun401JSONResponse) VisitCancelRunResponse added in v0.4.0 

func (response CancelRun401JSONResponse) VisitCancelRunResponse(w http.ResponseWriter) error

type CancelRun403JSONResponse added in v0.4.0 

type CancelRun403JSONResponse ErrorResponse

func (CancelRun403JSONResponse) VisitCancelRunResponse added in v0.4.0 

func (response CancelRun403JSONResponse) VisitCancelRunResponse(w http.ResponseWriter) error

type CancelRun502JSONResponse added in v0.4.0 

type CancelRun502JSONResponse ErrorResponse

func (CancelRun502JSONResponse) VisitCancelRunResponse added in v0.4.0 

func (response CancelRun502JSONResponse) VisitCancelRunResponse(w http.ResponseWriter) error

type CancelRunParams added in v0.4.0 

type CancelRunParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

CancelRunParams defines parameters for CancelRun.

type CancelRunRequestObject added in v0.4.0 

type CancelRunRequestObject struct {
	RunId  string `json:"run_id"`
	Params CancelRunParams
}

type CancelRunResponseObject added in v0.4.0 

type CancelRunResponseObject interface {
	VisitCancelRunResponse(w http.ResponseWriter) error
}

type CandidateDecision added in v0.4.0 

type CandidateDecision struct {
	AdapterType     string                       `json:"adapter_type,omitempty"`
	ConnectionId    string                       `json:"connection_id,omitempty"`
	Disposition     CandidateDecisionDisposition `json:"disposition"`
	Estimates       CandidateEstimates           `json:"estimates"`
	Feasible        bool                         `json:"feasible"`
	NativeRef       string                       `json:"native_ref,omitempty"`
	OfferSnapshotId string                       `json:"offer_snapshot_id"`
	Rejections      []Violation                  `json:"rejections,omitempty"`
	ScoreUsd        float64                      `json:"score_usd,omitempty"`
}

CandidateDecision defines model for CandidateDecision.

type CandidateDecisionDisposition added in v0.5.0 

type CandidateDecisionDisposition string

CandidateDecisionDisposition defines model for CandidateDecision.Disposition. 

const (
	ProvisionFreshRental CandidateDecisionDisposition = "provision_fresh_rental"
	QueueExistingRental  CandidateDecisionDisposition = "queue_existing_rental"
	RunNowExistingRental CandidateDecisionDisposition = "run_now_existing_rental"
)

Defines values for CandidateDecisionDisposition.

func (CandidateDecisionDisposition) Valid added in v0.5.0 

func (e CandidateDecisionDisposition) Valid() bool

Valid indicates whether the value is a known member of the CandidateDecisionDisposition enum.

type CandidateEstimates added in v0.4.0 

type CandidateEstimates struct {
	CostUsd          Estimate `json:"cost_usd"`
	ProvisionSeconds Estimate `json:"provision_seconds"`
	PullSeconds      Estimate `json:"pull_seconds"`
	QueueSeconds     Estimate `json:"queue_seconds"`
	StartSeconds     Estimate `json:"start_seconds"`
}

CandidateEstimates defines model for CandidateEstimates.

type CapabilityProfile added in v0.4.0 

type CapabilityProfile struct {
	Container     ContainerCapabilities         `json:"container"`
	Lifecycle     LifecycleCapabilities         `json:"lifecycle"`
	Network       NetworkCapabilities           `json:"network"`
	Observability ObservabilityCapabilities     `json:"observability"`
	OfferKinds    []CapabilityProfileOfferKinds `json:"offer_kinds,omitempty"`
	Pricing       PricingCapabilities           `json:"pricing"`
	Resources     ResourceCapabilities          `json:"resources"`
}

CapabilityProfile defines model for CapabilityProfile.

type CapabilityProfileOfferKinds added in v0.4.0 

type CapabilityProfileOfferKinds string

CapabilityProfileOfferKinds defines model for CapabilityProfile.OfferKinds. 

const (
	Provisionable CapabilityProfileOfferKinds = "provisionable"
	Standing      CapabilityProfileOfferKinds = "standing"
)

Defines values for CapabilityProfileOfferKinds.

func (CapabilityProfileOfferKinds) Valid added in v0.4.0 

func (e CapabilityProfileOfferKinds) Valid() bool

Valid indicates whether the value is a known member of the CapabilityProfileOfferKinds enum.

type CapacityEvidence added in v0.4.0 

type CapacityEvidence struct {
	Available  bool    `json:"available"`
	Confidence float64 `json:"confidence"`
}

CapacityEvidence defines model for CapacityEvidence.

type CleanupError added in v0.4.5 

type CleanupError struct {
	Code        string                  `json:"code"`
	Disposition CleanupErrorDisposition `json:"disposition"`
	LaunchKey   string                  `json:"launch_key"`
	Message     string                  `json:"message"`
	Retryable   bool                    `json:"retryable"`
}

CleanupError defines model for CleanupError.

type CleanupErrorDisposition added in v0.4.5 

type CleanupErrorDisposition string

CleanupErrorDisposition defines model for CleanupError.Disposition. 

const (
	Release   CleanupErrorDisposition = "release"
	Terminate CleanupErrorDisposition = "terminate"
)

Defines values for CleanupErrorDisposition.

func (CleanupErrorDisposition) Valid added in v0.4.5 

func (e CleanupErrorDisposition) Valid() bool

Valid indicates whether the value is a known member of the CleanupErrorDisposition enum.

type CloudEvent added in v0.4.0 

type CloudEvent = eventlog.CloudEvent

CloudEvent defines model for CloudEvent.

type CollectionReport added in v0.4.0 

type CollectionReport struct {
	ConnectionsFromCache []string `json:"connections_from_cache,omitempty"`
	ConnectionsQueried   []string `json:"connections_queried,omitempty"`
	ExcludedConnections  []string `json:"excluded_connections,omitempty"`
}

CollectionReport defines model for CollectionReport.

type CommandScenarioPlayback200JSONResponse added in v0.5.0 

type CommandScenarioPlayback200JSONResponse struct {
	Accepted bool `json:"accepted"`
}

func (CommandScenarioPlayback200JSONResponse) VisitCommandScenarioPlaybackResponse added in v0.5.0 

func (response CommandScenarioPlayback200JSONResponse) VisitCommandScenarioPlaybackResponse(w http.ResponseWriter) error

type CommandScenarioPlayback400JSONResponse added in v0.5.0 

type CommandScenarioPlayback400JSONResponse ErrorResponse

func (CommandScenarioPlayback400JSONResponse) VisitCommandScenarioPlaybackResponse added in v0.5.0 

func (response CommandScenarioPlayback400JSONResponse) VisitCommandScenarioPlaybackResponse(w http.ResponseWriter) error

type CommandScenarioPlayback401JSONResponse added in v0.5.0 

type CommandScenarioPlayback401JSONResponse ErrorResponse

func (CommandScenarioPlayback401JSONResponse) VisitCommandScenarioPlaybackResponse added in v0.5.0 

func (response CommandScenarioPlayback401JSONResponse) VisitCommandScenarioPlaybackResponse(w http.ResponseWriter) error

type CommandScenarioPlayback404JSONResponse added in v0.5.0 

type CommandScenarioPlayback404JSONResponse ErrorResponse

func (CommandScenarioPlayback404JSONResponse) VisitCommandScenarioPlaybackResponse added in v0.5.0 

func (response CommandScenarioPlayback404JSONResponse) VisitCommandScenarioPlaybackResponse(w http.ResponseWriter) error

type CommandScenarioPlayback501JSONResponse added in v0.5.0 

type CommandScenarioPlayback501JSONResponse ErrorResponse

func (CommandScenarioPlayback501JSONResponse) VisitCommandScenarioPlaybackResponse added in v0.5.0 

func (response CommandScenarioPlayback501JSONResponse) VisitCommandScenarioPlaybackResponse(w http.ResponseWriter) error

type CommandScenarioPlaybackJSONRequestBody added in v0.5.0 

type CommandScenarioPlaybackJSONRequestBody = ScenarioPlaybackCommand

CommandScenarioPlaybackJSONRequestBody defines body for CommandScenarioPlayback for application/json ContentType.

type CommandScenarioPlaybackRequestObject added in v0.5.0 

type CommandScenarioPlaybackRequestObject struct {
	WorkspaceId string `json:"workspace_id"`
	Body        *CommandScenarioPlaybackJSONRequestBody
}

type CommandScenarioPlaybackResponseObject added in v0.5.0 

type CommandScenarioPlaybackResponseObject interface {
	VisitCommandScenarioPlaybackResponse(w http.ResponseWriter) error
}

type ConnectionFailure added in v0.4.0 

type ConnectionFailure struct {
	AdapterType  string `json:"adapter_type"`
	ConnectionId string `json:"connection_id"`
	Message      string `json:"message"`
}

ConnectionFailure defines model for ConnectionFailure.

type ConnectionListResponse added in v0.4.0 

type ConnectionListResponse struct {
	Connections []ConnectionRecord `json:"connections"`
}

ConnectionListResponse defines model for ConnectionListResponse.

type ConnectionRecord added in v0.4.0 

type ConnectionRecord = connection.Record

ConnectionRecord defines model for ConnectionRecord.

type ConnectionResponse added in v0.4.0 

type ConnectionResponse struct {
	Connection ConnectionRecord `json:"connection"`
}

ConnectionResponse defines model for ConnectionResponse.

type ConsoleEventLog added in v0.5.0 

type ConsoleEventLog interface {
	ReadAll(context.Context, eventlog.GlobalPosition, int, eventlog.EventFilter) ([]eventlog.StoredEvent, error)
	LatestPosition(context.Context, eventlog.EventFilter) (eventlog.GlobalPosition, error)
	Subscribe(context.Context, eventlog.SubscriptionRequest) (<-chan eventlog.Delivery, error)
}

type ContainerCapabilities added in v0.4.0 

type ContainerCapabilities struct {
	MaxContainers              int  `json:"max_containers"`
	MaxEnvironmentBytes        int  `json:"max_environment_bytes"`
	SupportsDigestRefs         bool `json:"supports_digest_refs"`
	SupportsEntrypointOverride bool `json:"supports_entrypoint_override"`
}

ContainerCapabilities defines model for ContainerCapabilities.

type ContainerSpec added in v0.4.0 

type ContainerSpec struct {
	Args       []string              `json:"args,omitempty"`
	Entrypoint []string              `json:"entrypoint,omitempty"`
	Env        map[string]EnvBinding `json:"env,omitempty"`
	Image      string                `json:"image"`
	Name       string                `json:"name"`
	Platform   Platform              `json:"platform"`
	Ports      []PortSpec            `json:"ports,omitempty"`
}

ContainerSpec defines model for ContainerSpec.

type CreateConnection201JSONResponse added in v0.4.0 

type CreateConnection201JSONResponse ConnectionResponse

func (CreateConnection201JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection201JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection400JSONResponse added in v0.4.0 

type CreateConnection400JSONResponse ErrorResponse

func (CreateConnection400JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection400JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection401JSONResponse added in v0.4.0 

type CreateConnection401JSONResponse ErrorResponse

func (CreateConnection401JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection401JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection403JSONResponse added in v0.4.0 

type CreateConnection403JSONResponse ErrorResponse

func (CreateConnection403JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection403JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection409JSONResponse added in v0.4.0 

type CreateConnection409JSONResponse ErrorResponse

func (CreateConnection409JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection409JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection413JSONResponse added in v0.4.0 

type CreateConnection413JSONResponse ErrorResponse

func (CreateConnection413JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection413JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection500JSONResponse added in v0.4.0 

type CreateConnection500JSONResponse ErrorResponse

func (CreateConnection500JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection500JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnection501JSONResponse added in v0.4.0 

type CreateConnection501JSONResponse ErrorResponse

func (CreateConnection501JSONResponse) VisitCreateConnectionResponse added in v0.4.0 

func (response CreateConnection501JSONResponse) VisitCreateConnectionResponse(w http.ResponseWriter) error

type CreateConnectionJSONRequestBody added in v0.4.0 

type CreateConnectionJSONRequestBody = CreateConnectionRequest

CreateConnectionJSONRequestBody defines body for CreateConnection for application/json ContentType.

type CreateConnectionParams added in v0.4.0 

type CreateConnectionParams struct {
	WorkspaceId    string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
	IdempotencyKey string `json:"Idempotency-Key"`
}

CreateConnectionParams defines parameters for CreateConnection.

type CreateConnectionRequest added in v0.4.0 

type CreateConnectionRequest struct {
	AdapterType  string            `json:"adapter_type"`
	Config       map[string]string `json:"config,omitempty"`
	ConnectionId string            `json:"connection_id"`
	Credential   Credential        `json:"credential,omitempty"`

	// Secret Write-only: accepted on create, sealed at rest, never echoed in any response.
	Secret string `json:"secret,omitempty"`

	// WorkspaceId Optional. Defaults to the request's authorized workspace.
	WorkspaceId string `json:"workspace_id,omitempty"`
}

CreateConnectionRequest defines model for CreateConnectionRequest.

type CreateConnectionRequestObject added in v0.4.0 

type CreateConnectionRequestObject struct {
	Params CreateConnectionParams
	Body   *CreateConnectionJSONRequestBody
}

type CreateConnectionResponseObject added in v0.4.0 

type CreateConnectionResponseObject interface {
	VisitCreateConnectionResponse(w http.ResponseWriter) error
}

type CreateRevisionRequest added in v0.4.0 

type CreateRevisionRequest struct {
	Revision WorkloadRevision `json:"revision"`
}

CreateRevisionRequest defines model for CreateRevisionRequest.

type CreateRun202JSONResponse added in v0.4.0 

type CreateRun202JSONResponse RunResponse

func (CreateRun202JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun202JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRun400JSONResponse added in v0.4.0 

type CreateRun400JSONResponse ErrorResponse

func (CreateRun400JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun400JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRun401JSONResponse added in v0.4.0 

type CreateRun401JSONResponse ErrorResponse

func (CreateRun401JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun401JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRun403JSONResponse added in v0.4.0 

type CreateRun403JSONResponse ErrorResponse

func (CreateRun403JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun403JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRun404JSONResponse added in v0.4.0 

type CreateRun404JSONResponse ErrorResponse

func (CreateRun404JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun404JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRun409JSONResponse added in v0.4.0 

type CreateRun409JSONResponse ErrorResponse

func (CreateRun409JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun409JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRun413JSONResponse added in v0.4.0 

type CreateRun413JSONResponse ErrorResponse

func (CreateRun413JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun413JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRun500JSONResponse added in v0.4.0 

type CreateRun500JSONResponse ErrorResponse

func (CreateRun500JSONResponse) VisitCreateRunResponse added in v0.4.0 

func (response CreateRun500JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

type CreateRunJSONRequestBody added in v0.4.0 

type CreateRunJSONRequestBody = CreateRunRequest

CreateRunJSONRequestBody defines body for CreateRun for application/json ContentType.

type CreateRunParams added in v0.4.0 

type CreateRunParams struct {
	WorkspaceId    string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
	IdempotencyKey string `json:"Idempotency-Key"`
}

CreateRunParams defines parameters for CreateRun.

type CreateRunRequest added in v0.4.0 

type CreateRunRequest struct {
	// Args Container args for the image shorthand.
	Args []string `json:"args,omitempty"`

	// Env Run-level literal env bindings. For stored or explicit workload specs, these override or add to the workload container env for this run only. For image shorthand, these become the synthesized container env.
	Env map[string]EnvBinding `json:"env,omitempty"`

	// Image Top-level image shorthand. Synthesizes the single container when no full workload spec is supplied. Ignored when an explicit workload spec is present.
	Image string `json:"image,omitempty"`

	// RunId Optional. When omitted the server generates a uuidv7-based run id and returns it.
	RunId              string           `json:"run_id,omitempty"`
	Workload           WorkloadRevision `json:"workload,omitempty"`
	WorkloadId         string           `json:"workload_id,omitempty"`
	WorkloadRevisionId string           `json:"workload_revision_id,omitempty"`
	WorkspaceId        string           `json:"workspace_id,omitempty"`
}

CreateRunRequest Create a run. The only required input is an image (top-level shorthand) or a full workload spec. run_id is optional and server-generated (uuidv7) when omitted; an Idempotency-Key header is required for retry-safe replay.

type CreateRunRequestObject added in v0.4.0 

type CreateRunRequestObject struct {
	Params CreateRunParams
	Body   *CreateRunJSONRequestBody
}

type CreateRunResponseObject added in v0.4.0 

type CreateRunResponseObject interface {
	VisitCreateRunResponse(w http.ResponseWriter) error
}

type CreateWorkload202JSONResponse added in v0.4.0 

type CreateWorkload202JSONResponse struct {
	WorkloadId string `json:"workload_id"`
}

func (CreateWorkload202JSONResponse) VisitCreateWorkloadResponse added in v0.4.0 

func (response CreateWorkload202JSONResponse) VisitCreateWorkloadResponse(w http.ResponseWriter) error

type CreateWorkload400JSONResponse added in v0.4.0 

type CreateWorkload400JSONResponse ErrorResponse

func (CreateWorkload400JSONResponse) VisitCreateWorkloadResponse added in v0.4.0 

func (response CreateWorkload400JSONResponse) VisitCreateWorkloadResponse(w http.ResponseWriter) error

type CreateWorkload401JSONResponse added in v0.4.0 

type CreateWorkload401JSONResponse ErrorResponse

func (CreateWorkload401JSONResponse) VisitCreateWorkloadResponse added in v0.4.0 

func (response CreateWorkload401JSONResponse) VisitCreateWorkloadResponse(w http.ResponseWriter) error

type CreateWorkload403JSONResponse added in v0.4.0 

type CreateWorkload403JSONResponse ErrorResponse

func (CreateWorkload403JSONResponse) VisitCreateWorkloadResponse added in v0.4.0 

func (response CreateWorkload403JSONResponse) VisitCreateWorkloadResponse(w http.ResponseWriter) error

type CreateWorkload413JSONResponse added in v0.4.0 

type CreateWorkload413JSONResponse ErrorResponse

func (CreateWorkload413JSONResponse) VisitCreateWorkloadResponse added in v0.4.0 

func (response CreateWorkload413JSONResponse) VisitCreateWorkloadResponse(w http.ResponseWriter) error

type CreateWorkload501JSONResponse added in v0.4.0 

type CreateWorkload501JSONResponse ErrorResponse

func (CreateWorkload501JSONResponse) VisitCreateWorkloadResponse added in v0.4.0 

func (response CreateWorkload501JSONResponse) VisitCreateWorkloadResponse(w http.ResponseWriter) error

type CreateWorkloadJSONRequestBody added in v0.4.0 

type CreateWorkloadJSONRequestBody = CreateWorkloadRequest

CreateWorkloadJSONRequestBody defines body for CreateWorkload for application/json ContentType.

type CreateWorkloadParams added in v0.4.0 

type CreateWorkloadParams struct {
	IdempotencyKey string `json:"Idempotency-Key"`
}

CreateWorkloadParams defines parameters for CreateWorkload.

type CreateWorkloadRequest added in v0.4.0 

type CreateWorkloadRequest struct {
	Name        string `json:"name"`
	WorkloadId  string `json:"workload_id"`
	WorkspaceId string `json:"workspace_id"`
}

CreateWorkloadRequest defines model for CreateWorkloadRequest.

type CreateWorkloadRequestObject added in v0.4.0 

type CreateWorkloadRequestObject struct {
	Params CreateWorkloadParams
	Body   *CreateWorkloadJSONRequestBody
}

type CreateWorkloadResponseObject added in v0.4.0 

type CreateWorkloadResponseObject interface {
	VisitCreateWorkloadResponse(w http.ResponseWriter) error
}

type CreateWorkloadRevision202JSONResponse added in v0.4.0 

type CreateWorkloadRevision202JSONResponse WorkloadRevisionResponse

func (CreateWorkloadRevision202JSONResponse) VisitCreateWorkloadRevisionResponse added in v0.4.0 

func (response CreateWorkloadRevision202JSONResponse) VisitCreateWorkloadRevisionResponse(w http.ResponseWriter) error

type CreateWorkloadRevision400JSONResponse added in v0.4.0 

type CreateWorkloadRevision400JSONResponse ErrorResponse

func (CreateWorkloadRevision400JSONResponse) VisitCreateWorkloadRevisionResponse added in v0.4.0 

func (response CreateWorkloadRevision400JSONResponse) VisitCreateWorkloadRevisionResponse(w http.ResponseWriter) error

type CreateWorkloadRevision401JSONResponse added in v0.4.0 

type CreateWorkloadRevision401JSONResponse ErrorResponse

func (CreateWorkloadRevision401JSONResponse) VisitCreateWorkloadRevisionResponse added in v0.4.0 

func (response CreateWorkloadRevision401JSONResponse) VisitCreateWorkloadRevisionResponse(w http.ResponseWriter) error

type CreateWorkloadRevision403JSONResponse added in v0.4.0 

type CreateWorkloadRevision403JSONResponse ErrorResponse

func (CreateWorkloadRevision403JSONResponse) VisitCreateWorkloadRevisionResponse added in v0.4.0 

func (response CreateWorkloadRevision403JSONResponse) VisitCreateWorkloadRevisionResponse(w http.ResponseWriter) error

type CreateWorkloadRevision413JSONResponse added in v0.4.0 

type CreateWorkloadRevision413JSONResponse ErrorResponse

func (CreateWorkloadRevision413JSONResponse) VisitCreateWorkloadRevisionResponse added in v0.4.0 

func (response CreateWorkloadRevision413JSONResponse) VisitCreateWorkloadRevisionResponse(w http.ResponseWriter) error

type CreateWorkloadRevision501JSONResponse added in v0.4.0 

type CreateWorkloadRevision501JSONResponse ErrorResponse

func (CreateWorkloadRevision501JSONResponse) VisitCreateWorkloadRevisionResponse added in v0.4.0 

func (response CreateWorkloadRevision501JSONResponse) VisitCreateWorkloadRevisionResponse(w http.ResponseWriter) error

type CreateWorkloadRevisionJSONRequestBody added in v0.4.0 

type CreateWorkloadRevisionJSONRequestBody = CreateRevisionRequest

CreateWorkloadRevisionJSONRequestBody defines body for CreateWorkloadRevision for application/json ContentType.

type CreateWorkloadRevisionParams added in v0.4.0 

type CreateWorkloadRevisionParams struct {
	WorkspaceId    string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
	IdempotencyKey string `json:"Idempotency-Key"`
}

CreateWorkloadRevisionParams defines parameters for CreateWorkloadRevision.

type CreateWorkloadRevisionRequestObject added in v0.4.0 

type CreateWorkloadRevisionRequestObject struct {
	WorkloadId string `json:"workload_id"`
	Params     CreateWorkloadRevisionParams
	Body       *CreateWorkloadRevisionJSONRequestBody
}

type CreateWorkloadRevisionResponseObject added in v0.4.0 

type CreateWorkloadRevisionResponseObject interface {
	VisitCreateWorkloadRevisionResponse(w http.ResponseWriter) error
}

type CreateWorkspace201JSONResponse added in v0.4.5 

type CreateWorkspace201JSONResponse WorkspaceResponse

func (CreateWorkspace201JSONResponse) VisitCreateWorkspaceResponse added in v0.4.5 

func (response CreateWorkspace201JSONResponse) VisitCreateWorkspaceResponse(w http.ResponseWriter) error

type CreateWorkspace400JSONResponse added in v0.4.5 

type CreateWorkspace400JSONResponse ErrorResponse

func (CreateWorkspace400JSONResponse) VisitCreateWorkspaceResponse added in v0.4.5 

func (response CreateWorkspace400JSONResponse) VisitCreateWorkspaceResponse(w http.ResponseWriter) error

type CreateWorkspace401JSONResponse added in v0.4.5 

type CreateWorkspace401JSONResponse ErrorResponse

func (CreateWorkspace401JSONResponse) VisitCreateWorkspaceResponse added in v0.4.5 

func (response CreateWorkspace401JSONResponse) VisitCreateWorkspaceResponse(w http.ResponseWriter) error

type CreateWorkspace409JSONResponse added in v0.4.5 

type CreateWorkspace409JSONResponse ErrorResponse

func (CreateWorkspace409JSONResponse) VisitCreateWorkspaceResponse added in v0.4.5 

func (response CreateWorkspace409JSONResponse) VisitCreateWorkspaceResponse(w http.ResponseWriter) error

type CreateWorkspace500JSONResponse added in v0.4.5 

type CreateWorkspace500JSONResponse ErrorResponse

func (CreateWorkspace500JSONResponse) VisitCreateWorkspaceResponse added in v0.4.5 

func (response CreateWorkspace500JSONResponse) VisitCreateWorkspaceResponse(w http.ResponseWriter) error

type CreateWorkspaceJSONRequestBody added in v0.4.5 

type CreateWorkspaceJSONRequestBody = CreateWorkspaceRequest

CreateWorkspaceJSONRequestBody defines body for CreateWorkspace for application/json ContentType.

type CreateWorkspaceRequest added in v0.4.5 

type CreateWorkspaceRequest struct {
	DisplayName string `json:"display_name"`
}

CreateWorkspaceRequest defines model for CreateWorkspaceRequest.

type CreateWorkspaceRequestObject added in v0.4.5 

type CreateWorkspaceRequestObject struct {
	Body *CreateWorkspaceJSONRequestBody
}

type CreateWorkspaceResponseObject added in v0.4.5 

type CreateWorkspaceResponseObject interface {
	VisitCreateWorkspaceResponse(w http.ResponseWriter) error
}

type Credential added in v0.4.0 

type Credential = credential.Credential

Credential defines model for Credential.

type DeleteConnection200JSONResponse added in v0.4.0 

type DeleteConnection200JSONResponse struct {
	Deleted bool `json:"deleted"`
}

func (DeleteConnection200JSONResponse) VisitDeleteConnectionResponse added in v0.4.0 

func (response DeleteConnection200JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection400JSONResponse added in v0.4.0 

type DeleteConnection400JSONResponse ErrorResponse

func (DeleteConnection400JSONResponse) VisitDeleteConnectionResponse added in v0.4.0 

func (response DeleteConnection400JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection401JSONResponse added in v0.4.0 

type DeleteConnection401JSONResponse ErrorResponse

func (DeleteConnection401JSONResponse) VisitDeleteConnectionResponse added in v0.4.0 

func (response DeleteConnection401JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection403JSONResponse added in v0.4.0 

type DeleteConnection403JSONResponse ErrorResponse

func (DeleteConnection403JSONResponse) VisitDeleteConnectionResponse added in v0.4.0 

func (response DeleteConnection403JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection404JSONResponse added in v0.4.0 

type DeleteConnection404JSONResponse ErrorResponse

func (DeleteConnection404JSONResponse) VisitDeleteConnectionResponse added in v0.4.0 

func (response DeleteConnection404JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection500JSONResponse added in v0.4.0 

type DeleteConnection500JSONResponse ErrorResponse

func (DeleteConnection500JSONResponse) VisitDeleteConnectionResponse added in v0.4.0 

func (response DeleteConnection500JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnection501JSONResponse added in v0.4.0 

type DeleteConnection501JSONResponse ErrorResponse

func (DeleteConnection501JSONResponse) VisitDeleteConnectionResponse added in v0.4.0 

func (response DeleteConnection501JSONResponse) VisitDeleteConnectionResponse(w http.ResponseWriter) error

type DeleteConnectionParams added in v0.4.0 

type DeleteConnectionParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

DeleteConnectionParams defines parameters for DeleteConnection.

type DeleteConnectionRequestObject added in v0.4.0 

type DeleteConnectionRequestObject struct {
	ConnectionId string `json:"connection_id"`
	Params       DeleteConnectionParams
}

type DeleteConnectionResponseObject added in v0.4.0 

type DeleteConnectionResponseObject interface {
	VisitDeleteConnectionResponse(w http.ResponseWriter) error
}

type DeliverSink202JSONResponse added in v0.4.0 

type DeliverSink202JSONResponse SinkResult

func (DeliverSink202JSONResponse) VisitDeliverSinkResponse added in v0.4.0 

func (response DeliverSink202JSONResponse) VisitDeliverSinkResponse(w http.ResponseWriter) error

type DeliverSink401JSONResponse added in v0.4.0 

type DeliverSink401JSONResponse ErrorResponse

func (DeliverSink401JSONResponse) VisitDeliverSinkResponse added in v0.4.0 

func (response DeliverSink401JSONResponse) VisitDeliverSinkResponse(w http.ResponseWriter) error

type DeliverSink501JSONResponse added in v0.4.0 

type DeliverSink501JSONResponse ErrorResponse

func (DeliverSink501JSONResponse) VisitDeliverSinkResponse added in v0.4.0 

func (response DeliverSink501JSONResponse) VisitDeliverSinkResponse(w http.ResponseWriter) error

type DeliverSink502JSONResponse added in v0.4.0 

type DeliverSink502JSONResponse ErrorResponse

func (DeliverSink502JSONResponse) VisitDeliverSinkResponse added in v0.4.0 

func (response DeliverSink502JSONResponse) VisitDeliverSinkResponse(w http.ResponseWriter) error

type DeliverSinkRequestObject added in v0.4.0 

type DeliverSinkRequestObject struct {
	SinkId string `json:"sink_id"`
}

type DeliverSinkResponseObject added in v0.4.0 

type DeliverSinkResponseObject interface {
	VisitDeliverSinkResponse(w http.ResponseWriter) error
}

type Deps added in v0.2.0 

type Deps struct {
	Orchestrator *orchestrator.Orchestrator
	Offers       OfferAggregator
	Workloads    *workload.Service
	Sinks        *sinkspkg.Manager
	Connections  *connection.Service
	Resolver     ImageResolver
	Workspaces   *workspace.SQLiteCatalog
	Events       ConsoleEventLog
	Scenarios    *scenario.DashboardPlayback
}

Deps are the services the server routes to. Orchestrator and Offers are required; a nil optional service disables its endpoints. Placement preview and create-run intake both go through Orchestrator.

type DiskRequirement added in v0.4.0 

type DiskRequirement struct {
	MinBytes int64 `json:"min_bytes"`
}

DiskRequirement defines model for DiskRequirement.

type EnvBinding added in v0.4.0 

type EnvBinding = domain.EnvBinding

EnvBinding defines model for EnvBinding.

type ErrorResponse added in v0.4.0 

type ErrorResponse struct {
	Code    string      `json:"code"`
	Details []Violation `json:"details,omitempty"`
	Message string      `json:"message"`
}

ErrorResponse defines model for ErrorResponse.

type Estimate added in v0.4.0 

type Estimate struct {
	Confidence   float64 `json:"confidence,omitempty"`
	Expected     float64 `json:"expected,omitempty"`
	ModelVersion string  `json:"model_version,omitempty"`
	P50          float64 `json:"p50,omitempty"`
	P90          float64 `json:"p90,omitempty"`
	SampleCount  int     `json:"sample_count,omitempty"`
	Source       string  `json:"source,omitempty"`
}

Estimate defines model for Estimate.

type EventListResponse added in v0.4.0 

type EventListResponse struct {
	Events []CloudEvent `json:"events"`
}

EventListResponse defines model for EventListResponse.

type ExecutionPolicy added in v0.4.0 

type ExecutionPolicy struct {
	MaxPreStartAttempts int   `json:"max_pre_start_attempts"`
	MaxRuntimeSeconds   int64 `json:"max_runtime_seconds"`
}

ExecutionPolicy defines model for ExecutionPolicy.

type GetOpenAPI200JSONResponse added in v0.4.0 

type GetOpenAPI200JSONResponse map[string]interface{}

func (GetOpenAPI200JSONResponse) VisitGetOpenAPIResponse added in v0.4.0 

func (response GetOpenAPI200JSONResponse) VisitGetOpenAPIResponse(w http.ResponseWriter) error

type GetOpenAPIRequestObject added in v0.4.0 

type GetOpenAPIRequestObject struct {
}

type GetOpenAPIResponseObject added in v0.4.0 

type GetOpenAPIResponseObject interface {
	VisitGetOpenAPIResponse(w http.ResponseWriter) error
}

type GetRun200JSONResponse added in v0.4.0 

type GetRun200JSONResponse RunResponse

func (GetRun200JSONResponse) VisitGetRunResponse added in v0.4.0 

func (response GetRun200JSONResponse) VisitGetRunResponse(w http.ResponseWriter) error

type GetRun400JSONResponse added in v0.4.0 

type GetRun400JSONResponse ErrorResponse

func (GetRun400JSONResponse) VisitGetRunResponse added in v0.4.0 

func (response GetRun400JSONResponse) VisitGetRunResponse(w http.ResponseWriter) error

type GetRun401JSONResponse added in v0.4.0 

type GetRun401JSONResponse ErrorResponse

func (GetRun401JSONResponse) VisitGetRunResponse added in v0.4.0 

func (response GetRun401JSONResponse) VisitGetRunResponse(w http.ResponseWriter) error

type GetRun403JSONResponse added in v0.4.0 

type GetRun403JSONResponse ErrorResponse

func (GetRun403JSONResponse) VisitGetRunResponse added in v0.4.0 

func (response GetRun403JSONResponse) VisitGetRunResponse(w http.ResponseWriter) error

type GetRun404JSONResponse added in v0.4.0 

type GetRun404JSONResponse ErrorResponse

func (GetRun404JSONResponse) VisitGetRunResponse added in v0.4.0 

func (response GetRun404JSONResponse) VisitGetRunResponse(w http.ResponseWriter) error

type GetRunDecision200JSONResponse added in v0.4.0 

type GetRunDecision200JSONResponse BookingDecisionResponse

func (GetRunDecision200JSONResponse) VisitGetRunDecisionResponse added in v0.4.0 

func (response GetRunDecision200JSONResponse) VisitGetRunDecisionResponse(w http.ResponseWriter) error

type GetRunDecision400JSONResponse added in v0.4.0 

type GetRunDecision400JSONResponse ErrorResponse

func (GetRunDecision400JSONResponse) VisitGetRunDecisionResponse added in v0.4.0 

func (response GetRunDecision400JSONResponse) VisitGetRunDecisionResponse(w http.ResponseWriter) error

type GetRunDecision401JSONResponse added in v0.4.0 

type GetRunDecision401JSONResponse ErrorResponse

func (GetRunDecision401JSONResponse) VisitGetRunDecisionResponse added in v0.4.0 

func (response GetRunDecision401JSONResponse) VisitGetRunDecisionResponse(w http.ResponseWriter) error

type GetRunDecision403JSONResponse added in v0.4.0 

type GetRunDecision403JSONResponse ErrorResponse

func (GetRunDecision403JSONResponse) VisitGetRunDecisionResponse added in v0.4.0 

func (response GetRunDecision403JSONResponse) VisitGetRunDecisionResponse(w http.ResponseWriter) error

type GetRunDecision404JSONResponse added in v0.4.0 

type GetRunDecision404JSONResponse ErrorResponse

func (GetRunDecision404JSONResponse) VisitGetRunDecisionResponse added in v0.4.0 

func (response GetRunDecision404JSONResponse) VisitGetRunDecisionResponse(w http.ResponseWriter) error

type GetRunDecisionParams added in v0.4.0 

type GetRunDecisionParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

GetRunDecisionParams defines parameters for GetRunDecision.

type GetRunDecisionRequestObject added in v0.4.0 

type GetRunDecisionRequestObject struct {
	RunId  string `json:"run_id"`
	Params GetRunDecisionParams
}

type GetRunDecisionResponseObject added in v0.4.0 

type GetRunDecisionResponseObject interface {
	VisitGetRunDecisionResponse(w http.ResponseWriter) error
}

type GetRunParams added in v0.4.0 

type GetRunParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

GetRunParams defines parameters for GetRun.

type GetRunRequestObject added in v0.4.0 

type GetRunRequestObject struct {
	RunId  string `json:"run_id"`
	Params GetRunParams
}

type GetRunResponseObject added in v0.4.0 

type GetRunResponseObject interface {
	VisitGetRunResponse(w http.ResponseWriter) error
}

type GetSinkStatus200JSONResponse added in v0.4.0 

type GetSinkStatus200JSONResponse SinkStatus

func (GetSinkStatus200JSONResponse) VisitGetSinkStatusResponse added in v0.4.0 

func (response GetSinkStatus200JSONResponse) VisitGetSinkStatusResponse(w http.ResponseWriter) error

type GetSinkStatus401JSONResponse added in v0.4.0 

type GetSinkStatus401JSONResponse ErrorResponse

func (GetSinkStatus401JSONResponse) VisitGetSinkStatusResponse added in v0.4.0 

func (response GetSinkStatus401JSONResponse) VisitGetSinkStatusResponse(w http.ResponseWriter) error

type GetSinkStatus404JSONResponse added in v0.4.0 

type GetSinkStatus404JSONResponse ErrorResponse

func (GetSinkStatus404JSONResponse) VisitGetSinkStatusResponse added in v0.4.0 

func (response GetSinkStatus404JSONResponse) VisitGetSinkStatusResponse(w http.ResponseWriter) error

type GetSinkStatus501JSONResponse added in v0.4.0 

type GetSinkStatus501JSONResponse ErrorResponse

func (GetSinkStatus501JSONResponse) VisitGetSinkStatusResponse added in v0.4.0 

func (response GetSinkStatus501JSONResponse) VisitGetSinkStatusResponse(w http.ResponseWriter) error

type GetSinkStatusRequestObject added in v0.4.0 

type GetSinkStatusRequestObject struct {
	SinkId string `json:"sink_id"`
}

type GetSinkStatusResponseObject added in v0.4.0 

type GetSinkStatusResponseObject interface {
	VisitGetSinkStatusResponse(w http.ResponseWriter) error
}

type GetWorkloadRevision200JSONResponse added in v0.4.0 

type GetWorkloadRevision200JSONResponse WorkloadRevisionResponse

func (GetWorkloadRevision200JSONResponse) VisitGetWorkloadRevisionResponse added in v0.4.0 

func (response GetWorkloadRevision200JSONResponse) VisitGetWorkloadRevisionResponse(w http.ResponseWriter) error

type GetWorkloadRevision400JSONResponse added in v0.4.0 

type GetWorkloadRevision400JSONResponse ErrorResponse

func (GetWorkloadRevision400JSONResponse) VisitGetWorkloadRevisionResponse added in v0.4.0 

func (response GetWorkloadRevision400JSONResponse) VisitGetWorkloadRevisionResponse(w http.ResponseWriter) error

type GetWorkloadRevision401JSONResponse added in v0.4.0 

type GetWorkloadRevision401JSONResponse ErrorResponse

func (GetWorkloadRevision401JSONResponse) VisitGetWorkloadRevisionResponse added in v0.4.0 

func (response GetWorkloadRevision401JSONResponse) VisitGetWorkloadRevisionResponse(w http.ResponseWriter) error

type GetWorkloadRevision403JSONResponse added in v0.4.0 

type GetWorkloadRevision403JSONResponse ErrorResponse

func (GetWorkloadRevision403JSONResponse) VisitGetWorkloadRevisionResponse added in v0.4.0 

func (response GetWorkloadRevision403JSONResponse) VisitGetWorkloadRevisionResponse(w http.ResponseWriter) error

type GetWorkloadRevision404JSONResponse added in v0.4.0 

type GetWorkloadRevision404JSONResponse ErrorResponse

func (GetWorkloadRevision404JSONResponse) VisitGetWorkloadRevisionResponse added in v0.4.0 

func (response GetWorkloadRevision404JSONResponse) VisitGetWorkloadRevisionResponse(w http.ResponseWriter) error

type GetWorkloadRevision501JSONResponse added in v0.4.0 

type GetWorkloadRevision501JSONResponse ErrorResponse

func (GetWorkloadRevision501JSONResponse) VisitGetWorkloadRevisionResponse added in v0.4.0 

func (response GetWorkloadRevision501JSONResponse) VisitGetWorkloadRevisionResponse(w http.ResponseWriter) error

type GetWorkloadRevisionParams added in v0.4.0 

type GetWorkloadRevisionParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

GetWorkloadRevisionParams defines parameters for GetWorkloadRevision.

type GetWorkloadRevisionRequestObject added in v0.4.0 

type GetWorkloadRevisionRequestObject struct {
	WorkloadId string `json:"workload_id"`
	RevisionId string `json:"revision_id"`
	Params     GetWorkloadRevisionParams
}

type GetWorkloadRevisionResponseObject added in v0.4.0 

type GetWorkloadRevisionResponseObject interface {
	VisitGetWorkloadRevisionResponse(w http.ResponseWriter) error
}

type HealthLive200JSONResponse added in v0.4.0 

type HealthLive200JSONResponse struct {
	Status string `json:"status"`
}

func (HealthLive200JSONResponse) VisitHealthLiveResponse added in v0.4.0 

func (response HealthLive200JSONResponse) VisitHealthLiveResponse(w http.ResponseWriter) error

type HealthLiveRequestObject added in v0.4.0 

type HealthLiveRequestObject struct {
}

type HealthLiveResponseObject added in v0.4.0 

type HealthLiveResponseObject interface {
	VisitHealthLiveResponse(w http.ResponseWriter) error
}

type HealthReady200JSONResponse added in v0.4.0 

type HealthReady200JSONResponse struct {
	Status string `json:"status"`
}

func (HealthReady200JSONResponse) VisitHealthReadyResponse added in v0.4.0 

func (response HealthReady200JSONResponse) VisitHealthReadyResponse(w http.ResponseWriter) error

type HealthReadyRequestObject added in v0.4.0 

type HealthReadyRequestObject struct {
}

type HealthReadyResponseObject added in v0.4.0 

type HealthReadyResponseObject interface {
	VisitHealthReadyResponse(w http.ResponseWriter) error
}

type ImageCacheEvidence added in v0.4.0 

type ImageCacheEvidence struct {
	Known          bool  `json:"known"`
	ManifestCached bool  `json:"manifest_cached"`
	MissingBytes   int64 `json:"missing_bytes"`
}

ImageCacheEvidence defines model for ImageCacheEvidence.

type ImageResolver added in v0.2.0 

type ImageResolver interface {
	Resolve(context.Context, ociresolver.ResolveRequest) (ociresolver.ResolvedImage, error)
}

ImageResolver resolves a tag-form image reference to a digest-pinned one.

type InvalidParamFormatError added in v0.4.0 

type InvalidParamFormatError struct {
	ParamName string
	Err       error
}

func (*InvalidParamFormatError) Error added in v0.4.0 

func (e *InvalidParamFormatError) Error() string

func (*InvalidParamFormatError) Unwrap added in v0.4.0 

func (e *InvalidParamFormatError) Unwrap() error

type LifecycleCapabilities added in v0.4.0 

type LifecycleCapabilities struct {
	CancelQueued     bool   `json:"cancel_queued"`
	IdempotentLaunch string `json:"idempotent_launch"`
	ListOwned        bool   `json:"list_owned"`
	ProviderTtl      bool   `json:"provider_ttl"`
}

LifecycleCapabilities defines model for LifecycleCapabilities.

type ListAdapters200JSONResponse added in v0.4.0 

type ListAdapters200JSONResponse AdapterListResponse

func (ListAdapters200JSONResponse) VisitListAdaptersResponse added in v0.4.0 

func (response ListAdapters200JSONResponse) VisitListAdaptersResponse(w http.ResponseWriter) error

type ListAdapters401JSONResponse added in v0.4.0 

type ListAdapters401JSONResponse ErrorResponse

func (ListAdapters401JSONResponse) VisitListAdaptersResponse added in v0.4.0 

func (response ListAdapters401JSONResponse) VisitListAdaptersResponse(w http.ResponseWriter) error

type ListAdaptersRequestObject added in v0.4.0 

type ListAdaptersRequestObject struct {
}

type ListAdaptersResponseObject added in v0.4.0 

type ListAdaptersResponseObject interface {
	VisitListAdaptersResponse(w http.ResponseWriter) error
}

type ListConnections200JSONResponse added in v0.4.0 

type ListConnections200JSONResponse ConnectionListResponse

func (ListConnections200JSONResponse) VisitListConnectionsResponse added in v0.4.0 

func (response ListConnections200JSONResponse) VisitListConnectionsResponse(w http.ResponseWriter) error

type ListConnections400JSONResponse added in v0.4.0 

type ListConnections400JSONResponse ErrorResponse

func (ListConnections400JSONResponse) VisitListConnectionsResponse added in v0.4.0 

func (response ListConnections400JSONResponse) VisitListConnectionsResponse(w http.ResponseWriter) error

type ListConnections401JSONResponse added in v0.4.0 

type ListConnections401JSONResponse ErrorResponse

func (ListConnections401JSONResponse) VisitListConnectionsResponse added in v0.4.0 

func (response ListConnections401JSONResponse) VisitListConnectionsResponse(w http.ResponseWriter) error

type ListConnections403JSONResponse added in v0.4.0 

type ListConnections403JSONResponse ErrorResponse

func (ListConnections403JSONResponse) VisitListConnectionsResponse added in v0.4.0 

func (response ListConnections403JSONResponse) VisitListConnectionsResponse(w http.ResponseWriter) error

type ListConnections500JSONResponse added in v0.4.0 

type ListConnections500JSONResponse ErrorResponse

func (ListConnections500JSONResponse) VisitListConnectionsResponse added in v0.4.0 

func (response ListConnections500JSONResponse) VisitListConnectionsResponse(w http.ResponseWriter) error

type ListConnectionsParams added in v0.4.0 

type ListConnectionsParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

ListConnectionsParams defines parameters for ListConnections.

type ListConnectionsRequestObject added in v0.4.0 

type ListConnectionsRequestObject struct {
	Params ListConnectionsParams
}

type ListConnectionsResponseObject added in v0.4.0 

type ListConnectionsResponseObject interface {
	VisitListConnectionsResponse(w http.ResponseWriter) error
}

type ListOffers200JSONResponse added in v0.4.0 

type ListOffers200JSONResponse OfferListResponse

func (ListOffers200JSONResponse) VisitListOffersResponse added in v0.4.0 

func (response ListOffers200JSONResponse) VisitListOffersResponse(w http.ResponseWriter) error

type ListOffers400JSONResponse added in v0.4.0 

type ListOffers400JSONResponse ErrorResponse

func (ListOffers400JSONResponse) VisitListOffersResponse added in v0.4.0 

func (response ListOffers400JSONResponse) VisitListOffersResponse(w http.ResponseWriter) error

type ListOffers401JSONResponse added in v0.4.0 

type ListOffers401JSONResponse ErrorResponse

func (ListOffers401JSONResponse) VisitListOffersResponse added in v0.4.0 

func (response ListOffers401JSONResponse) VisitListOffersResponse(w http.ResponseWriter) error

type ListOffers403JSONResponse added in v0.4.0 

type ListOffers403JSONResponse ErrorResponse

func (ListOffers403JSONResponse) VisitListOffersResponse added in v0.4.0 

func (response ListOffers403JSONResponse) VisitListOffersResponse(w http.ResponseWriter) error

type ListOffers502JSONResponse added in v0.4.0 

type ListOffers502JSONResponse ErrorResponse

func (ListOffers502JSONResponse) VisitListOffersResponse added in v0.4.0 

func (response ListOffers502JSONResponse) VisitListOffersResponse(w http.ResponseWriter) error

type ListOffersParams added in v0.4.0 

type ListOffersParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

ListOffersParams defines parameters for ListOffers.

type ListOffersRequestObject added in v0.4.0 

type ListOffersRequestObject struct {
	Params ListOffersParams
}

type ListOffersResponseObject added in v0.4.0 

type ListOffersResponseObject interface {
	VisitListOffersResponse(w http.ResponseWriter) error
}

type ListRunEvents200JSONResponse added in v0.4.0 

type ListRunEvents200JSONResponse EventListResponse

func (ListRunEvents200JSONResponse) VisitListRunEventsResponse added in v0.4.0 

func (response ListRunEvents200JSONResponse) VisitListRunEventsResponse(w http.ResponseWriter) error

type ListRunEvents400JSONResponse added in v0.4.0 

type ListRunEvents400JSONResponse ErrorResponse

func (ListRunEvents400JSONResponse) VisitListRunEventsResponse added in v0.4.0 

func (response ListRunEvents400JSONResponse) VisitListRunEventsResponse(w http.ResponseWriter) error

type ListRunEvents401JSONResponse added in v0.4.0 

type ListRunEvents401JSONResponse ErrorResponse

func (ListRunEvents401JSONResponse) VisitListRunEventsResponse added in v0.4.0 

func (response ListRunEvents401JSONResponse) VisitListRunEventsResponse(w http.ResponseWriter) error

type ListRunEvents403JSONResponse added in v0.4.0 

type ListRunEvents403JSONResponse ErrorResponse

func (ListRunEvents403JSONResponse) VisitListRunEventsResponse added in v0.4.0 

func (response ListRunEvents403JSONResponse) VisitListRunEventsResponse(w http.ResponseWriter) error

type ListRunEvents500JSONResponse added in v0.4.0 

type ListRunEvents500JSONResponse ErrorResponse

func (ListRunEvents500JSONResponse) VisitListRunEventsResponse added in v0.4.0 

func (response ListRunEvents500JSONResponse) VisitListRunEventsResponse(w http.ResponseWriter) error

type ListRunEventsParams added in v0.4.0 

type ListRunEventsParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

ListRunEventsParams defines parameters for ListRunEvents.

type ListRunEventsRequestObject added in v0.4.0 

type ListRunEventsRequestObject struct {
	RunId  string `json:"run_id"`
	Params ListRunEventsParams
}

type ListRunEventsResponseObject added in v0.4.0 

type ListRunEventsResponseObject interface {
	VisitListRunEventsResponse(w http.ResponseWriter) error
}

type ListRuns200JSONResponse added in v0.4.0 

type ListRuns200JSONResponse RunListResponse

func (ListRuns200JSONResponse) VisitListRunsResponse added in v0.4.0 

func (response ListRuns200JSONResponse) VisitListRunsResponse(w http.ResponseWriter) error

type ListRuns400JSONResponse added in v0.4.0 

type ListRuns400JSONResponse ErrorResponse

func (ListRuns400JSONResponse) VisitListRunsResponse added in v0.4.0 

func (response ListRuns400JSONResponse) VisitListRunsResponse(w http.ResponseWriter) error

type ListRuns401JSONResponse added in v0.4.0 

type ListRuns401JSONResponse ErrorResponse

func (ListRuns401JSONResponse) VisitListRunsResponse added in v0.4.0 

func (response ListRuns401JSONResponse) VisitListRunsResponse(w http.ResponseWriter) error

type ListRuns403JSONResponse added in v0.4.0 

type ListRuns403JSONResponse ErrorResponse

func (ListRuns403JSONResponse) VisitListRunsResponse added in v0.4.0 

func (response ListRuns403JSONResponse) VisitListRunsResponse(w http.ResponseWriter) error

type ListRuns500JSONResponse added in v0.4.0 

type ListRuns500JSONResponse ErrorResponse

func (ListRuns500JSONResponse) VisitListRunsResponse added in v0.4.0 

func (response ListRuns500JSONResponse) VisitListRunsResponse(w http.ResponseWriter) error

type ListRunsParams added in v0.4.0 

type ListRunsParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

ListRunsParams defines parameters for ListRuns.

type ListRunsRequestObject added in v0.4.0 

type ListRunsRequestObject struct {
	Params ListRunsParams
}

type ListRunsResponseObject added in v0.4.0 

type ListRunsResponseObject interface {
	VisitListRunsResponse(w http.ResponseWriter) error
}

type ListWorkloadRevisions200JSONResponse added in v0.4.0 

type ListWorkloadRevisions200JSONResponse WorkloadRevisionListResponse

func (ListWorkloadRevisions200JSONResponse) VisitListWorkloadRevisionsResponse added in v0.4.0 

func (response ListWorkloadRevisions200JSONResponse) VisitListWorkloadRevisionsResponse(w http.ResponseWriter) error

type ListWorkloadRevisions400JSONResponse added in v0.4.0 

type ListWorkloadRevisions400JSONResponse ErrorResponse

func (ListWorkloadRevisions400JSONResponse) VisitListWorkloadRevisionsResponse added in v0.4.0 

func (response ListWorkloadRevisions400JSONResponse) VisitListWorkloadRevisionsResponse(w http.ResponseWriter) error

type ListWorkloadRevisions401JSONResponse added in v0.4.0 

type ListWorkloadRevisions401JSONResponse ErrorResponse

func (ListWorkloadRevisions401JSONResponse) VisitListWorkloadRevisionsResponse added in v0.4.0 

func (response ListWorkloadRevisions401JSONResponse) VisitListWorkloadRevisionsResponse(w http.ResponseWriter) error

type ListWorkloadRevisions403JSONResponse added in v0.4.0 

type ListWorkloadRevisions403JSONResponse ErrorResponse

func (ListWorkloadRevisions403JSONResponse) VisitListWorkloadRevisionsResponse added in v0.4.0 

func (response ListWorkloadRevisions403JSONResponse) VisitListWorkloadRevisionsResponse(w http.ResponseWriter) error

type ListWorkloadRevisions500JSONResponse added in v0.4.0 

type ListWorkloadRevisions500JSONResponse ErrorResponse

func (ListWorkloadRevisions500JSONResponse) VisitListWorkloadRevisionsResponse added in v0.4.0 

func (response ListWorkloadRevisions500JSONResponse) VisitListWorkloadRevisionsResponse(w http.ResponseWriter) error

type ListWorkloadRevisions501JSONResponse added in v0.4.0 

type ListWorkloadRevisions501JSONResponse ErrorResponse

func (ListWorkloadRevisions501JSONResponse) VisitListWorkloadRevisionsResponse added in v0.4.0 

func (response ListWorkloadRevisions501JSONResponse) VisitListWorkloadRevisionsResponse(w http.ResponseWriter) error

type ListWorkloadRevisionsParams added in v0.4.0 

type ListWorkloadRevisionsParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

ListWorkloadRevisionsParams defines parameters for ListWorkloadRevisions.

type ListWorkloadRevisionsRequestObject added in v0.4.0 

type ListWorkloadRevisionsRequestObject struct {
	WorkloadId string `json:"workload_id"`
	Params     ListWorkloadRevisionsParams
}

type ListWorkloadRevisionsResponseObject added in v0.4.0 

type ListWorkloadRevisionsResponseObject interface {
	VisitListWorkloadRevisionsResponse(w http.ResponseWriter) error
}

type ListWorkspaces200JSONResponse added in v0.4.5 

type ListWorkspaces200JSONResponse WorkspaceListResponse

func (ListWorkspaces200JSONResponse) VisitListWorkspacesResponse added in v0.4.5 

func (response ListWorkspaces200JSONResponse) VisitListWorkspacesResponse(w http.ResponseWriter) error

type ListWorkspaces401JSONResponse added in v0.4.5 

type ListWorkspaces401JSONResponse ErrorResponse

func (ListWorkspaces401JSONResponse) VisitListWorkspacesResponse added in v0.4.5 

func (response ListWorkspaces401JSONResponse) VisitListWorkspacesResponse(w http.ResponseWriter) error

type ListWorkspaces500JSONResponse added in v0.4.5 

type ListWorkspaces500JSONResponse ErrorResponse

func (ListWorkspaces500JSONResponse) VisitListWorkspacesResponse added in v0.4.5 

func (response ListWorkspaces500JSONResponse) VisitListWorkspacesResponse(w http.ResponseWriter) error

type ListWorkspacesParams added in v0.4.5 

type ListWorkspacesParams struct {
	IncludeArchived bool `form:"include_archived,omitempty" json:"include_archived,omitempty"`
}

ListWorkspacesParams defines parameters for ListWorkspaces.

type ListWorkspacesRequestObject added in v0.4.5 

type ListWorkspacesRequestObject struct {
	Params ListWorkspacesParams
}

type ListWorkspacesResponseObject added in v0.4.5 

type ListWorkspacesResponseObject interface {
	VisitListWorkspacesResponse(w http.ResponseWriter) error
}

type MemoryRequirement added in v0.4.0 

type MemoryRequirement struct {
	MinBytes int64 `json:"min_bytes"`
}

MemoryRequirement defines model for MemoryRequirement.

type MiddlewareFunc added in v0.4.0 

type MiddlewareFunc func(http.Handler) http.Handler

type NetworkCapabilities added in v0.4.0 

type NetworkCapabilities struct {
	Inbound    NetworkCapabilitiesInbound `json:"inbound"`
	Protocols  []string                   `json:"protocols,omitempty"`
	PublicIpv4 bool                       `json:"public_ipv4"`
}

NetworkCapabilities defines model for NetworkCapabilities.

type NetworkCapabilitiesInbound added in v0.4.0 

type NetworkCapabilitiesInbound string

NetworkCapabilitiesInbound defines model for NetworkCapabilities.Inbound. 

const (
	NetworkCapabilitiesInboundNone       NetworkCapabilitiesInbound = "none"
	NetworkCapabilitiesInboundPublicPort NetworkCapabilitiesInbound = "public_port"
)

Defines values for NetworkCapabilitiesInbound.

func (NetworkCapabilitiesInbound) Valid added in v0.4.0 

func (e NetworkCapabilitiesInbound) Valid() bool

Valid indicates whether the value is a known member of the NetworkCapabilitiesInbound enum.

type NetworkDownloadRequirement added in v0.4.0 

type NetworkDownloadRequirement struct {
	AllowUnknown             bool                            `json:"allow_unknown"`
	MaxMeasurementAgeSeconds int64                           `json:"max_measurement_age_seconds"`
	MinP10Mbps               float64                         `json:"min_p10_mbps"`
	Scope                    NetworkDownloadRequirementScope `json:"scope"`
}

NetworkDownloadRequirement defines model for NetworkDownloadRequirement.

type NetworkDownloadRequirementScope added in v0.4.0 

type NetworkDownloadRequirementScope string

NetworkDownloadRequirementScope defines model for NetworkDownloadRequirement.Scope. 

const (
	NetworkDownloadRequirementScopePublicInternet NetworkDownloadRequirementScope = "public_internet"
	NetworkDownloadRequirementScopeRegistry       NetworkDownloadRequirementScope = "registry"
)

Defines values for NetworkDownloadRequirementScope.

func (NetworkDownloadRequirementScope) Valid added in v0.4.0 

func (e NetworkDownloadRequirementScope) Valid() bool

Valid indicates whether the value is a known member of the NetworkDownloadRequirementScope enum.

type NetworkFact added in v0.4.0 

type NetworkFact struct {
	Confidence  float64          `json:"confidence"`
	ObservedAt  time.Time        `json:"observed_at"`
	SampleCount int              `json:"sample_count"`
	Scope       NetworkFactScope `json:"scope"`
	Source      string           `json:"source"`
	Statistic   string           `json:"statistic"`
	ValidUntil  time.Time        `json:"valid_until"`
	ValueMbps   float64          `json:"value_mbps"`
}

NetworkFact defines model for NetworkFact.

type NetworkFactScope added in v0.4.0 

type NetworkFactScope string

NetworkFactScope defines model for NetworkFact.Scope. 

const (
	NetworkFactScopePublicInternet NetworkFactScope = "public_internet"
	NetworkFactScopeRegistry       NetworkFactScope = "registry"
)

Defines values for NetworkFactScope.

func (NetworkFactScope) Valid added in v0.4.0 

func (e NetworkFactScope) Valid() bool

Valid indicates whether the value is a known member of the NetworkFactScope enum.

type NetworkFacts added in v0.4.0 

type NetworkFacts struct {
	Download []NetworkFact `json:"download,omitempty"`
}

NetworkFacts defines model for NetworkFacts.

type NetworkRequirements added in v0.4.0 

type NetworkRequirements struct {
	Download NetworkDownloadRequirement `json:"download,omitempty"`
	Inbound  NetworkRequirementsInbound `json:"inbound"`
}

NetworkRequirements defines model for NetworkRequirements.

type NetworkRequirementsInbound added in v0.4.0 

type NetworkRequirementsInbound string

NetworkRequirementsInbound defines model for NetworkRequirements.Inbound. 

const (
	NetworkRequirementsInboundNone       NetworkRequirementsInbound = "none"
	NetworkRequirementsInboundPublicPort NetworkRequirementsInbound = "public_port"
)

Defines values for NetworkRequirementsInbound.

func (NetworkRequirementsInbound) Valid added in v0.4.0 

func (e NetworkRequirementsInbound) Valid() bool

Valid indicates whether the value is a known member of the NetworkRequirementsInbound enum.

type ObservabilityCapabilities added in v0.4.0 

type ObservabilityCapabilities struct {
	Logs    string `json:"logs"`
	Metrics string `json:"metrics"`
	Shell   string `json:"shell"`
}

ObservabilityCapabilities defines model for ObservabilityCapabilities.

type OfferAggregator added in v0.4.0 

type OfferAggregator interface {
	AggregateOffers(context.Context, adapter.OfferRequest) (broker.OfferAggregation, error)
}

type OfferListResponse added in v0.4.0 

type OfferListResponse struct {
	Failures []ConnectionFailure `json:"failures"`
	Offers   []OfferSnapshot     `json:"offers"`
}

OfferListResponse defines model for OfferListResponse.

type OfferSnapshot added in v0.4.0 

type OfferSnapshot = domain.OfferSnapshot

OfferSnapshot defines model for OfferSnapshot.

type Option 

type Option func(*Server)

func WithAdapterManifests added in v0.4.0 

func WithAdapterManifests(manifests func() []adapter.Manifest) Option

WithAdapterManifests wires the registered adapters' onboarding manifests served by GET /v1/adapters (in practice broker.Factory.Manifests).

func WithBearerAuth 

func WithBearerAuth(token string) Option

func WithReportSigner 

func WithReportSigner(signer *reporting.Signer) Option

WithReportSigner wires the per-run token signer used to authenticate the POST /v1/runs/{id}/report ingest endpoint.

func WithVerifier 

func WithVerifier(verifier connectionVerifier) Option

WithVerifier wires the connection verifier (the Broker) the server uses to validate a connection during the authorize flow.

func WithWebAuth added in v0.3.0 

func WithWebAuth(auth WebAuth) Option

WithWebAuth mounts the OIDC human-login surface. Session-cookie requests are then accepted by the API gate with the signed-in email as the principal subject, and unauthenticated console page loads are routed into /auth/login.

type PlacementPolicy added in v0.4.0 

type PlacementPolicy struct {
	AllowUnknownPricing    bool                     `json:"allow_unknown_pricing,omitempty"`
	ExpectedRuntimeSeconds float64                  `json:"expected_runtime_seconds,omitempty"`
	MaxExpectedCostUsd     float64                  `json:"max_expected_cost_usd,omitempty"`
	MaxP90StartSeconds     float64                  `json:"max_p90_start_seconds,omitempty"`
	Objective              PlacementPolicyObjective `json:"objective"`
}

PlacementPolicy defines model for PlacementPolicy.

type PlacementPolicyObjective added in v0.4.0 

type PlacementPolicyObjective string

PlacementPolicyObjective defines model for PlacementPolicy.Objective. 

const (
	Balanced          PlacementPolicyObjective = "balanced"
	Cheapest          PlacementPolicyObjective = "cheapest"
	FastestCompletion PlacementPolicyObjective = "fastest_completion"
	FastestStart      PlacementPolicyObjective = "fastest_start"
)

Defines values for PlacementPolicyObjective.

func (PlacementPolicyObjective) Valid added in v0.4.0 

func (e PlacementPolicyObjective) Valid() bool

Valid indicates whether the value is a known member of the PlacementPolicyObjective enum.

type PlacementPreviewRequest added in v0.4.0 

type PlacementPreviewRequest struct {
	RunId       string           `json:"run_id,omitempty"`
	Workload    WorkloadRevision `json:"workload"`
	WorkspaceId string           `json:"workspace_id,omitempty"`
}

PlacementPreviewRequest defines model for PlacementPreviewRequest.

type PlacementPreviewResponse added in v0.4.0 

type PlacementPreviewResponse struct {
	Decision BookingDecision `json:"decision"`
}

PlacementPreviewResponse defines model for PlacementPreviewResponse.

type Platform added in v0.4.0 

type Platform struct {
	Architecture string `json:"architecture"`
	Os           string `json:"os"`
}

Platform defines model for Platform.

type PortSpec added in v0.4.0 

type PortSpec struct {
	ContainerPort int              `json:"container_port"`
	Exposure      PortSpecExposure `json:"exposure"`
	Name          string           `json:"name"`
	Protocol      string           `json:"protocol"`
}

PortSpec defines model for PortSpec.

type PortSpecExposure added in v0.4.0 

type PortSpecExposure string

PortSpecExposure defines model for PortSpec.Exposure. 

const (
	None    PortSpecExposure = "none"
	Private PortSpecExposure = "private"
	Public  PortSpecExposure = "public"
)

Defines values for PortSpecExposure.

func (PortSpecExposure) Valid added in v0.4.0 

func (e PortSpecExposure) Valid() bool

Valid indicates whether the value is a known member of the PortSpecExposure enum.

type PreviewPlacement200JSONResponse added in v0.4.0 

type PreviewPlacement200JSONResponse PlacementPreviewResponse

func (PreviewPlacement200JSONResponse) VisitPreviewPlacementResponse added in v0.4.0 

func (response PreviewPlacement200JSONResponse) VisitPreviewPlacementResponse(w http.ResponseWriter) error

type PreviewPlacement400JSONResponse added in v0.4.0 

type PreviewPlacement400JSONResponse ErrorResponse

func (PreviewPlacement400JSONResponse) VisitPreviewPlacementResponse added in v0.4.0 

func (response PreviewPlacement400JSONResponse) VisitPreviewPlacementResponse(w http.ResponseWriter) error

type PreviewPlacement401JSONResponse added in v0.4.0 

type PreviewPlacement401JSONResponse ErrorResponse

func (PreviewPlacement401JSONResponse) VisitPreviewPlacementResponse added in v0.4.0 

func (response PreviewPlacement401JSONResponse) VisitPreviewPlacementResponse(w http.ResponseWriter) error

type PreviewPlacement403JSONResponse added in v0.4.0 

type PreviewPlacement403JSONResponse ErrorResponse

func (PreviewPlacement403JSONResponse) VisitPreviewPlacementResponse added in v0.4.0 

func (response PreviewPlacement403JSONResponse) VisitPreviewPlacementResponse(w http.ResponseWriter) error

type PreviewPlacement413JSONResponse added in v0.4.0 

type PreviewPlacement413JSONResponse ErrorResponse

func (PreviewPlacement413JSONResponse) VisitPreviewPlacementResponse added in v0.4.0 

func (response PreviewPlacement413JSONResponse) VisitPreviewPlacementResponse(w http.ResponseWriter) error

type PreviewPlacement502JSONResponse added in v0.4.0 

type PreviewPlacement502JSONResponse ErrorResponse

func (PreviewPlacement502JSONResponse) VisitPreviewPlacementResponse added in v0.4.0 

func (response PreviewPlacement502JSONResponse) VisitPreviewPlacementResponse(w http.ResponseWriter) error

type PreviewPlacementJSONRequestBody added in v0.4.0 

type PreviewPlacementJSONRequestBody = PlacementPreviewRequest

PreviewPlacementJSONRequestBody defines body for PreviewPlacement for application/json ContentType.

type PreviewPlacementParams added in v0.4.0 

type PreviewPlacementParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

PreviewPlacementParams defines parameters for PreviewPlacement.

type PreviewPlacementRequestObject added in v0.4.0 

type PreviewPlacementRequestObject struct {
	Params PreviewPlacementParams
	Body   *PreviewPlacementJSONRequestBody
}

type PreviewPlacementResponseObject added in v0.4.0 

type PreviewPlacementResponseObject interface {
	VisitPreviewPlacementResponse(w http.ResponseWriter) error
}

type PriceModel added in v0.4.0 

type PriceModel struct {
	Currency             string  `json:"currency"`
	GranularitySeconds   int64   `json:"granularity_seconds"`
	Known                bool    `json:"known"`
	MinimumChargeSeconds int64   `json:"minimum_charge_seconds"`
	RatePerSecondUsd     float64 `json:"rate_per_second_usd"`
	SetupFeeUsd          float64 `json:"setup_fee_usd"`
}

PriceModel defines model for PriceModel.

type PricingCapabilities added in v0.4.0 

type PricingCapabilities struct {
	Known bool `json:"known"`
}

PricingCapabilities defines model for PricingCapabilities.

type QueueSnapshot added in v0.4.0 

type QueueSnapshot struct {
	ActiveSlots       int     `json:"active_slots"`
	QueuedWorkSeconds float64 `json:"queued_work_seconds"`
}

QueueSnapshot defines model for QueueSnapshot.

type RefreshRun200JSONResponse added in v0.4.0 

type RefreshRun200JSONResponse RunResponse

func (RefreshRun200JSONResponse) VisitRefreshRunResponse added in v0.4.0 

func (response RefreshRun200JSONResponse) VisitRefreshRunResponse(w http.ResponseWriter) error

type RefreshRun400JSONResponse added in v0.4.0 

type RefreshRun400JSONResponse ErrorResponse

func (RefreshRun400JSONResponse) VisitRefreshRunResponse added in v0.4.0 

func (response RefreshRun400JSONResponse) VisitRefreshRunResponse(w http.ResponseWriter) error

type RefreshRun401JSONResponse added in v0.4.0 

type RefreshRun401JSONResponse ErrorResponse

func (RefreshRun401JSONResponse) VisitRefreshRunResponse added in v0.4.0 

func (response RefreshRun401JSONResponse) VisitRefreshRunResponse(w http.ResponseWriter) error

type RefreshRun403JSONResponse added in v0.4.0 

type RefreshRun403JSONResponse ErrorResponse

func (RefreshRun403JSONResponse) VisitRefreshRunResponse added in v0.4.0 

func (response RefreshRun403JSONResponse) VisitRefreshRunResponse(w http.ResponseWriter) error

type RefreshRun502JSONResponse added in v0.4.0 

type RefreshRun502JSONResponse ErrorResponse

func (RefreshRun502JSONResponse) VisitRefreshRunResponse added in v0.4.0 

func (response RefreshRun502JSONResponse) VisitRefreshRunResponse(w http.ResponseWriter) error

type RefreshRunParams added in v0.4.0 

type RefreshRunParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

RefreshRunParams defines parameters for RefreshRun.

type RefreshRunRequestObject added in v0.4.0 

type RefreshRunRequestObject struct {
	RunId  string `json:"run_id"`
	Params RefreshRunParams
}

type RefreshRunResponseObject added in v0.4.0 

type RefreshRunResponseObject interface {
	VisitRefreshRunResponse(w http.ResponseWriter) error
}

type ReliabilityEvidence added in v0.4.0 

type ReliabilityEvidence struct {
	Confidence       float64 `json:"confidence,omitempty"`
	InterruptionRate float64 `json:"interruption_rate,omitempty"`
	StartFailureRate float64 `json:"start_failure_rate,omitempty"`
}

ReliabilityEvidence defines model for ReliabilityEvidence.

type ReplaySink202JSONResponse added in v0.4.0 

type ReplaySink202JSONResponse SinkResult

func (ReplaySink202JSONResponse) VisitReplaySinkResponse added in v0.4.0 

func (response ReplaySink202JSONResponse) VisitReplaySinkResponse(w http.ResponseWriter) error

type ReplaySink400JSONResponse added in v0.4.0 

type ReplaySink400JSONResponse ErrorResponse

func (ReplaySink400JSONResponse) VisitReplaySinkResponse added in v0.4.0 

func (response ReplaySink400JSONResponse) VisitReplaySinkResponse(w http.ResponseWriter) error

type ReplaySink401JSONResponse added in v0.4.0 

type ReplaySink401JSONResponse ErrorResponse

func (ReplaySink401JSONResponse) VisitReplaySinkResponse added in v0.4.0 

func (response ReplaySink401JSONResponse) VisitReplaySinkResponse(w http.ResponseWriter) error

type ReplaySink413JSONResponse added in v0.4.0 

type ReplaySink413JSONResponse ErrorResponse

func (ReplaySink413JSONResponse) VisitReplaySinkResponse added in v0.4.0 

func (response ReplaySink413JSONResponse) VisitReplaySinkResponse(w http.ResponseWriter) error

type ReplaySink501JSONResponse added in v0.4.0 

type ReplaySink501JSONResponse ErrorResponse

func (ReplaySink501JSONResponse) VisitReplaySinkResponse added in v0.4.0 

func (response ReplaySink501JSONResponse) VisitReplaySinkResponse(w http.ResponseWriter) error

type ReplaySink502JSONResponse added in v0.4.0 

type ReplaySink502JSONResponse ErrorResponse

func (ReplaySink502JSONResponse) VisitReplaySinkResponse added in v0.4.0 

func (response ReplaySink502JSONResponse) VisitReplaySinkResponse(w http.ResponseWriter) error

type ReplaySinkJSONRequestBody added in v0.4.0 

type ReplaySinkJSONRequestBody = ReplaySinkRequest

ReplaySinkJSONRequestBody defines body for ReplaySink for application/json ContentType.

type ReplaySinkRequest added in v0.4.0 

type ReplaySinkRequest struct {
	FromExclusive int    `json:"from_exclusive,omitempty"`
	Limit         int    `json:"limit,omitempty"`
	ReplayId      string `json:"replay_id,omitempty"`
}

ReplaySinkRequest defines model for ReplaySinkRequest.

type ReplaySinkRequestObject added in v0.4.0 

type ReplaySinkRequestObject struct {
	SinkId string `json:"sink_id"`
	Body   *ReplaySinkJSONRequestBody
}

type ReplaySinkResponseObject added in v0.4.0 

type ReplaySinkResponseObject interface {
	VisitReplaySinkResponse(w http.ResponseWriter) error
}

type ReportRun202JSONResponse added in v0.4.0 

type ReportRun202JSONResponse struct {
	Recorded bool `json:"recorded"`
}

func (ReportRun202JSONResponse) VisitReportRunResponse added in v0.4.0 

func (response ReportRun202JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRun400JSONResponse added in v0.4.0 

type ReportRun400JSONResponse ErrorResponse

func (ReportRun400JSONResponse) VisitReportRunResponse added in v0.4.0 

func (response ReportRun400JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRun401JSONResponse added in v0.4.0 

type ReportRun401JSONResponse ErrorResponse

func (ReportRun401JSONResponse) VisitReportRunResponse added in v0.4.0 

func (response ReportRun401JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRun404JSONResponse added in v0.4.0 

type ReportRun404JSONResponse ErrorResponse

func (ReportRun404JSONResponse) VisitReportRunResponse added in v0.4.0 

func (response ReportRun404JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRun409JSONResponse added in v0.4.5 

type ReportRun409JSONResponse ErrorResponse

func (ReportRun409JSONResponse) VisitReportRunResponse added in v0.4.5 

func (response ReportRun409JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRun413JSONResponse added in v0.4.0 

type ReportRun413JSONResponse ErrorResponse

func (ReportRun413JSONResponse) VisitReportRunResponse added in v0.4.0 

func (response ReportRun413JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRun501JSONResponse added in v0.4.0 

type ReportRun501JSONResponse ErrorResponse

func (ReportRun501JSONResponse) VisitReportRunResponse added in v0.4.0 

func (response ReportRun501JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRun502JSONResponse added in v0.4.0 

type ReportRun502JSONResponse ErrorResponse

func (ReportRun502JSONResponse) VisitReportRunResponse added in v0.4.0 

func (response ReportRun502JSONResponse) VisitReportRunResponse(w http.ResponseWriter) error

type ReportRunJSONRequestBody added in v0.4.0 

type ReportRunJSONRequestBody = ReportRunRequest

ReportRunJSONRequestBody defines body for ReportRun for application/json ContentType.

type ReportRunParams added in v0.4.0 

type ReportRunParams struct {
	WorkspaceId string `form:"workspace_id" json:"workspace_id"`

	// Authorization Per-run bearer token issued in the launch reporting environment.
	Authorization string `json:"Authorization,omitempty"`
}

ReportRunParams defines parameters for ReportRun.

type ReportRunRequest added in v0.4.0 

type ReportRunRequest struct {
	Data json.RawMessage `json:"data,omitempty"`

	// ExitCode Required when type is exit and forbidden for every other report type. The broker records the authoritative outcome and requests cleanup.
	ExitCode *int `json:"exit_code,omitempty"`

	// Type Report kind. The reserved exit kind is terminal and requires exit_code; every other kind is nonterminal and must omit exit_code.
	Type string `json:"type"`
}

ReportRunRequest defines model for ReportRunRequest.

type ReportRunRequestObject added in v0.4.0 

type ReportRunRequestObject struct {
	RunId  string `json:"run_id"`
	Params ReportRunParams
	Body   *ReportRunJSONRequestBody
}

type ReportRunResponseObject added in v0.4.0 

type ReportRunResponseObject interface {
	VisitReportRunResponse(w http.ResponseWriter) error
}

type RequiredHeaderError added in v0.4.0 

type RequiredHeaderError struct {
	ParamName string
	Err       error
}

func (*RequiredHeaderError) Error added in v0.4.0 

func (e *RequiredHeaderError) Error() string

func (*RequiredHeaderError) Unwrap added in v0.4.0 

func (e *RequiredHeaderError) Unwrap() error

type RequiredParamError added in v0.4.0 

type RequiredParamError struct {
	ParamName string
}

func (*RequiredParamError) Error added in v0.4.0 

func (e *RequiredParamError) Error() string

type ResolveImage200JSONResponse added in v0.4.0 

type ResolveImage200JSONResponse ResolveImageResponse

func (ResolveImage200JSONResponse) VisitResolveImageResponse added in v0.4.0 

func (response ResolveImage200JSONResponse) VisitResolveImageResponse(w http.ResponseWriter) error

type ResolveImage400JSONResponse added in v0.4.0 

type ResolveImage400JSONResponse ErrorResponse

func (ResolveImage400JSONResponse) VisitResolveImageResponse added in v0.4.0 

func (response ResolveImage400JSONResponse) VisitResolveImageResponse(w http.ResponseWriter) error

type ResolveImage401JSONResponse added in v0.4.0 

type ResolveImage401JSONResponse ErrorResponse

func (ResolveImage401JSONResponse) VisitResolveImageResponse added in v0.4.0 

func (response ResolveImage401JSONResponse) VisitResolveImageResponse(w http.ResponseWriter) error

type ResolveImage413JSONResponse added in v0.4.0 

type ResolveImage413JSONResponse ErrorResponse

func (ResolveImage413JSONResponse) VisitResolveImageResponse added in v0.4.0 

func (response ResolveImage413JSONResponse) VisitResolveImageResponse(w http.ResponseWriter) error

type ResolveImage501JSONResponse added in v0.4.0 

type ResolveImage501JSONResponse ErrorResponse

func (ResolveImage501JSONResponse) VisitResolveImageResponse added in v0.4.0 

func (response ResolveImage501JSONResponse) VisitResolveImageResponse(w http.ResponseWriter) error

type ResolveImageJSONRequestBody added in v0.4.0 

type ResolveImageJSONRequestBody = ResolveImageRequest

ResolveImageJSONRequestBody defines body for ResolveImage for application/json ContentType.

type ResolveImageRequest added in v0.4.0 

type ResolveImageRequest struct {
	Image    string `json:"image"`
	Platform string `json:"platform"`
}

ResolveImageRequest defines model for ResolveImageRequest.

type ResolveImageRequestObject added in v0.4.0 

type ResolveImageRequestObject struct {
	Body *ResolveImageJSONRequestBody
}

type ResolveImageResponse added in v0.4.0 

type ResolveImageResponse struct {
	Image ResolvedImage `json:"image"`
}

ResolveImageResponse defines model for ResolveImageResponse.

type ResolveImageResponseObject added in v0.4.0 

type ResolveImageResponseObject interface {
	VisitResolveImageResponse(w http.ResponseWriter) error
}

type ResolvedImage added in v0.4.0 

type ResolvedImage = ociresolver.ResolvedImage

ResolvedImage defines model for ResolvedImage.

type ResourceCapabilities added in v0.4.0 

type ResourceCapabilities struct {
	GpuVendors []string `json:"gpu_vendors,omitempty"`
}

ResourceCapabilities defines model for ResourceCapabilities.

type ResourceInventory added in v0.4.0 

type ResourceInventory struct {
	Accelerators       []AcceleratorInventory `json:"accelerators,omitempty"`
	CpuMillis          int64                  `json:"cpu_millis"`
	EphemeralDiskBytes int64                  `json:"ephemeral_disk_bytes"`
	MemoryBytes        int64                  `json:"memory_bytes"`
}

ResourceInventory defines model for ResourceInventory.

type ResourceRequirements added in v0.4.0 

type ResourceRequirements struct {
	Accelerators  []AcceleratorRequirement `json:"accelerators,omitempty"`
	Cpu           CPURequirement           `json:"cpu"`
	EphemeralDisk DiskRequirement          `json:"ephemeral_disk"`
	Memory        MemoryRequirement        `json:"memory"`
}

ResourceRequirements defines model for ResourceRequirements.

type Run added in v0.4.0 

type Run = domain.RunRecord

Run defines model for Run.

type RunListResponse added in v0.4.0 

type RunListResponse struct {
	Runs []Run `json:"runs"`
}

RunListResponse defines model for RunListResponse.

type RunResponse added in v0.4.0 

type RunResponse struct {
	// Duplicate True when this create was a safe idempotent replay of an existing run.
	Duplicate bool              `json:"duplicate,omitempty"`
	Links     map[string]string `json:"links,omitempty"`

	// Metadata Reserved for per-response metadata.
	Metadata map[string]interface{} `json:"metadata,omitempty"`
	Run      Run                    `json:"run"`

	// RunId Convenience top-level run identifier, equal to run.id. Returned on every run response alongside the full run record.
	RunId string `json:"run_id"`
}

RunResponse defines model for RunResponse.

type ScenarioPlaybackCommand added in v0.5.0 

type ScenarioPlaybackCommand struct {
	Speed ScenarioPlaybackCommandSpeed `json:"speed,omitempty"`
	Type  ScenarioPlaybackCommandType  `json:"type"`
}

ScenarioPlaybackCommand defines model for ScenarioPlaybackCommand.

type ScenarioPlaybackCommandSpeed added in v0.5.0 

type ScenarioPlaybackCommandSpeed int

ScenarioPlaybackCommandSpeed defines model for ScenarioPlaybackCommand.Speed. 

const (
	ScenarioPlaybackCommandSpeedN1 ScenarioPlaybackCommandSpeed = 1
	ScenarioPlaybackCommandSpeedN2 ScenarioPlaybackCommandSpeed = 2
	ScenarioPlaybackCommandSpeedN4 ScenarioPlaybackCommandSpeed = 4
)

Defines values for ScenarioPlaybackCommandSpeed.

func (ScenarioPlaybackCommandSpeed) Valid added in v0.5.0 

func (e ScenarioPlaybackCommandSpeed) Valid() bool

Valid indicates whether the value is a known member of the ScenarioPlaybackCommandSpeed enum.

type ScenarioPlaybackCommandType added in v0.5.0 

type ScenarioPlaybackCommandType string

ScenarioPlaybackCommandType defines model for ScenarioPlaybackCommand.Type. 

const (
	Next     ScenarioPlaybackCommandType = "next"
	Pause    ScenarioPlaybackCommandType = "pause"
	Play     ScenarioPlaybackCommandType = "play"
	Previous ScenarioPlaybackCommandType = "previous"
	Restart  ScenarioPlaybackCommandType = "restart"
	SetSpeed ScenarioPlaybackCommandType = "set_speed"
)

Defines values for ScenarioPlaybackCommandType.

func (ScenarioPlaybackCommandType) Valid added in v0.5.0 

func (e ScenarioPlaybackCommandType) Valid() bool

Valid indicates whether the value is a known member of the ScenarioPlaybackCommandType enum.

type ServeMux added in v0.4.0 

type ServeMux interface {
	HandleFunc(pattern string, handler func(http.ResponseWriter, *http.Request))
	ServeHTTP(w http.ResponseWriter, r *http.Request)
}

ServeMux is an abstraction of http.ServeMux.

type Server 

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

func (*Server) ArchiveWorkspace added in v0.4.5 

func (s *Server) ArchiveWorkspace(ctx context.Context, request ArchiveWorkspaceRequestObject) (ArchiveWorkspaceResponseObject, error)

func (*Server) AuthorizeConnection added in v0.4.0 

func (s *Server) AuthorizeConnection(ctx context.Context, request AuthorizeConnectionRequestObject) (AuthorizeConnectionResponseObject, error)

func (*Server) CancelRun added in v0.4.0 

func (s *Server) CancelRun(ctx context.Context, request CancelRunRequestObject) (CancelRunResponseObject, error)

func (*Server) CommandScenarioPlayback added in v0.5.0 

func (s *Server) CommandScenarioPlayback(_ context.Context, request CommandScenarioPlaybackRequestObject) (CommandScenarioPlaybackResponseObject, error)

func (*Server) CreateConnection added in v0.4.0 

func (s *Server) CreateConnection(ctx context.Context, request CreateConnectionRequestObject) (CreateConnectionResponseObject, error)

func (*Server) CreateRun added in v0.4.0 

func (s *Server) CreateRun(ctx context.Context, request CreateRunRequestObject) (CreateRunResponseObject, error)

func (*Server) CreateWorkload added in v0.4.0 

func (s *Server) CreateWorkload(ctx context.Context, request CreateWorkloadRequestObject) (CreateWorkloadResponseObject, error)

func (*Server) CreateWorkloadRevision added in v0.4.0 

func (s *Server) CreateWorkloadRevision(ctx context.Context, request CreateWorkloadRevisionRequestObject) (CreateWorkloadRevisionResponseObject, error)

func (*Server) CreateWorkspace added in v0.4.5 

func (s *Server) CreateWorkspace(ctx context.Context, request CreateWorkspaceRequestObject) (CreateWorkspaceResponseObject, error)

func (*Server) DeleteConnection added in v0.4.0 

func (s *Server) DeleteConnection(ctx context.Context, request DeleteConnectionRequestObject) (DeleteConnectionResponseObject, error)

DeleteConnection appends the deleted fact. The event stream itself is retained; the connection service removes sealed credentials atomically.

func (*Server) DeliverSink added in v0.4.0 

func (s *Server) DeliverSink(ctx context.Context, request DeliverSinkRequestObject) (DeliverSinkResponseObject, error)

func (*Server) GetOpenAPI added in v0.4.0 

func (s *Server) GetOpenAPI(context.Context, GetOpenAPIRequestObject) (GetOpenAPIResponseObject, error)

func (*Server) GetRun added in v0.4.0 

func (s *Server) GetRun(ctx context.Context, request GetRunRequestObject) (GetRunResponseObject, error)

func (*Server) GetRunDecision added in v0.4.0 

func (s *Server) GetRunDecision(ctx context.Context, request GetRunDecisionRequestObject) (GetRunDecisionResponseObject, error)

func (*Server) GetSinkStatus added in v0.4.0 

func (s *Server) GetSinkStatus(ctx context.Context, request GetSinkStatusRequestObject) (GetSinkStatusResponseObject, error)

func (*Server) GetWorkloadRevision added in v0.4.0 

func (s *Server) GetWorkloadRevision(ctx context.Context, request GetWorkloadRevisionRequestObject) (GetWorkloadRevisionResponseObject, error)

func (*Server) HealthLive added in v0.4.0 

func (s *Server) HealthLive(context.Context, HealthLiveRequestObject) (HealthLiveResponseObject, error)

func (*Server) HealthReady added in v0.4.0 

func (s *Server) HealthReady(context.Context, HealthReadyRequestObject) (HealthReadyResponseObject, error)

func (*Server) ListAdapters added in v0.4.0 

func (s *Server) ListAdapters(context.Context, ListAdaptersRequestObject) (ListAdaptersResponseObject, error)

ListAdapters serves the registered adapters' onboarding manifests. The list is static per process and carries no workspace state, but it sits behind the same /v1 auth gate as everything else.

func (*Server) ListConnections added in v0.4.0 

func (s *Server) ListConnections(ctx context.Context, request ListConnectionsRequestObject) (ListConnectionsResponseObject, error)

func (*Server) ListOffers added in v0.4.0 

func (s *Server) ListOffers(ctx context.Context, request ListOffersRequestObject) (ListOffersResponseObject, error)

func (*Server) ListRunEvents added in v0.4.0 

func (s *Server) ListRunEvents(ctx context.Context, request ListRunEventsRequestObject) (ListRunEventsResponseObject, error)

func (*Server) ListRuns added in v0.4.0 

func (s *Server) ListRuns(ctx context.Context, request ListRunsRequestObject) (ListRunsResponseObject, error)

func (*Server) ListWorkloadRevisions added in v0.4.0 

func (s *Server) ListWorkloadRevisions(ctx context.Context, request ListWorkloadRevisionsRequestObject) (ListWorkloadRevisionsResponseObject, error)

func (*Server) ListWorkspaces added in v0.4.5 

func (s *Server) ListWorkspaces(ctx context.Context, request ListWorkspacesRequestObject) (ListWorkspacesResponseObject, error)

func (*Server) PreviewPlacement added in v0.4.0 

func (s *Server) PreviewPlacement(ctx context.Context, request PreviewPlacementRequestObject) (PreviewPlacementResponseObject, error)

func (*Server) RefreshRun added in v0.4.0 

func (s *Server) RefreshRun(ctx context.Context, request RefreshRunRequestObject) (RefreshRunResponseObject, error)

func (*Server) ReplaySink added in v0.4.0 

func (s *Server) ReplaySink(ctx context.Context, request ReplaySinkRequestObject) (ReplaySinkResponseObject, error)

func (*Server) ReportRun added in v0.4.0 

func (s *Server) ReportRun(ctx context.Context, request ReportRunRequestObject) (ReportRunResponseObject, error)

func (*Server) ResolveImage added in v0.4.0 

func (s *Server) ResolveImage(ctx context.Context, request ResolveImageRequestObject) (ResolveImageResponseObject, error)

func (*Server) ServeHTTP 

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Server) StreamConsoleEvents added in v0.5.0 

func (s *Server) StreamConsoleEvents(ctx context.Context, request StreamConsoleEventsRequestObject) (StreamConsoleEventsResponseObject, error)

func (*Server) WaitRun added in v0.4.0 

func (s *Server) WaitRun(ctx context.Context, request WaitRunRequestObject) (WaitRunResponseObject, error)

type ServerInterface added in v0.4.0 

type ServerInterface interface {

	// (GET /health/live)
	HealthLive(w http.ResponseWriter, r *http.Request)

	// (GET /health/ready)
	HealthReady(w http.ResponseWriter, r *http.Request)

	// (GET /openapi.json)
	GetOpenAPI(w http.ResponseWriter, r *http.Request)

	// (GET /v1/adapters)
	ListAdapters(w http.ResponseWriter, r *http.Request)

	// (GET /v1/connections)
	ListConnections(w http.ResponseWriter, r *http.Request, params ListConnectionsParams)

	// (POST /v1/connections)
	CreateConnection(w http.ResponseWriter, r *http.Request, params CreateConnectionParams)

	// (DELETE /v1/connections/{connection_id})
	DeleteConnection(w http.ResponseWriter, r *http.Request, connectionId string, params DeleteConnectionParams)

	// (POST /v1/connections/{connection_id}/authorize)
	AuthorizeConnection(w http.ResponseWriter, r *http.Request, connectionId string, params AuthorizeConnectionParams)

	// (GET /v1/console/events)
	StreamConsoleEvents(w http.ResponseWriter, r *http.Request, params StreamConsoleEventsParams)

	// (POST /v1/dev/scenario-sessions/{workspace_id}/commands)
	CommandScenarioPlayback(w http.ResponseWriter, r *http.Request, workspaceId string)

	// (POST /v1/images:resolve)
	ResolveImage(w http.ResponseWriter, r *http.Request)

	// (GET /v1/offers)
	ListOffers(w http.ResponseWriter, r *http.Request, params ListOffersParams)

	// (POST /v1/placements:preview)
	PreviewPlacement(w http.ResponseWriter, r *http.Request, params PreviewPlacementParams)

	// (GET /v1/runs)
	ListRuns(w http.ResponseWriter, r *http.Request, params ListRunsParams)

	// (POST /v1/runs)
	CreateRun(w http.ResponseWriter, r *http.Request, params CreateRunParams)

	// (GET /v1/runs/{run_id})
	GetRun(w http.ResponseWriter, r *http.Request, runId string, params GetRunParams)

	// (POST /v1/runs/{run_id}/cancel)
	CancelRun(w http.ResponseWriter, r *http.Request, runId string, params CancelRunParams)

	// (GET /v1/runs/{run_id}/decision)
	GetRunDecision(w http.ResponseWriter, r *http.Request, runId string, params GetRunDecisionParams)

	// (GET /v1/runs/{run_id}/events)
	ListRunEvents(w http.ResponseWriter, r *http.Request, runId string, params ListRunEventsParams)

	// (POST /v1/runs/{run_id}/refresh)
	RefreshRun(w http.ResponseWriter, r *http.Request, runId string, params RefreshRunParams)

	// (POST /v1/runs/{run_id}/report)
	ReportRun(w http.ResponseWriter, r *http.Request, runId string, params ReportRunParams)

	// (GET /v1/runs/{run_id}/wait)
	WaitRun(w http.ResponseWriter, r *http.Request, runId string, params WaitRunParams)

	// (GET /v1/sinks/{sink_id})
	GetSinkStatus(w http.ResponseWriter, r *http.Request, sinkId string)

	// (POST /v1/sinks/{sink_id}/deliver)
	DeliverSink(w http.ResponseWriter, r *http.Request, sinkId string)

	// (POST /v1/sinks/{sink_id}/replay)
	ReplaySink(w http.ResponseWriter, r *http.Request, sinkId string)

	// (POST /v1/workloads)
	CreateWorkload(w http.ResponseWriter, r *http.Request, params CreateWorkloadParams)

	// (GET /v1/workloads/{workload_id}/revisions)
	ListWorkloadRevisions(w http.ResponseWriter, r *http.Request, workloadId string, params ListWorkloadRevisionsParams)

	// (POST /v1/workloads/{workload_id}/revisions)
	CreateWorkloadRevision(w http.ResponseWriter, r *http.Request, workloadId string, params CreateWorkloadRevisionParams)

	// (GET /v1/workloads/{workload_id}/revisions/{revision_id})
	GetWorkloadRevision(w http.ResponseWriter, r *http.Request, workloadId string, revisionId string, params GetWorkloadRevisionParams)

	// (GET /v1/workspaces)
	ListWorkspaces(w http.ResponseWriter, r *http.Request, params ListWorkspacesParams)

	// (POST /v1/workspaces)
	CreateWorkspace(w http.ResponseWriter, r *http.Request)

	// (POST /v1/workspaces/{workspace_id}/archive)
	ArchiveWorkspace(w http.ResponseWriter, r *http.Request, workspaceId string)
}

ServerInterface represents all server handlers.

func NewStrictHandler added in v0.4.0 

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

func NewStrictHandlerWithOptions added in v0.4.0 

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

type ServerInterfaceWrapper added in v0.4.0 

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

ServerInterfaceWrapper converts contexts to parameters.

func (*ServerInterfaceWrapper) ArchiveWorkspace added in v0.4.5 

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

ArchiveWorkspace operation middleware

func (*ServerInterfaceWrapper) AuthorizeConnection added in v0.4.0 

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

AuthorizeConnection operation middleware

func (*ServerInterfaceWrapper) CancelRun added in v0.4.0 

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

CancelRun operation middleware

func (*ServerInterfaceWrapper) CommandScenarioPlayback added in v0.5.0 

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

CommandScenarioPlayback operation middleware

func (*ServerInterfaceWrapper) CreateConnection added in v0.4.0 

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

CreateConnection operation middleware

func (*ServerInterfaceWrapper) CreateRun added in v0.4.0 

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

CreateRun operation middleware

func (*ServerInterfaceWrapper) CreateWorkload added in v0.4.0 

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

CreateWorkload operation middleware

func (*ServerInterfaceWrapper) CreateWorkloadRevision added in v0.4.0 

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

CreateWorkloadRevision operation middleware

func (*ServerInterfaceWrapper) CreateWorkspace added in v0.4.5 

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

CreateWorkspace operation middleware

func (*ServerInterfaceWrapper) DeleteConnection added in v0.4.0 

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

DeleteConnection operation middleware

func (*ServerInterfaceWrapper) DeliverSink added in v0.4.0 

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

DeliverSink operation middleware

func (*ServerInterfaceWrapper) GetOpenAPI added in v0.4.0 

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

GetOpenAPI operation middleware

func (*ServerInterfaceWrapper) GetRun added in v0.4.0 

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

GetRun operation middleware

func (*ServerInterfaceWrapper) GetRunDecision added in v0.4.0 

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

GetRunDecision operation middleware

func (*ServerInterfaceWrapper) GetSinkStatus added in v0.4.0 

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

GetSinkStatus operation middleware

func (*ServerInterfaceWrapper) GetWorkloadRevision added in v0.4.0 

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

GetWorkloadRevision operation middleware

func (*ServerInterfaceWrapper) HealthLive added in v0.4.0 

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

HealthLive operation middleware

func (*ServerInterfaceWrapper) HealthReady added in v0.4.0 

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

HealthReady operation middleware

func (*ServerInterfaceWrapper) ListAdapters added in v0.4.0 

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

ListAdapters operation middleware

func (*ServerInterfaceWrapper) ListConnections added in v0.4.0 

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

ListConnections operation middleware

func (*ServerInterfaceWrapper) ListOffers added in v0.4.0 

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

ListOffers operation middleware

func (*ServerInterfaceWrapper) ListRunEvents added in v0.4.0 

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

ListRunEvents operation middleware

func (*ServerInterfaceWrapper) ListRuns added in v0.4.0 

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

ListRuns operation middleware

func (*ServerInterfaceWrapper) ListWorkloadRevisions added in v0.4.0 

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

ListWorkloadRevisions operation middleware

func (*ServerInterfaceWrapper) ListWorkspaces added in v0.4.5 

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

ListWorkspaces operation middleware

func (*ServerInterfaceWrapper) PreviewPlacement added in v0.4.0 

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

PreviewPlacement operation middleware

func (*ServerInterfaceWrapper) RefreshRun added in v0.4.0 

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

RefreshRun operation middleware

func (*ServerInterfaceWrapper) ReplaySink added in v0.4.0 

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

ReplaySink operation middleware

func (*ServerInterfaceWrapper) ReportRun added in v0.4.0 

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

ReportRun operation middleware

func (*ServerInterfaceWrapper) ResolveImage added in v0.4.0 

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

ResolveImage operation middleware

func (*ServerInterfaceWrapper) StreamConsoleEvents added in v0.5.0 

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

StreamConsoleEvents operation middleware

func (*ServerInterfaceWrapper) WaitRun added in v0.4.0 

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

WaitRun operation middleware

type SinkResult added in v0.4.0 

type SinkResult = sinks.Result

SinkResult defines model for SinkResult.

type SinkStatus added in v0.4.0 

type SinkStatus = sinks.Status

SinkStatus defines model for SinkStatus.

type StdHTTPServerOptions added in v0.4.0 

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

type StreamConsoleEvents200TexteventStreamResponse added in v0.5.0 

type StreamConsoleEvents200TexteventStreamResponse struct {
	Body          io.Reader
	ContentLength int64
}

func (StreamConsoleEvents200TexteventStreamResponse) VisitStreamConsoleEventsResponse added in v0.5.0 

func (response StreamConsoleEvents200TexteventStreamResponse) VisitStreamConsoleEventsResponse(w http.ResponseWriter) error

type StreamConsoleEvents400JSONResponse added in v0.5.0 

type StreamConsoleEvents400JSONResponse ErrorResponse

func (StreamConsoleEvents400JSONResponse) VisitStreamConsoleEventsResponse added in v0.5.0 

func (response StreamConsoleEvents400JSONResponse) VisitStreamConsoleEventsResponse(w http.ResponseWriter) error

type StreamConsoleEvents401JSONResponse added in v0.5.0 

type StreamConsoleEvents401JSONResponse ErrorResponse

func (StreamConsoleEvents401JSONResponse) VisitStreamConsoleEventsResponse added in v0.5.0 

func (response StreamConsoleEvents401JSONResponse) VisitStreamConsoleEventsResponse(w http.ResponseWriter) error

type StreamConsoleEvents403JSONResponse added in v0.5.0 

type StreamConsoleEvents403JSONResponse ErrorResponse

func (StreamConsoleEvents403JSONResponse) VisitStreamConsoleEventsResponse added in v0.5.0 

func (response StreamConsoleEvents403JSONResponse) VisitStreamConsoleEventsResponse(w http.ResponseWriter) error

type StreamConsoleEvents501JSONResponse added in v0.5.0 

type StreamConsoleEvents501JSONResponse ErrorResponse

func (StreamConsoleEvents501JSONResponse) VisitStreamConsoleEventsResponse added in v0.5.0 

func (response StreamConsoleEvents501JSONResponse) VisitStreamConsoleEventsResponse(w http.ResponseWriter) error

type StreamConsoleEvents502JSONResponse added in v0.5.0 

type StreamConsoleEvents502JSONResponse ErrorResponse

func (StreamConsoleEvents502JSONResponse) VisitStreamConsoleEventsResponse added in v0.5.0 

func (response StreamConsoleEvents502JSONResponse) VisitStreamConsoleEventsResponse(w http.ResponseWriter) error

type StreamConsoleEventsParams added in v0.5.0 

type StreamConsoleEventsParams struct {
	WorkspaceId string                        `form:"workspace_id" json:"workspace_id"`
	Scenario    string                        `form:"scenario,omitempty" json:"scenario,omitempty"`
	Play        StreamConsoleEventsParamsPlay `form:"play,omitempty" json:"play,omitempty"`
	LastEventID string                        `json:"Last-Event-ID,omitempty"`
}

StreamConsoleEventsParams defines parameters for StreamConsoleEvents.

type StreamConsoleEventsParamsPlay added in v0.5.0 

type StreamConsoleEventsParamsPlay string

StreamConsoleEventsParamsPlay defines parameters for StreamConsoleEvents. 

const (
	StreamConsoleEventsParamsPlayN0 StreamConsoleEventsParamsPlay = "0"
	StreamConsoleEventsParamsPlayN1 StreamConsoleEventsParamsPlay = "1"
)

Defines values for StreamConsoleEventsParamsPlay.

func (StreamConsoleEventsParamsPlay) Valid added in v0.5.0 

func (e StreamConsoleEventsParamsPlay) Valid() bool

Valid indicates whether the value is a known member of the StreamConsoleEventsParamsPlay enum.

type StreamConsoleEventsRequestObject added in v0.5.0 

type StreamConsoleEventsRequestObject struct {
	Params StreamConsoleEventsParams
}

type StreamConsoleEventsResponseObject added in v0.5.0 

type StreamConsoleEventsResponseObject interface {
	VisitStreamConsoleEventsResponse(w http.ResponseWriter) error
}

type StrictHTTPServerOptions added in v0.4.0 

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 added in v0.4.0 

type StrictHandlerFunc = strictnethttp.StrictHTTPHandlerFunc

type StrictMiddlewareFunc added in v0.4.0 

type StrictMiddlewareFunc = strictnethttp.StrictHTTPMiddlewareFunc

type StrictServerInterface added in v0.4.0 

type StrictServerInterface interface {

	// (GET /health/live)
	HealthLive(ctx context.Context, request HealthLiveRequestObject) (HealthLiveResponseObject, error)

	// (GET /health/ready)
	HealthReady(ctx context.Context, request HealthReadyRequestObject) (HealthReadyResponseObject, error)

	// (GET /openapi.json)
	GetOpenAPI(ctx context.Context, request GetOpenAPIRequestObject) (GetOpenAPIResponseObject, error)

	// (GET /v1/adapters)
	ListAdapters(ctx context.Context, request ListAdaptersRequestObject) (ListAdaptersResponseObject, error)

	// (GET /v1/connections)
	ListConnections(ctx context.Context, request ListConnectionsRequestObject) (ListConnectionsResponseObject, error)

	// (POST /v1/connections)
	CreateConnection(ctx context.Context, request CreateConnectionRequestObject) (CreateConnectionResponseObject, error)

	// (DELETE /v1/connections/{connection_id})
	DeleteConnection(ctx context.Context, request DeleteConnectionRequestObject) (DeleteConnectionResponseObject, error)

	// (POST /v1/connections/{connection_id}/authorize)
	AuthorizeConnection(ctx context.Context, request AuthorizeConnectionRequestObject) (AuthorizeConnectionResponseObject, error)

	// (GET /v1/console/events)
	StreamConsoleEvents(ctx context.Context, request StreamConsoleEventsRequestObject) (StreamConsoleEventsResponseObject, error)

	// (POST /v1/dev/scenario-sessions/{workspace_id}/commands)
	CommandScenarioPlayback(ctx context.Context, request CommandScenarioPlaybackRequestObject) (CommandScenarioPlaybackResponseObject, error)

	// (POST /v1/images:resolve)
	ResolveImage(ctx context.Context, request ResolveImageRequestObject) (ResolveImageResponseObject, error)

	// (GET /v1/offers)
	ListOffers(ctx context.Context, request ListOffersRequestObject) (ListOffersResponseObject, error)

	// (POST /v1/placements:preview)
	PreviewPlacement(ctx context.Context, request PreviewPlacementRequestObject) (PreviewPlacementResponseObject, error)

	// (GET /v1/runs)
	ListRuns(ctx context.Context, request ListRunsRequestObject) (ListRunsResponseObject, error)

	// (POST /v1/runs)
	CreateRun(ctx context.Context, request CreateRunRequestObject) (CreateRunResponseObject, error)

	// (GET /v1/runs/{run_id})
	GetRun(ctx context.Context, request GetRunRequestObject) (GetRunResponseObject, error)

	// (POST /v1/runs/{run_id}/cancel)
	CancelRun(ctx context.Context, request CancelRunRequestObject) (CancelRunResponseObject, error)

	// (GET /v1/runs/{run_id}/decision)
	GetRunDecision(ctx context.Context, request GetRunDecisionRequestObject) (GetRunDecisionResponseObject, error)

	// (GET /v1/runs/{run_id}/events)
	ListRunEvents(ctx context.Context, request ListRunEventsRequestObject) (ListRunEventsResponseObject, error)

	// (POST /v1/runs/{run_id}/refresh)
	RefreshRun(ctx context.Context, request RefreshRunRequestObject) (RefreshRunResponseObject, error)

	// (POST /v1/runs/{run_id}/report)
	ReportRun(ctx context.Context, request ReportRunRequestObject) (ReportRunResponseObject, error)

	// (GET /v1/runs/{run_id}/wait)
	WaitRun(ctx context.Context, request WaitRunRequestObject) (WaitRunResponseObject, error)

	// (GET /v1/sinks/{sink_id})
	GetSinkStatus(ctx context.Context, request GetSinkStatusRequestObject) (GetSinkStatusResponseObject, error)

	// (POST /v1/sinks/{sink_id}/deliver)
	DeliverSink(ctx context.Context, request DeliverSinkRequestObject) (DeliverSinkResponseObject, error)

	// (POST /v1/sinks/{sink_id}/replay)
	ReplaySink(ctx context.Context, request ReplaySinkRequestObject) (ReplaySinkResponseObject, error)

	// (POST /v1/workloads)
	CreateWorkload(ctx context.Context, request CreateWorkloadRequestObject) (CreateWorkloadResponseObject, error)

	// (GET /v1/workloads/{workload_id}/revisions)
	ListWorkloadRevisions(ctx context.Context, request ListWorkloadRevisionsRequestObject) (ListWorkloadRevisionsResponseObject, error)

	// (POST /v1/workloads/{workload_id}/revisions)
	CreateWorkloadRevision(ctx context.Context, request CreateWorkloadRevisionRequestObject) (CreateWorkloadRevisionResponseObject, error)

	// (GET /v1/workloads/{workload_id}/revisions/{revision_id})
	GetWorkloadRevision(ctx context.Context, request GetWorkloadRevisionRequestObject) (GetWorkloadRevisionResponseObject, error)

	// (GET /v1/workspaces)
	ListWorkspaces(ctx context.Context, request ListWorkspacesRequestObject) (ListWorkspacesResponseObject, error)

	// (POST /v1/workspaces)
	CreateWorkspace(ctx context.Context, request CreateWorkspaceRequestObject) (CreateWorkspaceResponseObject, error)

	// (POST /v1/workspaces/{workspace_id}/archive)
	ArchiveWorkspace(ctx context.Context, request ArchiveWorkspaceRequestObject) (ArchiveWorkspaceResponseObject, error)
}

StrictServerInterface represents all server handlers.

type TooManyValuesForParamError added in v0.4.0 

type TooManyValuesForParamError struct {
	ParamName string
	Count     int
}

func (*TooManyValuesForParamError) Error added in v0.4.0 

func (e *TooManyValuesForParamError) Error() string

type UnescapedCookieParamError added in v0.4.0 

type UnescapedCookieParamError struct {
	ParamName string
	Err       error
}

func (*UnescapedCookieParamError) Error added in v0.4.0 

func (e *UnescapedCookieParamError) Error() string

func (*UnescapedCookieParamError) Unwrap added in v0.4.0 

func (e *UnescapedCookieParamError) Unwrap() error

type UnmarshalingParamError added in v0.4.0 

type UnmarshalingParamError struct {
	ParamName string
	Err       error
}

func (*UnmarshalingParamError) Error added in v0.4.0 

func (e *UnmarshalingParamError) Error() string

func (*UnmarshalingParamError) Unwrap added in v0.4.0 

func (e *UnmarshalingParamError) Unwrap() error

type Violation added in v0.4.0 

type Violation = domain.Violation

Violation defines model for Violation.

type WaitRun200JSONResponse added in v0.4.0 

type WaitRun200JSONResponse RunResponse

func (WaitRun200JSONResponse) VisitWaitRunResponse added in v0.4.0 

func (response WaitRun200JSONResponse) VisitWaitRunResponse(w http.ResponseWriter) error

type WaitRun202JSONResponse added in v0.4.0 

type WaitRun202JSONResponse RunResponse

func (WaitRun202JSONResponse) VisitWaitRunResponse added in v0.4.0 

func (response WaitRun202JSONResponse) VisitWaitRunResponse(w http.ResponseWriter) error

type WaitRun400JSONResponse added in v0.4.0 

type WaitRun400JSONResponse ErrorResponse

func (WaitRun400JSONResponse) VisitWaitRunResponse added in v0.4.0 

func (response WaitRun400JSONResponse) VisitWaitRunResponse(w http.ResponseWriter) error

type WaitRun401JSONResponse added in v0.4.0 

type WaitRun401JSONResponse ErrorResponse

func (WaitRun401JSONResponse) VisitWaitRunResponse added in v0.4.0 

func (response WaitRun401JSONResponse) VisitWaitRunResponse(w http.ResponseWriter) error

type WaitRun403JSONResponse added in v0.4.0 

type WaitRun403JSONResponse ErrorResponse

func (WaitRun403JSONResponse) VisitWaitRunResponse added in v0.4.0 

func (response WaitRun403JSONResponse) VisitWaitRunResponse(w http.ResponseWriter) error

type WaitRun404JSONResponse added in v0.4.0 

type WaitRun404JSONResponse ErrorResponse

func (WaitRun404JSONResponse) VisitWaitRunResponse added in v0.4.0 

func (response WaitRun404JSONResponse) VisitWaitRunResponse(w http.ResponseWriter) error

type WaitRun408JSONResponse added in v0.4.0 

type WaitRun408JSONResponse ErrorResponse

func (WaitRun408JSONResponse) VisitWaitRunResponse added in v0.4.0 

func (response WaitRun408JSONResponse) VisitWaitRunResponse(w http.ResponseWriter) error

type WaitRunParams added in v0.4.0 

type WaitRunParams struct {
	WorkspaceId string `form:"workspace_id,omitempty" json:"workspace_id,omitempty"`
}

WaitRunParams defines parameters for WaitRun.

type WaitRunRequestObject added in v0.4.0 

type WaitRunRequestObject struct {
	RunId  string `json:"run_id"`
	Params WaitRunParams
}

type WaitRunResponseObject added in v0.4.0 

type WaitRunResponseObject interface {
	VisitWaitRunResponse(w http.ResponseWriter) error
}

type WebAuth added in v0.3.0 

type WebAuth interface {
	http.Handler
	SessionEmail(*http.Request) (string, bool)
	VerifyCLIToken(token string) (string, bool)
}

WebAuth is the human-login surface the server mounts at /auth/ when OIDC is configured: it serves the login/callback/logout/session endpoints, answers which signed-in human a request's session cookie belongs to, and verifies the bearer tokens `mercator login` mints for CLI users.

type WorkloadRevision added in v0.4.0 

type WorkloadRevision = domain.WorkloadRevision

WorkloadRevision defines model for WorkloadRevision.

type WorkloadRevisionListResponse added in v0.4.0 

type WorkloadRevisionListResponse struct {
	Revisions []WorkloadRevision `json:"revisions"`
}

WorkloadRevisionListResponse defines model for WorkloadRevisionListResponse.

type WorkloadRevisionResponse added in v0.4.0 

type WorkloadRevisionResponse struct {
	Revision WorkloadRevision `json:"revision"`
}

WorkloadRevisionResponse defines model for WorkloadRevisionResponse.

type WorkloadSpec added in v0.4.0 

type WorkloadSpec struct {
	Containers []ContainerSpec        `json:"containers"`
	Execution  ExecutionPolicy        `json:"execution"`
	Metadata   map[string]string      `json:"metadata,omitempty"`
	Network    NetworkRequirements    `json:"network"`
	Placement  PlacementPolicy        `json:"placement"`
	Raw        map[string]interface{} `json:"raw,omitempty"`
	Resources  ResourceRequirements   `json:"resources"`
}

WorkloadSpec defines model for WorkloadSpec.

type Workspace added in v0.4.5 

type Workspace = workspace.Workspace

Workspace defines model for Workspace.

type WorkspaceListResponse added in v0.4.5 

type WorkspaceListResponse struct {
	Workspaces []Workspace `json:"workspaces"`
}

WorkspaceListResponse defines model for WorkspaceListResponse.

type WorkspaceResponse added in v0.4.5 

type WorkspaceResponse struct {
	Workspace Workspace `json:"workspace"`
}

WorkspaceResponse defines model for WorkspaceResponse.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.