schedule

type Auth struct {
	SecretToken string
}

type EventData struct {
	TaskID string    // task id
	TE     TaskEvent // task event: add change delete stop task
}

type HeartbeatService struct {
	Auth Auth
}

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

type LogCacher interface {
	// Read byte, but it not clean reader data
	// ReadOnly read data from buf
	// 从off后开始读，最多可以读取len(p)个字节，
	// - close为true,返回0,EOF
	// - off > len(l.buf),返回 noreaddata 这时读取方重新读取可以等待一会
	// - off+len(p) > len(l.buf),返回 p.buf.Len-off,nil
	// - off+len(p) < len(l.buf),返回 len(p), nil
	ReadOnly(p []byte, off int) (n int, err error)
	// Write byte buf
	Write(p []byte) (n int, err error)
	// Write byte buf,do not use it write recv task
	WriteString(p string) (n int, err error)
	// WriteStringf ,do not use it write recv task
	WriteStringf(tmpl string, args ...interface{}) (n int, err error)
	// Close will can not Read, and clean buf
	Clean()
	// Close will stop task
	Close()
	// ReadAll data from buf
	ReadAll() (p string)
	// GetCode return task return code
	GetCode() int
	// SetRunHost save task run host
	Save(interface{})
	// GetRunHost task run host addr
	Get() interface{}
	// SetTaskStatus set task status
	// wait running finish fail cancel
	SetTaskStatus(define.TaskStatus)
	GetTaskStatus() define.TaskStatus
}

type Next func() *define.Host

type TaskEvent uint8

type TaskService struct {
	Auth Auth
}