The highest tagged major version is v3.

watchers

package

v0.18.1-calicov3.21.2 Latest Latest Go to latest Published: Jan 7, 2022 License: Apache-2.0, Apache-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/projectcalico/vpp-dataplane

Documentation ¶

Index ¶

func NewIPAMCache(vpp *vpplink.VppLink, clientv3 calicov3cli.Interface, log *logrus.Entry) *ipamCache
type BGPConfigurationWatcher
- func NewBGPConfigurationWatcher(clientv3 calicov3cli.Interface, log *logrus.Entry) *BGPConfigurationWatcher
- func (w *BGPConfigurationWatcher) GetBGPConf() (*calicov3.BGPConfigurationSpec, error)
- func (w *BGPConfigurationWatcher) OnVppRestart()
- func (w *BGPConfigurationWatcher) WatchBGPConfiguration(t *tomb.Tomb) error
type FelixConfWatcher
- func NewFelixConfWatcher(clientv3 calicov3cli.Interface, log *logrus.Entry) *FelixConfWatcher
- func NewFelixProxyWatcher(log *logrus.Entry) *FelixConfWatcher
- func (w *FelixConfWatcher) OnVppRestart()
- func (w *FelixConfWatcher) WatchFelixConfiguration(t *tomb.Tomb) error
type FelixProxyWatcher
type IpamCache
type KernelWatcher
- func NewKernelWatcher(ipam IpamCache, log *logrus.Entry) *KernelWatcher
- func (w *KernelWatcher) OnVppRestart()
- func (w *KernelWatcher) SetOurBGPSpec(nodeBGPSpec *oldv3.NodeBGPSpec)
- func (w *KernelWatcher) WatchKernelRoute(t *tomb.Tomb) error
type LocalSIDWatcher
- func NewLocalSIDWatcher(vpp *vpplink.VppLink, clientv3 calicov3cli.Interface, log *logrus.Entry) *LocalSIDWatcher
- func (p *LocalSIDWatcher) AdvertiseSRv6Policy(localsid *types.SrLocalsid) (err error)
- func (w *LocalSIDWatcher) OnVppRestart()
- func (w *LocalSIDWatcher) SetOurBGPSpec(nodeBGPSpec *oldv3.NodeBGPSpec)
- func (w *LocalSIDWatcher) WatchLocalSID(t *tomb.Tomb) error
type NodeWatcher
- func NewNodeWatcher(vpp *vpplink.VppLink, clientv3 calicov3cli.Interface, log *logrus.Entry) *NodeWatcher
- func (w *NodeWatcher) OnVppRestart()
- func (w *NodeWatcher) WaitForOurBGPSpec() *oldv3.NodeBGPSpec
- func (w *NodeWatcher) WatchNodes(t *tomb.Tomb) error
type PeerWatcher
- func NewPeerWatcher(clientv3 calicov3cli.Interface, log *logrus.Entry) *PeerWatcher
- func (w *PeerWatcher) OnVppRestart()
- func (w *PeerWatcher) SetBGPConf(bgpConf *calicov3.BGPConfigurationSpec)
- func (w *PeerWatcher) WatchBGPPeers(t *tomb.Tomb) error
type PrefixWatcher
- func NewPrefixWatcher(client *calicocli.Client, log *logrus.Entry) *PrefixWatcher
- func (w *PrefixWatcher) OnVppRestart()
- func (w *PrefixWatcher) SetOurBGPSpec(nodeBGPSpec *oldv3.NodeBGPSpec)
- func (w *PrefixWatcher) WatchPrefix(t *tomb.Tomb) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

Types ¶

type BGPConfigurationWatcher ¶

type BGPConfigurationWatcher struct {
	BGPConfigurationWatcherEventChan chan common.CalicoVppEvent
	BGPConf                          *calicov3.BGPConfigurationSpec
	// contains filtered or unexported fields
}

func NewBGPConfigurationWatcher ¶

func NewBGPConfigurationWatcher(clientv3 calicov3cli.Interface, log *logrus.Entry) *BGPConfigurationWatcher

func (*BGPConfigurationWatcher) GetBGPConf ¶

func (w *BGPConfigurationWatcher) GetBGPConf() (*calicov3.BGPConfigurationSpec, error)

For now, this doesn't watch the BGP configuration nor produce events

func (*BGPConfigurationWatcher) OnVppRestart ¶

func (w *BGPConfigurationWatcher) OnVppRestart()

func (*BGPConfigurationWatcher) WatchBGPConfiguration ¶

func (w *BGPConfigurationWatcher) WatchBGPConfiguration(t *tomb.Tomb) error

type FelixConfWatcher ¶

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

func NewFelixConfWatcher ¶

func NewFelixConfWatcher(clientv3 calicov3cli.Interface, log *logrus.Entry) *FelixConfWatcher

