httpapi

package

Go to main page

Versions in this module

v0

v0.5.4

Jul 23, 2026

v0.5.3

Jul 23, 2026

v0.5.2

Jul 23, 2026

v0.5.1

Jul 23, 2026

v0.5.0

Jul 23, 2026

Changes in this version

+ type Booking = domain.Booking

+ type BookingDecision = domain.BookingDecision

+ type BookingDecisionResponse struct

+ Decision BookingDecision

type CandidateDecision

+ Disposition CandidateDecisionDisposition

+ type CandidateDecisionDisposition string

+ const ProvisionFreshRental

+ const QueueExistingRental

+ const RunNowExistingRental

+ func (e CandidateDecisionDisposition) Valid() bool

+ type CommandScenarioPlayback200JSONResponse struct

+ Accepted bool

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

+ type CommandScenarioPlayback400JSONResponse ErrorResponse

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

+ type CommandScenarioPlayback401JSONResponse ErrorResponse

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

+ type CommandScenarioPlayback404JSONResponse ErrorResponse

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

+ type CommandScenarioPlayback501JSONResponse ErrorResponse

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

+ type CommandScenarioPlaybackJSONRequestBody = ScenarioPlaybackCommand

+ type CommandScenarioPlaybackRequestObject struct

+ Body *CommandScenarioPlaybackJSONRequestBody

+ WorkspaceId string

+ type CommandScenarioPlaybackResponseObject interface

+ VisitCommandScenarioPlaybackResponse func(w http.ResponseWriter) error

+ type ConsoleEventLog interface

+ LatestPosition func(context.Context, eventlog.EventFilter) (eventlog.GlobalPosition, error)

+ ReadAll func(context.Context, eventlog.GlobalPosition, int, eventlog.EventFilter) ([]eventlog.StoredEvent, error)

+ Subscribe func(context.Context, eventlog.SubscriptionRequest) (<-chan eventlog.Delivery, error)

type Deps

+ Events ConsoleEventLog

+ Scenarios *scenario.DashboardPlayback

+ type ScenarioPlaybackCommand struct

+ Speed ScenarioPlaybackCommandSpeed

+ Type ScenarioPlaybackCommandType

+ type ScenarioPlaybackCommandSpeed int

+ const ScenarioPlaybackCommandSpeedN1

+ const ScenarioPlaybackCommandSpeedN2

+ const ScenarioPlaybackCommandSpeedN4

+ func (e ScenarioPlaybackCommandSpeed) Valid() bool

+ type ScenarioPlaybackCommandType string

+ const Next

+ const Pause

+ const Play

+ const Previous

+ const Restart

+ const SetSpeed

+ func (e ScenarioPlaybackCommandType) Valid() bool

type Server

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

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

type ServerInterface

+ CommandScenarioPlayback func(w http.ResponseWriter, r *http.Request, workspaceId string)

+ StreamConsoleEvents func(w http.ResponseWriter, r *http.Request, params StreamConsoleEventsParams)

type ServerInterfaceWrapper

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

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

+ type StreamConsoleEvents200TexteventStreamResponse struct

+ Body io.Reader

+ ContentLength int64

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

+ type StreamConsoleEvents400JSONResponse ErrorResponse

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

+ type StreamConsoleEvents401JSONResponse ErrorResponse

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

+ type StreamConsoleEvents403JSONResponse ErrorResponse

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

+ type StreamConsoleEvents501JSONResponse ErrorResponse

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

+ type StreamConsoleEvents502JSONResponse ErrorResponse

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

+ type StreamConsoleEventsParams struct

+ LastEventID string

+ Play StreamConsoleEventsParamsPlay

+ Scenario string

+ WorkspaceId string

+ type StreamConsoleEventsParamsPlay string

+ const StreamConsoleEventsParamsPlayN0

+ const StreamConsoleEventsParamsPlayN1

+ func (e StreamConsoleEventsParamsPlay) Valid() bool

+ type StreamConsoleEventsRequestObject struct

+ Params StreamConsoleEventsParams

+ type StreamConsoleEventsResponseObject interface

+ VisitStreamConsoleEventsResponse func(w http.ResponseWriter) error

type StrictServerInterface

+ CommandScenarioPlayback func(ctx context.Context, request CommandScenarioPlaybackRequestObject) (CommandScenarioPlaybackResponseObject, error)

+ StreamConsoleEvents func(ctx context.Context, request StreamConsoleEventsRequestObject) (StreamConsoleEventsResponseObject, error)

v0.4.5

Jul 21, 2026

Changes in this version

+ type ArchiveWorkspace200JSONResponse WorkspaceResponse

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

+ type ArchiveWorkspace400JSONResponse ErrorResponse

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

+ type ArchiveWorkspace401JSONResponse ErrorResponse

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

+ type ArchiveWorkspace404JSONResponse ErrorResponse

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

+ type ArchiveWorkspace500JSONResponse ErrorResponse

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

+ type ArchiveWorkspaceRequestObject struct

+ WorkspaceId string

+ type ArchiveWorkspaceResponseObject interface

+ VisitArchiveWorkspaceResponse func(w http.ResponseWriter) error

+ type CleanupError struct

+ Code string

+ Disposition CleanupErrorDisposition

+ LaunchKey string

+ Message string

+ Retryable bool

+ type CleanupErrorDisposition string

+ const Release

+ const Terminate

+ func (e CleanupErrorDisposition) Valid() bool

+ type CreateWorkspace201JSONResponse WorkspaceResponse

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

