Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

cidrallocator

package

Go to main page

Versions in this module

v0

v0.0.5

May 14, 2025

v0.0.4

May 13, 2025

v0.0.3

May 13, 2025

v0.0.2

May 13, 2025

v0.0.1

May 13, 2025

Changes in this version

+ const AllocationBackoffBaseMs

+ const AllocationBackoffFactor

+ const AllocationJitterRatio

+ const AllocationMaxRetries

+ const AsyncTimeoutDefaultSec

+ const ClaimStatusMaxRetries

+ const DefaultRequeueAfter

+ const EventReasonAllocated

+ const EventReasonConflict

+ const EventReasonPoolExhausted

+ const EventReasonValidationFailed

+ const IPAMFinalizer

+ const IPAMLabel

+ const MaxConcurrentReconciles

+ const MaxRetries

+ const NotFoundRetryMax

+ const PageSize

+ const ParentPoolLabelIndex

+ const PoolRefField

+ const ReadyCondition

+ var SubnetListContinueSkippedTotal = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ var SubnetListPagesTotal = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ func CalculatePoolStatus(poolCIDR string, allocations []string) (int, map[string]int, error)

+ func DeletionOnly() predicate.Predicate

+ func EncodeAllocationName(pool, cidr string) string

+ func IsConflictError(err error) bool

+ func IsExhaustedError(err error) bool

+ func NewConflictError(msg string) error

+ func NewExhaustedError(msg string) error

+ func NewPoolGaugePredicate() predicate.Predicate

+ func NewTestScheme() *runtime.Scheme

+ func ParseCIDRSize(cidr string) (int, error)

+ func PoolStatusPred() predicate.Predicate

+ func RecordParentPoolReconcileDuration(result string, duration time.Duration)

+ func RecordParentPoolRequeue(eventType string)

+ func RegisterAllPoolGauges(ctx context.Context, c client.Client) error

+ func RegisterControllers(mgr ctrl.Manager, ipamConfig *config.IPAMConfig, recorder record.EventRecorder) error

+ func RegisterPoolGauges(poolName string)

+ func SetupFieldIndexes(ctx context.Context, mgr ctrl.Manager, log logr.Logger) error

+ func SubnetEvents() predicate.Predicate

+ func UnregisterPoolGauges(poolName string)

+ type CIDRAllocatorReconciler struct

+ Config *config.IPAMConfig

+ ControllerName string

+ Recorder record.EventRecorder

+ Scheme *runtime.Scheme

+ func NewCIDRAllocatorReconciler(client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, ...) *CIDRAllocatorReconciler

+ func (r *CIDRAllocatorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *CIDRAllocatorReconciler) RegisterEventHandlers()

+ func (r *CIDRAllocatorReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type CIDRMap struct

+ func NewCIDRMap(cidr string) (*CIDRMap, error)

+ func (c *CIDRMap) AllocateNextAvailable(size int) (string, error)

+ func (c *CIDRMap) GetFreeBlockCount() map[string]int

+ func (c *CIDRMap) MarkAllocated(cidr string) error

+ type EventEmitter struct

+ func NewEventEmitter(recorder record.EventRecorder, scheme *runtime.Scheme) *EventEmitter

+ func (e *EventEmitter) EmitAllocationConflict(claim *ipamv1.SubnetClaim, details string)

+ func (e *EventEmitter) EmitAllocationSuccess(claim *ipamv1.SubnetClaim, cidr string)

+ func (e *EventEmitter) EmitPoolEvent(pool *ipamv1.SubnetPool, eventType string, reason string, msg string)

+ func (e *EventEmitter) EmitPoolExhausted(claim *ipamv1.SubnetClaim, poolName string)

+ func (e *EventEmitter) EmitValidationFailed(claim *ipamv1.SubnetClaim, details string)

+ type PoolGaugeEventHandler struct

+ func (p *PoolGaugeEventHandler) Create(e event.CreateEvent) bool

+ func (p *PoolGaugeEventHandler) Delete(e event.DeleteEvent) bool

+ func (p *PoolGaugeEventHandler) Generic(e event.GenericEvent) bool

+ func (p *PoolGaugeEventHandler) Update(e event.UpdateEvent) bool

+ type PoolStatusReconciler struct

+ ControllerName string

+ Scheme *runtime.Scheme

+ func (r *PoolStatusReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *PoolStatusReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type StaticGauge struct

+ type SubnetPoolClaimReconciler struct

+ Config *config.IPAMConfig

+ Scheme *runtime.Scheme

+ func NewSubnetPoolClaimReconciler(client client.Client, scheme *runtime.Scheme, config *config.IPAMConfig) *SubnetPoolClaimReconciler

+ func (r *SubnetPoolClaimReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *SubnetPoolClaimReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type SubnetReconciler struct

+ Config *config.IPAMConfig

+ ControllerName string

+ Scheme *runtime.Scheme

+ func NewSubnetReconciler(client client.Client, scheme *runtime.Scheme, config *config.IPAMConfig) *SubnetReconciler

+ func (r *SubnetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *SubnetReconciler) SetupWithManager(mgr ctrl.Manager) error