addressset

Documentation

Index

• Constants
• func GetHashNamesForAS(dbIDs *libovsdbops.DbObjectIDs) (string, string)
• func GetTestDbAddrSets(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (*nbdb.AddressSet, *nbdb.AddressSet)
• type AddressSet
• type AddressSetFactory
  • func NewOvnAddressSetFactory(nbClient libovsdbclient.Client, v4Mode, v6Mode bool) AddressSetFactory
• type AddressSetIterFunc
• type FakeAddressSetFactory
  • func NewFakeAddressSetFactory(controllerName string) *FakeAddressSetFactory
  • func (f *FakeAddressSetFactory) AddressSetExists(dbIDsOrNsName any) bool
  • func (f *FakeAddressSetFactory) DestroyAddressSet(dbIDs *libovsdbops.DbObjectIDs) error
  • func (f *FakeAddressSetFactory) EnsureAddressSet(dbIDs *libovsdbops.DbObjectIDs) (AddressSet, error)
  • func (f *FakeAddressSetFactory) ErrOnNextNewASCall()
  • func (f *FakeAddressSetFactory) EventuallyExpectAddressSet(dbIDsOrNsName any)
  • func (f *FakeAddressSetFactory) EventuallyExpectAddressSetWithAddresses(dbIDsOrNsName any, addresses []string)
  • func (f *FakeAddressSetFactory) EventuallyExpectEmptyAddressSetExist(dbIDsOrNsName any)
  • func (f *FakeAddressSetFactory) EventuallyExpectNoAddressSet(dbIDsOrNsName any)
  • func (f *FakeAddressSetFactory) ExpectAddressSetWithAddresses(dbIDsOrNsName any, addresses []string)
  • func (f *FakeAddressSetFactory) ExpectEmptyAddressSet(dbIDsOrNsName any)
  • func (f *FakeAddressSetFactory) ExpectNumberOfAddressSets(n int)
  • func (f *FakeAddressSetFactory) GetAddressSet(dbIDs *libovsdbops.DbObjectIDs) (AddressSet, error)
  • func (f *FakeAddressSetFactory) NewAddressSet(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (AddressSet, error)
  • func (f *FakeAddressSetFactory) NewAddressSetOps(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (AddressSet, []ovsdb.Operation, error)
  • func (f *FakeAddressSetFactory) ProcessEachAddressSet(ownerController string, indexT *libovsdbops.ObjectIDsType, ...) error

Constants

const FakeASFError = "fake asf error"

Functions

func GetHashNamesForAS

func GetHashNamesForAS(dbIDs *libovsdbops.DbObjectIDs) (string, string)

GetHashNamesForAS returns hashed address set names for given dbIDs for both ip families. Can be used to cleanup e.g. address set references if the address set was deleted.

func GetTestDbAddrSets

func GetTestDbAddrSets(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (*nbdb.AddressSet, *nbdb.AddressSet)

GetTestDbAddrSets returns nbdb.AddressSet objects both for ipv4 and ipv6, regardless of current config. May only be used for testing.

Types

type AddressSet

type AddressSet interface {
	// GetASHashNames returns the hashed name for v6 and v4 addressSets
	GetASHashNames() (string, string)
	// GetName returns the descriptive name of the address set
	GetName() string
	// AddAddresses adds the slice of addresses to the address set
	AddAddresses(addresses []string) error
	// AddAddressesReturnOps returns the ops needed to add the slice of addresses to the address set
	AddAddressesReturnOps(addresses []string) ([]ovsdb.Operation, error)
	// GetAddresses gets the list of v4 & v6 addresses from the address set
	GetAddresses() ([]string, []string)
	// SetAddresses sets the address set to the given slice of addresses
	SetAddresses(addresses []string) error
	// DeleteAddresses deletes the provided slice of addresses from the address set
	DeleteAddresses(addresses []string) error
	// DeleteAddressesReturnOps returns the ops needed to delete the slice of addresses from the address set
	DeleteAddressesReturnOps(addresses []string) ([]ovsdb.Operation, error)
	// Destroy deletes the entire address set
	Destroy() error
}

AddressSet is an interface for address set objects

type AddressSetFactory

type AddressSetFactory interface {
	// NewAddressSet returns a new object that implements AddressSet
	// and contains the given slice of addresses which today can be string
	// representations of net.IPs or net.IPNets, or an error. Internally it creates
	// an address set for v4 and v6 families each.
	NewAddressSet(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (AddressSet, error)
	// NewAddressSetOps returns a new object that implements AddressSet
	// and contains the given slice of addresses which today can be string
	// representations of net.IPs or net.IPNets, or an error. Internally it creates
	// ops to create an address set for for v4 and v6 families each.
	NewAddressSetOps(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (AddressSet, []ovsdb.Operation, error)
	// EnsureAddressSet makes sure that an address set object exists in ovn
	// with the given dbIDs.
	EnsureAddressSet(dbIDs *libovsdbops.DbObjectIDs) (AddressSet, error)
	// ProcessEachAddressSet calls the given function for each address set of type dbIDsType owned by given ownerController.
	ProcessEachAddressSet(ownerController string, dbIDsType *libovsdbops.ObjectIDsType, iteratorFn AddressSetIterFunc) error
	// DestroyAddressSet deletes the address sets with given dbIDs.
	DestroyAddressSet(dbIDs *libovsdbops.DbObjectIDs) error
	// GetAddressSet returns the address-set that matches the given dbIDs
	GetAddressSet(dbIDs *libovsdbops.DbObjectIDs) (AddressSet, error)
}

AddressSetFactory is an interface for managing address set objects.

func NewOvnAddressSetFactory

func NewOvnAddressSetFactory(nbClient libovsdbclient.Client, v4Mode, v6Mode bool) AddressSetFactory

NewOvnAddressSetFactory creates a new AddressSetFactory backed by address set objects that execute OVN commands

type AddressSetIterFunc

type AddressSetIterFunc func(dbIDs *libovsdbops.DbObjectIDs) error

type FakeAddressSetFactory

type FakeAddressSetFactory struct {
	// ControllerName is stored here for convenience, it is used to build dbIDs for fake-only methods like
	// AddressSetExists, EventuallyExpectAddressSet, etc.
	ControllerName string

	sync.Mutex
	// contains filtered or unexported fields
}

func NewFakeAddressSetFactory

func NewFakeAddressSetFactory(controllerName string) *FakeAddressSetFactory

func (*FakeAddressSetFactory) AddressSetExists

func (f *FakeAddressSetFactory) AddressSetExists(dbIDsOrNsName any) bool

func (*FakeAddressSetFactory) DestroyAddressSet

func (f *FakeAddressSetFactory) DestroyAddressSet(dbIDs *libovsdbops.DbObjectIDs) error

func (*FakeAddressSetFactory) EnsureAddressSet

func (f *FakeAddressSetFactory) EnsureAddressSet(dbIDs *libovsdbops.DbObjectIDs) (AddressSet, error)

EnsureAddressSet returns set object

func (*FakeAddressSetFactory) ErrOnNextNewASCall

func (f *FakeAddressSetFactory) ErrOnNextNewASCall()

ErrOnNextNewASCall will make FakeAddressSetFactory return FakeASFError on the next NewAddressSet call

func (*FakeAddressSetFactory) EventuallyExpectAddressSet

func (f *FakeAddressSetFactory) EventuallyExpectAddressSet(dbIDsOrNsName any)

EventuallyExpectAddressSet ensures the named address set eventually exists

func (*FakeAddressSetFactory) EventuallyExpectAddressSetWithAddresses

func (f *FakeAddressSetFactory) EventuallyExpectAddressSetWithAddresses(dbIDsOrNsName any, addresses []string)

func (*FakeAddressSetFactory) EventuallyExpectEmptyAddressSetExist

func (f *FakeAddressSetFactory) EventuallyExpectEmptyAddressSetExist(dbIDsOrNsName any)

EventuallyExpectEmptyAddressSetExist ensures the named address set eventually exists with no Addresses

func (*FakeAddressSetFactory) EventuallyExpectNoAddressSet

func (f *FakeAddressSetFactory) EventuallyExpectNoAddressSet(dbIDsOrNsName any)

EventuallyExpectNoAddressSet ensures the named address set eventually does not exist For namespaces address set deletion is delayed by 20 seconds, it is only tested once in namespace_test to not slow down tests. Don't use for namespace-owned address sets

func (*FakeAddressSetFactory) ExpectAddressSetWithAddresses

func (f *FakeAddressSetFactory) ExpectAddressSetWithAddresses(dbIDsOrNsName any, addresses []string)

ExpectAddressSetWithAddresses ensure address set exists with the given set of ips. Address set is identified by dbIDsOrNsName, which may be a namespace name (string) or a *libovsdbops.DbObjectIDs.

func (*FakeAddressSetFactory) ExpectEmptyAddressSet

func (f *FakeAddressSetFactory) ExpectEmptyAddressSet(dbIDsOrNsName any)

ExpectEmptyAddressSet ensures the address set owned by dbIDsOrNsName exists with no Addresses

func (*FakeAddressSetFactory) ExpectNumberOfAddressSets

func (f *FakeAddressSetFactory) ExpectNumberOfAddressSets(n int)

ExpectNumberOfAddressSets ensures the number of created address sets equals given number

func (*FakeAddressSetFactory) GetAddressSet

func (f *FakeAddressSetFactory) GetAddressSet(dbIDs *libovsdbops.DbObjectIDs) (AddressSet, error)

GetAddressSet returns set object

func (*FakeAddressSetFactory) NewAddressSet

func (f *FakeAddressSetFactory) NewAddressSet(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (AddressSet, error)

NewAddressSet returns a new address set object

func (*FakeAddressSetFactory) NewAddressSetOps

func (f *FakeAddressSetFactory) NewAddressSetOps(dbIDs *libovsdbops.DbObjectIDs, addresses []string) (AddressSet, []ovsdb.Operation, error)

NewAddressSetOps returns a new address set object

func (*FakeAddressSetFactory) ProcessEachAddressSet

func (f *FakeAddressSetFactory) ProcessEachAddressSet(ownerController string, indexT *libovsdbops.ObjectIDsType, iteratorFn AddressSetIterFunc) error