master

Documentation

Index

• type Context
  • func NewContext(isLocal bool, minWorkers int, masterPath string) *Context
  • func (c *Context) ExecuteAction(actionId string, list *common.LinkedList[common.Maplan]) []*protos.TaskResult
  • func (c *Context) InitContext()
• type Mafream
  • func NewDataFrame(c *Context, preplan *common.Maplan) *Mafream
  • func (w *Mafream) Count() int
  • func (w *Mafream) Show() *Mafream
• type Master
  • func NewMaster(isLocal bool, host string, port int, minWorkers int) *Master
  • func (m *Master) Load(path string) *Mafream
  • func (m *Master) RegisterHandler(c *gin.Context)

Types

type Context

type Context struct {
	IsLocal bool
	Workers map[string]string
	// contains filtered or unexported fields
}

func NewContext

func NewContext(isLocal bool, minWorkers int, masterPath string) *Context

func (*Context) ExecuteAction

func (c *Context) ExecuteAction(actionId string, list *common.LinkedList[common.Maplan]) []*protos.TaskResult

func (*Context) InitContext

func (c *Context) InitContext()

type Mafream

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

func NewDataFrame

func NewDataFrame(c *Context, preplan *common.Maplan) *Mafream

func (*Mafream) Count

func (w *Mafream) Count() int

func (*Mafream) Show

func (w *Mafream) Show() *Mafream

type Master

type Master struct {
	MasterPath string

	Http *gin.Engine
	// contains filtered or unexported fields
}

func NewMaster

func NewMaster(isLocal bool, host string, port int, minWorkers int) *Master

func (*Master) Load

func (m *Master) Load(path string) *Mafream

func (*Master) RegisterHandler

func (m *Master) RegisterHandler(c *gin.Context)