nftman

Documentation

Index

• Constants
• Variables
• type NFTManager
  • func New(opts ...Opt) (ret *NFTManager, err error)
  • func (nft *NFTManager) AddChainAndRulesForTProxies(tps []*config.TProxy) (err error)
  • func (nft *NFTManager) AddRoutes(routes []types.Route) (err error)
  • func (nft *NFTManager) Clear() (err error)
  • func (nft *NFTManager) Release() (err error)
  • func (nft *NFTManager) RemoveRoutes(paths []string) (err error)
• type Opt
  • func WithBypass(bypass config.Bypass) Opt
  • func WithCgroupRoot(root config.CGroupRoot) Opt
  • func WithConnFactory(f interfaces.NetlinkConnector) Opt
  • func WithLogger(log *zap.SugaredLogger) Opt

Constants

const (
	NftTableName = "cgtproxy"
)

Variables

var (
	ErrNftableConnMissing = errors.New("`nftables.Conn` is missing.")
	ErrRerouteMarkMissing = errors.New("reroute mark is missing.")
	ErrLoggerMissing      = errors.New("logger is missing.")
	ErrCGroupRootMissing  = errors.New("cgroupv2 file system mount point is missing.")
	ErrConnFactoryMissing = errors.New("netlink conn factory is missing.")
)

Types

type NFTManager

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

func New

func New(opts ...Opt) (ret *NFTManager, err error)

func (*NFTManager) AddChainAndRulesForTProxies

func (nft *NFTManager) AddChainAndRulesForTProxies(tps []*config.TProxy) (err error)

func (*NFTManager) AddRoutes

func (nft *NFTManager) AddRoutes(routes []types.Route) (err error)

func (*NFTManager) Clear

func (nft *NFTManager) Clear() (err error)

func (*NFTManager) Release

func (nft *NFTManager) Release() (err error)

func (*NFTManager) RemoveRoutes

func (nft *NFTManager) RemoveRoutes(paths []string) (err error)

type Opt

type Opt = (func(*NFTManager) (*NFTManager, error))

func WithBypass

func WithBypass(bypass config.Bypass) Opt

func WithCgroupRoot

func WithCgroupRoot(root config.CGroupRoot) Opt

func WithConnFactory

func WithConnFactory(f interfaces.NetlinkConnector) Opt

func WithLogger

func WithLogger(log *zap.SugaredLogger) Opt