SVI Добавление функций, нейминг; 100.0%

cmd/demo/main.go

@@ -9,7 +9,7 @@ import (
 var app IKernelMonolit
 
 func main() {
-	app = kern.NewMonolitLocal("Demo monolit")
+	app = kern.GetMonolitLocal("Demo monolit")
 
 	modServHttp := kern.NewModuleServHttp()
 	app.Add(modServHttp)

kern.go

@@ -10,6 +10,7 @@ import (
 	"gitp78su.ipnodns.ru/svi/kern/kc/safe_bool"
 	"gitp78su.ipnodns.ru/svi/kern/kc/safe_bool_react"
 	"gitp78su.ipnodns.ru/svi/kern/kc/safe_int"
+	"gitp78su.ipnodns.ru/svi/kern/kc/safe_string"
 	. "gitp78su.ipnodns.ru/svi/kern/krn/kalias"
 	"gitp78su.ipnodns.ru/svi/kern/krn/kbus/kbus_http"
 	"gitp78su.ipnodns.ru/svi/kern/krn/kbus/kbus_http/client_bus_http"
@@ -26,20 +27,20 @@ import (
 	"gitp78su.ipnodns.ru/svi/kern/mds/mod_serv_http"
 )
 
-// NewKernelCtx -- возвращает контекст ядра
-func NewKernelCtx() IKernelCtx {
+// GetKernelCtx -- возвращает контекст ядра
+func GetKernelCtx() IKernelCtx {
 	ctx := kctx.GetKernelCtx()
 	return ctx
 }
 
-// NewKernelStoreKv -- возвращает быстрое key-value хранилище ядра
-func NewKernelStoreKv() IKernelStoreKv {
+// GetKernelStoreKv -- возвращает быстрое key-value хранилище ядра
+func GetKernelStoreKv() IKernelStoreKv {
 	store := kstore_kv.GetKernelStore()
 	return store
 }
 
-// NewKernelServerHttp -- возвращает веб-сервер ядра
-func NewKernelServerHttp() IKernelServerHttp {
+// GetKernelServerHttp -- возвращает веб-сервер ядра
+func GetKernelServerHttp() IKernelServerHttp {
 	kernServHttp := kserv_http.GetKernelServHttp()
 	return kernServHttp
 }
@@ -50,22 +51,22 @@ func NewSafeBool() ISafeBool {
 	return sb
 }
 
-// NewKernelBusLocal -- возвращает локальную шину данных
-func NewKernelBusLocal() IKernelBus {
+// GetKernelBusLocal -- возвращает локальную шину данных
+func GetKernelBusLocal() IKernelBus {
 	ctx := kctx.GetKernelCtx()
 	ctx.Set("monolitName", "unknown monolit", "GetKernelBusLocal()")
 	bus := kbus_local.GetKernelBusLocal()
 	return bus
 }
 
-// NewKernelBusHttp -- возвращает HTTP шину данных
-func NewKernelBusHttp() IKernelBus {
+// GetKernelBusHttp -- возвращает HTTP шину данных
+func GetKernelBusHttp() IKernelBus {
 	bus := kbus_http.GetKernelBusHttp()
 	return bus
 }
 
-// NewMonolitLocal -- возвращает монолит с локальной шиной
-func NewMonolitLocal(name string) IKernelMonolit {
+// GetMonolitLocal -- возвращает монолит с локальной шиной
+func GetMonolitLocal(name string) IKernelMonolit {
 	ctx := kctx.GetKernelCtx()
 	ctx.Set("isLocal", true, "bus type")
 	for {
@@ -79,8 +80,8 @@ func NewMonolitLocal(name string) IKernelMonolit {
 	return monolit
 }
 
-// NewMonolitHttp -- возвращает монолит с локальной шиной поверх HTTP
-func NewMonolitHttp(name string) IKernelMonolit {
+// GetMonolitHttp -- возвращает монолит с локальной шиной поверх HTTP
+func GetMonolitHttp(name string) IKernelMonolit {
 	ctx := kctx.GetKernelCtx()
 	_ = kbus_http.GetKernelBusHttp()
 	ctx.Set("isLocal", false, "bus type")
@@ -153,3 +154,9 @@ func NewLocalCtx(ctx context.Context) ILocalCtx {
 	ctx_ := local_ctx.NewLocalCtx(ctx)
 	return ctx_
 }
+
+// NewSafeString -- возвращает новую потокобезопасную строку
+func NewSafeString() ISafeString {
+	str := safe_string.NewSafeString()
+	return str
+}

kern_test.go

@@ -44,11 +44,11 @@ func (sf *tester) newModBad() {
 // создание компонентов
 func (sf *tester) new() {
 	sf.t.Log("new")
-	ctx := NewKernelCtx()
+	ctx := GetKernelCtx()
 	if ctx == nil {
 		sf.t.Fatalf("new(): IKernelCtx==nil")
 	}
-	store := NewKernelStoreKv()
+	store := GetKernelStoreKv()
 	err := store.Delete("test_builders")
 	if err != nil {
 		sf.t.Fatalf("new(): get empty key, store, err=%v", err)
@@ -59,22 +59,22 @@ func (sf *tester) new() {
 		sf.t.Fatalf("new(): ISafeBool==nil")
 	}
 
-	kernBus := NewKernelBusLocal()
+	kernBus := GetKernelBusLocal()
 	if kernBus == nil {
 		sf.t.Fatalf("new(): (local) IKernelBus==nil")
 	}
 
-	kernBusHttp := NewKernelBusHttp()
+	kernBusHttp := GetKernelBusHttp()
 	if kernBusHttp == nil {
 		sf.t.Fatalf("new(): (http) IKernelBus==nil")
 	}
 
-	monLocal := NewMonolitLocal("mon_local")
+	monLocal := GetMonolitLocal("mon_local")
 	if monLocal == nil {
 		sf.t.Fatalf("new(): (local) IKernelMonolit==nil")
 	}
 
-	monHttp := NewMonolitHttp("mon_http")
+	monHttp := GetMonolitHttp("mon_http")
 	if monHttp == nil {
 		sf.t.Fatalf("new(): (http) IKernelMonolit==nil")
 	}
@@ -123,7 +123,12 @@ func (sf *tester) new() {
 		sf.t.Fatalf("new(): ILocalCtx==nil")
 	}
 
-	kernServHttp := NewKernelServerHttp()
+	safeStr := NewSafeString()
+	if safeStr == nil {
+		sf.t.Fatalf("new(): ISafeStr==nil")
+	}
+
+	kernServHttp := GetKernelServerHttp()
 	go kernServHttp.Run()
 	ctx.Cancel()
 	ctx.Wg().Wait()