serverless

package
v1.2.1 Latest Latest
Warning

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

Go to latest
Published: Sep 30, 2026 License: MIT Imports: 20 Imported by: 0

Documentation

Overview

Package serverless is a thin wrapper around the OpenAPI-generated client for the Runware Serverless control-plane API (api.serverless.runware.ai).

Regenerate the client after updating api/serverless/openapi.yaml:

make generate-serverless

Index

Constants

View Source
const (
	// AppSourceTypeCode is appSource.type = "code".
	AppSourceTypeCode = gen.Code
	// AppSourceTypeContainer is appSource.type = "container".
	AppSourceTypeContainer = gen.Container
)
View Source
const (
	// LogQueryRuntime is the pageable application log query.
	LogQueryRuntime = "runtime"
	// LogQueryRuntimeTail is the only log query the tail route accepts.
	LogQueryRuntimeTail = "runtime_tail"
	// DefaultLogLimit is sent when the caller sets no page size. The API
	// documents 20 but does not apply it, so an omitted limit falls through
	// to the downstream default of 100.
	DefaultLogLimit = 20
)
View Source
const (
	UsageDimensionApp      = gen.UsageDimensionApp
	UsageDimensionGpuType  = gen.UsageDimensionGpuType
	UsageDimensionDay      = gen.UsageDimensionDay
	UsageDimensionCoverage = gen.UsageDimensionCoverage
)

Usage summary grouping dimensions.

View Source
const SourceUploadStateReady = gen.SourceUploadStateReady

SourceUploadStateReady is the state a session reaches once completion has verified the staged archive against the declaration.

Variables

View Source
var ErrSSEEventTooLarge = errors.New("log stream event exceeds " + strconv.Itoa(maxSSEFrameBytes) + " bytes")

ErrSSEEventTooLarge reports an event whose lines together exceed maxSSEFrameBytes.

View Source
var ErrTailEnded = errors.New("log stream ended")

ErrTailEnded reports that the server closed a log stream on purpose, at the end of its connection lifetime or on shutdown. The caller may reconnect.

Functions

func AppDeployTerminal

func AppDeployTerminal(status AppStatus) bool

AppDeployTerminal reports whether WaitApp would stop polling for status.

func ValidateEndpointPath

func ValidateEndpointPath(path string) error

ValidateEndpointPath checks ADR-034. A leading slash is rejected by the API with 422; fail locally with a hint naming the bare segment.

Types

type App

type App = gen.App

App is a serverless application.

type AppCreate

type AppCreate = gen.AppCreate

AppCreate is the request body for createApp.

type AppEvent

type AppEvent = gen.AppEvent

AppEvent is a deploy, scaling, audit, or error event on an app.

type AppEventType

type AppEventType = gen.AppEventType

AppEventType is an AppEvent.type value.

type AppSort

type AppSort = gen.AppSort

AppSort is a listApps ordering.

const (
	AppSortCreatedAt AppSort = gen.CreatedAt
	AppSortName      AppSort = gen.Name
)

type AppSourceType

type AppSourceType = gen.AppSourceType

AppSourceType selects the version creation path (`code` or `container`).

type AppSourceUpsert

type AppSourceUpsert = gen.AppSourceUpsert

AppSourceUpsert selects the initial version creation path.

func NewCodeAppSource

func NewCodeAppSource(src CodeSourceUpsert) (AppSourceUpsert, error)

NewCodeAppSource builds an appSource for a code-based create or update.

func NewContainerAppSource

func NewContainerAppSource(src ContainerSource) (AppSourceUpsert, error)

NewContainerAppSource builds an appSource for a container-based create or update.

type AppStatus

type AppStatus = gen.AppStatus

AppStatus is an app lifecycle status.

const (
	AppStatusActive       AppStatus = gen.AppStatusActive
	AppStatusDeleted      AppStatus = gen.AppStatusDeleted
	AppStatusDeleting     AppStatus = gen.AppStatusDeleting
	AppStatusFailed       AppStatus = gen.AppStatusFailed
	AppStatusInitializing AppStatus = gen.AppStatusInitializing
	AppStatusStopped      AppStatus = gen.AppStatusStopped
	AppStatusStopping     AppStatus = gen.AppStatusStopping
)

type AppUpdate

type AppUpdate = gen.AppUpdate

AppUpdate is the request body for updateApp.

type AppVolume

