service

Aug 20, 2026

Changes in this version

+ func KubernetesConfigured() bool

+ func RegisterCarrier(c Carrier)

+ func RegisterCredentials(f func() []Credential)

+ type Carrier func(p Credential) (*http.Client, error)

type CreateClusterSpec

+ Provider string

+ type Credential struct

+ KeyID string

+ Name string

+ Provider string

+ Region string

+ Secret string

type DOKSClient

+ func NewDOKSClientFromConfig(clusterID string) (*DOKSClient, error)

+ func (c *DOKSClient) Provider() string

+ type KubernetesCapable interface

+ Kubernetes func() KubernetesClientInterface

+ type KubernetesClientInterface interface

+ CreateCluster func(ctx context.Context, spec *CreateClusterSpec, tags []string) (*KubernetesCluster, error)

+ DeleteCluster func(ctx context.Context, id string) error

+ GetCluster func(ctx context.Context, id string) (*KubernetesClusterDetail, error)

+ ListClusters func(ctx context.Context) ([]*KubernetesCluster, error)

+ NodeMachines func(ctx context.Context) ([]*Machine, error)

+ Provider func() string

type KubernetesCluster

+ Provider string

+ type LivePool struct

+ ClusterID string

+ Created string

+ Name string

+ Nodes int

+ Org string

+ PoolID string

+ Size string

+ func ListLivePools(ctx context.Context) ([]LivePool, error)

+ type LoadBalancerCapable interface

+ LoadBalancers func() LoadBalancerClientInterface

type Machine

+ func ListMeteredMachines() ([]*Machine, error)

type MachineDigitalOceanClient

+ func (c MachineDigitalOceanClient) Kubernetes() KubernetesClientInterface

+ func (c MachineDigitalOceanClient) LoadBalancers() LoadBalancerClientInterface

+ func (c MachineDigitalOceanClient) Volumes() VolumeClientInterface

+ func (c MachineDigitalOceanClient) Vpcs() VpcClientInterface

type MachineHetznerClient

+ func (c MachineHetznerClient) Volumes() VolumeClientInterface

+ type ProviderStatus struct

+ Account string

+ OK bool

+ Provider string

+ Reason string

+ func KubernetesProviderStatus(ctx context.Context) []ProviderStatus

+ type VolumeCapable interface

+ Volumes func() VolumeClientInterface

+ type VpcCapable interface

+ Vpcs func() VpcClientInterface

Aug 20, 2026

Changes in this version

+ type CreateLoadBalancerSpec struct

+ DisplayName string

+ ForwardingRules []ForwardingRule

+ Name string

+ Region string

+ Size string

+ Type string

+ type CreateVpcSpec struct

+ Cidr string

+ DisplayName string

+ Name string

+ Region string

+ type ForwardingRule struct

+ EntryPort int

+ EntryProtocol string

+ TargetPort int

+ TargetProtocol string

+ type LoadBalancer struct

+ DisplayName string

+ Id string

+ Ip string

+ Name string

+ Region string

+ State string

+ Targets int

+ Type string

+ type LoadBalancerClientInterface interface

+ CreateLoadBalancer func(spec *CreateLoadBalancerSpec) (*LoadBalancer, error)

+ DeleteLoadBalancer func(name string) error

+ GetLoadBalancer func(name string) (*LoadBalancer, error)

+ GetLoadBalancers func() ([]*LoadBalancer, error)

+ func NewLoadBalancerClient(providerType string, accessKeyId string, accessKeySecret string, region string) (LoadBalancerClientInterface, error)

+ type LoadBalancerDigitalOceanClient struct

+ Client *godo.Client

+ func (c *LoadBalancerDigitalOceanClient) CreateLoadBalancer(spec *CreateLoadBalancerSpec) (*LoadBalancer, error)

+ func (c *LoadBalancerDigitalOceanClient) DeleteLoadBalancer(name string) error

+ func (c *LoadBalancerDigitalOceanClient) GetLoadBalancer(name string) (*LoadBalancer, error)

+ func (c *LoadBalancerDigitalOceanClient) GetLoadBalancers() ([]*LoadBalancer, error)

+ type Vpc struct

+ Cidr string

+ DisplayName string

+ Id string

+ Name string

+ Region string

+ State string

+ type VpcClientInterface interface

+ CreateVpc func(spec *CreateVpcSpec) (*Vpc, error)

+ DeleteVpc func(name string) error

+ GetVpc func(name string) (*Vpc, error)

+ GetVpcs func() ([]*Vpc, error)

+ func NewVpcClient(providerType string, accessKeyId string, accessKeySecret string, region string) (VpcClientInterface, error)

+ type VpcDigitalOceanClient struct

+ Client *godo.Client

+ func (c *VpcDigitalOceanClient) CreateVpc(spec *CreateVpcSpec) (*Vpc, error)

