do

Documentation

Index

• Constants
• func BuildMockDOCloud(region string) *doCloudMockImplementation
• func SafeClusterName(clusterName string) string
• type DOAPITarget
  • func NewDOAPITarget(cloud DOCloud) *DOAPITarget
  • func (t *DOAPITarget) Finish(taskMap map[string]fi.Task) error
  • func (t *DOAPITarget) ProcessDeletions() bool
• type DOCloud
  • func NewDOCloud(region string) (DOCloud, error)
• type DOInstanceGroup
• type TokenSource
  • func (t *TokenSource) Token() (*oauth2.Token, error)

Constants

const TagKubernetesClusterIndex = "k8s-index"

const TagKubernetesClusterMasterPrefix = "KubernetesCluster-Master"

const TagKubernetesClusterNamePrefix = "KubernetesCluster"

const TagKubernetesInstanceGroup = "kops-instancegroup"

const TagNameEtcdClusterPrefix = "etcdCluster-"

const TagNameRolePrefix = "k8s.io/role/"

Functions

func BuildMockDOCloud

func BuildMockDOCloud(region string) *doCloudMockImplementation

func SafeClusterName

func SafeClusterName(clusterName string) string

Types

type DOAPITarget

type DOAPITarget struct {
	Cloud DOCloud
}

func NewDOAPITarget

func NewDOAPITarget(cloud DOCloud) *DOAPITarget

func (*DOAPITarget) Finish

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

func (*DOAPITarget) ProcessDeletions

func (t *DOAPITarget) ProcessDeletions() bool

type DOCloud

type DOCloud interface {
	fi.Cloud
	DropletsService() godo.DropletsService
	DropletActionService() godo.DropletActionsService
	VolumeService() godo.StorageService
	VolumeActionService() godo.StorageActionsService
	LoadBalancersService() godo.LoadBalancersService
	DomainService() godo.DomainsService
	ActionsService() godo.ActionsService
	FindClusterStatus(cluster *kops.Cluster) (*kops.ClusterStatus, error)
	GetAllLoadBalancers() ([]godo.LoadBalancer, error)
	GetAllDropletsByTag(tag string) ([]godo.Droplet, error)
	GetAllVolumesByRegion() ([]godo.Volume, 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

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 TokenSource

type TokenSource struct {
	AccessToken string
}

TokenSource implements oauth2.TokenSource

func (*TokenSource) Token

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

Token() returns oauth2.Token