type AppVolume = gen.AppVolume

AppVolume is a persistent node-local directory mounted into the application.

type Build

type Build = gen.Build

Build is a code build or container validation for an app.

type BuildStatus

type BuildStatus = gen.BuildStatus

BuildStatus is a build lifecycle status.

const (
	BuildStatusBuilding BuildStatus = gen.BuildStatusBuilding
	BuildStatusFailed   BuildStatus = gen.BuildStatusFailed
	BuildStatusQueued   BuildStatus = gen.BuildStatusQueued
	BuildStatusReady    BuildStatus = gen.BuildStatusReady
)

type Client

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

Client talks to the Serverless control-plane REST API.

func NewClient

func NewClient(apiKey, baseURL string, logger *slog.Logger) *Client

NewClient creates a Serverless API client for the given API key and base URL.

func (*Client) AttachAppSecret

func (c *Client) AttachAppSecret(ctx context.Context, appID string, body SecretAttach) error

AttachAppSecret records that an organization secret is attached to an app and rolls the live deployment so a running worker picks up the value.

func (*Client) CompleteSourceUpload

func (c *Client) CompleteSourceUpload(ctx context.Context, uploadID SourceUploadID) (*SourceUpload, error)

CompleteSourceUpload asks the API to verify the staged archive against the session declaration and returns the session in its settled state.

func (*Client) CreateApp

func (c *Client) CreateApp(ctx context.Context, body AppCreate) (*App, error)

CreateApp creates a new app and starts its initial rollout.

func (*Client) CreateSecret

func (c *Client) CreateSecret(ctx context.Context, body SecretCreate) (*Secret, error)

CreateSecret creates an organization-scoped secret. The value is encrypted at rest; the response is metadata only.

func (*Client) CreateSourceUpload

func (c *Client) CreateSourceUpload(ctx context.Context, body SourceUploadCreate) (*SourceUploadCreation, error)

CreateSourceUpload opens an upload session for appId, which need not exist yet, and returns it with a short-lived instruction for staging the archive.

func (*Client) DeleteApp

func (c *Client) DeleteApp(ctx context.Context, appID string) (*App, error)

DeleteApp accepts a soft delete and returns the app with status deleting. Router removal and worker drain are asynchronous.

func (*Client) DeleteAppEnvironmentVariable

func (c *Client) DeleteAppEnvironmentVariable(ctx context.Context, appID, key string) error

DeleteAppEnvironmentVariable removes one plain-text environment variable from an app.

func (*Client) DeleteBuild

func (c *Client) DeleteBuild(ctx context.Context, appID string, buildID uuid.UUID) error

DeleteBuild cancels a queued or running build (recorded as superseded) or deletes a terminal build that no live version still needs. Returns 409 while a live version still references a ready build.

func (*Client) DeleteSecret

func (c *Client) DeleteSecret(ctx context.Context, name string) error

DeleteSecret soft-deletes an organization secret. Returns 409 while any app still attaches it.

func (*Client) DeleteSourceUpload

func (c *Client) DeleteSourceUpload(ctx context.Context, uploadID SourceUploadID) error

DeleteSourceUpload aborts an unconsumed session and removes its staging object. Repeating a successful abort is idempotent.

func (*Client) DeleteVersion

func (c *Client) DeleteVersion(ctx context.Context, appID string, versionNumber int32) error

DeleteVersion deletes an unused version. Returns 409 while the version is active, is the app's only remaining version, has a non-stopped worker, is targeted by a live rollout, or the app is deleting.

func (*Client) DeployVersion

func (c *Client) DeployVersion(ctx context.Context, appID string, versionNumber int32) (*App, error)

DeployVersion activates a ready version by number. Worker rollout is asynchronous; the 202 App reflects the persisted intent (activeVersionId and status), not healthy workers. An older ready number is a rollback.

func (*Client) DetachAppSecret

func (c *Client) DetachAppSecret(ctx context.Context, appID, secretName string) error

DetachAppSecret removes a secret attachment from an app and rolls the live deployment so a running worker stops receiving the value. It does not delete the organization secret.

func (*Client) GetApp

func (c *Client) GetApp(ctx context.Context, appID string) (*App, error)

GetApp returns a single app by ID.

func (*Client) GetBuild

func (c *Client) GetBuild(ctx context.Context, appID string, buildID uuid.UUID) (*Build, error)

