kubernetes

Documentation

Index

• type Task
  • func NewTask(ctx context.Context, cloud universal.Cloud, identifier string, ...) (*Task, error)
  • func (t *Task) Create(ctx context.Context) error
  • func (t *Task) Delete(ctx context.Context) error
  • func (t *Task) GetAddresses(ctx context.Context) []net.IP
  • func (t *Task) GetEvents(ctx context.Context) []universal.Event
  • func (t *Task) GetIdentifier(ctx context.Context) string
  • func (t *Task) GetKeyPair(ctx context.Context) (*ssh.DeterministicSSHKeyPair, error)
  • func (t *Task) GetStatus(ctx context.Context) map[string]int
  • func (t *Task) Logs(ctx context.Context) ([]string, error)
  • func (t *Task) Pull(ctx context.Context, destination string) error
  • func (t *Task) Push(ctx context.Context, source string, unsafe bool) error
  • func (t *Task) Read(ctx context.Context) error
  • func (t *Task) Stop(ctx context.Context) error

Types

type Task

type Task struct {
	Client      *client.Client
	Identifier  string
	Attributes  universal.Task
	DataSources struct{}
	Resources   struct {
		*resources.Job
	}
}

func NewTask

func NewTask(ctx context.Context, cloud universal.Cloud, identifier string, task universal.Task) (*Task, error)

func (*Task) Create

func (t *Task) Create(ctx context.Context) error

func (*Task) Delete

func (t *Task) Delete(ctx context.Context) error

func (*Task) GetAddresses

func (t *Task) GetAddresses(ctx context.Context) []net.IP

func (*Task) GetEvents

func (t *Task) GetEvents(ctx context.Context) []universal.Event

func (*Task) GetIdentifier

func (t *Task) GetIdentifier(ctx context.Context) string

func (*Task) GetKeyPair

func (t *Task) GetKeyPair(ctx context.Context) (*ssh.DeterministicSSHKeyPair, error)

func (*Task) GetStatus

func (t *Task) GetStatus(ctx context.Context) map[string]int

func (*Task) Logs

func (t *Task) Logs(ctx context.Context) ([]string, error)

func (*Task) Pull

func (t *Task) Pull(ctx context.Context, destination string) error

func (*Task) Push

func (t *Task) Push(ctx context.Context, source string, unsafe bool) error

func (*Task) Read

func (t *Task) Read(ctx context.Context) error

func (*Task) Stop

func (t *Task) Stop(ctx context.Context) error