Archived
31 lines
469 B
Go
31 lines
469 B
Go
package rpc
|
|
|
|
import (
|
|
"github.com/TeaOSLab/EdgeNode/internal/configs"
|
|
"sync"
|
|
)
|
|
|
|
var sharedRPC *RPCClient = nil
|
|
var locker = &sync.Mutex{}
|
|
|
|
func SharedRPC() (*RPCClient, error) {
|
|
locker.Lock()
|
|
defer locker.Unlock()
|
|
|
|
if sharedRPC != nil {
|
|
return sharedRPC, nil
|
|
}
|
|
|
|
config, err := configs.LoadAPIConfig()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
client, err := NewRPCClient(config)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
sharedRPC = client
|
|
return sharedRPC, nil
|
|
}
|