func NewFelixProxyWatcher ¶

func NewFelixProxyWatcher(log *logrus.Entry) *FelixConfWatcher

func (*FelixConfWatcher) OnVppRestart ¶

func (w *FelixConfWatcher) OnVppRestart()

func (*FelixConfWatcher) WatchFelixConfiguration ¶

func (w *FelixConfWatcher) WatchFelixConfiguration(t *tomb.Tomb) error

type FelixProxyWatcher ¶

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

type IpamCache ¶

type IpamCache interface {
	GetPrefixIPPool(*net.IPNet) *calicov3.IPPool
	SyncIPAM(t *tomb.Tomb) error
	WaitReady()
	OnVppRestart()
	IPNetNeedsSNAT(prefix *net.IPNet) bool
}

type KernelWatcher ¶

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

func NewKernelWatcher ¶

func NewKernelWatcher(ipam IpamCache, log *logrus.Entry) *KernelWatcher

func (*KernelWatcher) OnVppRestart ¶

func (w *KernelWatcher) OnVppRestart()

func (*KernelWatcher) SetOurBGPSpec ¶

func (w *KernelWatcher) SetOurBGPSpec(nodeBGPSpec *oldv3.NodeBGPSpec)

func (*KernelWatcher) WatchKernelRoute ¶

func (w *KernelWatcher) WatchKernelRoute(t *tomb.Tomb) error

watchKernelRoute receives netlink route update notification and announces kernel/boot routes using BGP. TODO: should we leverage this to update VPP routes as well?

type LocalSIDWatcher ¶

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

func NewLocalSIDWatcher ¶

func NewLocalSIDWatcher(vpp *vpplink.VppLink, clientv3 calicov3cli.Interface, log *logrus.Entry) *LocalSIDWatcher

func (*LocalSIDWatcher) AdvertiseSRv6Policy ¶

func (p *LocalSIDWatcher) AdvertiseSRv6Policy(localsid *types.SrLocalsid) (err error)

func (*LocalSIDWatcher) OnVppRestart ¶

func (w *LocalSIDWatcher) OnVppRestart()

func (*LocalSIDWatcher) SetOurBGPSpec ¶

func (w *LocalSIDWatcher) SetOurBGPSpec(nodeBGPSpec *oldv3.NodeBGPSpec)

func (*LocalSIDWatcher) WatchLocalSID ¶

func (w *LocalSIDWatcher) WatchLocalSID(t *tomb.Tomb) error

type NodeWatcher ¶

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

func NewNodeWatcher ¶

func NewNodeWatcher(vpp *vpplink.VppLink, clientv3 calicov3cli.Interface, log *logrus.Entry) *NodeWatcher

func (*NodeWatcher) OnVppRestart ¶

func (w *NodeWatcher) OnVppRestart()

func (*NodeWatcher) WaitForOurBGPSpec ¶

func (w *NodeWatcher) WaitForOurBGPSpec() *oldv3.NodeBGPSpec

func (*NodeWatcher) WatchNodes ¶

func (w *NodeWatcher) WatchNodes(t *tomb.Tomb) error

type PeerWatcher ¶

type PeerWatcher struct {
	BGPConf *calicov3.BGPConfigurationSpec
	// contains filtered or unexported fields
}

func NewPeerWatcher ¶

func NewPeerWatcher(clientv3 calicov3cli.Interface, log *logrus.Entry) *PeerWatcher

func (*PeerWatcher) OnVppRestart ¶

func (w *PeerWatcher) OnVppRestart()

func (*PeerWatcher) SetBGPConf ¶

func (w *PeerWatcher) SetBGPConf(bgpConf *calicov3.BGPConfigurationSpec)

func (*PeerWatcher) WatchBGPPeers ¶

func (w *PeerWatcher) WatchBGPPeers(t *tomb.Tomb) error

This function watches BGP peers configured in Calico These peers are configured in GoBGP in addition to the other nodes in the cluster They may also control which nodes to pair with if the peerSelector is set

type PrefixWatcher ¶

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

func NewPrefixWatcher ¶

func NewPrefixWatcher(client *calicocli.Client, log *logrus.Entry) *PrefixWatcher

func (*PrefixWatcher) OnVppRestart ¶

func (w *PrefixWatcher) OnVppRestart()

func (*PrefixWatcher) SetOurBGPSpec ¶

func (w *PrefixWatcher) SetOurBGPSpec(nodeBGPSpec *oldv3.NodeBGPSpec)

func (*PrefixWatcher) WatchPrefix ¶

func (w *PrefixWatcher) WatchPrefix(t *tomb.Tomb) error

watchPrefix watches etcd /calico/ipam/v2/host/$NODENAME and add/delete aggregated routes which are assigned to the node. This function also updates policy appropriately.

Source Files ¶

View all Source files

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