task

package
v0.0.0-...-d1826b6 Latest Latest
Warning

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

Go to latest
Published: Feb 23, 2022 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TaskStateUnknown     = 0
	TaskStateRunning     = 1
	TaskStatePaused      = 2
	TaskStateDied        = 3
	TaskStateCalculating = 4
	TaskStateSpecialBrk  = 5
)

Variables

View Source
var ActivateTaskStatus chan bool = make(chan bool)
View Source
var BrokSender chan string = make(chan string)
View Source
var ExportWaiter chan map[string]interface{}
View Source
var ExtraDisplayStrings []string = []string{}
View Source
var ProgressThemes = []func(*AsyncInfo) string{
	func(asyncInfo *AsyncInfo) string {
		return fmt.Sprintf("%d/%d(%.2f%%) %.2fblocks/s", asyncInfo.Built, asyncInfo.Total, (float64(asyncInfo.Built)/float64(asyncInfo.Total))*100, float64(asyncInfo.Built)/time.Now().Sub(asyncInfo.BeginTime).Seconds())
	},
}
View Source
var TaskIdCounter *atomic.Int64 = atomic.NewInt64(0)
View Source
var TaskMap sync.Map

Functions

func GetStateDesc

func GetStateDesc(st byte) string

func InitTaskStatusDisplay

func InitTaskStatusDisplay(conn *minecraft.Conn)

Types

type AsyncInfo

type AsyncInfo struct {
	Built     int
	Total     int
	BeginTime time.Time
}

type SolidRet

type SolidRet struct {
	BlockName  string         `json:"blockName"`
	Position   SolidSimplePos `json:"position"`
	StatusCode int64          `json:"statusCode"`
}

type SolidSimplePos

type SolidSimplePos struct {
	X int64 `json:"x"`
	Y int64 `json:"y"`
	Z int64 `json:"z"`
}

type Task

type Task struct {
	TaskId        int64
	CommandLine   string
	OutputChannel chan *types.Module
	ContinueLock  sync.Mutex
	State         byte
	Type          byte
	AsyncInfo
	Config *configuration.FullConfig
}

func CreateExportTask

func CreateExportTask(commandLine string, conn *minecraft.Conn) *Task

func CreateTask

func CreateTask(commandLine string, conn *minecraft.Conn) *Task

func FindTask

func FindTask(taskId int64) *Task

func (*Task) Break

func (task *Task) Break()

func (*Task) Finalize

func (task *Task) Finalize()

func (*Task) Pause

func (task *Task) Pause()

func (*Task) Resume

func (task *Task) Resume()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL