maxaddr

package

v0.2.1 Latest Latest Go to latest Published: Apr 2, 2026 License: AGPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type AddressDisabler interface {
	DisableAddresses(ctx context.Context, addressIDs []device.AddressID, source device.EventSource) error
}

AddressDisabler is implemented by *device.Service.

type EnabledAddressFetcher interface {
	GetEnabledAddressesForDevice(ctx context.Context, deviceID device.DeviceID) ([]device.Address, error)
}

EnabledAddressFetcher is implemented by *device.Service.

type MaxAddressesProvider interface {
	GetMaxActiveAddresses(ctx context.Context, deviceID device.DeviceID) (*int, error)
}

MaxAddressesProvider is implemented by *rule.Service.

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

Service listens for address events and enforces the max active addresses rule asynchronously.

func NewService(provider MaxAddressesProvider, fetcher EnabledAddressFetcher, disabler AddressDisabler, logger *slog.Logger) *Service

NewService creates a new maxaddr enforcement service.

func (s *Service) OnAddressEvent(ctx context.Context, event device.AddressEvent)

OnAddressEvent implements device.AddressObserver. It filters events before enqueuing: only Created and Enabled events trigger enforcement.

func (s *Service) OnRuleEvent(ctx context.Context, event rule.RuleEvent)

OnRuleEvent implements rule.RuleObserver. It triggers enforcement when the max active addresses rule is enabled or updated.

func (s *Service) RunListener(ctx context.Context) error

RunListener processes address and rule events until the context is cancelled. Run this in a goroutine.