+ func (c *VpcDigitalOceanClient) DeleteVpc(name string) error

+ func (c *VpcDigitalOceanClient) GetVpc(name string) (*Vpc, error)

+ func (c *VpcDigitalOceanClient) GetVpcs() ([]*Vpc, error)

Aug 20, 2026

Changes in this version

+ func ComputeReachable(ctx context.Context) error

Aug 11, 2026

Changes in this version

+ const DefaultLaunchSize

Aug 6, 2026

Changes in this version

+ var ErrPriceUnavailable = errors.New("price unavailable")

+ func AuthorizeCompute(ctx context.Context, org, project string, cents int64) error

+ func Billable(ctx context.Context, sweep string) bool

+ func CreatedInHour(createdTime, stamp string) bool

+ func HourStamp(now time.Time) string

+ func HourlyCents(slug string) (int64, error)

+ func Provision(ctx context.Context, org, project string, authorize, debit int64, model string, ...) error

+ func RateOf(si *SizeInfo) (int64, error)

+ func RecordCompute(ctx context.Context, org, project string, cents int64, ...) error

type DOKSClient

+ func NewHouseDOKSClient(clusterID string) (*DOKSClient, error)

+ type HousePool struct

+ ClusterID string

+ Created string

+ Name string

+ Nodes int

+ Org string

+ PoolID string

+ Size string

+ func ListHousePools(ctx context.Context) ([]HousePool, error)

+ type SeedPool struct

+ CentsHour int64

+ ClusterID string

+ Count int

+ Name string

+ Org string

+ Project string

+ Size string

Aug 6, 2026

Changes in this version

+ const KindTab

+ func Opens(kind string) bool

Jul 2, 2026

Changes in this version

type MachineGcpClient

+ Client *computepb.InstancesClient

+ ProjectID string

+ Zone string

Jul 21, 2026

Changes in this version

+ const ComputeDestroyed

+ const ComputeLaunched

+ const ComputeRunning

+ const KindBot

+ const KindCluster

+ const KindContainer

+ const KindFunction

+ const KindMachine

+ const KindNodePool

+ var ErrCostUnavailable = errors.New("cloud cost: unavailable (cost-read not configured for this provider)")

+ func AnalyticsConfigured() bool

+ func CanonicalKind(kind string) string

+ func ComputeConfigured() bool

+ func DeleteOrgKubernetesCluster(org, id string) error

+ func DeleteOrgMachine(org, id string) error

+ func EmitCompute(org, event string, m *Machine, priceCents int64)

+ func EmitComputeEvent(ev ComputeEvent)

+ func HanzoPrice(doPrice float64, isGPU bool) float64

+ func IsNotFound(err error) bool

+ func MachineApp(m *Machine) string

+ func MachineKind(m *Machine) string

+ func MachineProject(m *Machine) string

+ func MeterActor(org, project string) string

+ func MeterRunningMachines(ctx context.Context)

+ func MeteringConfigured() bool

+ func NewMeteringClient(org string) *metering.Client

+ func NormalizeProject(project string) string

+ func PriceToCents(price float64) int64

+ func SetKind(spec *CreateMachineSpec, kind string)

+ func SetScope(spec *CreateMachineSpec, app, project string)

+ type CloudCostReader interface

+ MonthToDateCents func(ctx context.Context, now time.Time) (int64, error)

+ func NewCostReader(providerType, clientId, clientSecret, region, costScope string) (CloudCostReader, error)

+ type ComputeEvent struct

+ App string

+ Event string

+ Kind string

+ MachineID string

+ Org string

+ PriceCents int64

+ Project string

+ Size string

+ Ts string

+ type Cpu struct

+ Processors int

+ type CreateClusterNodePool struct

+ Count int

+ Name string

+ Size string

+ type CreateClusterSpec struct

+ Name string

+ NodePool CreateClusterNodePool

+ Region string

+ Version string

+ type CreateMachineSpec struct

+ DisplayName string

+ ImageID string

+ InstanceType string

+ Name string

+ OS string

+ Region string

+ SSHKeyIDs []string

+ Tags map[string]string

+ type CreateNodePoolSpec struct

+ AutoScale bool

+ Count int

+ Labels map[string]string

+ MaxNodes int

+ MinNodes int

+ Name string

+ Size string

+ Tags []string

+ type CreateVolumeSpec struct

+ DisplayName string

+ Format string

+ MachineID string

+ Name string

+ Region string

+ Size int

+ type DOKSClient struct

+ Client *godo.Client

+ ClusterID string

+ func NewDOKSClient(token, clusterID string) (*DOKSClient, error)

+ func (c *DOKSClient) CreateCluster(ctx context.Context, spec *CreateClusterSpec, tags []string) (*KubernetesCluster, error)

