binary

Documentation

Index

• Constants
• type Plugin
  • func NewPlugin(_ context.Context, path string, config coretypes.Config) (*Plugin, error)
  • func (p Plugin) AddNode(ctx context.Context, nodename string, resource plugintypes.NodeResourceRequest, ...) (*plugintypes.AddNodeResponse, error)
  • func (p Plugin) CalculateDeploy(ctx context.Context, nodename string, deployCount int, ...) (*plugintypes.CalculateDeployResponse, error)
  • func (p Plugin) CalculateRealloc(ctx context.Context, nodename string, resource plugintypes.WorkloadResource, ...) (*plugintypes.CalculateReallocResponse, error)
  • func (p Plugin) CalculateRemap(ctx context.Context, nodename string, ...) (*plugintypes.CalculateRemapResponse, error)
  • func (p Plugin) FixNodeResource(ctx context.Context, nodename string, ...) (*plugintypes.GetNodeResourceInfoResponse, error)
  • func (p Plugin) GetMetrics(ctx context.Context, podname, nodename string) (*plugintypes.GetMetricsResponse, error)
  • func (p Plugin) GetMetricsDescription(ctx context.Context) (*plugintypes.GetMetricsDescriptionResponse, error)
  • func (p Plugin) GetMostIdleNode(ctx context.Context, nodenames []string) (*plugintypes.GetMostIdleNodeResponse, error)
  • func (p Plugin) GetNodeResourceInfo(ctx context.Context, nodename string, ...) (*plugintypes.GetNodeResourceInfoResponse, error)
  • func (p Plugin) GetNodesDeployCapacity(ctx context.Context, nodenames []string, ...) (*plugintypes.GetNodesDeployCapacityResponse, error)
  • func (p Plugin) Name() string
  • func (p Plugin) RemoveNode(ctx context.Context, nodename string) (*plugintypes.RemoveNodeResponse, error)
  • func (p Plugin) SetNodeResourceCapacity(ctx context.Context, nodename string, resource plugintypes.NodeResource, ...) (*plugintypes.SetNodeResourceCapacityResponse, error)
  • func (p Plugin) SetNodeResourceInfo(ctx context.Context, nodename string, capacity plugintypes.NodeResource, ...) (*plugintypes.SetNodeResourceInfoResponse, error)
  • func (p Plugin) SetNodeResourceUsage(ctx context.Context, nodename string, resource plugintypes.NodeResource, ...) (*plugintypes.SetNodeResourceUsageResponse, error)

Constants

const (
	CalculateDeployCommand  = "calculate-deploy"
	CalculateReallocCommand = "calculate-realloc"
	CalculateRemapCommand   = "calculate-remap"

	AddNodeCommand    = "add-node"
	RemoveNodeCommand = "remove-node"

	GetNodesDeployCapacityCommand = "get-nodes-deploy-capacity"

	SetNodeResourceCapacityCommand = "set-node-resource-capacity"

	GetNodeResourceInfoCommand = "get-node-resource-info"
	SetNodeResourceInfoCommand = "set-node-resource-info"

	SetNodeResourceUsageCommand = "set-node-resource-usage"

	GetMostIdleNodeCommand = "get-most-idle-node"

	FixNodeResourceCommand = "fix-node-resource"

	GetMetricsDescriptionCommand = "get-metrics-description"
	GetMetricsCommand            = "get-metrics"
)

Types

type Plugin

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

Plugin

func NewPlugin

func NewPlugin(_ context.Context, path string, config coretypes.Config) (*Plugin, error)

NewPlugin .

func (Plugin) AddNode

func (p Plugin) AddNode(ctx context.Context, nodename string, resource plugintypes.NodeResourceRequest, info *enginetypes.Info) (*plugintypes.AddNodeResponse, error)

AddNode .

func (Plugin) CalculateDeploy

func (p Plugin) CalculateDeploy(ctx context.Context, nodename string, deployCount int, resourceRequest plugintypes.WorkloadResourceRequest) (*plugintypes.CalculateDeployResponse, error)

CalculateDeploy .

func (Plugin) CalculateRealloc

func (p Plugin) CalculateRealloc(ctx context.Context, nodename string, resource plugintypes.WorkloadResource, resourceRequest plugintypes.WorkloadResourceRequest) (*plugintypes.CalculateReallocResponse, error)

CalculateRealloc .

func (Plugin) CalculateRemap

func (p Plugin) CalculateRemap(ctx context.Context, nodename string, workloadsResource map[string]plugintypes.WorkloadResource) (*plugintypes.CalculateRemapResponse, error)

CalculateRemap .

func (Plugin) FixNodeResource

func (p Plugin) FixNodeResource(ctx context.Context, nodename string, workloadsResource []plugintypes.WorkloadResource) (*plugintypes.GetNodeResourceInfoResponse, error)

FixNodeResource .

func (Plugin) GetMetrics

func (p Plugin) GetMetrics(ctx context.Context, podname, nodename string) (*plugintypes.GetMetricsResponse, error)

GetMetrics .

func (Plugin) GetMetricsDescription

func (p Plugin) GetMetricsDescription(ctx context.Context) (*plugintypes.GetMetricsDescriptionResponse, error)

GetMetricsDescription .

func (Plugin) GetMostIdleNode

func (p Plugin) GetMostIdleNode(ctx context.Context, nodenames []string) (*plugintypes.GetMostIdleNodeResponse, error)

GetMostIdleNode .

func (Plugin) GetNodeResourceInfo

func (p Plugin) GetNodeResourceInfo(ctx context.Context, nodename string, workloadsResource []plugintypes.WorkloadResource) (*plugintypes.GetNodeResourceInfoResponse, error)

GetNodeResourceInfo .

func (Plugin) GetNodesDeployCapacity

func (p Plugin) GetNodesDeployCapacity(ctx context.Context, nodenames []string, resource plugintypes.WorkloadResourceRequest) (*plugintypes.GetNodesDeployCapacityResponse, error)

GetNodesDeployCapacity .

func (Plugin) Name

func (p Plugin) Name() string

Name .

func (Plugin) RemoveNode

func (p Plugin) RemoveNode(ctx context.Context, nodename string) (*plugintypes.RemoveNodeResponse, error)

RemoveNode .

func (Plugin) SetNodeResourceCapacity

func (p Plugin) SetNodeResourceCapacity(ctx context.Context, nodename string, resource plugintypes.NodeResource, resourceRequest plugintypes.NodeResourceRequest, delta bool, incr bool) (*plugintypes.SetNodeResourceCapacityResponse, error)

SetNodeResourceCapacity .

func (Plugin) SetNodeResourceInfo

func (p Plugin) SetNodeResourceInfo(ctx context.Context, nodename string, capacity plugintypes.NodeResource, usage plugintypes.NodeResource) (*plugintypes.SetNodeResourceInfoResponse, error)

SetNodeResourceInfo .

func (Plugin) SetNodeResourceUsage

func (p Plugin) SetNodeResourceUsage(ctx context.Context, nodename string, resource plugintypes.NodeResource, resourceRequest plugintypes.NodeResourceRequest, workloadsResource []plugintypes.WorkloadResource, delta bool, incr bool) (*plugintypes.SetNodeResourceUsageResponse, error)

SetNodeResourceUsage .