activator

Documentation

Index

• Constants
• Variables
• func MapsPath() string
• func MountBPFFS(path string) error
• func MountDebugFS() error
• func PinPath(pid int) string
• type BPF
  • func InitBPF(pid int) (*BPF, error)
  • func (bpf *BPF) AttachRedirector(ifaces ...string) error
  • func (bpf *BPF) Cleanup() error
• type OnAccept
• type Server
  • func NewServer(ctx context.Context, nn ns.NetNS) (*Server, error)
  • func (s *Server) DisableRedirects() error
  • func (a *Server) RedirectPort(from, to uint16) error
  • func (s *Server) Reset() error
  • func (s *Server) Start(ctx context.Context, ports []uint16, onAccept OnAccept) error
  • func (s *Server) Started() bool
  • func (s *Server) Stop(ctx context.Context)

Constants

const BPFFSPath = "/sys/fs/bpf"

Variables

var ErrMapNotFound = errors.New("bpf map could not be found")

Functions

func MapsPath

func MapsPath() string

func MountBPFFS

func MountBPFFS(path string) error

MountBPFFS executes a mount -t bpf on the supplied path

func MountDebugFS

func MountDebugFS() error

MountBPFFS mounts the kernel debugfs

func PinPath

func PinPath(pid int) string

Types

type BPF

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

func InitBPF

func InitBPF(pid int) (*BPF, error)

func (*BPF) AttachRedirector

func (bpf *BPF) AttachRedirector(ifaces ...string) error

func (*BPF) Cleanup

func (bpf *BPF) Cleanup() error

type OnAccept

type OnAccept func() error

type Server

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

func NewServer

func NewServer(ctx context.Context, nn ns.NetNS) (*Server, error)

func (*Server) DisableRedirects

func (s *Server) DisableRedirects() error

func (*Server) RedirectPort

func (a *Server) RedirectPort(from, to uint16) error

RedirectPort redirects the port from to on ingress and to from on egress.

func (*Server) Reset

func (s *Server) Reset() error

func (*Server) Start

func (s *Server) Start(ctx context.Context, ports []uint16, onAccept OnAccept) error

func (*Server) Started

func (s *Server) Started() bool

func (*Server) Stop

func (s *Server) Stop(ctx context.Context)