do

package
v1.28.4 Latest Latest
Warning

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

Go to latest
Published: Feb 2, 2024 License: Apache-2.0 Imports: 24 Imported by: 56

Documentation

Index

Constants

View Source
const (
	TagKubernetesClusterIndex        = "k8s-index"
	TagNameEtcdClusterPrefix         = "etcdCluster-"
	TagKubernetesClusterNamePrefix   = "KubernetesCluster"
	TagKubernetesClusterMasterPrefix = "KubernetesCluster-Master"
	TagKubernetesInstanceGroup       = "kops-instancegroup"
)
View Source
const DOAuthenticationTokenPrefix = "x-digitalocean-droplet-id "

Variables

This section is empty.

Functions

func BuildMockDOCloud added in v1.21.3

func BuildMockDOCloud(region string) *doCloudMockImplementation

func NewAuthenticator added in v1.27.0

func NewAuthenticator() (bootstrap.Authenticator, error)

func NewVerifier added in v1.27.0

func SafeClusterName added in v1.15.1

func SafeClusterName(clusterName string) string

Types

type DOAPITarget

type DOAPITarget struct {
	Cloud DOCloud
}

func NewDOAPITarget

func NewDOAPITarget(cloud DOCloud) *DOAPITarget

func (*DOAPITarget) DefaultCheckExisting added in v1.26.0

func (t *DOAPITarget) DefaultCheckExisting() bool

func (*DOAPITarget) Finish

func (t *DOAPITarget) Finish(taskMap map[string]fi.CloudupTask) error

func (*DOAPITarget) ProcessDeletions

func (t *DOAPITarget) ProcessDeletions() bool

type DOCloud added in v1.21.3

type DOCloud interface {
	fi.Cloud
	DropletsService() godo.DropletsService
	DropletActionService() godo.DropletActionsService
	VolumeService() godo.StorageService
	VolumeActionService() godo.StorageActionsService
	KeysService() godo.KeysService
	LoadBalancersService() godo.LoadBalancersService
	DomainService() godo.DomainsService
	ActionsService() godo.ActionsService
	VPCsService() godo.VPCsService
	FindClusterStatus(cluster *kops.Cluster) (*kops.ClusterStatus, error)
	GetAllLoadBalancers() ([]godo.LoadBalancer, error)
	GetAllDropletsByTag(tag string) ([]godo.Droplet, error)
	GetAllVolumesByRegion() ([]godo.Volume, error)
	GetVPCUUID(networkCIDR string, vpcName string) (string, error)
	GetAllVPCs() ([]*godo.VPC, error)
}

DOCloud exposes all the interfaces required to operate on DigitalOcean resources

func NewDOCloud

func NewDOCloud(region string) (DOCloud, error)

NewCloud returns a Cloud, expecting the env var DIGITALOCEAN_ACCESS_TOKEN NewCloud will return an err if DIGITALOCEAN_ACCESS_TOKEN is not defined

type DOInstanceGroup added in v1.21.3

type DOInstanceGroup struct {
	ClusterName       string
	InstanceGroupName string
	GroupType         string   // will be either "master" or "worker"
	Members           []string // will store the droplet names that matches.
}

type DigitalOceanVerifierOptions added in v1.27.0

type DigitalOceanVerifierOptions struct {
}

type TokenSource added in v1.21.3

type TokenSource struct {
	AccessToken string
}

TokenSource implements oauth2.TokenSource

func (*TokenSource) Token added in v1.21.3

func (t *TokenSource) Token() (*oauth2.Token, error)

Token() returns oauth2.Token

Jump to

Keyboard shortcuts

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