workload

Oct 8, 2026

Changes in this version

type ListOptions

+ Cursor string

type ListResult

+ NextCursor string

Jun 1, 2026

Changes in this version

+ func NewService(store Store, instances instance.Service, deploys deploy.Service, ...) *service

+ func ValidateTransition(from, to State) error

+ type AggregatedSample struct

+ At time.Time

+ CPUPercent float64

+ LatencyP95Ms float64

+ MemoryLimitMB int

+ MemoryUsedMB int

+ NetworkInBytesPerSec float64

+ NetworkOutBytesPerSec float64

+ ReplicaCount int

+ RequestsPerSec float64

+ type CreateRequest struct

+ DatacenterID id.ID

+ FromTemplateID id.ID

+ Kind provider.WorkloadKind

+ Labels map[string]string

+ Name string

+ ProviderName string

+ Region string

+ Replicas int

+ Services []provider.ServiceSpec

+ type DeployRequest struct

+ Notes string

+ Services []provider.ServiceDeploySpec

+ Strategy string

+ type HealthEvent struct

+ InstanceID id.ID

+ ReplicaIndex int

+ Result any

+ WorkloadID id.ID

+ type ListOptions struct

+ Limit int

+ ProviderName string

+ Region string

+ State State

+ type ListResult struct

+ Items []*Workload

+ Total int

+ type LogEvent struct

+ InstanceID id.ID

+ Line []byte

+ ReplicaIndex int

+ WorkloadID id.ID

+ type LogsOptions struct

+ Follow bool

+ Since time.Time

+ Tail int

+ type MetricsEvent struct

+ InstanceID id.ID

+ ReplicaIndex int

+ Sample any

+ WorkloadID id.ID

+ type MetricsRange struct

+ Resolution time.Duration

+ Since time.Time

+ Until time.Time

+ type MetricsSeries []AggregatedSample

+ type Service interface

+ Create func(ctx context.Context, req CreateRequest) (*Workload, error)

+ Delete func(ctx context.Context, workloadID id.ID) error

+ Deploy func(ctx context.Context, workloadID id.ID, req DeployRequest) (*deploy.Deployment, error)

+ Get func(ctx context.Context, workloadID id.ID) (*Workload, error)

+ GetBySlug func(ctx context.Context, slug string) (*Workload, error)

+ GetHealth func(ctx context.Context, workloadID id.ID) (*WorkloadHealth, error)

+ List func(ctx context.Context, opts ListOptions) (*ListResult, error)

+ ListDeployments func(ctx context.Context, workloadID id.ID, opts deploy.ListOptions) (*deploy.DeployListResult, error)

+ ListDomains func(ctx context.Context, workloadID id.ID) ([]network.Domain, error)

+ ListInstances func(ctx context.Context, workloadID id.ID) ([]*instance.Instance, error)

+ ListReleases func(ctx context.Context, workloadID id.ID, opts deploy.ListOptions) (*deploy.ReleaseListResult, error)

+ ListRoutes func(ctx context.Context, workloadID id.ID) ([]network.Route, error)

+ Pause func(ctx context.Context, workloadID id.ID) error

+ RangeMetrics func(ctx context.Context, workloadID id.ID, q MetricsRange) (MetricsSeries, error)

+ Restart func(ctx context.Context, workloadID id.ID) error

+ Resume func(ctx context.Context, workloadID id.ID) error

+ Scale func(ctx context.Context, workloadID id.ID, replicas int) (*Workload, error)

+ StreamLogs func(ctx context.Context, workloadID id.ID, opts LogsOptions) (<-chan *LogEvent, error)

+ Update func(ctx context.Context, workloadID id.ID, req UpdateRequest) (*Workload, error)

+ WatchHealth func(ctx context.Context, workloadID id.ID) (<-chan *HealthEvent, error)

+ WatchMetrics func(ctx context.Context, workloadID id.ID) (<-chan *MetricsEvent, error)

+ type SpecReader struct

+ func NewSpecReader(source workloadGetter) *SpecReader

+ func (r *SpecReader) ReadWorkloadSpec(ctx context.Context, tenantID string, workloadID id.ID) (*template.WorkloadSpec, error)

+ type State string

+ const StateActive

+ const StateDeploying

+ const StateDestroyed

+ const StateDestroying

+ const StateFailed

+ const StatePaused

+ const StateProvisioning

+ const StateScaling

+ type Store interface

+ DeleteWorkload func(ctx context.Context, tenantID string, workloadID id.ID) error

+ GetWorkloadByID func(ctx context.Context, tenantID string, workloadID id.ID) (*Workload, error)

+ GetWorkloadBySlug func(ctx context.Context, tenantID, slug string) (*Workload, error)

+ InsertWorkload func(ctx context.Context, w *Workload) error

+ ListWorkloads func(ctx context.Context, tenantID string, opts ListOptions) (*ListResult, error)

+ UpdateWorkload func(ctx context.Context, w *Workload) error

+ type UpdateRequest struct

+ Labels map[string]string

+ Name *string

+ Services []provider.ServiceSpec

+ type Workload struct

+ CurrentReleaseID id.ID

+ DatacenterID id.ID

+ Kind provider.WorkloadKind

+ Labels map[string]string

+ Name string

+ PausedAt *time.Time

+ PreviousReplicas int

+ ProviderName string

+ Region string

+ ReplicaCount int

+ Services []provider.ServiceSpec

+ Slug string

+ State State

+ TemplateID id.ID

+ TenantID string

+ func NewWorkload() *Workload

+ func (w *Workload) MainService() *provider.ServiceSpec

+ type WorkloadHealth struct

+ DegradedCount int

+ HealthyCount int

+ ReplicaCount int

+ Status string

+ UnhealthyCnt int

+ UnknownCount int

+ WorkloadID id.ID