drivers

May 10, 2026

Changes in this version

type DatabaseDriver

+ func (d *DatabaseDriver) AdoptionRef(spec interfaces.ResourceSpec) (interfaces.ResourceRef, bool, error)

May 9, 2026

Changes in this version

+ type SpacesKeyDriver struct

+ func NewSpacesKeyDriver(client *godo.Client) *SpacesKeyDriver

+ func (d *SpacesKeyDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *SpacesKeyDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *SpacesKeyDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *SpacesKeyDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *SpacesKeyDriver) ProviderIDFormat() interfaces.ProviderIDFormat

+ func (d *SpacesKeyDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *SpacesKeyDriver) ResourceType() string

+ func (d *SpacesKeyDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *SpacesKeyDriver) SensitiveKeys() []string

+ func (d *SpacesKeyDriver) SupportsUpsert() bool

+ func (d *SpacesKeyDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

May 8, 2026

Changes in this version

type AppPlatformDriver

+ func NewAppPlatformDriverWithClients(c AppPlatformClient, r RegistryClient, region string) *AppPlatformDriver

type RegistryClient

+ ListRepositoryTags func(ctx context.Context, registry, repository string, opts *godo.ListOptions) ([]*godo.RepositoryTag, *godo.Response, error)

May 8, 2026

Changes in this version

+ type ActionsClient interface

+ Get func(ctx context.Context, actionID int) (*godo.Action, *godo.Response, error)

type DropletDriver

+ func (d *DropletDriver) Replace(ctx context.Context, oldRef interfaces.ResourceRef, ...) (*interfaces.ResourceOutput, error)

+ func (d *DropletDriver) SetReplaceTimeoutsForTest(timeout, pollInterval time.Duration)

type StorageActionsClient

+ DetachByDropletID func(ctx context.Context, volumeID string, dropletID int) (*godo.Action, *godo.Response, error)

May 3, 2026

Changes in this version

+ type StorageActionsClient interface

+ Resize func(ctx context.Context, volumeID string, sizeGigabytes int, regionSlug string) (*godo.Action, *godo.Response, error)

+ type StorageClient interface

+ CreateVolume func(ctx context.Context, req *godo.VolumeCreateRequest) (*godo.Volume, *godo.Response, error)

+ DeleteVolume func(ctx context.Context, volumeID string) (*godo.Response, error)

+ GetVolume func(ctx context.Context, volumeID string) (*godo.Volume, *godo.Response, error)

+ ListVolumes func(ctx context.Context, params *godo.ListVolumeParams) ([]godo.Volume, *godo.Response, error)

+ type VolumeDriver struct

+ func NewVolumeDriver(c *godo.Client, region string) *VolumeDriver

+ func NewVolumeDriverWithClient(c StorageClient, actions StorageActionsClient, region string) *VolumeDriver

+ func (d *VolumeDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *VolumeDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *VolumeDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *VolumeDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *VolumeDriver) ProviderIDFormat() interfaces.ProviderIDFormat

+ func (d *VolumeDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *VolumeDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *VolumeDriver) SensitiveKeys() []string

+ func (d *VolumeDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

May 2, 2026

Changes in this version

type AppPlatformClient

+ GetLogs func(ctx context.Context, appID, deploymentID, component string, ...) (*godo.AppLogs, *godo.Response, error)

May 2, 2026

Changes in this version

+ var ErrAppNotFound = fmt.Errorf("trusted_sources app: %w", ErrResourceNotFound)

type DatabaseDriver

+ func (d *DatabaseDriver) FlushDeferredUpdates(ctx context.Context) error

+ func (d *DatabaseDriver) HasDeferredUpdates() bool

Apr 28, 2026

Changes in this version

+ const NoTargetsErrFmt

Apr 27, 2026

Changes in this version

type AppPlatformDriver

+ func (d *AppPlatformDriver) RepairDirtyMigration(ctx context.Context, req interfaces.MigrationRepairRequest) (*interfaces.MigrationRepairResult, error)

Apr 25, 2026

Changes in this version

type DatabaseDriver

+ func NewDatabaseDriverWithClients(c DatabaseClient, apps appNameLister, region string) *DatabaseDriver

Apr 24, 2026

Changes in this version

type APIGatewayAppClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]*godo.App, *godo.Response, error)

