digitalocean

package
v2.0.0-beta.2+incompat... Latest Latest
Warning

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

Go to latest
Published: Nov 26, 2018 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

View Source
const (
	CreateMachineStepName = "createMachineDigitalOcean"
	DeleteMachineStepName = "deleteMachineDigitalOcean"
	DeleteClusterStepName = "deleteClusterDigitalOcean"
)

Variables

View Source
var (
	// TODO(stgleb): We need global error for timeout exceeding
	ErrTimeoutExceeded = errors.New("timeout exceeded")
)

Functions

func Init

func Init()

func TestCreateInstanceStep_Rollback

func TestCreateInstanceStep_Rollback(t *testing.T)

Types

type CreateInstanceStep

type CreateInstanceStep struct {
	DropletTimeout time.Duration
	CheckPeriod    time.Duration
}

func NewCreateInstanceStep

func NewCreateInstanceStep(dropletTimeout, checkPeriod time.Duration) *CreateInstanceStep

func (*CreateInstanceStep) Depends

func (s *CreateInstanceStep) Depends() []string

func (*CreateInstanceStep) Description

func (s *CreateInstanceStep) Description() string

func (*CreateInstanceStep) Name

func (s *CreateInstanceStep) Name() string

func (*CreateInstanceStep) Rollback

func (*CreateInstanceStep) Run

func (s *CreateInstanceStep) Run(ctx context.Context, output io.Writer, config *steps.Config) error

type DeleteClusterStep

type DeleteClusterStep struct {
	// contains filtered or unexported fields
}

func NewDeleteClusterStep

func NewDeleteClusterStep(timeout time.Duration) *DeleteClusterStep

func (*DeleteClusterStep) Depends

func (s *DeleteClusterStep) Depends() []string

func (*DeleteClusterStep) Description

func (s *DeleteClusterStep) Description() string

func (*DeleteClusterStep) Name

func (s *DeleteClusterStep) Name() string

func (*DeleteClusterStep) Rollback

func (*DeleteClusterStep) Run

func (s *DeleteClusterStep) Run(ctx context.Context, output io.Writer, config *steps.Config) error

type DeleteMachineStep

type DeleteMachineStep struct {
	// contains filtered or unexported fields
}

func NewDeleteMachineStep

func NewDeleteMachineStep(timeout time.Duration) *DeleteMachineStep

func (*DeleteMachineStep) Depends

func (s *DeleteMachineStep) Depends() []string

func (*DeleteMachineStep) Description

func (s *DeleteMachineStep) Description() string

func (*DeleteMachineStep) Name

func (s *DeleteMachineStep) Name() string

func (*DeleteMachineStep) Rollback

func (*DeleteMachineStep) Run

func (s *DeleteMachineStep) Run(ctx context.Context, output io.Writer, config *steps.Config) error

type DeleteService

type DeleteService interface {
	DeleteByTag(context.Context, string) (*godo.Response, error)
}

type DropletService

type DropletService interface {
	Get(int) (*godo.Droplet, *godo.Response, error)
	Create(*godo.DropletCreateRequest) (*godo.Droplet, *godo.Response, error)
}

type KeyService

type KeyService interface {
	Create(context.Context, *godo.KeyCreateRequest) (*godo.Key, *godo.Response, error)
}

type TagService

type TagService interface {
	TagResources(string, *godo.TagResourcesRequest) (*godo.Response, error)
}

Jump to

Keyboard shortcuts

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