cni

package

v1.16.0 Latest Latest Go to latest Published: Feb 14, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubeedge/edgemesh

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Register(c *v1alpha1.EdgeCNIConfig, cli *clients.Clients) error
type Adapter
type EdgeCni
type MeshAdapter
- func NewMeshAdapter(cfg *v1alpha1.EdgeCNIConfig, cli clientset.Interface) (*MeshAdapter, error)

Constants ¶

View Source

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

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL