「连载」边缘计算（三十三）03-15：边缘部分源码（源码分析篇）

KubeEdge/edgemesh/pkg/proxy/proxy.go

// Init: init the proxy. create virtual device and assign ips, etc..

func Init() {

go func() {

unused = make([]string, 0)

addrByService = &addrTable{}

c := context.GetContext(context.MsgCtxTypeChannel)

metaClient = client.New(c)

//create virtual network device

for {

err := vdev.CreateDevice()

if err == nil {

break

}

klog.Warningf("[L4 Proxy] create Device is failed : %s", err)

//there may have some exception need to be fixed on OS

time.Sleep(2 * time.Second)

}

//configure vir ip

ipPoolSize = 0

expandIpPool()

//open epoll

ep, err := poll.CreatePoll(pollCallback)

if err != nil {

vdev.DestroyDevice()

klog.Errorf("[L4 Proxy] epoll is open failed : %s", err)

return

}

epoll = ep

go epoll.Loop()

klog.Infof("[L4 Proxy] proxy is running now")

}()

}

KubeEdge/edgemesh/pkg/server/server.go

func Start() {

//Initialize the resolvers

r := &resolver.MyResolver{"http"}

resolver.RegisterResolver(r)

//Initialize the handlers

config.GlobalDefinition = &model.GlobalCfg{}

config.GlobalDefinition.Panel.Infra = "fake"

opts := control.Options{

Infra:   config.GlobalDefinition.Panel.Infra,

Address: config.GlobalDefinition.Panel.Settings["address"],

}

config.GlobalDefinition.Ssl = make(map[string]string)

control.Init(opts)

opt := registry.Options{}

registry.DefaultServiceDiscoveryService = edgeregistry.NewServiceDiscovery(opt)

myStrategy := mconfig.CONFIG.GetConfigurationByKey("mesh.loadbalance.strategy-name").(string)

loadbalancer.InstallStrategy(myStrategy, func() loadbalancer.Strategy {

switch myStrategy {

case "RoundRobin":

return &loadbalancer.RoundRobinStrategy{}

case "Random":

return &loadbalancer.RandomStrategy{}

default:

return &loadbalancer.RoundRobinStrategy{}

}

})

//Start dns server

go DnsStart()

//Start server

StartTCP()

}

KubeEdge/edgemesh/pkg/module.go

//Start sets context and starts the controller

func (em *EdgeMesh) Start(c *context.Context) {

...

// we need watch message to update the cache of instances

for {

if msg, ok := em.context.Receive(constant.ModuleNameEdgeMesh); ok == nil {

proxy.MsgProcess(msg)

klog.Infof("get message: %v", msg)

continue

}

}

}