Versions in this module Expand all Collapse all v2 v2.0.0 Jul 8, 2024 Changes in this version + const MainTablePrefix + var ErrNfTablesProcessor = errors.New("NfTablesProcessor error") + var ErrPatchNotApplicable = errors.New("patch is not applicable") + var NewTx = nftrc.NewTx + func BeginRule() (ret ruleBuilder) + func IfBaseRulesFromConfig(ctx context.Context, cons func(BaseRules) error) error + func LastAppliedRulesUpd(netNS string, data *AppliedRules) + func MakeBatchBackoff() backoff.Backoff + func PatchAppliedRules(ctx context.Context, rules *AppliedRules, p Patch) (err error) + func WithBaseRules(baseRules BaseRules) funcBatchOpt — linux/amd64 + func WithLogger(l logger.TypeOfLogger) funcBatchOpt — linux/amd64 + type AppliedRules struct + BaseRules BaseRules + ID uuid.UUID + LocalData resources.LocalData + NetNS string + TargetTable string + func LastAppliedRules(netNS string) *AppliedRules + type BaseRules struct + Nets []config.NetCIDR + type BatchOpt interface — linux/amd64 + type BatchPerformer struct — linux/amd64 + TableName string + Tx TxProvider + func (exc *BatchPerformer) Exec(ctx context.Context, data resources.LocalData, opts ...BatchOpt) error + type IPAdresses = host.IPAdresses + type IPAdressesMapKey = host.IPAdressesMapKey + type IpAddr = host.IpAddr + type IpDev = host.IpDev + type IpDevs = host.IpDevs + type LinkID = host.LinkID + type LinkRefs = host.LinkRefs + type NFTablesConf = nftrc.StateOfNFTables — linux/amd64 + func NFTconfLoad(conn *nftlib.Conn) (NFTablesConf, error) + type NetConf = host.NetConf + type NfChain = nftrc.NfChain — linux/amd64 + type NfChainKey = nftrc.NfChainKey — linux/amd64 + type NfSet = nftrc.NfSet — linux/amd64 + type NfTableKey = nftrc.NfTableKey — linux/amd64 + type NfTablesProcessor interface + ApplyConf func(ctx context.Context, data resources.LocalData) (AppliedRules, error) + Close func() error + func NewNfTablesProcessor(client SGClient, opts ...NfTablesProcessorOpt) NfTablesProcessor + type NfTablesProcessorOpt interface + type Patch interface + Apply func(context.Context, *AppliedRules) error + String func() string + type SGClient = sgAPI.SecGroupServiceClient + type Tx = nftrc.Tx + type TxProvider func() (*Tx, error) — linux/amd64 + type UpdStrategy = host.UpdStrategy + type UpdateFqdnNetsets struct + Addresses []net.IP + FQDN model.FQDN + IPVersion int + func (ns UpdateFqdnNetsets) Apply(ctx context.Context, rules *AppliedRules) error + func (ns UpdateFqdnNetsets) NetSet() []net.IPNet + func (p UpdateFqdnNetsets) String() string + type WithNetNS struct + NetNS string
Go to main page