+ type CreateWorkspace400JSONResponse ErrorResponse

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

+ type CreateWorkspace401JSONResponse ErrorResponse

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

+ type CreateWorkspace409JSONResponse ErrorResponse

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

+ type CreateWorkspace500JSONResponse ErrorResponse

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

+ type CreateWorkspaceJSONRequestBody = CreateWorkspaceRequest

+ type CreateWorkspaceRequest struct

+ DisplayName string

+ type CreateWorkspaceRequestObject struct

+ Body *CreateWorkspaceJSONRequestBody

+ type CreateWorkspaceResponseObject interface

+ VisitCreateWorkspaceResponse func(w http.ResponseWriter) error

type Deps

+ Workspaces *workspace.SQLiteCatalog

+ type ListWorkspaces200JSONResponse WorkspaceListResponse

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

+ type ListWorkspaces401JSONResponse ErrorResponse

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

+ type ListWorkspaces500JSONResponse ErrorResponse

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

+ type ListWorkspacesParams struct

+ IncludeArchived bool

+ type ListWorkspacesRequestObject struct

+ Params ListWorkspacesParams

+ type ListWorkspacesResponseObject interface

+ VisitListWorkspacesResponse func(w http.ResponseWriter) error

+ type ReportRun409JSONResponse ErrorResponse

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

type Server

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

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

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

type ServerInterface

+ ArchiveWorkspace func(w http.ResponseWriter, r *http.Request, workspaceId string)

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

+ ListWorkspaces func(w http.ResponseWriter, r *http.Request, params ListWorkspacesParams)

type ServerInterfaceWrapper

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

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

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

type StrictServerInterface

+ ArchiveWorkspace func(ctx context.Context, request ArchiveWorkspaceRequestObject) (ArchiveWorkspaceResponseObject, error)

+ CreateWorkspace func(ctx context.Context, request CreateWorkspaceRequestObject) (CreateWorkspaceResponseObject, error)

+ ListWorkspaces func(ctx context.Context, request ListWorkspacesRequestObject) (ListWorkspacesResponseObject, error)

+ type Workspace = workspace.Workspace

+ type WorkspaceListResponse struct

+ Workspaces []Workspace

+ type WorkspaceResponse struct

+ Workspace Workspace

v0.4.4

Jul 20, 2026

v0.4.3

Jul 19, 2026

v0.4.2

Jul 19, 2026

v0.4.1

Jul 19, 2026

v0.4.0

Jul 19, 2026

Changes in this version

+ const BearerAuthScopes

+ func Handler(si ServerInterface) http.Handler

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

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

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

+ type AcceleratorInventory struct

+ CanonicalModel string

+ Count int

+ MemoryBytes int64

+ Model string

+ Vendor string

+ type AcceleratorRequirement struct

+ Count int

+ MemoryMinBytes int64

+ ModelAnyOf []string

+ Vendor string

+ type AdapterListResponse struct

+ Adapters []AdapterManifest

+ type AdapterManifest = adapter.Manifest

+ type AuthorizeConnection200JSONResponse ConnectionResponse

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

+ type AuthorizeConnection400JSONResponse ErrorResponse

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

+ type AuthorizeConnection401JSONResponse ErrorResponse

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

+ type AuthorizeConnection403JSONResponse ErrorResponse

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

+ type AuthorizeConnection500JSONResponse ErrorResponse

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

+ type AuthorizeConnection501JSONResponse ErrorResponse

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

+ type AuthorizeConnection502JSONResponse ErrorResponse

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

+ type AuthorizeConnectionParams struct

+ WorkspaceId string

+ type AuthorizeConnectionRequestObject struct

+ ConnectionId string

+ Params AuthorizeConnectionParams

+ type AuthorizeConnectionResponseObject interface

+ VisitAuthorizeConnectionResponse func(w http.ResponseWriter) error

+ type CPURequirement struct

+ MinMillis int64

+ type CancelRun200JSONResponse RunResponse

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

+ type CancelRun400JSONResponse ErrorResponse

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

+ type CancelRun401JSONResponse ErrorResponse

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

+ type CancelRun403JSONResponse ErrorResponse

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

+ type CancelRun502JSONResponse ErrorResponse

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

+ type CancelRunParams struct

+ WorkspaceId string

+ type CancelRunRequestObject struct

+ Params CancelRunParams

+ RunId string

+ type CancelRunResponseObject interface

+ VisitCancelRunResponse func(w http.ResponseWriter) error

+ type CandidateDecision struct

+ AdapterType string

+ ConnectionId string

+ Estimates CandidateEstimates

+ Feasible bool

+ NativeRef string

+ OfferSnapshotId string

+ Rejections []Violation

+ ScoreUsd float64

+ type CandidateEstimates struct

+ CostUsd Estimate

+ ProvisionSeconds Estimate

+ PullSeconds Estimate

+ QueueSeconds Estimate

+ StartSeconds Estimate

+ type CapabilityProfile struct

+ Container ContainerCapabilities

+ Lifecycle LifecycleCapabilities

+ Network NetworkCapabilities

+ Observability ObservabilityCapabilities

+ OfferKinds []CapabilityProfileOfferKinds

+ Pricing PricingCapabilities

+ Resources ResourceCapabilities

+ type CapabilityProfileOfferKinds string

+ const Provisionable

+ const Standing

+ func (e CapabilityProfileOfferKinds) Valid() bool

+ type CapacityEvidence struct

+ Available bool

+ Confidence float64

+ type CloudEvent = eventlog.CloudEvent

+ type CollectionReport struct

