digitalocean

package
v2.0.0-beta.13+incompa... Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source
const (
	CreateMachineStepName    = "createMachineDigitalOcean"
	DeleteMachineStepName    = "deleteMachineDigitalOcean"
	DeleteClusterMachines    = "deleteClusterMachineDigitalOcean"
	DeleteDeleteKeysStepName = "deleteKeysDigitalOcean"
)

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 DeleteKeysStep

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

func NewDeleteKeysStep

func NewDeleteKeysStep() *DeleteKeysStep

func (*DeleteKeysStep) Depends

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

func (*DeleteKeysStep) Description

func (s *DeleteKeysStep) Description() string

func (*DeleteKeysStep) Name

func (s *DeleteKeysStep) Name() string

func (*DeleteKeysStep) Rollback

func (*DeleteKeysStep) Run

func (s *DeleteKeysStep) 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 DeleteMachinesStep

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

func NewDeletemachinesStep

func NewDeletemachinesStep(timeout time.Duration) *DeleteMachinesStep

func (*DeleteMachinesStep) Depends

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

func (*DeleteMachinesStep) Description

func (s *DeleteMachinesStep) Description() string

func (*DeleteMachinesStep) Name

func (s *DeleteMachinesStep) Name() string

func (*DeleteMachinesStep) Rollback

func (*DeleteMachinesStep) Run

func (s *DeleteMachinesStep) 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