GetBuild returns a single build by ID.

func (*Client) GetEndpoint

func (c *Client) GetEndpoint(ctx context.Context, appID string, endpointID uuid.UUID) (*Endpoint, error)

GetEndpoint returns a single endpoint by ID.

func (*Client) GetLogEntries

func (c *Client) GetLogEntries(ctx context.Context, queryID string, params GetLogEntriesParams) (LogEntryPage, error)

GetLogEntries returns one page of a named log query.

func (*Client) GetTask

func (c *Client) GetTask(ctx context.Context, appID, taskID string) (*Task, error)

GetTask returns a task by id.

func (*Client) GetUsageSummary

func (c *Client) GetUsageSummary(ctx context.Context, params *GetUsageSummaryParams) (*UsageSummary, error)

GetUsageSummary returns GPU time and spend for the authenticated organization over a half-open window, grouped by the requested dimensions. The API derives every figure on read; usage it cannot price fails the whole request rather than being left out of the totals.

func (*Client) GetVersion

func (c *Client) GetVersion(ctx context.Context, appID string, versionNumber int32) (*Version, error)

GetVersion returns a single version by number.

func (*Client) GetWorker

func (c *Client) GetWorker(ctx context.Context, appID string, workerID uuid.UUID) (*Worker, error)

GetWorker returns a single worker by ID (the Kubernetes pod UID).

func (*Client) InvokeAsync

func (c *Client) InvokeAsync(ctx context.Context, appID, endpointPath, taskID string, body TaskPayload) (*Task, error)

InvokeAsync starts a task and returns the accepted (typically pending) task. taskID is the client-owned identifier; an empty value is replaced with a new UUID.

func (*Client) InvokeSync

func (c *Client) InvokeSync(ctx context.Context, appID, endpointPath, taskID string, body TaskPayload) (*Task, error)

InvokeSync starts a task and waits up to the platform wait window. A wait-window expiry is not a failure: the accepted task is returned so the caller can poll. Never resubmit.

func (*Client) ListAppEnvironmentVariables

func (c *Client) ListAppEnvironmentVariables(ctx context.Context, appID string, params *ListAppEnvironmentVariablesParams) (Page[EnvironmentVariable], error)

ListAppEnvironmentVariables returns a page of plain-text environment variables for an app. Values are included in the response.

func (*Client) ListAppErrors

func (c *Client) ListAppErrors(ctx context.Context, appID string, params *ListAppErrorsParams) (Page[LogEntry], error)

ListAppErrors returns one page of failed inference requests for an app.

func (*Client) ListAppEvents

func (c *Client) ListAppEvents(ctx context.Context, appID string, params *ListAppEventsParams) (Page[AppEvent], error)

ListAppEvents returns a page of deploy, scaling, audit, and error events for an app.

func (*Client) ListAppSecrets

func (c *Client) ListAppSecrets(ctx context.Context, appID string, params *ListAppSecretsParams) (Page[SecretAttachment], error)

ListAppSecrets returns a page of secrets attached to an app.

func (*Client) ListApps

func (c *Client) ListApps(ctx context.Context, params *ListAppsParams) (Page[App], error)

ListApps returns a page of apps for the authenticated organization.

func (*Client) ListBuilds

func (c *Client) ListBuilds(ctx context.Context, appID string, params *ListBuildsParams) (Page[Build], error)

ListBuilds returns a page of builds for an app.

func (*Client) ListEndpoints

func (c *Client) ListEndpoints(ctx context.Context, appID string, params *ListEndpointsParams) (Page[Endpoint], error)

ListEndpoints returns a page of endpoints for an app.

func (*Client) ListGpuTypes

func (c *Client) ListGpuTypes(ctx context.Context) ([]GpuType, error)

ListGpuTypes returns the catalog of supported GPU types and their pricing.

func (*Client) ListSecrets

func (c *Client) ListSecrets(ctx context.Context, params *ListSecretsParams) (Page[Secret], error)

ListSecrets returns a page of organization secret metadata.

func (*Client) ListTasks

func (c *Client) ListTasks(ctx context.Context, appID string, params *ListTasksParams) (Page[Task], error)

ListTasks returns a page of tasks for an app.

func (*Client) ListUsageEvents

func (c *Client) ListUsageEvents(ctx context.Context, params *ListUsageEventsParams) (Page[UsageEvent], error)

