indexallocator

Documentation

Index

• Constants
• type IndexAllocator
  • func NewIndexAllocator(ctx context.Context, client client.Client) (*IndexAllocator, error)
  • func (s *IndexAllocator) AssignIndex(podName string) (int, error)
  • func (s *IndexAllocator) SetupWithManager(ctx context.Context, mgr manager.Manager) <-chan struct{}

Constants

const (
	IndexRangeStart = 1
	IndexRangeEnd   = 512
)

Types

type IndexAllocator

type IndexAllocator struct {
	IsLeader bool

	Client client.Client
	// contains filtered or unexported fields
}

IndexAllocator manages allocation of 1-512 temporary indices for Pod-to-DevicePlugin communication Uses a simple atomic counter that increments from 1 to 512, then wraps around to 1 No bitmap tracking needed - index reuse is acceptable after 512 cycles

func NewIndexAllocator

func NewIndexAllocator(ctx context.Context, client client.Client) (*IndexAllocator, error)

func (*IndexAllocator) AssignIndex

func (s *IndexAllocator) AssignIndex(podName string) (int, error)

AssignIndex assigns a temporary index (1-512) for Pod-to-DevicePlugin communication Uses atomic increment to ensure thread-safe assignment Index wraps around from 512 to 1 (simple modulo operation)

func (*IndexAllocator) SetupWithManager

func (s *IndexAllocator) SetupWithManager(ctx context.Context, mgr manager.Manager) <-chan struct{}