type APIGatewayDriver

+ func (d *APIGatewayDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type AppPlatformDriver

+ func (d *AppPlatformDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type CacheClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]godo.Database, *godo.Response, error)

type CacheDriver

+ func (d *CacheDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type CertificateDriver

+ func (d *CertificateDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type DNSDriver

+ func (d *DNSDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type DatabaseDriver

+ func (d *DatabaseDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type DropletDriver

+ func (d *DropletDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type FirewallDriver

+ func (d *FirewallDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type IAMRoleDriver

+ func (d *IAMRoleDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type KubernetesClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]*godo.KubernetesCluster, *godo.Response, error)

type KubernetesDriver

+ func (d *KubernetesDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type LoadBalancerClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]godo.LoadBalancer, *godo.Response, error)

type LoadBalancerDriver

+ func (d *LoadBalancerDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type RegistryDriver

+ func (d *RegistryDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type SpacesDriver

+ func (d *SpacesDriver) ProviderIDFormat() interfaces.ProviderIDFormat

type VPCDriver

+ func (d *VPCDriver) ProviderIDFormat() interfaces.ProviderIDFormat

Apr 24, 2026

Changes in this version

type AppPlatformClient

+ ListDeployments func(ctx context.Context, appID string, opts *godo.ListOptions) ([]*godo.Deployment, *godo.Response, error)

type AppPlatformDriver

+ func (d *AppPlatformDriver) Troubleshoot(ctx context.Context, ref interfaces.ResourceRef, _ string) ([]interfaces.Diagnostic, error)

Apr 23, 2026

Changes in this version

type DatabaseClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]godo.Database, *godo.Response, error)

type DatabaseDriver

+ func (d *DatabaseDriver) SupportsUpsert() bool

type FirewallClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]godo.Firewall, *godo.Response, error)

type FirewallDriver

+ func (d *FirewallDriver) SupportsUpsert() bool

type VPCClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]*godo.VPC, *godo.Response, error)

type VPCDriver

+ func (d *VPCDriver) SupportsUpsert() bool

Apr 23, 2026

Changes in this version

type AppPlatformDriver

+ func (d *AppPlatformDriver) SupportsUpsert() bool

Apr 23, 2026

Changes in this version

type DatabaseClient

+ UpdateFirewallRules func(ctx context.Context, databaseID string, ...) (*godo.Response, error)

Apr 22, 2026

Changes in this version

+ func WrapGodoError(err error) error

type AppPlatformClient

+ CreateDeployment func(ctx context.Context, appID string, req ...*godo.DeploymentCreateRequest) (*godo.Deployment, *godo.Response, error)

Apr 22, 2026

Changes in this version

+ var ErrResourceNotFound = errors.New("resource not found")

type AppPlatformClient

+ List func(ctx context.Context, opts *godo.ListOptions) ([]*godo.App, *godo.Response, error)

Apr 21, 2026

Changes in this version

+ func ParseImageRef(imageStr string) (*godo.ImageSourceSpec, error)

Apr 8, 2026

Changes in this version

type APIGatewayDriver

+ func (d *APIGatewayDriver) SensitiveKeys() []string

type AppPlatformDriver

+ func (d *AppPlatformDriver) SensitiveKeys() []string

type CacheDriver

+ func (d *CacheDriver) SensitiveKeys() []string

type CertificateDriver

+ func (d *CertificateDriver) SensitiveKeys() []string

type DNSDriver

+ func (d *DNSDriver) SensitiveKeys() []string

type DatabaseDriver

+ func (d *DatabaseDriver) SensitiveKeys() []string

type DropletDriver

+ func (d *DropletDriver) SensitiveKeys() []string

