runtime

type Archive struct {
	Env       string
	Name      string
	Remote    string
	Local     string
	BatchSize int
}

type Batch struct {
}

type Batcher interface {
	Batch(<-chan *Task) (*Batch, error)
}

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

type CreateOption func(*CreateOptions)

type CreateOptions struct {
	Env       string
	Remote    string
	Local     string
	BatchSize int
}

type Group struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Option func(*Options)

type Options struct {
	Dir    string
	GPU    int32
	Runner runner.Runner
}

type Scheduler struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Stat struct {
	Id     int
	GPU    int32
	Uptime time.Duration
	State  State
}

type State int32

type Task struct {
	Id      string
	Group   string
	Command string
	Request proto.Message
}

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