diff --git a/internal/util/etcd/etcd_util.go b/internal/util/etcd/etcd_util.go index a3a57cc2b6..2b18fb7167 100644 --- a/internal/util/etcd/etcd_util.go +++ b/internal/util/etcd/etcd_util.go @@ -27,8 +27,10 @@ import ( "go.etcd.io/etcd/server/v3/etcdserver/api/v3client" ) +// EtcdServer is the singleton of embedded etcd server var EtcdServer *embed.Etcd +// InitEtcdServer initializes embedded etcd server singleton. func InitEtcdServer(pt *paramtable.BaseParamTable) error { if pt.UseEmbedEtcd { path := pt.EtcdConfigPath @@ -54,6 +56,7 @@ func InitEtcdServer(pt *paramtable.BaseParamTable) error { return nil } +// StopEtcdServer stops embedded etcd server singleton. func StopEtcdServer() { if EtcdServer != nil { EtcdServer.Close()