do

Documentation

Index

• Constants
• func BuildMockDOCloud(region string) *doCloudMockImplementation
• func NewAuthenticator() (bootstrap.Authenticator, error)
• func NewVerifier(ctx context.Context, opt *DigitalOceanVerifierOptions) (bootstrap.Verifier, error)
• func SafeClusterName(clusterName string) string
• type DOAPITarget
  • func NewDOAPITarget(cloud DOCloud) *DOAPITarget
  • func (t *DOAPITarget) DefaultCheckExisting() bool
  • func (t *DOAPITarget) Finish(taskMap map[string]fi.CloudupTask) error
• type DOCloud
  • func NewDOCloud(region string) (DOCloud, error)
• type DOInstanceGroup
• type DigitalOceanVerifierOptions
• type TokenSource
  • func (t *TokenSource) Token() (*oauth2.Token, error)

Constants

const (
	TagKubernetesClusterIndex        = "k8s-index"
	TagNameEtcdClusterPrefix         = "etcdCluster-"
	TagKubernetesClusterNamePrefix   = "KubernetesCluster"
	TagKubernetesClusterMasterPrefix = "KubernetesCluster-Master"
	TagKubernetesInstanceGroup       = "kops-instancegroup"
)

const DOAuthenticationTokenPrefix = "x-digitalocean-droplet-id "

Functions

func BuildMockDOCloud

func BuildMockDOCloud(region string) *doCloudMockImplementation

func NewAuthenticator

func NewAuthenticator() (bootstrap.Authenticator, error)

func NewVerifier

func NewVerifier(ctx context.Context, opt *DigitalOceanVerifierOptions) (bootstrap.Verifier, error)

func SafeClusterName

func SafeClusterName(clusterName string) string

Types

type DOAPITarget

type DOAPITarget struct {
	Cloud DOCloud
}

func NewDOAPITarget

func NewDOAPITarget(cloud DOCloud) *DOAPITarget

func (*DOAPITarget) DefaultCheckExisting

func (t *DOAPITarget) DefaultCheckExisting() bool

func (*DOAPITarget) Finish

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

type DOCloud

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)

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

type DOInstanceGroup

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

type DigitalOceanVerifierOptions struct {
}

type TokenSource

type TokenSource struct {
	AccessToken string
}

TokenSource implements oauth2.TokenSource

func (*TokenSource) Token

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

Token() returns oauth2.Token