tc

func EnsureMQQdisc ¶

func EnsureMQQdisc(link netlink.Link) error

EnsureMQQdisc write qdisc

func FilterAdd ¶

func FilterAdd(filter netlink.Filter) error

func FilterDel ¶

func FilterDel(filter netlink.Filter) error

func FilterListBySrcIP ¶

func FilterListBySrcIP(link netlink.Link, parent uint32, ipNets []*net.IPNet) ([]*netlink.U32, error)

FilterBySrcIP found u32 filter by pod ip used for prio only

func NewU32RuleBySrcIP ¶

func NewU32RuleBySrcIP(linkIndex int, parentID uint32, ipnet *net.IPNet) *netlink.U32

func QdiscDel ¶

func QdiscDel(qdisc netlink.Qdisc) error

func QdiscReplace ¶

func QdiscReplace(qdisc netlink.Qdisc) error

func U32IPv4Src ¶

func U32IPv4Src(ipNet *net.IPNet) netlink.TcU32Key

func U32IPv6Src ¶

func U32IPv6Src(ipNet *net.IPNet) []netlink.TcU32Key

func U32KeyToIPNet ¶

func U32KeyToIPNet(keys []nl.TcU32Key) *net.IPNet

U32KeyToIPNet convert u32 key to ipnet

func U32MatchSrc ¶

func U32MatchSrc(ipNet *net.IPNet) []netlink.TcU32Key

U32MatchSrc return u32 match key by src ip