+ ConnectionsFromCache []string

+ ConnectionsQueried []string

+ ExcludedConnections []string

+ type ConnectionFailure struct

+ AdapterType string

+ ConnectionId string

+ Message string

+ type ConnectionListResponse struct

+ Connections []ConnectionRecord

+ type ConnectionRecord = connection.Record

+ type ConnectionResponse struct

+ Connection ConnectionRecord

+ type ContainerCapabilities struct

+ MaxContainers int

+ MaxEnvironmentBytes int

+ SupportsDigestRefs bool

+ SupportsEntrypointOverride bool

+ type ContainerSpec struct

+ Args []string

+ Entrypoint []string

+ Env map[string]EnvBinding

+ Image string

+ Name string

+ Platform Platform

+ Ports []PortSpec

+ type CreateConnection201JSONResponse ConnectionResponse

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

+ type CreateConnection400JSONResponse ErrorResponse

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

+ type CreateConnection401JSONResponse ErrorResponse

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

+ type CreateConnection403JSONResponse ErrorResponse

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

+ type CreateConnection409JSONResponse ErrorResponse

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

+ type CreateConnection413JSONResponse ErrorResponse

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

+ type CreateConnection500JSONResponse ErrorResponse

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

+ type CreateConnection501JSONResponse ErrorResponse

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

+ type CreateConnectionJSONRequestBody = CreateConnectionRequest

+ type CreateConnectionParams struct

+ IdempotencyKey string

+ WorkspaceId string

+ type CreateConnectionRequest struct

+ AdapterType string

+ Config map[string]string

+ ConnectionId string

+ Credential Credential

+ Secret string

+ WorkspaceId string

+ type CreateConnectionRequestObject struct

+ Body *CreateConnectionJSONRequestBody

+ Params CreateConnectionParams

+ type CreateConnectionResponseObject interface

+ VisitCreateConnectionResponse func(w http.ResponseWriter) error

+ type CreateRevisionRequest struct

+ Revision WorkloadRevision

+ type CreateRun202JSONResponse RunResponse

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

+ type CreateRun400JSONResponse ErrorResponse

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

+ type CreateRun401JSONResponse ErrorResponse

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

+ type CreateRun403JSONResponse ErrorResponse

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

+ type CreateRun404JSONResponse ErrorResponse

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

+ type CreateRun409JSONResponse ErrorResponse

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

+ type CreateRun413JSONResponse ErrorResponse

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

+ type CreateRun500JSONResponse ErrorResponse

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

+ type CreateRun502JSONResponse ErrorResponse

+ func (response CreateRun502JSONResponse) VisitCreateRunResponse(w http.ResponseWriter) error

+ type CreateRunJSONRequestBody = CreateRunRequest

+ type CreateRunParams struct

+ IdempotencyKey string

+ WorkspaceId string

+ type CreateRunRequest struct

+ Args []string

+ Env map[string]EnvBinding

+ Image string

+ RunId string

+ Workload WorkloadRevision

+ WorkloadId string

+ WorkloadRevisionId string

+ WorkspaceId string

+ type CreateRunRequestObject struct

+ Body *CreateRunJSONRequestBody

+ Params CreateRunParams

+ type CreateRunResponseObject interface

+ VisitCreateRunResponse func(w http.ResponseWriter) error

+ type CreateWorkload202JSONResponse struct

+ WorkloadId string

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

+ type CreateWorkload400JSONResponse ErrorResponse

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

+ type CreateWorkload401JSONResponse ErrorResponse

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

+ type CreateWorkload403JSONResponse ErrorResponse

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

+ type CreateWorkload413JSONResponse ErrorResponse

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

+ type CreateWorkload501JSONResponse ErrorResponse

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

+ type CreateWorkloadJSONRequestBody = CreateWorkloadRequest

+ type CreateWorkloadParams struct

+ IdempotencyKey string

+ type CreateWorkloadRequest struct

+ Name string

+ WorkloadId string

+ WorkspaceId string

+ type CreateWorkloadRequestObject struct

+ Body *CreateWorkloadJSONRequestBody

+ Params CreateWorkloadParams

+ type CreateWorkloadResponseObject interface

+ VisitCreateWorkloadResponse func(w http.ResponseWriter) error

+ type CreateWorkloadRevision202JSONResponse WorkloadRevisionResponse

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

+ type CreateWorkloadRevision400JSONResponse ErrorResponse

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

+ type CreateWorkloadRevision401JSONResponse ErrorResponse

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

+ type CreateWorkloadRevision403JSONResponse ErrorResponse

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

+ type CreateWorkloadRevision413JSONResponse ErrorResponse

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

+ type CreateWorkloadRevision501JSONResponse ErrorResponse

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

+ type CreateWorkloadRevisionJSONRequestBody = CreateRevisionRequest

+ type CreateWorkloadRevisionParams struct

+ IdempotencyKey string

+ WorkspaceId string

+ type CreateWorkloadRevisionRequestObject struct

+ Body *CreateWorkloadRevisionJSONRequestBody

+ Params CreateWorkloadRevisionParams

+ WorkloadId string

+ type CreateWorkloadRevisionResponseObject interface

+ VisitCreateWorkloadRevisionResponse func(w http.ResponseWriter) error

+ type Credential = credential.Credential

+ type DeleteConnection200JSONResponse struct

+ Deleted bool

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

+ type DeleteConnection400JSONResponse ErrorResponse

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

+ type DeleteConnection401JSONResponse ErrorResponse

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

+ type DeleteConnection403JSONResponse ErrorResponse

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