type FirewallDriver

+ func (d *FirewallDriver) SensitiveKeys() []string

type IAMRoleDriver

+ func (d *IAMRoleDriver) SensitiveKeys() []string

type KubernetesDriver

+ func (d *KubernetesDriver) SensitiveKeys() []string

type LoadBalancerDriver

+ func (d *LoadBalancerDriver) SensitiveKeys() []string

type RegistryDriver

+ func (d *RegistryDriver) SensitiveKeys() []string

type SpacesDriver

+ func (d *SpacesDriver) SensitiveKeys() []string

type VPCDriver

+ func (d *VPCDriver) SensitiveKeys() []string

Apr 7, 2026

Changes in this version

+ type AppBlueGreenDriver struct

+ func NewAppBlueGreenDriver(c AppPlatformClient, region, blueID, blueName string) *AppBlueGreenDriver

+ func (d *AppBlueGreenDriver) CreateGreen(ctx context.Context, image string) error

+ func (d *AppBlueGreenDriver) CurrentImage(ctx context.Context) (string, error)

+ func (d *AppBlueGreenDriver) DestroyBlue(ctx context.Context) error

+ func (d *AppBlueGreenDriver) GreenEndpoint(_ context.Context) (string, error)

+ func (d *AppBlueGreenDriver) HealthCheck(ctx context.Context, path string) error

+ func (d *AppBlueGreenDriver) ReplicaCount(ctx context.Context) (int, error)

+ func (d *AppBlueGreenDriver) SwitchTraffic(ctx context.Context) error

+ func (d *AppBlueGreenDriver) Update(ctx context.Context, image string) error

+ type AppCanaryDriver struct

+ func NewAppCanaryDriver(c AppPlatformClient, region, stableID, stableName string) *AppCanaryDriver

+ func (d *AppCanaryDriver) CheckMetricGate(_ context.Context, _ string) error

+ func (d *AppCanaryDriver) CreateCanary(ctx context.Context, image string) error

+ func (d *AppCanaryDriver) CurrentImage(ctx context.Context) (string, error)

+ func (d *AppCanaryDriver) DestroyCanary(ctx context.Context) error

+ func (d *AppCanaryDriver) HealthCheck(ctx context.Context, path string) error

+ func (d *AppCanaryDriver) PromoteCanary(ctx context.Context) error

+ func (d *AppCanaryDriver) ReplicaCount(ctx context.Context) (int, error)

+ func (d *AppCanaryDriver) RoutePercent(_ context.Context, percent int) error

+ func (d *AppCanaryDriver) Update(ctx context.Context, image string) error

+ type AppDeployDriver struct

+ func NewAppDeployDriver(c AppPlatformClient, region, appID, appName string) *AppDeployDriver

+ func (d *AppDeployDriver) CurrentImage(ctx context.Context) (string, error)

+ func (d *AppDeployDriver) HealthCheck(ctx context.Context, _ string) error

+ func (d *AppDeployDriver) ReplicaCount(ctx context.Context) (int, error)

+ func (d *AppDeployDriver) Update(ctx context.Context, image string) error

Mar 22, 2026

Changes in this version

+ type APIGatewayAppClient interface

+ Create func(ctx context.Context, req *godo.AppCreateRequest) (*godo.App, *godo.Response, error)

+ Delete func(ctx context.Context, appID string) (*godo.Response, error)

+ Get func(ctx context.Context, appID string) (*godo.App, *godo.Response, error)

+ Update func(ctx context.Context, appID string, req *godo.AppUpdateRequest) (*godo.App, *godo.Response, error)

+ type APIGatewayDriver struct

+ func NewAPIGatewayDriver(c *godo.Client, region string) *APIGatewayDriver

+ func NewAPIGatewayDriverWithClient(c APIGatewayAppClient, region string) *APIGatewayDriver

