Documentation ¶
Index ¶
- func ReconcileIPs(errorChan chan error)
- type ConfigWatcher
- type OrphanedIPReservations
- type ReconcileLooper
- func NewReconcileLooper(ctx context.Context, timeout int) (*ReconcileLooper, error)
- func NewReconcileLooperWithClient(ctx context.Context, k8sClient *kubernetes.Client, timeout int) (*ReconcileLooper, error)
- func NewReconcileLooperWithKubeconfig(ctx context.Context, kubeconfigPath string, timeout int) (*ReconcileLooper, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReconcileIPs ¶ added in v0.6.1
func ReconcileIPs(errorChan chan error)
Types ¶
type ConfigWatcher ¶ added in v0.6.3
type ConfigWatcher struct {
// contains filtered or unexported fields
}
func NewConfigWatcher ¶ added in v0.6.3
func NewConfigWatcher(configPath string, scheduler gocron.Scheduler, configWatcher *fsnotify.Watcher, handlerFunc func()) (*ConfigWatcher, error)
func (*ConfigWatcher) SyncConfiguration ¶ added in v0.6.3
func (c *ConfigWatcher) SyncConfiguration(relevantEventPredicate func(event fsnotify.Event) bool)
type OrphanedIPReservations ¶
type OrphanedIPReservations struct { Pool storage.IPPool Allocations []types.IPReservation }
type ReconcileLooper ¶
type ReconcileLooper struct {
// contains filtered or unexported fields
}
func NewReconcileLooper ¶
func NewReconcileLooper(ctx context.Context, timeout int) (*ReconcileLooper, error)
func NewReconcileLooperWithClient ¶ added in v0.6.1
func NewReconcileLooperWithClient(ctx context.Context, k8sClient *kubernetes.Client, timeout int) (*ReconcileLooper, error)
func (ReconcileLooper) ReconcileIPPools ¶
func (ReconcileLooper) ReconcileOverlappingIPAddresses ¶
func (rl ReconcileLooper) ReconcileOverlappingIPAddresses(ctx context.Context) error
Click to show internal directories.
Click to hide internal directories.