+ type DeleteConnection404JSONResponse ErrorResponse

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

+ type DeleteConnection500JSONResponse ErrorResponse

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

+ type DeleteConnection501JSONResponse ErrorResponse

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

+ type DeleteConnectionParams struct

+ WorkspaceId string

+ type DeleteConnectionRequestObject struct

+ ConnectionId string

+ Params DeleteConnectionParams

+ type DeleteConnectionResponseObject interface

+ VisitDeleteConnectionResponse func(w http.ResponseWriter) error

+ type DeliverSink202JSONResponse SinkResult

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

+ type DeliverSink401JSONResponse ErrorResponse

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

+ type DeliverSink501JSONResponse ErrorResponse

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

+ type DeliverSink502JSONResponse ErrorResponse

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

+ type DeliverSinkRequestObject struct

+ SinkId string

+ type DeliverSinkResponseObject interface

+ VisitDeliverSinkResponse func(w http.ResponseWriter) error

type Deps

+ Offers OfferAggregator

+ type DiskRequirement struct

+ MinBytes int64

+ type EnvBinding = domain.EnvBinding

+ type ErrorResponse struct

+ Code string

+ Details []Violation

+ Message string

+ type Estimate struct

+ Confidence float64

+ Expected float64

+ ModelVersion string

+ P50 float64

+ P90 float64

+ SampleCount int

+ Source string

+ type EventListResponse struct

+ Events []CloudEvent

+ type ExecutionPolicy struct

+ MaxPreStartAttempts int

+ MaxRuntimeSeconds int64

+ type GetOpenAPI200JSONResponse map[string]interface

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

+ type GetOpenAPIRequestObject struct

+ type GetOpenAPIResponseObject interface

+ VisitGetOpenAPIResponse func(w http.ResponseWriter) error

+ type GetRun200JSONResponse RunResponse

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

+ type GetRun400JSONResponse ErrorResponse

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

+ type GetRun401JSONResponse ErrorResponse

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

+ type GetRun403JSONResponse ErrorResponse

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

+ type GetRun404JSONResponse ErrorResponse

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

+ type GetRunDecision200JSONResponse PlacementDecisionResponse

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

+ type GetRunDecision400JSONResponse ErrorResponse

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

+ type GetRunDecision401JSONResponse ErrorResponse

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

+ type GetRunDecision403JSONResponse ErrorResponse

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

+ type GetRunDecision404JSONResponse ErrorResponse

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

+ type GetRunDecisionParams struct

+ WorkspaceId string

+ type GetRunDecisionRequestObject struct

+ Params GetRunDecisionParams

+ RunId string

+ type GetRunDecisionResponseObject interface

+ VisitGetRunDecisionResponse func(w http.ResponseWriter) error

+ type GetRunParams struct

+ WorkspaceId string

+ type GetRunRequestObject struct

+ Params GetRunParams

+ RunId string

+ type GetRunResponseObject interface

+ VisitGetRunResponse func(w http.ResponseWriter) error

+ type GetSinkStatus200JSONResponse SinkStatus

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

+ type GetSinkStatus401JSONResponse ErrorResponse

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

+ type GetSinkStatus404JSONResponse ErrorResponse

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

+ type GetSinkStatus501JSONResponse ErrorResponse

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

+ type GetSinkStatusRequestObject struct

+ SinkId string

+ type GetSinkStatusResponseObject interface

+ VisitGetSinkStatusResponse func(w http.ResponseWriter) error

+ type GetWorkloadRevision200JSONResponse WorkloadRevisionResponse

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

+ type GetWorkloadRevision400JSONResponse ErrorResponse

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

+ type GetWorkloadRevision401JSONResponse ErrorResponse

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

+ type GetWorkloadRevision403JSONResponse ErrorResponse

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

+ type GetWorkloadRevision404JSONResponse ErrorResponse

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

+ type GetWorkloadRevision501JSONResponse ErrorResponse

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

+ type GetWorkloadRevisionParams struct

+ WorkspaceId string

+ type GetWorkloadRevisionRequestObject struct

+ Params GetWorkloadRevisionParams

+ RevisionId string

+ WorkloadId string

+ type GetWorkloadRevisionResponseObject interface

+ VisitGetWorkloadRevisionResponse func(w http.ResponseWriter) error

+ type HealthLive200JSONResponse struct

+ Status string

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

+ type HealthLiveRequestObject struct

+ type HealthLiveResponseObject interface

+ VisitHealthLiveResponse func(w http.ResponseWriter) error

+ type HealthReady200JSONResponse struct

+ Status string

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

+ type HealthReadyRequestObject struct

+ type HealthReadyResponseObject interface

+ VisitHealthReadyResponse func(w http.ResponseWriter) error

+ type ImageCacheEvidence struct

+ Known bool

+ ManifestCached bool

+ MissingBytes int64

+ type InvalidParamFormatError struct

+ Err error

+ ParamName string

+ func (e *InvalidParamFormatError) Error() string

+ func (e *InvalidParamFormatError) Unwrap() error

+ type LifecycleCapabilities struct

+ CancelQueued bool

+ IdempotentLaunch string

+ ListOwned bool

+ ProviderTtl bool

+ type ListAdapters200JSONResponse AdapterListResponse

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

+ type ListAdapters401JSONResponse ErrorResponse

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

+ type ListAdaptersRequestObject struct

+ type ListAdaptersResponseObject interface

+ VisitListAdaptersResponse func(w http.ResponseWriter) error

+ type ListConnections200JSONResponse ConnectionListResponse

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

