cni

Documentation

Index

• Constants
• func Register(c *v1alpha1.EdgeCNIConfig, cli *clients.Clients) error
• type Adapter
• type EdgeCni
  • func (cni *EdgeCni) CleanupAndExit() error
  • func (cni *EdgeCni) Enable() bool
  • func (cni *EdgeCni) Group() string
  • func (cni *EdgeCni) Name() string
  • func (cni *EdgeCni) Run()
  • func (cni *EdgeCni) Shutdown()
  • func (cni *EdgeCni) Start()
• type MeshAdapter
  • func NewMeshAdapter(cfg *v1alpha1.EdgeCNIConfig, cli clientset.Interface) (*MeshAdapter, error)
  • func (mesh *MeshAdapter) CheckTunCIDR(outerCidr string) (bool, error)
  • func (mesh *MeshAdapter) CloseRoute()
  • func (mesh *MeshAdapter) GetNodeNameByPodIP(podIP string) (string, error)
  • func (mesh *MeshAdapter) HandleReceiveFromTun()
  • func (mesh *MeshAdapter) Run()
  • func (mesh *MeshAdapter) TunToTunnel()
  • func (mesh *MeshAdapter) WatchRoute() error

Constants

const (
	TCP          = "tcp"
	AgentPodName = "edgemesh-agent"
)

Functions

func Register

func Register(c *v1alpha1.EdgeCNIConfig, cli *clients.Clients) error

Register edgeproxy to beehive modules

Types

type Adapter

type Adapter interface {
	// HandleReceive deal with data from Pod to Tunnel
	TunToTunnel()

	// WatchRoute watch CIDR in overlayNetwork and insert Route to Tun dev
	WatchRoute() error

	// CloseRoute close all the Tun and stream
	CloseRoute()
}

type EdgeCni

type EdgeCni struct {
	Config *v1alpha1.EdgeCNIConfig

	ConfigSyncPeriod time.Duration
	MeshAdapter      *MeshAdapter
	// contains filtered or unexported fields
}

EdgeCni is used for cni traffic control

func (*EdgeCni) CleanupAndExit

func (cni *EdgeCni) CleanupAndExit() error

func (*EdgeCni) Enable

func (cni *EdgeCni) Enable() bool

Enable indicates whether enable this module

func (*EdgeCni) Group

func (cni *EdgeCni) Group() string

Group of EdgeCni

func (*EdgeCni) Name

func (cni *EdgeCni) Name() string

Name of EdgeCni

func (*EdgeCni) Run

func (cni *EdgeCni) Run()

func (*EdgeCni) Shutdown

func (cni *EdgeCni) Shutdown()

Shutdown edgeproxy

func (*EdgeCni) Start

func (cni *EdgeCni) Start()

Start EdgeCni

type MeshAdapter

type MeshAdapter struct {
	IptInterface utiliptables.Interface

	ConfigSyncPeriod time.Duration
	TunConn          *cni.TunConn
	HostCIDR         string
	Cloud            []string      // PodCIDR in cloud
	Edge             []string      // PodCIDR in edge
	Close            chan struct{} // stop signal
	// contains filtered or unexported fields
}

func NewMeshAdapter

func NewMeshAdapter(cfg *v1alpha1.EdgeCNIConfig, cli clientset.Interface) (*MeshAdapter, error)

func (*MeshAdapter) CheckTunCIDR

func (mesh *MeshAdapter) CheckTunCIDR(outerCidr string) (bool, error)

CheckTunCIDR check whether the mesh CIDR and the given parameter CIDR are in the same network or not.

func (*MeshAdapter) CloseRoute

func (mesh *MeshAdapter) CloseRoute()

func (*MeshAdapter) GetNodeNameByPodIP

func (mesh *MeshAdapter) GetNodeNameByPodIP(podIP string) (string, error)

func (*MeshAdapter) HandleReceiveFromTun

func (mesh *MeshAdapter) HandleReceiveFromTun()

func (*MeshAdapter) Run

func (mesh *MeshAdapter) Run()

func (*MeshAdapter) TunToTunnel

func (mesh *MeshAdapter) TunToTunnel()

func (*MeshAdapter) WatchRoute

func (mesh *MeshAdapter) WatchRoute() error