+ func (c *DOKSClient) CreateNodePool(spec *CreateNodePoolSpec) (*NodePool, error)

+ func (c *DOKSClient) DeleteCluster(ctx context.Context, id string) error

+ func (c *DOKSClient) DeleteNodePool(poolID string) error

+ func (c *DOKSClient) GetCluster(ctx context.Context, id string) (*KubernetesClusterDetail, error)

+ func (c *DOKSClient) GetNodePool(poolID string) (*NodePool, error)

+ func (c *DOKSClient) ListClusters(ctx context.Context) ([]*KubernetesCluster, error)

+ func (c *DOKSClient) ListNodePools() ([]*NodePool, error)

+ func (c *DOKSClient) NodeMachines(ctx context.Context) ([]*Machine, error)

+ func (c *DOKSClient) RecycleNodePoolNodes(poolID string, nodeIDs []string) error

+ func (c *DOKSClient) UpdateNodePool(poolID string, spec *CreateNodePoolSpec) (*NodePool, error)

+ type GPUSpec struct

+ Count int

+ Model string

+ Vram int

+ VramUnit string

+ type ImageInfo struct

+ Distribution string

+ ID int

+ Kind string

+ MinDiskGB int

+ Name string

+ Regions []string

+ SizeGB float64

+ Slug string

+ Status string

+ func CreateOrgImage(org, name, url, region, distribution string) (*ImageInfo, error)

+ func ListImages(org string) ([]ImageInfo, error)

+ type KubernetesCluster struct

+ ID string

+ Name string

+ RegionSlug string

+ Status string

+ Tags []string

+ func CreateOrgKubernetesCluster(org string, spec *CreateClusterSpec) (*KubernetesCluster, error)

+ func ListOrgKubernetesClusters(org string) ([]*KubernetesCluster, error)

+ type KubernetesClusterDetail struct

+ NodePools []*NodePool

+ Nodes []*Machine

+ func GetOrgKubernetesCluster(org, id string) (*KubernetesClusterDetail, error)

+ type Machine struct

+ Category string

+ CpuSize string

+ CreatedTime string

+ DisplayName string

+ ExpireTime string

+ Id string

+ Image string

+ MemSize string

+ Name string

+ Os string

+ Owner string

+ PrivateIp string

+ Provider string

+ PublicIp string

+ Region string

+ Size string

+ State string

+ Tag string

+ Type string

+ UpdatedTime string

+ Zone string

+ func GetOrgMachine(org, id string) (*Machine, error)

+ func LaunchOrgMachine(org, project string, spec *CreateMachineSpec) (*Machine, error)

+ func ListOrgKubernetesNodes(org string) ([]*Machine, error)

+ func ListOrgMachines(org, project string) ([]*Machine, error)

+ func ListRunningHouseMachines() ([]*Machine, error)

+ type MachineAliyunClient struct

+ Client *ecs.Client

+ func (client MachineAliyunClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineAliyunClient) GetMachine(name string) (*Machine, error)

+ func (client MachineAliyunClient) GetMachines() ([]*Machine, error)