+ type ListConnections400JSONResponse ErrorResponse

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

+ type ListConnections401JSONResponse ErrorResponse

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

+ type ListConnections403JSONResponse ErrorResponse

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

+ type ListConnections500JSONResponse ErrorResponse

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

+ type ListConnectionsParams struct

+ WorkspaceId string

+ type ListConnectionsRequestObject struct

+ Params ListConnectionsParams

+ type ListConnectionsResponseObject interface

+ VisitListConnectionsResponse func(w http.ResponseWriter) error

+ type ListOffers200JSONResponse OfferListResponse

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

+ type ListOffers400JSONResponse ErrorResponse

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

+ type ListOffers401JSONResponse ErrorResponse

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

+ type ListOffers403JSONResponse ErrorResponse

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

+ type ListOffers502JSONResponse ErrorResponse

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

+ type ListOffersParams struct

+ WorkspaceId string

+ type ListOffersRequestObject struct

+ Params ListOffersParams

+ type ListOffersResponseObject interface

+ VisitListOffersResponse func(w http.ResponseWriter) error

+ type ListRunEvents200JSONResponse EventListResponse

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

+ type ListRunEvents400JSONResponse ErrorResponse

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

+ type ListRunEvents401JSONResponse ErrorResponse

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

+ type ListRunEvents403JSONResponse ErrorResponse

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

+ type ListRunEvents500JSONResponse ErrorResponse

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

+ type ListRunEventsParams struct

+ WorkspaceId string

+ type ListRunEventsRequestObject struct

+ Params ListRunEventsParams

+ RunId string

+ type ListRunEventsResponseObject interface

+ VisitListRunEventsResponse func(w http.ResponseWriter) error

+ type ListRuns200JSONResponse RunListResponse

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

+ type ListRuns400JSONResponse ErrorResponse

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

+ type ListRuns401JSONResponse ErrorResponse

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

+ type ListRuns403JSONResponse ErrorResponse

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

+ type ListRuns500JSONResponse ErrorResponse

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

+ type ListRunsParams struct

+ WorkspaceId string

+ type ListRunsRequestObject struct

+ Params ListRunsParams

+ type ListRunsResponseObject interface

+ VisitListRunsResponse func(w http.ResponseWriter) error

+ type ListWorkloadRevisions200JSONResponse WorkloadRevisionListResponse

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

+ type ListWorkloadRevisions400JSONResponse ErrorResponse

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

+ type ListWorkloadRevisions401JSONResponse ErrorResponse

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

+ type ListWorkloadRevisions403JSONResponse ErrorResponse

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

+ type ListWorkloadRevisions500JSONResponse ErrorResponse

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

+ type ListWorkloadRevisions501JSONResponse ErrorResponse

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

+ type ListWorkloadRevisionsParams struct

+ WorkspaceId string

+ type ListWorkloadRevisionsRequestObject struct

+ Params ListWorkloadRevisionsParams

+ WorkloadId string

+ type ListWorkloadRevisionsResponseObject interface

+ VisitListWorkloadRevisionsResponse func(w http.ResponseWriter) error

+ type MemoryRequirement struct

+ MinBytes int64

+ type MiddlewareFunc func(http.Handler) http.Handler

+ type NetworkCapabilities struct

+ Inbound NetworkCapabilitiesInbound

+ Protocols []string

+ PublicIpv4 bool

+ type NetworkCapabilitiesInbound string

+ const NetworkCapabilitiesInboundNone

+ const NetworkCapabilitiesInboundPublicPort

+ func (e NetworkCapabilitiesInbound) Valid() bool

+ type NetworkDownloadRequirement struct

+ AllowUnknown bool

+ MaxMeasurementAgeSeconds int64

+ MinP10Mbps float64

+ Scope NetworkDownloadRequirementScope

+ type NetworkDownloadRequirementScope string

+ const NetworkDownloadRequirementScopePublicInternet

+ const NetworkDownloadRequirementScopeRegistry

+ func (e NetworkDownloadRequirementScope) Valid() bool

+ type NetworkFact struct

+ Confidence float64

+ ObservedAt time.Time

+ SampleCount int

+ Scope NetworkFactScope

+ Source string

+ Statistic string

+ ValidUntil time.Time

+ ValueMbps float64

+ type NetworkFactScope string

+ const NetworkFactScopePublicInternet

+ const NetworkFactScopeRegistry

+ func (e NetworkFactScope) Valid() bool

+ type NetworkFacts struct

+ Download []NetworkFact

+ type NetworkRequirements struct

+ Download NetworkDownloadRequirement

+ Inbound NetworkRequirementsInbound

+ type NetworkRequirementsInbound string

+ const NetworkRequirementsInboundNone

+ const NetworkRequirementsInboundPublicPort

+ func (e NetworkRequirementsInbound) Valid() bool

+ type ObservabilityCapabilities struct

+ Logs string

+ Metrics string

+ Shell string

+ type OfferAggregator interface

+ AggregateOffers func(context.Context, adapter.OfferRequest) (broker.OfferAggregation, error)

+ type OfferListResponse struct

+ Failures []ConnectionFailure

+ Offers []OfferSnapshot

+ type OfferSnapshot = domain.OfferSnapshot

type Option

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

+ type PlacementDecision = domain.PlacementDecision

+ type PlacementDecisionResponse struct

+ Decision PlacementDecision

+ type PlacementPolicy struct

+ AllowUnknownPricing bool

+ ExpectedRuntimeSeconds float64

+ MaxExpectedCostUsd float64

