cobalt

Documentation

Index

• type Manager
  • func New(config types.Config) (*Manager, error)
  • func (m Manager) AddNode(ctx context.Context, nodename string, opts resourcetypes.Resources, ...) (resourcetypes.Resources, error)
  • func (m *Manager) AddPlugins(plugins ...plugins.Plugin)
  • func (m Manager) Alloc(ctx context.Context, nodename string, deployCount int, ...) ([]resourcetypes.Resources, []resourcetypes.Resources, error)
  • func (m Manager) GetMetricsDescription(ctx context.Context) ([]*plugintypes.MetricsDescription, error)
  • func (m Manager) GetMostIdleNode(ctx context.Context, nodenames []string) (string, error)
  • func (m Manager) GetNodeMetrics(ctx context.Context, node *types.Node) ([]*plugintypes.Metrics, error)
  • func (m Manager) GetNodeResourceInfo(ctx context.Context, nodename string, workloads []*types.Workload, fix bool) (resourcetypes.Resources, resourcetypes.Resources, []string, error)
  • func (m Manager) GetNodesDeployCapacity(ctx context.Context, nodenames []string, opts resourcetypes.Resources) (map[string]*plugintypes.NodeDeployCapacity, int, error)
  • func (m Manager) GetPlugins() []plugins.Plugin
  • func (m *Manager) LoadPlugins(ctx context.Context, t *testing.T) error
  • func (m Manager) Realloc(ctx context.Context, nodename string, nodeResource resourcetypes.Resources, ...) (resourcetypes.Resources, resourcetypes.Resources, resourcetypes.Resources, ...)
  • func (m Manager) Remap(ctx context.Context, nodename string, workloads []*types.Workload) (map[string]resourcetypes.Resources, error)
  • func (m Manager) RemoveNode(ctx context.Context, nodename string) error
  • func (m Manager) RollbackAlloc(ctx context.Context, nodename string, ...) error
  • func (m Manager) RollbackRealloc(ctx context.Context, nodename string, workloadParams resourcetypes.Resources) error
  • func (m Manager) SetNodeResourceCapacity(ctx context.Context, nodename string, nodeResource resourcetypes.Resources, ...) (resourcetypes.Resources, resourcetypes.Resources, error)
  • func (m Manager) SetNodeResourceUsage(ctx context.Context, nodename string, nodeResource resourcetypes.Resources, ...) (resourcetypes.Resources, resourcetypes.Resources, error)

Types

type Manager

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

Manager manager plugins

func New

func New(config types.Config) (*Manager, error)

New creates a plugin manager

func (Manager) AddNode

func (m Manager) AddNode(ctx context.Context, nodename string, opts resourcetypes.Resources, nodeInfo *enginetypes.Info) (resourcetypes.Resources, error)

AddNode .

func (*Manager) AddPlugins

func (m *Manager) AddPlugins(plugins ...plugins.Plugin)

AddPlugins adds a plugin (for test and debug)

func (Manager) Alloc

func (m Manager) Alloc(ctx context.Context, nodename string, deployCount int, opts resourcetypes.Resources) ([]resourcetypes.Resources, []resourcetypes.Resources, error)

Alloc alloc resource opts struct

{
	"plugin1":{
		"cpu-request": 1.2,
		"cpu-limit": 2.0,
	},
	"plugin2":{
	},
}

func (Manager) GetMetricsDescription

func (m Manager) GetMetricsDescription(ctx context.Context) ([]*plugintypes.MetricsDescription, error)

GetMetricsDescription .

func (Manager) GetMostIdleNode

func (m Manager) GetMostIdleNode(ctx context.Context, nodenames []string) (string, error)

GetMostIdleNode .

func (Manager) GetNodeMetrics

func (m Manager) GetNodeMetrics(ctx context.Context, node *types.Node) ([]*plugintypes.Metrics, error)

GetNodeMetrics .

func (Manager) GetNodeResourceInfo

func (m Manager) GetNodeResourceInfo(ctx context.Context, nodename string, workloads []*types.Workload, fix bool) (resourcetypes.Resources, resourcetypes.Resources, []string, error)

GetNodeResourceInfo .

func (Manager) GetNodesDeployCapacity

func (m Manager) GetNodesDeployCapacity(ctx context.Context, nodenames []string, opts resourcetypes.Resources) (map[string]*plugintypes.NodeDeployCapacity, int, error)

GetNodesDeployCapacity returns available nodes which meet all the requirements the caller should require locks pure calculation

func (Manager) GetPlugins

func (m Manager) GetPlugins() []plugins.Plugin

GetPlugins is used for mock

func (*Manager) LoadPlugins

func (m *Manager) LoadPlugins(ctx context.Context, t *testing.T) error

LoadPlugins .

func (Manager) Realloc

func (m Manager) Realloc(ctx context.Context, nodename string, nodeResource resourcetypes.Resources, opts resourcetypes.Resources) (resourcetypes.Resources, resourcetypes.Resources, resourcetypes.Resources, error)

Realloc .

func (Manager) Remap

func (m Manager) Remap(ctx context.Context, nodename string, workloads []*types.Workload) (map[string]resourcetypes.Resources, error)

Remap remaps resource and returns engine args for workloads. format: {"workload-1": {"cpus": ["1-3"]}} remap doesn't change resource args

func (Manager) RemoveNode

func (m Manager) RemoveNode(ctx context.Context, nodename string) error

RemoveNode .

func (Manager) RollbackAlloc

func (m Manager) RollbackAlloc(ctx context.Context, nodename string, workloadsParams []resourcetypes.Resources) error

RollbackAlloc rollbacks the allocated resource

func (Manager) RollbackRealloc

func (m Manager) RollbackRealloc(ctx context.Context, nodename string, workloadParams resourcetypes.Resources) error

RollbackRealloc .

func (Manager) SetNodeResourceCapacity

func (m Manager) SetNodeResourceCapacity(ctx context.Context, nodename string, nodeResource resourcetypes.Resources, nodeResourceRequest resourcetypes.Resources, delta bool, incr bool) (resourcetypes.Resources, resourcetypes.Resources, error)

SetNodeResourceCapacity updates node resource capacity receives resource options instead of resource args

func (Manager) SetNodeResourceUsage

func (m Manager) SetNodeResourceUsage(ctx context.Context, nodename string, nodeResource resourcetypes.Resources, nodeResourceRequest resourcetypes.Resources, workloadsResource []resourcetypes.Resources, delta bool, incr bool) (resourcetypes.Resources, resourcetypes.Resources, error)

SetNodeResourceUsage .