resources

Documentation

Index

• type Job
  • func NewJob(client *client.Client, identifier string, task universal.Task) *Job
  • func (j *Job) Create(ctx context.Context) error
  • func (j *Job) Delete(ctx context.Context) error
  • func (j *Job) Logs(ctx context.Context) ([]string, error)
  • func (j *Job) Read(ctx context.Context) error

Types

type Job

type Job struct {
	Client     *client.Client
	Identifier string
	Attributes struct {
		Task        universal.Task
		Parallelism uint16
		Addresses   []net.IP
		Status      map[string]int
		Events      []universal.Event
	}
	Dependencies struct{}
	Resource     *kubernetes_batch.Job
}

func NewJob

func NewJob(client *client.Client, identifier string, task universal.Task) *Job

func (*Job) Create

func (j *Job) Create(ctx context.Context) error

func (*Job) Delete

func (j *Job) Delete(ctx context.Context) error

func (*Job) Logs

func (j *Job) Logs(ctx context.Context) ([]string, error)

func (*Job) Read

func (j *Job) Read(ctx context.Context) error