+ MaxP90StartSeconds float64

+ Objective PlacementPolicyObjective

+ type PlacementPolicyObjective string

+ const Balanced

+ const Cheapest

+ const FastestCompletion

+ const FastestStart

+ func (e PlacementPolicyObjective) Valid() bool

+ type PlacementPreviewRequest struct

+ RunId string

+ Workload WorkloadRevision

+ WorkspaceId string

+ type PlacementPreviewResponse struct

+ Decision PlacementDecision

+ type Platform struct

+ Architecture string

+ Os string

+ type PortSpec struct

+ ContainerPort int

+ Exposure PortSpecExposure

+ Name string

+ Protocol string

+ type PortSpecExposure string

+ const None

+ const Private

+ const Public

+ func (e PortSpecExposure) Valid() bool

+ type PreviewPlacement200JSONResponse PlacementPreviewResponse

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

+ type PreviewPlacement400JSONResponse ErrorResponse

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

+ type PreviewPlacement401JSONResponse ErrorResponse

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

+ type PreviewPlacement403JSONResponse ErrorResponse

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

+ type PreviewPlacement413JSONResponse ErrorResponse

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

+ type PreviewPlacement502JSONResponse ErrorResponse

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

+ type PreviewPlacementJSONRequestBody = PlacementPreviewRequest

+ type PreviewPlacementParams struct

+ WorkspaceId string

+ type PreviewPlacementRequestObject struct

+ Body *PreviewPlacementJSONRequestBody

+ Params PreviewPlacementParams

+ type PreviewPlacementResponseObject interface

+ VisitPreviewPlacementResponse func(w http.ResponseWriter) error

+ type PriceModel struct

+ Currency string

+ GranularitySeconds int64

+ Known bool

+ MinimumChargeSeconds int64

+ RatePerSecondUsd float64

+ SetupFeeUsd float64

+ type PricingCapabilities struct

+ Known bool

+ type QueueSnapshot struct

+ ActiveSlots int

+ QueuedWorkSeconds float64

+ type RefreshRun200JSONResponse RunResponse

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

+ type RefreshRun400JSONResponse ErrorResponse

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

+ type RefreshRun401JSONResponse ErrorResponse

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

+ type RefreshRun403JSONResponse ErrorResponse

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

+ type RefreshRun502JSONResponse ErrorResponse

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

+ type RefreshRunParams struct

+ WorkspaceId string

+ type RefreshRunRequestObject struct

+ Params RefreshRunParams

+ RunId string

+ type RefreshRunResponseObject interface

+ VisitRefreshRunResponse func(w http.ResponseWriter) error

+ type ReliabilityEvidence struct

+ Confidence float64

+ InterruptionRate float64

+ StartFailureRate float64

+ type ReplaySink202JSONResponse SinkResult

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

+ type ReplaySink400JSONResponse ErrorResponse

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

+ type ReplaySink401JSONResponse ErrorResponse

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

+ type ReplaySink413JSONResponse ErrorResponse

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

+ type ReplaySink501JSONResponse ErrorResponse

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

+ type ReplaySink502JSONResponse ErrorResponse

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

+ type ReplaySinkJSONRequestBody = ReplaySinkRequest

+ type ReplaySinkRequest struct

+ FromExclusive int

+ Limit int

+ ReplayId string

+ type ReplaySinkRequestObject struct

+ Body *ReplaySinkJSONRequestBody

+ SinkId string

+ type ReplaySinkResponseObject interface

+ VisitReplaySinkResponse func(w http.ResponseWriter) error

+ type ReportRun202JSONResponse struct

+ Recorded bool

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

+ type ReportRun400JSONResponse ErrorResponse

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

+ type ReportRun401JSONResponse ErrorResponse

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

+ type ReportRun404JSONResponse ErrorResponse

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

+ type ReportRun413JSONResponse ErrorResponse

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

+ type ReportRun501JSONResponse ErrorResponse

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

+ type ReportRun502JSONResponse ErrorResponse

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

+ type ReportRunJSONRequestBody = ReportRunRequest

+ type ReportRunParams struct

+ Authorization string

+ WorkspaceId string

+ type ReportRunRequest struct

+ Data json.RawMessage

+ ExitCode *int

+ Type string

+ type ReportRunRequestObject struct

+ Body *ReportRunJSONRequestBody

+ Params ReportRunParams

+ RunId string

+ type ReportRunResponseObject interface

+ VisitReportRunResponse func(w http.ResponseWriter) error

+ type RequiredHeaderError struct

+ Err error

+ ParamName string

+ func (e *RequiredHeaderError) Error() string

+ func (e *RequiredHeaderError) Unwrap() error

+ type RequiredParamError struct

+ ParamName string

+ func (e *RequiredParamError) Error() string

+ type ResolveImage200JSONResponse ResolveImageResponse

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

+ type ResolveImage400JSONResponse ErrorResponse

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

+ type ResolveImage401JSONResponse ErrorResponse

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

+ type ResolveImage413JSONResponse ErrorResponse

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

+ type ResolveImage501JSONResponse ErrorResponse

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

+ type ResolveImageJSONRequestBody = ResolveImageRequest

+ type ResolveImageRequest struct

+ Image string

+ Platform string

+ type ResolveImageRequestObject struct

+ Body *ResolveImageJSONRequestBody

+ type ResolveImageResponse struct

+ Image ResolvedImage

+ type ResolveImageResponseObject interface

+ VisitResolveImageResponse func(w http.ResponseWriter) error

+ type ResolvedImage = ociresolver.ResolvedImage

