ebpfem

Documentation

Index

• Constants
• type EBPFem
  • func New() *EBPFem
  • func (e *EBPFem) BlockLink(source orchestrator.MachineID, target net.IPNet) error
  • func (e *EBPFem) Register(id orchestrator.MachineID, netIf string) error
  • func (e *EBPFem) SetBandwidth(source orchestrator.MachineID, target net.IPNet, bandwidthKbits uint64) error
  • func (e *EBPFem) SetLatency(source orchestrator.MachineID, target net.IPNet, latency uint32) error
  • func (e *EBPFem) Stop() error
  • func (e *EBPFem) UnblockLink(source orchestrator.MachineID, target net.IPNet) error

Constants

const (
	DEFAULT_LATENCY_US     = 0
	DEFAULT_BANDWIDTH_KBPS = 1_000_000

	BLOCKED_LATENCY_US     = 1_000_000_000
	BLOCKED_BANDWIDTH_KBPS = 0
)

Types

type EBPFem

type EBPFem struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New() *EBPFem

func (*EBPFem) BlockLink

func (e *EBPFem) BlockLink(source orchestrator.MachineID, target net.IPNet) error

func (*EBPFem) Register

func (e *EBPFem) Register(id orchestrator.MachineID, netIf string) error

func (*EBPFem) SetBandwidth

func (e *EBPFem) SetBandwidth(source orchestrator.MachineID, target net.IPNet, bandwidthKbits uint64) error

func (*EBPFem) SetLatency

func (e *EBPFem) SetLatency(source orchestrator.MachineID, target net.IPNet, latency uint32) error

func (*EBPFem) Stop

func (e *EBPFem) Stop() error

func (*EBPFem) UnblockLink

func (e *EBPFem) UnblockLink(source orchestrator.MachineID, target net.IPNet) error