ListUsageEvents returns one newest-first page of worker state transitions. from and to bound occurredAt. An unknown appId selects an empty page.

func (*Client) ListVersions

func (c *Client) ListVersions(ctx context.Context, appID string, params *ListVersionsParams) (Page[Version], error)

ListVersions returns a page of versions for an app.

func (*Client) ListWorkers

func (c *Client) ListWorkers(ctx context.Context, appID string, params *ListWorkersParams) (Page[Worker], error)

ListWorkers returns a page of workers for an app.

func (*Client) ResumeApp

func (c *Client) ResumeApp(ctx context.Context, appID string) (*App, error)

ResumeApp accepts a resume and returns the app with status initializing. Worker start is asynchronous.

func (*Client) StageSourceArchive

func (c *Client) StageSourceArchive(ctx context.Context, transfer SourceUploadTransfer, archive []byte) error

StageSourceArchive sends the archive to the staging object the transfer instruction names.

The request is issued through the bare doer rather than the generated client: the URL carries its own signature, and the Authorization header the generated client attaches to every call would invalidate it. Only the headers the instruction lists are sent.

func (*Client) StopApp

func (c *Client) StopApp(ctx context.Context, appID string) (*App, error)

StopApp accepts a stop and returns the app with status stopping. Worker drain is asynchronous.

func (*Client) TailLogs

func (c *Client) TailLogs(ctx context.Context, queryID, appID string, emit func(LogEntry) error) error

TailLogs follows a named log query for one app and hands every new entry to emit. It returns ErrTailEnded when the server closes the stream cleanly, a *TailStreamError when the server reports a failure, a *TailUnavailableError when a gateway answers before the stream opens, ctx.Err() when the caller stops, and any error emit returns.

func (*Client) UpdateApp

func (c *Client) UpdateApp(ctx context.Context, appID string, body AppUpdate) (*App, error)

UpdateApp patches an app in place. Omitted fields are left unchanged. appSource starts a build and records version N+1; name and configuration do not replace source.

func (*Client) UpdateAppEnvironmentVariable

func (c *Client) UpdateAppEnvironmentVariable(ctx context.Context, appID, key string, body EnvironmentVariableUpdate) (*EnvironmentVariable, error)

UpdateAppEnvironmentVariable creates or replaces one plain-text environment variable on an app.

func (*Client) UpdateSecret

func (c *Client) UpdateSecret(ctx context.Context, name string, body SecretUpdate) (*Secret, error)

UpdateSecret replaces the value of an existing organization secret and rolls every live deployment that attaches it.

func (*Client) WaitApp

func (c *Client) WaitApp(ctx context.Context, appID string, interval time.Duration) (*App, error)

WaitApp polls getApp until the application leaves initializing/stopping. Active is success; failed, stopped, deleting, and deleted are also terminal so a create or redeploy wait cannot spin forever. The caller inspects Status.

func (*Client) WaitTask

func (c *Client) WaitTask(ctx context.Context, appID, taskID string, interval time.Duration) (*Task, error)

WaitTask polls getTask until the task is completed or failed. Transient 404s are retried for taskNotFoundRetry; the invocation is never resubmitted.

type CodeSourceUpsert

type CodeSourceUpsert = gen.CodeSourceUpsert

CodeSourceUpsert is a code-based app source.

type CodebaseSource

type CodebaseSource = gen.CodebaseSource

CodebaseSource is the zipped customer code payload.

type ContainerSource

type ContainerSource = gen.ContainerSource

ContainerSource is a Dockerfile + container.yaml archive identified by sourceId.

type Cursor

type Cursor = gen.Cursor

Cursor is an opaque pagination cursor.

type DeployRequest

type DeployRequest = gen.DeployRequest

DeployRequest is the request body for DeployVersion.

type Endpoint

type Endpoint = gen.Endpoint

Endpoint is an app HTTP endpoint.

type EndpointRuntime

type EndpointRuntime = gen.EndpointRuntime

EndpointRuntime is latest-window traffic for one endpoint.

type EnvironmentVariable

type EnvironmentVariable = gen.EnvironmentVariable

EnvironmentVariable is a plain-text app environment variable.

type EnvironmentVariableUpdate

type EnvironmentVariableUpdate = gen.EnvironmentVariableUpdate

EnvironmentVariableUpdate is the request body for updateAppEnvironmentVariable.

type GetLogEntriesParams

