portallocator

package

v0.0.0-...-a8331be Latest Latest Go to latest Published: Jan 21, 2026 License: GPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type AllocatePortsParams struct {
	Count   uint   `json:"count"`
	Network string `json:"network"`
}

type AllocatedPortRange struct {
	From  uint `json:"from"`
	Count uint `json:"count"`
}

type AllocationErrorKind = string

const NO_ALLOCATABLE_RANGES AllocationErrorKind = "NO_ALLOCATABLE_RANGES"

type AllowedPorts struct {
	From uint `json:"from"`
	To   uint `json:"to"`
}

func (a AllowedPorts) IsAllowed(pr AllocatedPortRange) bool

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

func (e *PortAllocationError) Error() string

type PortAllocator struct{}

func (p *PortAllocator) AllocatePortRange(ctx restate.ObjectContext, params AllocatePortsParams) (*AllocatedPortRange, error)

func (p *PortAllocator) FreePortsForNetwork(ctx restate.ObjectContext, network string) error

func (p *PortAllocator) Initialize(ctx restate.ObjectContext, allowedPorts AllowedPorts) error