inventory

Documentation

Index

• type Inventory
  • func InitInventory() *Inventory
  • func (inventory *Inventory) BuildVpcCache(discoveredVpcMap map[string]*runtimev1alpha1.Vpc, ...) error
  • func (inventory *Inventory) DeleteVpcCache(namespacedName *types.NamespacedName) error
  • func (inventory *Inventory) GetAllVpcs() []interface{}
  • func (inventory *Inventory) GetVpcsFromIndexer(indexName string, indexedValue string) ([]interface{}, error)
  • func (inventory *Inventory) Watch(ctx context.Context, key string, labelSelector labels.Selector, ...) (watch.Interface, error)

Types

type Inventory

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

func InitInventory

func InitInventory() *Inventory

InitInventory creates an instance of Inventory struct and initializes inventory with cache indexers.

func (*Inventory) BuildVpcCache

func (inventory *Inventory) BuildVpcCache(discoveredVpcMap map[string]*runtimev1alpha1.Vpc, namespacedName *types.NamespacedName) error

BuildVpcCache using vpc list from cloud, update vpc cache(with vpcs applicable for the current cloud account).

func (*Inventory) DeleteVpcCache

func (inventory *Inventory) DeleteVpcCache(namespacedName *types.NamespacedName) error

DeleteVpcCache deletes all entries from vpc cache.

func (*Inventory) GetAllVpcs

func (inventory *Inventory) GetAllVpcs() []interface{}

GetAllVpcs returns all vpcs from the indexer.

func (*Inventory) GetVpcsFromIndexer

func (inventory *Inventory) GetVpcsFromIndexer(indexName string, indexedValue string) ([]interface{}, error)

GetVpcsFromIndexer returns vpcs matching the indexedValue for the requested index.

func (*Inventory) Watch

func (inventory *Inventory) Watch(ctx context.Context, key string, labelSelector labels.Selector,
	fieldSelector fields.Selector) (watch.Interface, error)

Watch returns a Watch interface of VPC.