type GetLogEntriesParams = gen.GetLogEntriesParams

GetLogEntriesParams narrows a log page: window, page size, cursor, sort, app and endpoint.

type GetUsageSummaryParams

type GetUsageSummaryParams = gen.GetUsageSummaryParams

GetUsageSummaryParams are the query parameters of GET /v1/usage/summary.

type GpuType

type GpuType = gen.GpuType

GpuType is the public catalog entry for a supported GPU type.

type Limit

type Limit = gen.Limit

Limit is a page size for cursor-paginated list endpoints.

type ListAppEnvironmentVariablesParams

type ListAppEnvironmentVariablesParams = gen.ListAppEnvironmentVariablesParams

ListAppEnvironmentVariablesParams are optional filters for ListAppEnvironmentVariables.

type ListAppErrorsParams

type ListAppErrorsParams = gen.ListAppErrorsParams

ListAppErrorsParams filters the request-error page for an app.

type ListAppErrorsParamsStatusClass

type ListAppErrorsParamsStatusClass = gen.ListAppErrorsParamsStatusClass

ListAppErrorsParamsStatusClass filters listAppErrors by 4xx or 5xx.

type ListAppErrorsParamsWindow

type ListAppErrorsParamsWindow = gen.ListAppErrorsParamsWindow

ListAppErrorsParamsWindow is the closed set of time windows listAppErrors accepts.

type ListAppEventsParams

type ListAppEventsParams = gen.ListAppEventsParams

ListAppEventsParams are optional filters for ListAppEvents.

type ListAppSecretsParams

type ListAppSecretsParams = gen.ListAppSecretsParams

ListAppSecretsParams are optional filters for ListAppSecrets.

type ListAppsParams

type ListAppsParams = gen.ListAppsParams

ListAppsParams are optional filters for ListApps.

type ListBuildsParams

type ListBuildsParams = gen.ListBuildsParams

ListBuildsParams are optional filters for ListBuilds.

type ListEndpointsParams

type ListEndpointsParams = gen.ListEndpointsParams

ListEndpointsParams are optional filters for ListEndpoints.

type ListSecretsParams

type ListSecretsParams = gen.ListSecretsParams

ListSecretsParams are optional filters for ListSecrets.

type ListTasksParams

type ListTasksParams = gen.ListTasksParams

ListTasksParams are optional filters for ListTasks.

type ListUsageEventsParams

type ListUsageEventsParams = gen.ListUsageEventsParams

ListUsageEventsParams are the query parameters of GET /v1/usage.

type ListVersionsParams

type ListVersionsParams = gen.ListVersionsParams

ListVersionsParams are optional filters for ListVersions.

type ListWorkersParams

type ListWorkersParams = gen.ListWorkersParams

ListWorkersParams are optional filters for ListWorkers.

type LogEntry

type LogEntry = gen.LogEntry

LogEntry is one application log line.

type LogEntryPage

type LogEntryPage = gen.LogEntryPage

LogEntryPage is one page of log entries in the requested sort order.

type LogSort

type LogSort = gen.LogSort

LogSort is the ordering of a log page.

const (
	// LogSortNewest lists newest first; nextCursor walks older.
	LogSortNewest LogSort = gen.Newest
	// LogSortOldest lists oldest first; nextCursor walks newer.
	LogSortOldest LogSort = gen.Oldest
)

type LogWindow

type LogWindow = gen.GetLogEntriesParamsWindow

LogWindow is the closed set of time windows a log query accepts.

type MoneyAmount

type MoneyAmount = gen.MoneyAmount

MoneyAmount is an exact decimal amount in a currency's major unit.

type Page

type Page[T any] struct {
	Data       []T     `json:"data"`
	NextCursor *string `json:"nextCursor,omitempty"`
}

Page is one page of results from a cursor-paginated list endpoint.

type Secret

type Secret = gen.Secret

Secret is organization-scoped secret metadata. The encrypted value is never returned.

type SecretAttach

type SecretAttach = gen.SecretAttach

SecretAttach is the request body for attachAppSecret.

type SecretAttachment

type SecretAttachment = gen.SecretAttachment

SecretAttachment is a secret attached to an app. The encrypted value is never returned.

type SecretCreate

type SecretCreate = gen.SecretCreate

SecretCreate is the request body for createSecret.

type SecretType

type SecretType = gen.SecretType

