watchers

type Action ¶

type Action string

const (
	AddAction Action = "added"
	RmAction  Action = "removed"
)

type ChainEvent ¶

type ChainEvent nftEvent[*nftLib.Chain]

func (c ChainEvent) ActionInfo() string

type ErrWatcher ¶

type ErrWatcher struct {
	Err error
}

ErrWatcher -

func (e ErrWatcher) Cause() error

func (e ErrWatcher) Error() string

type Link ¶

type Link struct {
	Name  string
	Index int
}

type LinkEvent ¶

type LinkEvent event[Link]

func (l LinkEvent) ActionInfo() string

type NftEvent ¶

type NftEvent event[NftEventFace]

func (t NftEvent) ActionInfo() string

type NftEventFace ¶

type NftEventFace interface {
	ActionInfo() string
	// contains filtered or unexported methods
}

type RuleEvent ¶

type RuleEvent nftEvent[*nftLib.Rule]

func (r RuleEvent) ActionInfo() string

type SetElementEvent ¶

type SetElementEvent nftEvent[*nlparser.SetElems]

func (t SetElementEvent) ActionInfo() string

type SetEvent ¶

type SetEvent nftEvent[*nftLib.Set]

func (s SetEvent) ActionInfo() string

type TableEvent ¶

type TableEvent nftEvent[*nftLib.Table]

func (t TableEvent) ActionInfo() string

type Watcher ¶

type Watcher[T watcherT] interface {
	Close() error
	Stream(ctx context.Context) <-chan WatcherEvent[T]
}

Watcher is an interface for a watcher that can stream events of type T. T is a type that implements the watcherT interface, which can be either Link or Rule.

type WatcherEvent ¶

type WatcherEvent[T watcherT] struct {
	Evt T
	Err error
}