watchers

package

v0.0.0-...-9647dda Latest Latest Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 21 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/noironetworks/aci-containers

Documentation ¶

Index ¶

Constants
type ApicInfo
type ApicWatcher
- func NewApicWatcher(gs *gbpserver.Server) *ApicWatcher
type EPSyncer
type K8sStateDriver
type K8sWatcher
- func NewK8sWatcher(gs *gbpserver.Server) (*K8sWatcher, error)
- func (kw *K8sWatcher) InitEPInformer(stopCh <-chan struct{}) error
- func (kw *K8sWatcher) InitIntentInformers(stopCh <-chan struct{}) error
type NetflowWatcher
- func NewNetflowWatcher(gs *gbpserver.Server) (*NetflowWatcher, error)
- func (nfw *NetflowWatcher) InitNetflowInformer(stopCh <-chan struct{})

Constants ¶

View Source

const (
	FieldClassID = iota
	FieldTunnelID
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ApicInfo ¶

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

type ApicWatcher ¶

type ApicWatcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewApicWatcher ¶

func NewApicWatcher(gs *gbpserver.Server) *ApicWatcher

func (*ApicWatcher) ContractChanged ¶

func (aw *ApicWatcher) ContractChanged(obj apicapi.ApicObject)

func (*ApicWatcher) ContractDeleted ¶

func (aw *ApicWatcher) ContractDeleted(dn string)

func (*ApicWatcher) EpgChanged ¶

func (aw *ApicWatcher) EpgChanged(obj apicapi.ApicObject)

func (*ApicWatcher) EpgDeleted ¶

func (aw *ApicWatcher) EpgDeleted(dn string)

func (*ApicWatcher) FilterChanged ¶

func (aw *ApicWatcher) FilterChanged(obj apicapi.ApicObject)

func (*ApicWatcher) FilterDeleted ¶

func (aw *ApicWatcher) FilterDeleted(dn string)

func (*ApicWatcher) Init ¶

func (aw *ApicWatcher) Init(apicUrl []string, stopCh <-chan struct{}) error

func (*ApicWatcher) NetPolChanged ¶

func (aw *ApicWatcher) NetPolChanged(obj apicapi.ApicObject)

func (*ApicWatcher) NetPolDeleted ¶

func (aw *ApicWatcher) NetPolDeleted(dn string)

func (*ApicWatcher) ProcessEpg ¶

func (aw *ApicWatcher) ProcessEpg(tenant, epgDn string, obj apicapi.ApicObject)

type EPSyncer ¶

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

func (*EPSyncer) AddExtEP ¶

func (eps *EPSyncer) AddExtEP(subnet, epgDn string)

func (*EPSyncer) Init ¶

func (eps *EPSyncer) Init() error

func (*EPSyncer) Run ¶

func (eps *EPSyncer) Run(stopCh <-chan struct{})

type K8sStateDriver ¶

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

K8sStateDriver implements gbpserver.StateDriver

func (*K8sStateDriver) Get ¶

func (ks *K8sStateDriver) Get() (*aciv1.GBPSState, error)

func (*K8sStateDriver) Init ¶

func (ks *K8sStateDriver) Init(wrField int) error

func (*K8sStateDriver) StateExists ¶

func (ks *K8sStateDriver) StateExists() (bool, error)

func (*K8sStateDriver) Update ¶

func (ks *K8sStateDriver) Update(s *aciv1.GBPSState) error

type K8sWatcher ¶

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

func NewK8sWatcher ¶

func NewK8sWatcher(gs *gbpserver.Server) (*K8sWatcher, error)

func (*K8sWatcher) InitEPInformer ¶

func (kw *K8sWatcher) InitEPInformer(stopCh <-chan struct{}) error

func (*K8sWatcher) InitIntentInformers ¶

func (kw *K8sWatcher) InitIntentInformers(stopCh <-chan struct{}) error

type NetflowWatcher ¶

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

func NewNetflowWatcher ¶

func NewNetflowWatcher(gs *gbpserver.Server) (*NetflowWatcher, error)

func (*NetflowWatcher) InitNetflowInformer ¶

func (nfw *NetflowWatcher) InitNetflowInformer(stopCh <-chan struct{})

Source Files ¶

View all Source files

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