swarm

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: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSwarmResourcesDiscovery

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

NewSwarmResourcesDiscovery creates a resource discovery backend based on the Docker Swarm.

Types

type Discovery

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

Discovery backend is based on a master-slave cluster architecture (Centralized) that simulates the Docker Swarm. It is implemented on top of a Chord overlay because it suits better our prototype framework. It is NOT DESIGNED to be used in REAL DEPLOYMENT, we only use it in Simulation to compare with our discovery backends.

func (*Discovery) AddTrader

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

func (*Discovery) AdvertiseNeighborOffers

func (d *Discovery) AdvertiseNeighborOffers(_, _, _ *types.Node)

func (*Discovery) CreateOffer

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

func (*Discovery) DebugSizeBytes

func (d *Discovery) DebugSizeBytes() int

func (*Discovery) FindOffers

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

func (*Discovery) GUID

func (d *Discovery) GUID() string

func (*Discovery) GetOffers

func (d *Discovery) GetOffers(_ context.Context, _, _ *types.Node, _ 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(_ int64, resourcesNecessary resources.Resources, numContainersToRun int) bool

func (*Discovery) RefreshOffer

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

func (*Discovery) RefreshOffersSim

func (d *Discovery) RefreshOffersSim()

Simulation

func (*Discovery) RemoveOffer

func (d *Discovery) RemoveOffer(_ *types.Node, _ *types.Node, _ *types.Offer)

func (*Discovery) ReturnResources

func (d *Discovery) ReturnResources(releasedResources 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, _ *types.Node, offer *types.Offer)

Jump to

Keyboard shortcuts

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