+ func (d *APIGatewayDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *APIGatewayDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *APIGatewayDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *APIGatewayDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *APIGatewayDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *APIGatewayDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *APIGatewayDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type CacheClient interface

+ Create func(ctx context.Context, req *godo.DatabaseCreateRequest) (*godo.Database, *godo.Response, error)

+ Delete func(ctx context.Context, databaseID string) (*godo.Response, error)

+ Get func(ctx context.Context, databaseID string) (*godo.Database, *godo.Response, error)

+ Resize func(ctx context.Context, databaseID string, req *godo.DatabaseResizeRequest) (*godo.Response, error)

+ type CacheDriver struct

+ func NewCacheDriver(c *godo.Client, region string) *CacheDriver

+ func NewCacheDriverWithClient(c CacheClient, region string) *CacheDriver

+ func (d *CacheDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *CacheDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *CacheDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *CacheDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *CacheDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *CacheDriver) Scale(ctx context.Context, ref interfaces.ResourceRef, replicas int) (*interfaces.ResourceOutput, error)

+ func (d *CacheDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type IAMRoleDriver struct

+ func NewIAMRoleDriver() *IAMRoleDriver

+ func (d *IAMRoleDriver) Create(_ context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *IAMRoleDriver) Delete(_ context.Context, _ interfaces.ResourceRef) error

+ func (d *IAMRoleDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *IAMRoleDriver) HealthCheck(_ context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *IAMRoleDriver) Read(_ context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *IAMRoleDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *IAMRoleDriver) Update(_ context.Context, _ interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

type KubernetesClient

+ UpdateNodePool func(ctx context.Context, clusterID, poolID string, ...) (*godo.KubernetesNodePool, *godo.Response, error)

Mar 21, 2026

Changes in this version

+ type AppPlatformClient interface

+ Create func(ctx context.Context, req *godo.AppCreateRequest) (*godo.App, *godo.Response, error)

+ Delete func(ctx context.Context, appID string) (*godo.Response, error)

+ Get func(ctx context.Context, appID string) (*godo.App, *godo.Response, error)

+ Update func(ctx context.Context, appID string, req *godo.AppUpdateRequest) (*godo.App, *godo.Response, error)

+ type AppPlatformDriver struct

+ func NewAppPlatformDriver(c *godo.Client, region string) *AppPlatformDriver

+ func NewAppPlatformDriverWithClient(c AppPlatformClient, region string) *AppPlatformDriver

+ func (d *AppPlatformDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *AppPlatformDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *AppPlatformDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *AppPlatformDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *AppPlatformDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *AppPlatformDriver) Scale(ctx context.Context, ref interfaces.ResourceRef, replicas int) (*interfaces.ResourceOutput, error)

+ func (d *AppPlatformDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type CertificateClient interface

+ Create func(ctx context.Context, req *godo.CertificateRequest) (*godo.Certificate, *godo.Response, error)

+ Delete func(ctx context.Context, certID string) (*godo.Response, error)

+ Get func(ctx context.Context, certID string) (*godo.Certificate, *godo.Response, error)

+ List func(ctx context.Context, opts *godo.ListOptions) ([]godo.Certificate, *godo.Response, error)

+ type CertificateDriver struct

+ func NewCertificateDriver(c *godo.Client) *CertificateDriver

+ func NewCertificateDriverWithClient(c CertificateClient) *CertificateDriver

+ func (d *CertificateDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *CertificateDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *CertificateDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *CertificateDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *CertificateDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *CertificateDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *CertificateDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type DNSDriver struct

+ func NewDNSDriver(c *godo.Client) *DNSDriver

+ func NewDNSDriverWithClient(c DomainsClient) *DNSDriver

+ func (d *DNSDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *DNSDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *DNSDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *DNSDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *DNSDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *DNSDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *DNSDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type DatabaseClient interface

+ Create func(ctx context.Context, req *godo.DatabaseCreateRequest) (*godo.Database, *godo.Response, error)

+ Delete func(ctx context.Context, databaseID string) (*godo.Response, error)

+ Get func(ctx context.Context, databaseID string) (*godo.Database, *godo.Response, error)

+ Resize func(ctx context.Context, databaseID string, req *godo.DatabaseResizeRequest) (*godo.Response, error)

+ type DatabaseDriver struct

+ func NewDatabaseDriver(c *godo.Client, region string) *DatabaseDriver

+ func NewDatabaseDriverWithClient(c DatabaseClient, region string) *DatabaseDriver

+ func (d *DatabaseDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *DatabaseDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *DatabaseDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *DatabaseDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *DatabaseDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *DatabaseDriver) Scale(ctx context.Context, ref interfaces.ResourceRef, replicas int) (*interfaces.ResourceOutput, error)

+ func (d *DatabaseDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type DomainsClient interface

+ Create func(ctx context.Context, req *godo.DomainCreateRequest) (*godo.Domain, *godo.Response, error)

+ CreateRecord func(ctx context.Context, domain string, req *godo.DomainRecordEditRequest) (*godo.DomainRecord, *godo.Response, error)

+ Delete func(ctx context.Context, name string) (*godo.Response, error)

+ DeleteRecord func(ctx context.Context, domain string, id int) (*godo.Response, error)

+ EditRecord func(ctx context.Context, domain string, id int, req *godo.DomainRecordEditRequest) (*godo.DomainRecord, *godo.Response, error)

+ Get func(ctx context.Context, name string) (*godo.Domain, *godo.Response, error)

+ Records func(ctx context.Context, domain string, opts *godo.ListOptions) ([]godo.DomainRecord, *godo.Response, error)

+ type DropletDriver struct

+ func NewDropletDriver(c *godo.Client, region string) *DropletDriver

+ func NewDropletDriverWithClient(c DropletsClient, region string) *DropletDriver

+ func (d *DropletDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *DropletDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *DropletDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *DropletDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *DropletDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *DropletDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *DropletDriver) Update(_ context.Context, _ interfaces.ResourceRef, _ interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type DropletsClient interface

+ Create func(ctx context.Context, req *godo.DropletCreateRequest) (*godo.Droplet, *godo.Response, error)

+ Delete func(ctx context.Context, dropletID int) (*godo.Response, error)

+ Get func(ctx context.Context, dropletID int) (*godo.Droplet, *godo.Response, error)

+ type FirewallClient interface

+ Create func(ctx context.Context, req *godo.FirewallRequest) (*godo.Firewall, *godo.Response, error)

+ Delete func(ctx context.Context, fwID string) (*godo.Response, error)

+ Get func(ctx context.Context, fwID string) (*godo.Firewall, *godo.Response, error)

+ Update func(ctx context.Context, fwID string, req *godo.FirewallRequest) (*godo.Firewall, *godo.Response, error)

+ type FirewallDriver struct

+ func NewFirewallDriver(c *godo.Client) *FirewallDriver

+ func NewFirewallDriverWithClient(c FirewallClient) *FirewallDriver

+ func (d *FirewallDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *FirewallDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *FirewallDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *FirewallDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *FirewallDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *FirewallDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *FirewallDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type KubernetesClient interface

+ Create func(ctx context.Context, req *godo.KubernetesClusterCreateRequest) (*godo.KubernetesCluster, *godo.Response, error)

+ Delete func(ctx context.Context, clusterID string) (*godo.Response, error)

+ Get func(ctx context.Context, clusterID string) (*godo.KubernetesCluster, *godo.Response, error)

+ Update func(ctx context.Context, clusterID string, ...) (*godo.KubernetesCluster, *godo.Response, error)

+ type KubernetesDriver struct

+ func NewKubernetesDriver(c *godo.Client, region string) *KubernetesDriver

+ func NewKubernetesDriverWithClient(c KubernetesClient, region string) *KubernetesDriver

+ func (d *KubernetesDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *KubernetesDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *KubernetesDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *KubernetesDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *KubernetesDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *KubernetesDriver) Scale(ctx context.Context, ref interfaces.ResourceRef, replicas int) (*interfaces.ResourceOutput, error)

+ func (d *KubernetesDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type LoadBalancerClient interface

+ Create func(ctx context.Context, req *godo.LoadBalancerRequest) (*godo.LoadBalancer, *godo.Response, error)

+ Delete func(ctx context.Context, lbID string) (*godo.Response, error)

+ Get func(ctx context.Context, lbID string) (*godo.LoadBalancer, *godo.Response, error)

+ Update func(ctx context.Context, lbID string, req *godo.LoadBalancerRequest) (*godo.LoadBalancer, *godo.Response, error)

+ type LoadBalancerDriver struct

+ func NewLoadBalancerDriver(c *godo.Client, region string) *LoadBalancerDriver

+ func NewLoadBalancerDriverWithClient(c LoadBalancerClient, region string) *LoadBalancerDriver

+ func (d *LoadBalancerDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *LoadBalancerDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *LoadBalancerDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *LoadBalancerDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *LoadBalancerDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *LoadBalancerDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *LoadBalancerDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type RegistryClient interface

+ Create func(ctx context.Context, req *godo.RegistryCreateRequest) (*godo.Registry, *godo.Response, error)

+ Delete func(ctx context.Context) (*godo.Response, error)

+ Get func(ctx context.Context) (*godo.Registry, *godo.Response, error)

+ type RegistryDriver struct

+ func NewRegistryDriver(c *godo.Client) *RegistryDriver

+ func NewRegistryDriverWithClient(c RegistryClient) *RegistryDriver

+ func (d *RegistryDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *RegistryDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *RegistryDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *RegistryDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *RegistryDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *RegistryDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *RegistryDriver) Update(ctx context.Context, _ interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type SpacesBucket struct

+ CreatedAt time.Time

+ Name string

+ Region string

+ type SpacesBucketClient interface

+ CreateBucket func(ctx context.Context, name, region string) (*SpacesBucket, error)

+ DeleteBucket func(ctx context.Context, name, region string) error

+ GetBucket func(ctx context.Context, name, region string) (*SpacesBucket, error)

+ type SpacesDriver struct

+ func NewSpacesDriver(_ *godo.Client, region string) *SpacesDriver

+ func NewSpacesDriverWithClient(c SpacesBucketClient, region string) *SpacesDriver

+ func (d *SpacesDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *SpacesDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *SpacesDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *SpacesDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *SpacesDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *SpacesDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *SpacesDriver) Update(_ context.Context, _ interfaces.ResourceRef, _ interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ type VPCClient interface

+ Create func(ctx context.Context, req *godo.VPCCreateRequest) (*godo.VPC, *godo.Response, error)

+ Delete func(ctx context.Context, vpcID string) (*godo.Response, error)

+ Get func(ctx context.Context, vpcID string) (*godo.VPC, *godo.Response, error)

+ Update func(ctx context.Context, vpcID string, req *godo.VPCUpdateRequest) (*godo.VPC, *godo.Response, error)

+ type VPCDriver struct

+ func NewVPCDriver(c *godo.Client, region string) *VPCDriver

+ func NewVPCDriverWithClient(c VPCClient, region string) *VPCDriver

+ func (d *VPCDriver) Create(ctx context.Context, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)

+ func (d *VPCDriver) Delete(ctx context.Context, ref interfaces.ResourceRef) error

+ func (d *VPCDriver) Diff(_ context.Context, desired interfaces.ResourceSpec, ...) (*interfaces.DiffResult, error)

+ func (d *VPCDriver) HealthCheck(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.HealthResult, error)

+ func (d *VPCDriver) Read(ctx context.Context, ref interfaces.ResourceRef) (*interfaces.ResourceOutput, error)

+ func (d *VPCDriver) Scale(_ context.Context, _ interfaces.ResourceRef, _ int) (*interfaces.ResourceOutput, error)

+ func (d *VPCDriver) Update(ctx context.Context, ref interfaces.ResourceRef, spec interfaces.ResourceSpec) (*interfaces.ResourceOutput, error)