placement

Documentation

Index

• type PlacementAPI
  • func NewPlacementAPI(mon datasources.Monitor, k keystone.KeystoneAPI, ...) PlacementAPI
• type PlacementSyncer
  • func (s *PlacementSyncer) Init(ctx context.Context) error
  • func (s *PlacementSyncer) Sync(ctx context.Context) (int64, error)
  • func (s *PlacementSyncer) SyncInventoryUsages(ctx context.Context) (int64, error)
  • func (s *PlacementSyncer) SyncResourceProviders(ctx context.Context) (int64, error)
  • func (s *PlacementSyncer) SyncTraits(ctx context.Context) (int64, error)

Types

type PlacementAPI

type PlacementAPI interface {
	// Init the placement API.
	Init(ctx context.Context) error
	// Fetch all resource providers from the placement API.
	GetAllResourceProviders(ctx context.Context) ([]placement.ResourceProvider, error)
	// Fetch all traits for the given resource providers from the placement API.
	GetAllTraits(ctx context.Context, providers []placement.ResourceProvider) ([]placement.Trait, error)
	// Fetch all inventories + usages for the given resource providers from the placement API.
	GetAllInventoryUsages(ctx context.Context, providers []placement.ResourceProvider) ([]placement.InventoryUsage, error)
}

func NewPlacementAPI

func NewPlacementAPI(mon datasources.Monitor, k keystone.KeystoneAPI, conf v1alpha1.PlacementDatasource) PlacementAPI

Create a new OpenStack placement api.

type PlacementSyncer

type PlacementSyncer struct {
	// Database to store the placement objects in.
	DB db.DB
	// Monitor to track the syncer.
	Mon datasources.Monitor
	// Configuration for the placement syncer.
	Conf v1alpha1.PlacementDatasource
	// Placement API client to fetch the data.
	API PlacementAPI
}

Syncer for OpenStack placement.

func (*PlacementSyncer) Init

func (s *PlacementSyncer) Init(ctx context.Context) error

Init the OpenStack resource provider and trait syncer.

func (*PlacementSyncer) Sync

func (s *PlacementSyncer) Sync(ctx context.Context) (int64, error)

Sync the OpenStack placement objects.

func (*PlacementSyncer) SyncInventoryUsages

func (s *PlacementSyncer) SyncInventoryUsages(ctx context.Context) (int64, error)

Sync the OpenStack resource provider inventories and usages into the database.

func (*PlacementSyncer) SyncResourceProviders

func (s *PlacementSyncer) SyncResourceProviders(ctx context.Context) (int64, error)

Sync the OpenStack resource providers into the database.

func (*PlacementSyncer) SyncTraits

func (s *PlacementSyncer) SyncTraits(ctx context.Context) (int64, error)

Sync the OpenStack traits into the database.