|
|
@@ -5,9 +5,10 @@ import (
|
|
|
"context"
|
|
|
"time"
|
|
|
|
|
|
- mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
|
|
|
+ "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
|
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
|
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
|
|
|
+
|
|
|
// "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
|
|
|
mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
|
|
|
"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
|
|
|
@@ -41,21 +42,21 @@ func GetKernelCtx() kspec.IKernelCtx {
|
|
|
}
|
|
|
|
|
|
// Result — обёртка вокруг результата с возможной ошибкой.
|
|
|
-type Result[T any] = mL0.Result[T]
|
|
|
+type Result[T any] = lev0.Result[T]
|
|
|
|
|
|
// NewErr -- возвращает Result с ошибкой.
|
|
|
-func NewErr[T any](err defs.IErr) *Result[T] {
|
|
|
- return mL0.NewErr[T](err)
|
|
|
+func NewErr[T any](err T) *Result[T] {
|
|
|
+ return lev0.NewErr[T](err)
|
|
|
}
|
|
|
|
|
|
// NewOk -- возвращает успешный Result с значением.
|
|
|
func NewOk[T any](res T) *Result[T] {
|
|
|
- return mL0.NewOk(res)
|
|
|
+ return lev0.NewOk(res)
|
|
|
}
|
|
|
|
|
|
// WrapErr -- оборачивает существующий Result с ошибкой с новой ошибкой.
|
|
|
-func WrapErr[T any](res *Result[T], err defs.IErr) *Result[T] {
|
|
|
- return mL0.WrapErr(res, err)
|
|
|
+func WrapErr[T any](res *Result[T], err T) *Result[T] {
|
|
|
+ return lev0.WrapErr(res, err)
|
|
|
}
|
|
|
|
|
|
// GetKernelStoreKv -- возвращает быстрое key-value хранилище ядра.
|
|
|
@@ -87,9 +88,9 @@ func NewSafeBool(val defs.Bool) ISafeBool {
|
|
|
// GetKernelBusLocal -- возвращает локальную шину данных.
|
|
|
func GetKernelBusLocal() bus_spec.IKernelBus {
|
|
|
kCtx := kctx.GetKernelCtx()
|
|
|
- kCtx.Set(defs.TxtFix("monolitName"),
|
|
|
+ kCtx.Set(defs.LetTxt("monolitName"),
|
|
|
"unknown monolit",
|
|
|
- defs.TxtFix("GetKernelBusLocal()"))
|
|
|
+ defs.LetTxt("GetKernelBusLocal()"))
|
|
|
lBus := kbus_local.GetKernelBusLocal()
|
|
|
return lBus
|
|
|
}
|
|
|
@@ -112,10 +113,10 @@ func SleepMs() {
|
|
|
// GetMonolitLocal -- возвращает монолит с локальной шиной.
|
|
|
func GetMonolitLocal(name mod_ent.AModuleName) mod_spec.IKernelMonolit {
|
|
|
kCtx := kctx.GetKernelCtx()
|
|
|
- kCtx.Set(defs.TxtFix("isLocal"), true, defs.TxtFix("bus type"))
|
|
|
+ kCtx.Set(defs.LetTxt("isLocal"), true, defs.LetTxt("bus type"))
|
|
|
for {
|
|
|
time.Sleep(time.Millisecond * 1)
|
|
|
- optIsLocal := kCtx.Get(defs.TxtFix("isLocal"))
|
|
|
+ optIsLocal := kCtx.Get(defs.LetTxt("isLocal"))
|
|
|
if optIsLocal.IsSome() {
|
|
|
break
|
|
|
}
|
|
|
@@ -129,10 +130,10 @@ func GetMonolitLocal(name mod_ent.AModuleName) mod_spec.IKernelMonolit {
|
|
|
func GetMonolitHttp(name mod_ent.AModuleName) mod_spec.IKernelMonolit {
|
|
|
kCtx := kctx.GetKernelCtx()
|
|
|
_ = kbus_http.GetKernelBusHttp()
|
|
|
- kCtx.Set(defs.TxtFix("isLocal"), false, defs.TxtFix("bus type"))
|
|
|
+ kCtx.Set(defs.LetTxt("isLocal"), false, defs.LetTxt("bus type"))
|
|
|
for {
|
|
|
time.Sleep(time.Millisecond * 1)
|
|
|
- optIsLocal := kCtx.Get(defs.TxtFix("isLocal"))
|
|
|
+ optIsLocal := kCtx.Get(defs.LetTxt("isLocal"))
|
|
|
if optIsLocal.IsSome() {
|
|
|
break
|
|
|
}
|
|
|
@@ -160,7 +161,7 @@ func NewClientBusLocal() bus_spec.IBusClient {
|
|
|
// NewClientBusHttp -- возвращает клиент для работы с шиной поверх HTTP.
|
|
|
//
|
|
|
|
|
|
-func NewClientBusHttp(url defs.ITxtFix) bus_spec.IBusClient {
|
|
|
+func NewClientBusHttp(url *defs.LTxt) bus_spec.IBusClient {
|
|
|
client := client_bus_http.NewClientBusHttp(url)
|
|
|
return client
|
|
|
}
|
|
|
@@ -230,8 +231,8 @@ func NewSafeInt(val defs.Int) core_spec.ISafeInt {
|
|
|
// NewInt -- возвращает новую целочисленную переменную.
|
|
|
//
|
|
|
|
|
|
-func NewInt(val defs.Int) core_spec.Int {
|
|
|
- val_ := mL1.NewInt(val)
|
|
|
+func LetInt(val lev0.Int) *lev0.LInt {
|
|
|
+ val_ := lev0.LetInt(val)
|
|
|
return val_
|
|
|
}
|
|
|
|
|
|
@@ -251,20 +252,15 @@ func NewSafeString() core_spec.ISafeString {
|
|
|
return str
|
|
|
}
|
|
|
|
|
|
+// Option — обёртка вокруг результата с возможной пустотой.
|
|
|
+type Option[T any] = lev0.Option[T]
|
|
|
+
|
|
|
// NewSome -- возвращает новый не пустой результат операции.
|
|
|
-func NewSome[T any](some T) mL0.IOption[T] {
|
|
|
- return mL0.NewSome(some)
|
|
|
+func NewSome[T any](some T) *Option[T] {
|
|
|
+ return lev0.NewSome(some)
|
|
|
}
|
|
|
|
|
|
// NewNone -- возвращает новый пустой результат операции.
|
|
|
-func NewNone[T any]() mL0.IOption[T] {
|
|
|
- return mL0.NewNone[T]()
|
|
|
+func NewNone[T any]() *Option[T] {
|
|
|
+ return lev0.NewNone[T]()
|
|
|
}
|
|
|
-
|
|
|
-// FnIf -- проверяет с жёстким падением условие.
|
|
|
-// type FnIf = helpers.FnIf
|
|
|
-
|
|
|
-// If -- возвращает ссылку на функцию If (Hasssert/Assert).
|
|
|
-// func If() FnIf {
|
|
|
-// return helpers.If
|
|
|
-// }
|