workload

package

v0.1.14 Latest Latest Go to latest Published: Mar 21, 2024 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Manager struct {
	*db.SQLDB
	// contains filtered or unexported fields
}

Manager node workload

func NewManager(sdb *db.SQLDB, configFunc dtypes.GetSchedulerConfigFunc, lmgr *leadership.Manager, nmgr *node.Manager) *Manager

NewManager return new node manager instance

func (m *Manager) HandleNodeWorkload(data []byte, node *node.Node) error

HandleNodeWorkload handle node workload

func (m *Manager) HandleUserWorkload(data []byte, node *node.Node) error

HandleUserWorkload handle user workload

func (m *Manager) PushResult(data []byte, node *node.Node) error

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