+ type ResourceCapabilities struct

+ GpuVendors []string

+ type ResourceInventory struct

+ Accelerators []AcceleratorInventory

+ CpuMillis int64

+ EphemeralDiskBytes int64

+ MemoryBytes int64

+ type ResourceRequirements struct

+ Accelerators []AcceleratorRequirement

+ Cpu CPURequirement

+ EphemeralDisk DiskRequirement

+ Memory MemoryRequirement

+ type Run = domain.RunRecord

+ type RunListResponse struct

+ Runs []Run

+ type RunResponse struct

+ Duplicate bool

+ Links map[string]string

+ Metadata map[string]interface{}

+ Run Run

+ RunId string

+ type ServeMux interface

+ HandleFunc func(pattern string, handler func(http.ResponseWriter, *http.Request))

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

type Server

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ServerInterface interface

+ AuthorizeConnection func(w http.ResponseWriter, r *http.Request, connectionId string, ...)

+ CancelRun func(w http.ResponseWriter, r *http.Request, runId string, params CancelRunParams)

+ CreateConnection func(w http.ResponseWriter, r *http.Request, params CreateConnectionParams)

+ CreateRun func(w http.ResponseWriter, r *http.Request, params CreateRunParams)

+ CreateWorkload func(w http.ResponseWriter, r *http.Request, params CreateWorkloadParams)

+ CreateWorkloadRevision func(w http.ResponseWriter, r *http.Request, workloadId string, ...)

+ DeleteConnection func(w http.ResponseWriter, r *http.Request, connectionId string, ...)

+ DeliverSink func(w http.ResponseWriter, r *http.Request, sinkId string)

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

+ GetRun func(w http.ResponseWriter, r *http.Request, runId string, params GetRunParams)

+ GetRunDecision func(w http.ResponseWriter, r *http.Request, runId string, ...)

+ GetSinkStatus func(w http.ResponseWriter, r *http.Request, sinkId string)

+ GetWorkloadRevision func(w http.ResponseWriter, r *http.Request, workloadId string, revisionId string, ...)

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

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

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

+ ListConnections func(w http.ResponseWriter, r *http.Request, params ListConnectionsParams)

+ ListOffers func(w http.ResponseWriter, r *http.Request, params ListOffersParams)

+ ListRunEvents func(w http.ResponseWriter, r *http.Request, runId string, ...)

+ ListRuns func(w http.ResponseWriter, r *http.Request, params ListRunsParams)

+ ListWorkloadRevisions func(w http.ResponseWriter, r *http.Request, workloadId string, ...)

+ PreviewPlacement func(w http.ResponseWriter, r *http.Request, params PreviewPlacementParams)

+ RefreshRun func(w http.ResponseWriter, r *http.Request, runId string, params RefreshRunParams)

+ ReplaySink func(w http.ResponseWriter, r *http.Request, sinkId string)

+ ReportRun func(w http.ResponseWriter, r *http.Request, runId string, params ReportRunParams)

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

+ WaitRun func(w http.ResponseWriter, r *http.Request, runId string, params WaitRunParams)

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

+ func NewStrictHandlerWithOptions(ssi StrictServerInterface, middlewares []StrictMiddlewareFunc, ...) ServerInterface

+ type ServerInterfaceWrapper struct

+ ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)

+ Handler ServerInterface

+ HandlerMiddlewares []MiddlewareFunc

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type SinkResult = sinks.Result

+ type SinkStatus = sinks.Status

+ type StdHTTPServerOptions struct

+ BaseRouter ServeMux

+ BaseURL string

+ ErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)

+ Middlewares []MiddlewareFunc

+ type StrictHTTPServerOptions struct

+ RequestErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)

+ ResponseErrorHandlerFunc func(w http.ResponseWriter, r *http.Request, err error)

+ type StrictHandlerFunc = strictnethttp.StrictHTTPHandlerFunc

+ type StrictMiddlewareFunc = strictnethttp.StrictHTTPMiddlewareFunc

+ type StrictServerInterface interface

+ AuthorizeConnection func(ctx context.Context, request AuthorizeConnectionRequestObject) (AuthorizeConnectionResponseObject, error)

+ CancelRun func(ctx context.Context, request CancelRunRequestObject) (CancelRunResponseObject, error)

+ CreateConnection func(ctx context.Context, request CreateConnectionRequestObject) (CreateConnectionResponseObject, error)

+ CreateRun func(ctx context.Context, request CreateRunRequestObject) (CreateRunResponseObject, error)

+ CreateWorkload func(ctx context.Context, request CreateWorkloadRequestObject) (CreateWorkloadResponseObject, error)

+ CreateWorkloadRevision func(ctx context.Context, request CreateWorkloadRevisionRequestObject) (CreateWorkloadRevisionResponseObject, error)

+ DeleteConnection func(ctx context.Context, request DeleteConnectionRequestObject) (DeleteConnectionResponseObject, error)

+ DeliverSink func(ctx context.Context, request DeliverSinkRequestObject) (DeliverSinkResponseObject, error)

+ GetOpenAPI func(ctx context.Context, request GetOpenAPIRequestObject) (GetOpenAPIResponseObject, error)

+ GetRun func(ctx context.Context, request GetRunRequestObject) (GetRunResponseObject, error)

+ GetRunDecision func(ctx context.Context, request GetRunDecisionRequestObject) (GetRunDecisionResponseObject, error)

+ GetSinkStatus func(ctx context.Context, request GetSinkStatusRequestObject) (GetSinkStatusResponseObject, error)

