filter

Feb 14, 2026

Changes in this version

+ var ErrNotConfigured = errors.New("filter is not configured")

type Backend

+ FlushAuthorizations func(ctx context.Context) (FlushResult, error)

+ type FlushResult struct

+ ActiveFlowsRemoved uint64

+ PendingEntriesRemoved uint64

+ type RuntimeConfigurator interface

+ ConfigureRuntime func(backend Backend, window time.Duration) error

type Service

+ func (s *Service) BlockAll(ctx context.Context) (FlushResult, error)

+ func (s *Service) ConfigureRuntime(backend Backend, window time.Duration) error

type UseCase

+ BlockAll func(ctx context.Context) (FlushResult, error)

Feb 4, 2026

Changes in this version

+ var ErrInvalidPort = errors.New("invalid port")

+ var ErrPortNotGuarded = errors.New("port is not guarded")

+ type Backend interface

+ InsertPending func(ctx context.Context, ip net.IP, port uint16, window time.Duration) error

+ IsPortGuarded func(ctx context.Context, port uint16) (bool, error)

+ Stats func(ctx context.Context) (Counters, error)

+ VerifyPending func(ctx context.Context, ip net.IP, port uint16) error

+ type Counters struct

+ ActiveFlowHits uint64

+ Allowed uint64

+ Dropped uint64

+ GuardedPortDropped uint64

+ IPPortAuthHits uint64

+ NonGuardedPortAllowed uint64

+ PendingExpiredCleanups uint64

+ PendingPromotions uint64

+ SYNAllowed uint64

+ SYNDropped uint64

+ type Options struct

+ Debug bool

+ Now func() time.Time

+ Window time.Duration

+ type Service struct

+ func New(backend Backend, opts Options) *Service

+ func (s *Service) Allow(ctx context.Context, ip net.IP, port uint16) (time.Time, error)

+ func (s *Service) Stats(ctx context.Context) (Stats, error)

+ type Stats struct

+ AllowRatePercent float64

+ DropRatePercent float64

+ type UseCase interface

+ Allow func(ctx context.Context, ip net.IP, port uint16) (expires time.Time, err error)

+ Stats func(ctx context.Context) (Stats, error)