primitives

package
v0.1.10 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 26, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetCapacity 

func GetCapacity(ctx context.Context) gridtypes.Capacity

GetCapacity gets current capacity from context

func NewPrimitivesProvisioner 

func NewPrimitivesProvisioner(zbus zbus.Client) provision.Provisioner

NewPrimitivesProvisioner creates a new 0-OS provisioner

func NewStatisticsStream 

func NewStatisticsStream(s *Statistics) pkg.Statistics

Types

type Reserved 

type Reserved func() (gridtypes.Capacity, error)

type Statistics 

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

Statistics a provisioner interceptor that keeps track of consumed capacity. It also does validate of required capacity and then can report that this capacity can not be fulfilled

func NewStatistics 

func NewStatistics(total gridtypes.Capacity, storage provision.Storage, reserved Reserved, inner provision.Provisioner) *Statistics

NewStatistics creates a new statistics provisioner interceptor. Statistics provisioner keeps track of used capacity and update explorer when it changes

func (*Statistics) CanUpdate 

func (s *Statistics) CanUpdate(ctx context.Context, typ gridtypes.WorkloadType) bool

CanUpdate implements the provisioner interface

func (*Statistics) Deprovision 

func (s *Statistics) Deprovision(ctx context.Context, wl *gridtypes.WorkloadWithID) error

Decommission implements the decomission interface

func (*Statistics) Initialize 

func (s *Statistics) Initialize(ctx context.Context) error

Initialize implements provisioner interface

func (*Statistics) Pause 

func (s *Statistics) Pause(ctx context.Context, wl *gridtypes.WorkloadWithID) (gridtypes.Result, error)

func (*Statistics) Provision 

func (s *Statistics) Provision(ctx context.Context, wl *gridtypes.WorkloadWithID) (result gridtypes.Result, err error)

Provision implements the provisioner interface

func (*Statistics) Resume 

func (s *Statistics) Resume(ctx context.Context, wl *gridtypes.WorkloadWithID) (gridtypes.Result, error)

func (*Statistics) Total 

func (s *Statistics) Total() gridtypes.Capacity

Total returns the node total capacity

func (*Statistics) Update 

func (s *Statistics) Update(ctx context.Context, wl *gridtypes.WorkloadWithID) (gridtypes.Result, error)

Update implements the provisioner interface

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.