+ GetWorkloadRevision func(ctx context.Context, request GetWorkloadRevisionRequestObject) (GetWorkloadRevisionResponseObject, error)

+ HealthLive func(ctx context.Context, request HealthLiveRequestObject) (HealthLiveResponseObject, error)

+ HealthReady func(ctx context.Context, request HealthReadyRequestObject) (HealthReadyResponseObject, error)

+ ListAdapters func(ctx context.Context, request ListAdaptersRequestObject) (ListAdaptersResponseObject, error)

+ ListConnections func(ctx context.Context, request ListConnectionsRequestObject) (ListConnectionsResponseObject, error)

+ ListOffers func(ctx context.Context, request ListOffersRequestObject) (ListOffersResponseObject, error)

+ ListRunEvents func(ctx context.Context, request ListRunEventsRequestObject) (ListRunEventsResponseObject, error)

+ ListRuns func(ctx context.Context, request ListRunsRequestObject) (ListRunsResponseObject, error)

+ ListWorkloadRevisions func(ctx context.Context, request ListWorkloadRevisionsRequestObject) (ListWorkloadRevisionsResponseObject, error)

+ PreviewPlacement func(ctx context.Context, request PreviewPlacementRequestObject) (PreviewPlacementResponseObject, error)

+ RefreshRun func(ctx context.Context, request RefreshRunRequestObject) (RefreshRunResponseObject, error)

+ ReplaySink func(ctx context.Context, request ReplaySinkRequestObject) (ReplaySinkResponseObject, error)

+ ReportRun func(ctx context.Context, request ReportRunRequestObject) (ReportRunResponseObject, error)

+ ResolveImage func(ctx context.Context, request ResolveImageRequestObject) (ResolveImageResponseObject, error)

+ WaitRun func(ctx context.Context, request WaitRunRequestObject) (WaitRunResponseObject, error)

+ type TooManyValuesForParamError struct

+ Count int

+ ParamName string

+ func (e *TooManyValuesForParamError) Error() string

+ type UnescapedCookieParamError struct

+ Err error

+ ParamName string

+ func (e *UnescapedCookieParamError) Error() string

+ func (e *UnescapedCookieParamError) Unwrap() error

+ type UnmarshalingParamError struct

+ Err error

+ ParamName string

+ func (e *UnmarshalingParamError) Error() string

+ func (e *UnmarshalingParamError) Unwrap() error

+ type Violation = domain.Violation

+ type WaitRun200JSONResponse RunResponse

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

+ type WaitRun202JSONResponse RunResponse

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

+ type WaitRun400JSONResponse ErrorResponse

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

+ type WaitRun401JSONResponse ErrorResponse

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

+ type WaitRun403JSONResponse ErrorResponse

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

+ type WaitRun404JSONResponse ErrorResponse

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

+ type WaitRun408JSONResponse ErrorResponse

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

+ type WaitRunParams struct

+ WorkspaceId string

+ type WaitRunRequestObject struct

+ Params WaitRunParams

+ RunId string

+ type WaitRunResponseObject interface

+ VisitWaitRunResponse func(w http.ResponseWriter) error

+ type WorkloadRevision = domain.WorkloadRevision

+ type WorkloadRevisionListResponse struct

+ Revisions []WorkloadRevision

+ type WorkloadRevisionResponse struct

+ Revision WorkloadRevision

+ type WorkloadSpec struct

+ Containers []ContainerSpec

+ Execution ExecutionPolicy

+ Metadata map[string]string

+ Network NetworkRequirements

+ Placement PlacementPolicy

+ Raw map[string]interface{}

+ Resources ResourceRequirements

v0.3.0

Jul 18, 2026

Changes in this version

type Option

+ func WithWebAuth(auth WebAuth) Option

+ type WebAuth interface

+ SessionEmail func(*http.Request) (string, bool)

+ VerifyCLIToken func(token string) (string, bool)

v0.2.2

Jul 16, 2026

v0.2.1

Jul 3, 2026

v0.2.0

Jul 3, 2026

Changes in this version

+ type Deps struct

+ Adapter adapter.Adapter

+ Connections *connection.Service

+ Orchestrator *orchestrator.Orchestrator

+ Resolver ImageResolver

+ Scheduler scheduler.Scheduler

+ Sinks *sinkspkg.Manager

+ Workloads *workload.Service

+ type ImageResolver interface

+ Resolve func(context.Context, ociresolver.ResolveRequest) (ociresolver.ResolvedImage, error)

v0.1.0

Jul 1, 2026

Changes in this version

+ const OpenAPIJSON

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

+ func HandlerForSQLiteWithAdapter(ctx context.Context, dsn string, ad adapter.Adapter, options ...Option) (http.Handler, func() error, error)

+ func HandlerForSQLiteWithOptions(ctx context.Context, dsn string, offer []domain.OfferSnapshot, ...) (http.Handler, func() error, error)

+ func New(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, ...) http.Handler

+ func NewWithAllServices(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, ...) http.Handler

+ func NewWithServices(orch *orchestrator.Orchestrator, sched scheduler.Scheduler, ad adapter.Adapter, ...) http.Handler

+ type Option func(*Server)

+ func WithBearerAuth(token string, workspaces []string) Option

+ func WithCredentialResolver(resolver *credential.Resolver) Option

+ func WithReportSigner(signer *reporting.Signer) Option

+ func WithSecretStore(store credential.SecretStore) Option

+ func WithVerifier(verifier connectionVerifier) Option

+ type Server struct

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL