controller

Jul 3, 2025

Changes in this version

type NodeENIReconciler

+ func (r *NodeENIReconciler) ShouldUseNodeLevelCoordinationTest(nodeENI *networkingv1alpha1.NodeENI, ...) bool

May 25, 2025

Changes in this version

+ const CleanupStartTimeAnnotation

+ type CoordinatedOperation struct

+ DependsOn []string

+ Execute func(ctx context.Context) error

+ ID string

+ Priority int

+ ResourceIDs []string

+ Timeout time.Duration

+ Type string

+ type CoordinationManager struct

+ func NewCoordinationManager(logger logr.Logger) *CoordinationManager

+ func (cm *CoordinationManager) AcquireLock(ctx context.Context, resourceID, resourceType, operationID string, ...) (*ResourceLock, error)

+ func (cm *CoordinationManager) CheckDependencies(operationID string) (bool, []string)

+ func (cm *CoordinationManager) CleanupStaleLocks()

+ func (cm *CoordinationManager) CompleteDependency(operationID string)

+ func (cm *CoordinationManager) ExecuteCoordinated(ctx context.Context, op *CoordinatedOperation) error

+ func (cm *CoordinationManager) GetDependencyStatus() map[string]OperationDependency

+ func (cm *CoordinationManager) GetLockStatus() map[string]ResourceLock

+ func (cm *CoordinationManager) GetResourceConflicts(resourceIDs []string) []string

+ func (cm *CoordinationManager) RegisterDependency(operationID string, dependsOn []string, resourceIDs []string, priority int)

+ func (cm *CoordinationManager) ReleaseLock(resourceID, operationID string) error

+ type Dependency struct

+ CreatedAt time.Time

+ DependsOn []string

+ ID string

+ Metadata map[string]interface{}

+ Priority int

+ RequiredState ResourceState

+ ResourceID string

+ Type DependencyType

+ type DependencyGraph struct

+ func NewDependencyGraph(logger logr.Logger) *DependencyGraph

+ func (dg *DependencyGraph) AddDependency(dep *Dependency) error

+ func (dg *DependencyGraph) GetBlockedDependencies() []*Dependency

+ func (dg *DependencyGraph) GetDependencyConflicts() []string

+ func (dg *DependencyGraph) GetReadyDependencies() []*Dependency

+ func (dg *DependencyGraph) GetResourceState(resourceID string) ResourceState

+ func (dg *DependencyGraph) RemoveDependency(id string)

+ func (dg *DependencyGraph) ResolveDependencyOrder() ([]*Dependency, error)

+ func (dg *DependencyGraph) UpdateResourceState(resourceID string, state ResourceState)

+ type DependencyManager struct

+ func NewDependencyManager(logger logr.Logger) *DependencyManager

+ func (dm *DependencyManager) CompleteDependency(dependencyID string)

+ func (dm *DependencyManager) CreateENIAttachmentDependencies(ctx context.Context, nodeENI *networkingv1alpha1.NodeENI, ...) error

+ func (dm *DependencyManager) CreateENIDetachmentDependencies(ctx context.Context, nodeENI *networkingv1alpha1.NodeENI, ...) error

+ func (dm *DependencyManager) GetDependencyStatus() map[string]interface{}

+ func (dm *DependencyManager) GetReadyOperations() []*Dependency

+ func (dm *DependencyManager) UpdateResourceState(resourceID string, state ResourceState)

+ type DependencyType int

+ const DependencyTypeENI

+ const DependencyTypeInstance

+ const DependencyTypeNode

+ const DependencyTypeSecurityGroup

+ const DependencyTypeSubnet

+ type InterfaceState struct

+ CurrentDriver string

+ IfaceName string

+ IsBoundToDPDK bool

+ PCIAddress string

type NodeENIReconciler

+ CircuitBreaker *retry.CircuitBreaker

+ Coordinator *CoordinationManager

+ Metrics *observability.Metrics

+ StructuredLog *observability.StructuredLogger

+ type OperationDependency struct

+ DependsOn []string

+ OperationID string

+ Priority int

+ ResourceIDs []string

+ type ResourceLock struct

+ Cancel context.CancelFunc

+ Context context.Context

+ LockedAt time.Time

+ LockedBy string

+ ResourceID string

+ ResourceType string

+ type ResourceState int

+ const ResourceStateAvailable

+ const ResourceStateDeleting

+ const ResourceStateInUse

+ const ResourceStateUnavailable

+ const ResourceStateUnknown

May 9, 2025

Changes in this version

type NodeENIReconciler

+ AWS awsutil.EC2Interface

+ Config *config.ControllerConfig

May 6, 2025

Changes in this version

+ const NodeENIFinalizer

+ type NodeENIReconciler struct

+ EC2 *ec2.EC2

+ Log logr.Logger

+ Recorder record.EventRecorder

+ Scheme *runtime.Scheme

+ func NewNodeENIReconciler(mgr manager.Manager) (*NodeENIReconciler, error)

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

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