binary

package

v0.1.5 Latest Latest Go to latest Published: Sep 9, 2026 License: MIT Imports: 15 Imported by: 18

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/projecteru2/core

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Plugin
- func NewPlugin(ctx context.Context, path string, config coretypes.Config) (*Plugin, error)

Constants ¶

View Source

const (
	VerbsCommand = "verbs"

	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"
	GetNodesResourceInfoCommand = "get-nodes-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"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Plugin ¶

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

Plugin drives a resource plugin binary.

func NewPlugin ¶

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

NewPlugin asks the binary which verbs it implements, so a verb it lacks never spawns it.

func (Plugin) AddNode ¶

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

func (Plugin) CalculateDeploy ¶

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

func (Plugin) CalculateRealloc ¶

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

func (Plugin) CalculateRemap ¶

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

func (Plugin) FixNodeResource ¶

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

func (Plugin) GetMetrics ¶

func (p Plugin) GetMetrics(ctx context.Context, nodes []plugintypes.NodeRef) (*plugintypes.GetMetricsResponse, error)

func (Plugin) GetMetricsDescription ¶

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

func (Plugin) GetMostIdleNode ¶

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

func (Plugin) GetNodeResourceInfo ¶

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

func (Plugin) GetNodesDeployCapacity ¶

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

func (Plugin) GetNodesResourceInfo ¶ added in v0.1.5

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

func (Plugin) Name ¶

func (p Plugin) Name() string

func (Plugin) RemoveNode ¶

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

func (Plugin) SetNodeResourceCapacity ¶

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

func (Plugin) SetNodeResourceInfo ¶

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

func (Plugin) SetNodeResourceUsage ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
types

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