ipcache

Aug 19, 2019

Changes in this version

+ func AllocateCIDRsForIPs(prefixes []net.IP) ([]*identity.Identity, error)

+ func WaitForKVStoreSync()

type IPCache

+ func (ipc *IPCache) AddListener(listener IPIdentityMappingListener)

Apr 26, 2019

Changes in this version

+ const DefaultAddressSpace

+ var AddressSpace = DefaultAddressSpace

+ var IPIdentitiesPath = path.Join(kvstore.BaseKeyPrefix, "state", "ip", "v1")

+ var IPIdentityCache = NewIPCache()

+ func AllocateCIDRs(impl Implementation, prefixes []*net.IPNet) error

+ func DeleteIPFromKVStore(ctx context.Context, ip string) error

+ func GetIPIdentityMapModel()

+ func InitIPIdentityWatcher()

+ func ReleaseCIDRs(prefixes []*net.IPNet)

+ func UpsertIPToKVStore(ctx context.Context, IP, hostIP net.IP, ID identity.NumericIdentity, key uint8, ...) error

+ func WaitForInitialSync()

+ type CacheModification string

+ const Delete

+ const Upsert

+ type IPCache struct

+ func NewIPCache() *IPCache

+ func (ipc *IPCache) Delete(IP string, source Source)

+ func (ipc *IPCache) DumpToListenerLocked(listener IPIdentityMappingListener)

+ func (ipc *IPCache) Lock()

+ func (ipc *IPCache) LookupByIP(IP string) (Identity, bool)

+ func (ipc *IPCache) LookupByIPRLocked(IP string) (Identity, bool)

+ func (ipc *IPCache) LookupByIdentity(id identity.NumericIdentity) (map[string]struct{}, bool)

+ func (ipc *IPCache) LookupByPrefix(IP string) (Identity, bool)

+ func (ipc *IPCache) LookupByPrefixRLocked(prefix string) (identity Identity, exists bool)

+ func (ipc *IPCache) RLock()

+ func (ipc *IPCache) RUnlock()

+ func (ipc *IPCache) SetListeners(listeners []IPIdentityMappingListener)

+ func (ipc *IPCache) Unlock()

+ func (ipc *IPCache) Upsert(ip string, hostIP net.IP, hostKey uint8, newIdentity Identity) bool

+ type IPIdentityMappingListener interface

+ OnIPIdentityCacheChange func(modType CacheModification, cidr net.IPNet, oldHostIP, newHostIP net.IP, ...)

+ OnIPIdentityCacheGC func()

+ type IPIdentityWatcher struct

+ func NewIPIdentityWatcher(backend kvstore.BackendOperations) *IPIdentityWatcher

+ func (iw *IPIdentityWatcher) Close()

+ func (iw *IPIdentityWatcher) Watch()

+ type IPKeyPair struct

+ IP net.IP

+ Key uint8

+ type Identity struct

+ ID identity.NumericIdentity

+ Source Source

+ type Implementation interface

+ GetMaxPrefixLengths func(ipv6 bool) int

+ type Source string

+ const FromAgentLocal

+ const FromCIDR

+ const FromKVStore

+ const FromKubernetes