flowctl

Documentation

Index

• func FlowOutputLog(flows []ebpfmap.Flow, out string, o ipfix.OutputLog) error
• func NewCommand() *cobra.Command
• func NewCommandAgent() *cobra.Command
• func NewCommandDependencyCheck() *cobra.Command
• func NewCommandDump() *cobra.Command
• func NewCommandEbpf() *cobra.Command
• func NewCommandEbpfCodeDump() *cobra.Command
• func NewCommandFlush() *cobra.Command
• func NewCommandIpfix() *cobra.Command
• func NewCommandIpfixDump() *cobra.Command
• func NewCommandIpfixTemplate() *cobra.Command
• func NewCommandMeter() *cobra.Command
• func NewCommandMeterAttach() *cobra.Command
• func NewCommandMeterDetach() *cobra.Command
• func NewCommandMeterStatus() *cobra.Command
• type FlowMeterByteCode
  • func DecodeFromBpfName(bpfname string) (*FlowMeterByteCode, error)
  • func DecodeFromFullpath(s string) (*FlowMeterByteCode, error)
  • func NewFlowMeterByteCode(netns, device string, lim uint16) (*FlowMeterByteCode, error)
  • func (v FlowMeterByteCode) EncodeToFilename() string
  • func (v FlowMeterByteCode) SameDigest(bpfname string) (bool, error)
• type SystemCapability
  • func (sc SystemCapability) Capable() bool
  • func (sc SystemCapability) DumpToStdout()
  • func (sc *SystemCapability) Get() error

Functions

func FlowOutputLog

func FlowOutputLog(flows []ebpfmap.Flow, out string, o ipfix.OutputLog) error

func NewCommand

func NewCommand() *cobra.Command

func NewCommandAgent

func NewCommandAgent() *cobra.Command

func NewCommandDependencyCheck

func NewCommandDependencyCheck() *cobra.Command

func NewCommandDump

func NewCommandDump() *cobra.Command

func NewCommandEbpf

func NewCommandEbpf() *cobra.Command

func NewCommandEbpfCodeDump

func NewCommandEbpfCodeDump() *cobra.Command

func NewCommandFlush

func NewCommandFlush() *cobra.Command

func NewCommandIpfix

func NewCommandIpfix() *cobra.Command

func NewCommandIpfixDump

func NewCommandIpfixDump() *cobra.Command

func NewCommandIpfixTemplate

func NewCommandIpfixTemplate() *cobra.Command

func NewCommandMeter

func NewCommandMeter() *cobra.Command

func NewCommandMeterAttach

func NewCommandMeterAttach() *cobra.Command

func NewCommandMeterDetach

func NewCommandMeterDetach() *cobra.Command

func NewCommandMeterStatus

func NewCommandMeterStatus() *cobra.Command

Types

type FlowMeterByteCode

type FlowMeterByteCode struct {
	// AttachedTime indicates when the tc filter was created.
	AttachedTime time.Time
	// Digest is a Hash of Code. It is used to determine if the Bytecode
	// currently in use needs to be changed.
	// Code contains the source code of the BPF program. This is useful
	// to check the differences between versions, since the table entry
	// size is not embedded.
	Digest string
	// NetnsName indicates network namespace name like ns0, ns1, etc...
	// It's not include device information.
	// Currently we are expecting the name is not include special characters,
	// like .,:/-?
	NetnsName string
	// DeviceName indicates network interface name like eth0, eth1, etc...
	// It's not include namespace information
	// It is possible to include special characters like .-@
	DeviceName string
	// InterfaceMaxFlowLimit will be mapped on follow
	// #define INTERFACE_MAX_FLOW_LIMIT 6
	InterfaceMaxFlowLimit uint16
}

func DecodeFromBpfName

func DecodeFromBpfName(bpfname string) (*FlowMeterByteCode, error)

func DecodeFromFullpath

func DecodeFromFullpath(s string) (*FlowMeterByteCode, error)

func NewFlowMeterByteCode

func NewFlowMeterByteCode(netns, device string, lim uint16) (*FlowMeterByteCode, error)

func (FlowMeterByteCode) EncodeToFilename

func (v FlowMeterByteCode) EncodeToFilename() string

func (FlowMeterByteCode) SameDigest

func (v FlowMeterByteCode) SameDigest(bpfname string) (bool, error)

type SystemCapability

type SystemCapability struct {
	ClangVersionCurrent         string
	ClangVersionExpected        string
	KernelVersionCurrent        string
	KernelVersionExpected       string
	Iproute2binVersionCurrent   string
	Iproute2binVersionExpected  string
	Iproute2lbpfVersionCurrent  string
	Iproute2lbpfVersionExpected string
}

func (SystemCapability) Capable

func (sc SystemCapability) Capable() bool

func (SystemCapability) DumpToStdout

func (sc SystemCapability) DumpToStdout()

func (*SystemCapability) Get

func (sc *SystemCapability) Get() error