SecretType is the kind of organization secret.

const SecretTypeGeneric SecretType = gen.Generic

SecretTypeGeneric is the only supported secret type (environment-variable secrets).

type SecretUpdate

type SecretUpdate = gen.SecretUpdate

SecretUpdate is the request body for updateSecret.

type SourceUpload

type SourceUpload = gen.SourceUpload

SourceUpload is one upload session for an app's source archive.

type SourceUploadCreate

type SourceUploadCreate = gen.SourceUploadCreate

SourceUploadCreate declares the archive a session is opened for.

type SourceUploadCreation

type SourceUploadCreation = gen.SourceUploadCreation

SourceUploadCreation is a new session plus the transfer instruction for it.

type SourceUploadID

type SourceUploadID = gen.SourceUploadId

SourceUploadID identifies an upload session.

type SourceUploadState

type SourceUploadState = gen.SourceUploadState

SourceUploadState is the lifecycle state of an upload session.

type SourceUploadTransfer

type SourceUploadTransfer = gen.SourceUploadTransfer

SourceUploadTransfer is the instruction for staging one archive.

type TailStreamError

type TailStreamError struct {
	Detail string
}

TailStreamError is the server's `error` event: the stream is over and the detail says why.

func (*TailStreamError) Error

func (e *TailStreamError) Error() string

type TailUnavailableError

type TailUnavailableError struct {
	StatusCode int
	Err        error
}

TailUnavailableError reports that a gateway answered the tail request instead of the log store, so the stream never opened. No entry was delivered, which makes a reconnect free of repeated output. An app that has not written an entry yet answers this way: the store holds the request without writing its response headers, and the edge times it out before the first entry arrives.

func (*TailUnavailableError) Error

func (e *TailUnavailableError) Error() string

func (*TailUnavailableError) Unwrap

func (e *TailUnavailableError) Unwrap() error

type Task

type Task = gen.Task

Task is a serverless invocation.

type TaskPayload

type TaskPayload = map[string]any

TaskPayload is the JSON object forwarded to an endpoint handler. It is the TaskInvocation.payload member, not the request body itself.

type TaskStatus

type TaskStatus = gen.TaskStatus

TaskStatus is a task lifecycle status.

const (
	TaskStatusPending   TaskStatus = gen.TaskStatusPending
	TaskStatusCompleted TaskStatus = gen.TaskStatusCompleted
	TaskStatusFailed    TaskStatus = gen.TaskStatusFailed
)

type UsageBucket

type UsageBucket = gen.UsageBucket

UsageBucket is the usage that fell into one grouping key.

type UsageCoverage

type UsageCoverage = gen.UsageCoverage

UsageCoverage is which commercial capacity paid for a span of GPU time.

type UsageDimension

type UsageDimension = gen.UsageDimension

UsageDimension is one grouping a usage summary can be aggregated by.

type UsageEvent

type UsageEvent = gen.UsageEvent

UsageEvent is one worker state transition in the billing ledger.

type UsageSummary

type UsageSummary = gen.UsageSummary

UsageSummary is GPU time and spend aggregated over one half-open window.

type Version

type Version = gen.Version

Version is a deployed application version.

type Worker

type Worker = gen.Worker

Worker is a runtime worker instance.

type WorkerConfig

type WorkerConfig = gen.WorkerConfig

WorkerConfig is the live worker configuration on an app.

type WorkerConfigCreate

type WorkerConfigCreate = gen.WorkerConfigCreate

WorkerConfigCreate is the worker configuration supplied at create time.

type WorkerConfigPatch

type WorkerConfigPatch = gen.WorkerConfigPatch

WorkerConfigPatch is a partial worker configuration for updateApp.

type WorkerStateFilter

type WorkerStateFilter = gen.WorkerStateFilter

WorkerStateFilter selects whether listWorkers includes terminal stopped rows.

const (
	WorkerStateFilterAll  WorkerStateFilter = gen.WorkerStateFilterAll
	WorkerStateFilterLive WorkerStateFilter = gen.WorkerStateFilterLive
)

type WorkerStatus

type WorkerStatus = gen.WorkerStatus

WorkerStatus is a worker lifecycle status.

Directories

Path Synopsis
Package gen provides primitives to interact with the openapi HTTP API.
Package gen provides primitives to interact with the openapi HTTP API.

Jump to

Keyboard shortcuts

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