+ func (client MachineAliyunClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineAwsClient struct

+ Client *ec2.Client

+ func (client MachineAwsClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineAwsClient) GetMachine(name string) (*Machine, error)

+ func (client MachineAwsClient) GetMachines() ([]*Machine, error)

+ func (client MachineAwsClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineAzureClient struct

+ Client *armcompute.VirtualMachinesClient

+ func (client MachineAzureClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineAzureClient) GetMachine(name string) (*Machine, error)

+ func (client MachineAzureClient) GetMachines() ([]*Machine, error)

+ func (client MachineAzureClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineClientInterface interface

+ CreateMachine func(spec *CreateMachineSpec) (*Machine, error)

+ GetMachine func(name string) (*Machine, error)

+ GetMachines func() ([]*Machine, error)

+ UpdateMachineState func(name string, state string) (bool, string, error)

+ func NewMachineClient(providerType string, accessKeyId string, accessKeySecret string, region string) (MachineClientInterface, error)

+ type MachineDigitalOceanClient struct

+ Client *godo.Client

+ func (client MachineDigitalOceanClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineDigitalOceanClient) DeleteMachine(name string) error

+ func (client MachineDigitalOceanClient) GetMachine(name string) (*Machine, error)

+ func (client MachineDigitalOceanClient) GetMachines() ([]*Machine, error)

+ func (client MachineDigitalOceanClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineGcpClient struct

+ func (client MachineGcpClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineGcpClient) GetMachine(name string) (*Machine, error)

+ func (client MachineGcpClient) GetMachines() ([]*Machine, error)

+ func (client MachineGcpClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineHetznerClient struct

+ Client *hcloud.Client

+ func (client MachineHetznerClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineHetznerClient) GetMachine(name string) (*Machine, error)

+ func (client MachineHetznerClient) GetMachines() ([]*Machine, error)

+ func (client MachineHetznerClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineKvmClient struct

+ L *libvirt.Libvirt

+ func (client MachineKvmClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineKvmClient) GetMachine(name string) (*Machine, error)

+ func (client MachineKvmClient) GetMachines() ([]*Machine, error)

+ func (client MachineKvmClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineLightsailClient struct

+ Client *lightsail.Client

+ func (client MachineLightsailClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineLightsailClient) GetMachine(name string) (*Machine, error)

+ func (client MachineLightsailClient) GetMachines() ([]*Machine, error)

+ func (client MachineLightsailClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachinePveClient struct

+ func (client MachinePveClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachinePveClient) GetMachine(name string) (*Machine, error)

+ func (client MachinePveClient) GetMachines() ([]*Machine, error)

+ func (client MachinePveClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type MachineVmwareClient struct

+ func (client MachineVmwareClient) CreateMachine(spec *CreateMachineSpec) (*Machine, error)

+ func (client MachineVmwareClient) GetMachine(name string) (*Machine, error)

+ func (client MachineVmwareClient) GetMachines() ([]*Machine, error)

+ func (client MachineVmwareClient) UpdateMachineState(name string, state string) (bool, string, error)

+ type NodeInfo struct

+ CreatedAt string

+ DropletID string

+ ID string

+ Name string

+ Status string

+ UpdatedAt string

+ type NodePool struct

+ AutoScale bool

+ Count int

+ ID string

+ Labels map[string]string

+ MaxNodes int

+ MinNodes int

+ Name string

+ Nodes []NodeInfo

+ Size string

+ Tags []string

+ type RegionInfo struct

+ Available bool

+ Features []string

+ Name string

+ Sizes []string

+ Slug string

+ func ListRegions() ([]RegionInfo, error)

+ type SizeInfo struct

+ Available bool

+ Currency string

+ DiskGB int

+ GPU *GPUSpec

+ MemoryMB int

+ PriceHourly float64

+ PriceMonthly float64

+ Regions []string

+ Slug string

+ Vcpus int

+ func ListGPUSizes() ([]SizeInfo, error)

+ func ListSizes() ([]SizeInfo, error)

+ func SizeBySlug(slug string) (*SizeInfo, error)

+ type VirtualMachine struct

+ Cpu Cpu

+ ID string

+ Memory int

+ type VirtualMachinePath struct

+ ID string

+ Path string

+ type Volume struct

+ DisplayName string

+ Format string

+ Id string

+ MachineName string

+ Name string

+ Region string

+ Size int

+ State string

+ type VolumeClientInterface interface

+ AttachVolume func(volumeName string, machineName string) error

+ CreateVolume func(spec *CreateVolumeSpec) (*Volume, error)

+ DeleteVolume func(name string) error

+ DetachVolume func(volumeName string) error

+ GetVolume func(name string) (*Volume, error)

+ GetVolumes func() ([]*Volume, error)

+ ResizeVolume func(volumeName string, sizeGB int) error

+ func NewVolumeClient(providerType string, accessKeyId string, accessKeySecret string, region string) (VolumeClientInterface, error)

+ type VolumeDigitalOceanClient struct

+ Client *godo.Client

+ func (c *VolumeDigitalOceanClient) AttachVolume(volumeName string, machineName string) error

+ func (c *VolumeDigitalOceanClient) CreateVolume(spec *CreateVolumeSpec) (*Volume, error)

+ func (c *VolumeDigitalOceanClient) DeleteVolume(name string) error

+ func (c *VolumeDigitalOceanClient) DetachVolume(volumeName string) error

+ func (c *VolumeDigitalOceanClient) GetVolume(name string) (*Volume, error)

+ func (c *VolumeDigitalOceanClient) GetVolumes() ([]*Volume, error)

+ func (c *VolumeDigitalOceanClient) ResizeVolume(volumeName string, sizeGB int) error

+ type VolumeHetznerClient struct

+ Client *hcloud.Client

+ func (c *VolumeHetznerClient) AttachVolume(volumeName string, machineName string) error

+ func (c *VolumeHetznerClient) CreateVolume(spec *CreateVolumeSpec) (*Volume, error)

+ func (c *VolumeHetznerClient) DeleteVolume(name string) error

+ func (c *VolumeHetznerClient) DetachVolume(volumeName string) error

+ func (c *VolumeHetznerClient) GetVolume(name string) (*Volume, error)

+ func (c *VolumeHetznerClient) GetVolumes() ([]*Volume, error)

+ func (c *VolumeHetznerClient) ResizeVolume(volumeName string, sizeGB int) error