offering

package
v0.0.0-...-10b4495 Latest Latest
Warning

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

Go to latest
Published: Oct 22, 2021 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewOfferingDiscovery

func NewOfferingDiscovery(node common.Node, config *configuration.Configuration, overlay overlay.Overlay,
	client external.Caravela, resourcesMap *resources.Mapping, maxResources resources.Resources) (backend.Discovery, error)

Types

type Discovery

type Discovery struct {
	common.NodeComponent // Base component
	// contains filtered or unexported fields
}

Discovery is responsible for dealing with the resource management local and remote. It allows the other components to use its services.

func (*Discovery) AddTrader

func (d *Discovery) AddTrader(traderGUID guid.GUID)

Adds a new local "virtual" trader when the overlay notifies its presence.

func (*Discovery) AdvertiseNeighborOffers

func (d *Discovery) AdvertiseNeighborOffers(fromTrader, toNeighborTrader, traderOffering *types.Node)

func (*Discovery) CreateOffer

func (d *Discovery) CreateOffer(fromSupp *types.Node, toTrader *types.Node, offer *types.Offer)

func (*Discovery) DebugSizeBytes

func (d *Discovery) DebugSizeBytes() int

func (*Discovery) FindOffers

func (d *Discovery) FindOffers(ctx context.Context, resources resources.Resources) []types.AvailableOffer

func (*Discovery) GUID

func (d *Discovery) GUID() string

func (*Discovery) GetOffers

func (d *Discovery) GetOffers(ctx context.Context, fromNode, toTrader *types.Node, relay bool) []types.AvailableOffer

func (*Discovery) IsWorking

func (d *Discovery) IsWorking() bool

func (*Discovery) NodeInformationSim

func (d *Discovery) NodeInformationSim() (types.Resources, types.Resources, int, int)

Simulation

func (*Discovery) ObtainResources

func (d *Discovery) ObtainResources(offerID int64, resourcesNecessary resources.Resources, numContainersToRun int) bool

func (*Discovery) RefreshOffer

func (d *Discovery) RefreshOffer(fromTrader *types.Node, offer *types.Offer) bool

func (*Discovery) RefreshOffersSim

func (d *Discovery) RefreshOffersSim()

Simulation

func (*Discovery) RemoveOffer

func (d *Discovery) RemoveOffer(fromSupp *types.Node, toTrader *types.Node, offer *types.Offer)

func (*Discovery) ReturnResources

func (d *Discovery) ReturnResources(resources resources.Resources, numContainersStopped int)

func (*Discovery) SpreadOffersSim

func (d *Discovery) SpreadOffersSim()

Simulation

func (*Discovery) Start

func (d *Discovery) Start()

func (*Discovery) Stop

func (d *Discovery) Stop()

func (*Discovery) UpdateOffer

func (d *Discovery) UpdateOffer(fromSupp, toTrader *types.Node, offer *types.Offer)

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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