SVI Рабочее сохранение

v4/kern_test.go

@@ -159,8 +159,8 @@ func (sf *tester) new1() {
 	}
 }
 
-var(
-	str1=store_ent.NewStoreKeyFix("test_builders")
+var (
+	str1 = store_ent.NewStoreKeyFix("test_builders")
 )
 
 func (sf *tester) new0() {

v4/lev0/core_spec/isafe_bool_react.go

@@ -1,6 +1,6 @@
 package core_spec
 
-import(
+import (
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 )
 

v4/lev0/option/option_test.go

@@ -86,7 +86,7 @@ func (sf *testerOption) unwrapErr(res *Option[defs.AStr]) {
 }
 
 var (
-	str = defs.Str("test val")
+	str = defs.AStr("test val")
 )
 
 func (sf *testerOption) createSomeGood2() {
@@ -98,23 +98,23 @@ func (sf *testerOption) createSomeGood2() {
 	}()
 	opt := NewSome(str)
 	if !opt.IsSome() {
-		sf.t.Fatalf("createSomeGood1(): not ok")
+		sf.t.Fatalf("createSomeGood2(): not ok")
 	}
 	if opt.IsNone() {
-		sf.t.Fatalf("createSomeGood1(): is err")
+		sf.t.Fatalf("createSomeGood2(): is err")
 	}
 	if val := opt.Some(); val != str {
-		sf.t.Fatalf("createSomeGood1(): val bad")
+		sf.t.Fatalf("createSomeGood2(): val bad")
 	}
-	strTest1:=defs.Str("test1")
+	strTest1 := defs.AStr("test1")
 	if val := opt.SomeOr(strTest1); val != str {
-		sf.t.Fatalf("createSomeGood1(): val bad")
+		sf.t.Fatalf("createSomeGood2(): val bad")
 	}
-	if val := opt.SomeOr(strTest1); val.Str() != "str" {
-		sf.t.Fatalf("createSomeGood1(): val bad")
+	if val := opt.SomeOr(strTest1); val != "str" {
+		sf.t.Fatalf("createSomeGood2(): val bad")
 	}
 	if val := opt.SomeOrFn(sf.fnWrap); val != str {
-		sf.t.Fatalf("createSomeGood1(): val bad")
+		sf.t.Fatalf("createSomeGood2(): val bad")
 	}
 	opt.Hassert("test")
 	opt.Assert("test")

v4/lev0/quark/quark_int/quark_int.go

@@ -56,6 +56,6 @@ func FromStr(sf *QInt[quark_val.Mut], s string) {
 	iVal, err := strconv.Atoi(s)
 	mKh.Hassert(err == nil,
 		defs.Str("QInt.FromStr(): не удалось преобразовать строку(%v) в int, err=\n\t%v",
-		s, err))
+			s, err))
 	quark_val.Set(sf.Val(), iVal)
 }

v4/lev0/quark/quark_str/quark_str_test.go

@@ -19,8 +19,6 @@ func TestQStr(t *testing.T) {
 	sf.newMut()
 }
 
-
-
 // Создание строки с мутацией.
 func (sf *tester) newMut() {
 	sf.t.Log("newMut")

v4/lev0/result/result.go

@@ -13,13 +13,13 @@ import (
 //
 // Может быть либо только полезное значение, либо только ошибка.
 type Result[T any] struct {
-	val     T     // Полезное значение
-	isCheck bool  // Если проверено
+	val     T         // Полезное значение
+	isCheck bool      // Если проверено
 	err     defs.IErr // Ошибка
 }
 
 var (
-	str5 = defs.Str("NewOk(): result==nil")
+	str5 = defs.AStr("NewOk(): result==nil")
 )
 
 // NewOk -- возвращает успешный Result с значением.
@@ -28,7 +28,7 @@ func NewOk[T any](result T) mKs.IResult[T] {
 	v := reflect.ValueOf(result)
 	switch v.Kind() {
 	case reflect.Pointer, reflect.Slice, reflect.Map, reflect.Chan, reflect.Func, reflect.Interface:
-		mKh.Hassert(!v.IsNil(), str5.Str())
+		mKh.Hassert(!v.IsNil(), str5)
 	}
 	sf := &Result[T]{
 		val: result,
@@ -37,13 +37,13 @@ func NewOk[T any](result T) mKs.IResult[T] {
 	return sf
 }
 
-var(
-	str6= defs.Str("NewErr(): err==nil")
+var (
+	str6 = defs.AStr("NewErr(): err==nil")
 )
 
 // NewErr -- возвращает Result с ошибкой.
 func NewErr[T any](err defs.IErr) mKs.IResult[T] {
-	mKh.Hassert(err != nil, str6.Str())
+	mKh.Hassert(err != nil, str6)
 	sf := &Result[T]{
 		err: err,
 	}
@@ -51,28 +51,28 @@ func NewErr[T any](err defs.IErr) mKs.IResult[T] {
 	return sf
 }
 
-var(
-	str7=defs.Str("WrapErr(): result not have error")
-	str8=defs.Str("WrapErr(): err==nil")
+var (
+	str7 = defs.AStr("WrapErr(): result not have error")
+	str8 = defs.AStr("WrapErr(): err==nil")
 )
 
 // WrapErr -- оборачивает существующий Result с ошибкой с новой ошибкой.
 func WrapErr[T any](res mKs.IResult[T], err defs.IErr) mKs.IResult[T] {
-	mKh.Hassert(res.IsErr(), str7.Str())
-	mKh.Hassert(err != nil, str8.Str())
+	mKh.Hassert(res.IsErr(), str7)
+	mKh.Hassert(err != nil, str8)
 	err0 := res.Err() // Чтобы не было паники при финализации и обернуть ошибку
 	err = defs.NewErr("%v, err=\n\t%w", err0, err)
 	sf := NewErr[T](err)
 	return sf
 }
 
-var(
-	str9=defs.Str("Result[T].destroy(): err not checked")
+var (
+	str9 = defs.AStr("Result[T].destroy(): err not checked")
 )
 
 func (sf *Result[T]) destroy(res *Result[T]) {
 	if !res.isCheck {
-		mKh.Hassert(false, str9.Str())
+		mKh.Hassert(false, str9)
 	}
 }
 
@@ -90,7 +90,6 @@ func (sf *Result[T]) IsErr() bool {
 
 // Ok -- возвращает значение, если оно есть, иначе паникует.
 func (sf *Result[T]) Ok() T {
-
 	mKh.Hassert(sf.err == nil, "Result[T].Ok(): err!=nil, err=\n\t%v", sf.err)
 	sf.isCheck = true
 	return sf.val
@@ -106,13 +105,13 @@ func (sf *Result[T]) OkOr(defaultValue T) T {
 	return sf.Ok()
 }
 
-var(
-	str11=defs.Str("Result[T].OkOrFn(): fn==nil")
+var (
+	str11 = defs.AStr("Result[T].OkOrFn(): fn==nil")
 )
 
 // OkOrFn -- возвращает значение, если оно есть, или результат выполнения функции.
 func (sf *Result[T]) OkOrFn(fn func() T) T {
-	mKh.Hassert(fn != nil, str11.Str())
+	mKh.Hassert(fn != nil, str11)
 	sf.isCheck = true
 	if sf.err != nil {
 		sf.val = fn()
@@ -121,20 +120,24 @@ func (sf *Result[T]) OkOrFn(fn func() T) T {
 	return sf.Ok()
 }
 
-var(
-	str12=defs.Str("Result[T].Err(): err==nil")
+var (
+	str12 = defs.AStr("Result[T].Err(): err==nil")
 )
 
 // Err -- возвращает ошибку, если она есть.
 func (sf *Result[T]) Err() error {
-	mKh.Hassert(sf.err != nil, str12.Str())
+	mKh.Hassert(sf.err != nil, str12)
 	sf.isCheck = true
 	return sf.err
 }
 
+var(
+	str13= defs.AStr("Result[T].Error(): err==nil")
+)
+
 // Error -- возвращает строковое представление ошибки, если она есть.
 func (sf *Result[T]) Error() string {
-	mKh.Hassert(sf.err != nil, defs.Str("Result[T].Error(): err==nil"))
+	mKh.Hassert(sf.err != nil, str13)
 	sf.isCheck = true
 	return sf.err.Error()
 }
@@ -143,19 +146,19 @@ func (sf *Result[T]) Error() string {
 func (sf *Result[T]) Hassert(msgFormat defs.AStr, args ...any) T {
 	strErr := defs.AStr("")
 	if !sf.isCheck {
-		strErr = defs.Str(", err=\n\t%v", sf.err).Str()
+		strErr = defs.Str("Result[T].Hassert(): not check error, err=\n\t%v", sf.err)
 	}
-	msg := defs.Str(msgFormat+strErr, args...)
-	mKh.Hassert(sf.err == nil, msg)
+	strErr = defs.Str(msgFormat+strErr, args...)
+	mKh.Hassert(sf.err == nil, strErr)
 	sf.isCheck = true
 	return sf.val
 }
 
 // Assert -- проверяет, что нет ошибки (с паникой только на локальном стенде).
 func (sf *Result[T]) Assert(msgFormat defs.AStr, args ...any) T {
-	strErr := defs.Str("")
+	strErr := defs.AStr("")
 	if !sf.isCheck {
-		strErr = defs.Str(", err=\n\t%v", sf.err).Str()
+		strErr = defs.Str("Result[T].Assert(): not check error, , err=\n\t%v", sf.err).Str()
 	}
 	mKh.Assert(sf.err == nil, msgFormat+strErr, args...)
 	sf.isCheck = true

v4/lev0/result/result_test.go

@@ -21,8 +21,8 @@ func TestResult(t *testing.T) {
 
 }
 
-var(
-	str1=defs.Str("test")
+const (
+	str1 = defs.AStr("test result")
 )
 
 // Создаёт новый результат и не проверяет его.
@@ -102,8 +102,8 @@ func (sf *tester) createErrGood1() {
 	sf.assert2()
 }
 
-var(
-	str2=defs.Str("test assert2")
+const (
+	str2 = defs.AStr("test assert2")
 )
 
 func (sf *tester) assert2() {
@@ -118,8 +118,8 @@ func (sf *tester) assert2() {
 	res.Assert(str2)
 }
 
-var(
-	str3=defs.Str("test hassert2")
+const (
+	str3 = "test hassert2"
 )
 
 func (sf *tester) hassert2(res mKs.IResult[string]) {
@@ -132,8 +132,8 @@ func (sf *tester) hassert2(res mKs.IResult[string]) {
 	res.Hassert(str3)
 }
 
-var(
-	str4=defs.Str("test assert")
+const (
+	str4 = "test assert"
 )
 
 func (sf *tester) hassert(res mKs.IResult[string]) {
@@ -202,7 +202,7 @@ func (sf *tester) createOkGood2() {
 	if err := res0.Err(); err == nil {
 		sf.t.Fatalf("createOkGood1(): err==nil")
 	}
-	str1:=defs.Str("test assert")
+	str1 := defs.Str("test assert")
 	res.Hassert(str1)
 	res.Assert(str1)
 }

v4/lev1/local_ctx/ctx_value/ctx_value.go

@@ -37,7 +37,7 @@ type CtxValue struct {
 
 // NewCtxValue -- возвращает новое потокобезопасное значение локального контекста.
 func NewCtxValue(key defs.AStr, val any, comment defs.AStr) ICtxValue {
-	helpers.Hassert(key.Str() != "", "NewCtxValue(): key is empty", []any{})
+	helpers.Hassert(key != "", "NewCtxValue(): key is empty", []any{})
 	sf := &CtxValue{
 		key:       key,
 		createAt:  etime.NewETimeAuto(),

v4/lev1/local_ctx/ctx_value/ctx_value_test.go

@@ -4,7 +4,6 @@ import (
 	"testing"
 
 	. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 )
 
 type tester struct {
@@ -23,7 +22,7 @@ func TestCtxValue(t *testing.T) {
 // Создаёт значение локального контекста.
 func (sf *tester) new() {
 	sf.t.Log("new")
-	sf.val = NewCtxValue(defs.Str("test_key"), 5, defs.Str("test_value"))
+	sf.val = NewCtxValue("test_key", 5, "test_value")
 	if sf.val == nil {
 		sf.t.Fatalf("new(): val==nil")
 	}

v4/lev1/local_ctx/local_ctx.go

@@ -48,8 +48,8 @@ type LocalCtx struct {
 	fnCancel func()          // Функция отмены контекста
 
 	dictVal map[defs.AStr]comp_spec.ICtxValue // Словарь различных значений
-	lstSort *lst_sort.LstSort              // Сортированный список значений
-	log     comp_spec.ILogBuf              // Локальный буфер
+	lstSort *lst_sort.LstSort                 // Сортированный список значений
+	log     comp_spec.ILogBuf                 // Локальный буфер
 }
 
 // NewLocalCtx -- возвращает новый локальный контекст.
@@ -99,7 +99,7 @@ func (sf *LocalCtx) Get(key defs.AStr) mL0.IOption[comp_spec.ICtxValue] {
 	if key == "" {
 		return mL0.NewNone[comp_spec.ICtxValue]()
 	}
-	msg:=defs.Str("Get(): key='%v'", key)
+	msg := defs.Str("Get(): key='%v'", key)
 	sf.log.Debug(msg)
 	val, isOk := sf.dictVal[key]
 	if !isOk {
@@ -112,7 +112,7 @@ func (sf *LocalCtx) Get(key defs.AStr) mL0.IOption[comp_spec.ICtxValue] {
 func (sf *LocalCtx) Del(key defs.AStr) {
 	sf.Lock()
 	defer sf.Unlock()
-	msg:=defs.Str("Del(): key='%v'", key)
+	msg := defs.Str("Del(): key='%v'", key)
 	sf.log.Debug(msg)
 	val := sf.dictVal[key.Str()]
 	delete(sf.dictVal, key.Str())
@@ -123,7 +123,7 @@ func (sf *LocalCtx) Del(key defs.AStr) {
 func (sf *LocalCtx) Set(key defs.AStr, val any, comment defs.AStr) {
 	sf.Lock()
 	defer sf.Unlock()
-	msg:=defs.Str("Set(): key='%v'", key)
+	msg := defs.Str("Set(): key='%v'", key)
 	sf.log.Debug(msg)
 	_val, isOk := sf.dictVal[key]
 	if isOk {

v4/lev1/local_ctx/local_ctx_test.go

@@ -52,9 +52,9 @@ func (sf *tester) get() {
 // Устанавливает значение.
 func (sf *tester) set() {
 	sf.t.Log("set")
-	msg:=defs.Str("count")
-	sf.lCtx.Set(msg, 5, defs.Str("test_val"))
-	sf.lCtx.Set(msg, 15, defs.Str("test_val1"))
+	msg := defs.AStr("count")
+	sf.lCtx.Set(msg, 5, "test_val")
+	sf.lCtx.Set(msg, 15, "test_val1")
 }
 
 // Создание нового локального контекста.

v4/lev1/log_buf/log_buf.go

@@ -42,7 +42,7 @@ var (
 
 // LogBufParam -- параметры логирующего буфера.
 type LogBufParam struct {
-	Prefix_ defs.AStr              // Префикс для сообщений
+	Prefix_ defs.AStr           // Префикс для сообщений
 	IsTerm_ core_spec.ISafeBool // Признак вывода в терминал
 }
 

v4/lev1/safe_bool/safe_bool.go

@@ -80,7 +80,7 @@ func (sf *safeBool) FromStr(strVal defs.AStr) core_spec.IResult[core_spec.EBool]
 	case "false":
 		sf.val = false
 	default:
-		err:=defs.NewErr("safeBool.FromStr(): val(%v) bad", strVal)
+		err := defs.NewErr("safeBool.FromStr(): val(%v) bad", strVal)
 		return mL0.NewErr[core_spec.EBool](err)
 	}
 	return mL0.NewOk(ebool.NewEBool(sf.val))

v4/lev1/safe_bool_react/safe_bool_react.go

@@ -61,12 +61,12 @@ func (sf *safeBoolReact) Add(key defs.AStr, fn func(core_spec.EBoolMut)) mL0.IRe
 	sf.Lock()
 	defer sf.Unlock()
 	if key == "" {
-		err:=defs.NewErr("safeBoolReact.Add(): key is empty")
+		err := defs.NewErr("safeBoolReact.Add(): key is empty")
 		return mL0.NewErr[core_spec.EBool](err)
 	}
 	_, isOk := sf.dict[key]
 	if isOk {
-		err:=defs.NewErr("safeBoolReact.Add(): key(%v) already exists", key)
+		err := defs.NewErr("safeBoolReact.Add(): key(%v) already exists", key)
 		return mL0.NewErr[core_spec.EBool](err)
 	}
 	sf.dict[key] = fn
@@ -111,7 +111,7 @@ func (sf *safeBoolReact) FromStr(strVal defs.AStr) core_spec.IResult[core_spec.E
 	case "false":
 		sf.val = false
 	default:
-		err:=defs.NewErr("safeBoolReact.FromStr(): val(%v) bad", strVal)
+		err := defs.NewErr("safeBoolReact.FromStr(): val(%v) bad", strVal)
 		return mL0.NewErr[core_spec.EBool](err)
 	}
 	return mL0.NewOk(ebool.NewEBool(sf.val))

v4/lev2/kctx/kctx.go

@@ -5,7 +5,6 @@ import (
 	"context"
 	"sync"
 
-	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kernel_keeper"
@@ -66,7 +65,7 @@ func (sf *kCtx) Wg() kspec.IKernelWg {
 // Done -- блокирующий вызов ожидания отмены контекста ядра.
 func (sf *kCtx) Done() {
 	<-sf.ctx.Done()
-	sf.log.Debug(defs.Str("kCtx.Done()"))
+	sf.log.Debug("kCtx.Done()")
 }
 
 // CtxBg -- возвращает неотменяемый контекст ядра (лучше не использовать).
@@ -77,5 +76,5 @@ func (sf *kCtx) CtxBg() context.Context {
 // Cancel -- отменяет контекст ядра.
 func (sf *kCtx) Cancel() {
 	sf.fnCancel()
-	sf.log.Debug(defs.Str("kCtx.Cancel()"))
+	sf.log.Debug("kCtx.Cancel()")
 }

v4/lev2/kctx/kctx_test.go

@@ -2,8 +2,6 @@ package kctx
 
 import (
 	"testing"
-
-	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 )
 
 type tester struct {
@@ -17,6 +15,8 @@ func TestKernelCtx(t *testing.T) {
 	sf.new()
 }
 
+const counter = "counter"
+
 // Создание контекста ядра.
 func (sf *tester) new() {
 	sf.t.Log("new")
@@ -30,8 +30,7 @@ func (sf *tester) new() {
 	if ctx := kCtx.Ctx(); ctx == nil {
 		sf.t.Fatalf("new(): ctx==nil")
 	}
-	counter:=defs.Str("counter")
-	kCtx.Set(counter, 5, defs.Str("test_counter"))
+	kCtx.Set(counter, 5, "test_counter")
 	if kCtx.Get(counter) == nil {
 		sf.t.Fatalf("new(): counter==nil")
 	}

v4/lev2/kmonolit/kmonolit.go

@@ -42,8 +42,7 @@ func GetMonolit(name mod_ent.AModuleName) *kMonolit {
 	}
 	mKh.Hassert(name != "", "NewMonolit(): name is empty")
 	kCtx := kctx.GetKernelCtx()
-	strIsLocal:=defs.Str("isLocal")
-	opt := kCtx.Get(strIsLocal)
+	opt := kCtx.Get("isLocal")
 	opt.Hassert("GetMonolit(): in get from kernCtx isLocal -- not found")
 	isLocalCtx := opt.Some()
 	isLocal := isLocalCtx.Val().(bool)
@@ -95,7 +94,7 @@ func (sf *kMonolit) Add(module mod_spec.IKernelModule) {
 	}
 	key := defs.Str("module_%v", len(sf.dict))
 	moduleName := module.Name()
-	comment:=defs.Str("kMonolit.Add(): module="+moduleName.Str())
+	comment := defs.Str("kMonolit.Add(): module=" + moduleName.Str())
 	sf.lCtx.Set(key, module, comment)
 }
 

v4/lev2/kmonolit/kmonolit_test.go

@@ -100,6 +100,8 @@ func (sf *tester) new() {
 	sf.newGood1()
 }
 
+	const strIsLocal = "isLocal"
+
 func (sf *tester) newGood1() {
 	sf.t.Log("newGood1")
 	defer func() {
@@ -107,7 +109,6 @@ func (sf *tester) newGood1() {
 			sf.t.Fatalf("newGood1(): panic=%v", _panic)
 		}
 	}()
-	strIsLocal:=defs.Str("isLocal")
 	kCtx := kctx.GetKernelCtx()
 	kCtx.Set(strIsLocal, true, defs.Str("type bus"))
 	for {

v4/lev2/kwg/kwg.go

@@ -94,7 +94,7 @@ func (sf *kernelWg) Done(name *stream_name.AStreamName) {
 	sf.Lock()
 	defer sf.Unlock()
 	delete(sf.dictStream, name)
-	msg:=defs.Str("Done(): stream(%v) done", name)
+	msg := defs.Str("Done(): stream(%v) done", name)
 	sf.log.Debug(msg)
 }
 
@@ -113,7 +113,7 @@ func (sf *kernelWg) Wait() {
 func (sf *kernelWg) Add(name *stream_name.AStreamName) {
 	sf.Lock()
 	defer sf.Unlock()
-	msg:=defs.Str("Add(): stream('%v') done", name)
+	msg := defs.Str("Add(): stream('%v') done", name)
 	sf.log.Debug(msg)
 	mKh.Hassert(sf.isWork.Get(), "Add(): stream=%v, work end", []any{name})
 	mKh.Hassert(name.Get() != "", "Add(): name stream is empty")

v4/lev2/lsi/kstore_kv/kstore_kv.go

@@ -82,7 +82,7 @@ func (sf *kStoreKv) Log() comp_spec.ILogBuf {
 func (sf *kStoreKv) Set(rec store_ent.IRecKvFix) mL0.IResult[core_spec.EBool] {
 	sf.Lock()
 	defer sf.Unlock()
-	key:=rec.Key()
+	key := rec.Key()
 	sf.log.Debug("Set(): key='%v'", key.Get())
 	fnSet := func(txn *badger.Txn) error {
 		err := txn.Set(key.Byte(), rec.Val().Byte())
@@ -133,7 +133,7 @@ func (sf *kStoreKv) ByPrefix(prefix store_ent.IStoreKeyFix) core_spec.IResult[[]
 	fnPrefix := func(txn *badger.Txn) error {
 		it := txn.NewIterator(badger.DefaultIteratorOptions)
 		defer it.Close()
-		binPref:=prefix.Byte()
+		binPref := prefix.Byte()
 		for it.Seek(binPref); it.ValidForPrefix(binPref); it.Next() {
 			item := it.Item()
 			binKey = item.Key()

v4/lev2/lsi/kstore_kv_std/kv_bucket_base/kv_bucket_base.go

@@ -21,14 +21,14 @@ import (
 // Он должен быть разумным значением (например, до 100 МБ).
 // Как только бакет заполнится, он будет вытеснен на диск.
 type KvBucketBase struct {
-	Name_      string                                `json:"name"`       // Имя бакета
-	Level_     int                                   `json:"level"`      // Уровень бакета
-	Number_    int                                   `json:"num"`        // Номер бакета
-	Size_      int64                                 `json:"size"`       // Размер бакета
-	SizeLimit_ int64                                 `json:"size_limit"` // Лимит размера бакета
-	CreatedAt_ core_spec.ITime                       `json:"created_at"` // Время создания бакета
-	UpdatedAt_ core_spec.ITimeMut                    `json:"updated_at"` // Время обновления бакета
-	Vers_      int                                   `json:"vers"`       // Версия бакета
+	Name_      string                               `json:"name"`       // Имя бакета
+	Level_     int                                  `json:"level"`      // Уровень бакета
+	Number_    int                                  `json:"num"`        // Номер бакета
+	Size_      int64                                `json:"size"`       // Размер бакета
+	SizeLimit_ int64                                `json:"size_limit"` // Лимит размера бакета
+	CreatedAt_ core_spec.ITime                      `json:"created_at"` // Время создания бакета
+	UpdatedAt_ core_spec.ITimeMut                   `json:"updated_at"` // Время обновления бакета
+	Vers_      int                                  `json:"vers"`       // Версия бакета
 	dictRec    map[rec_key.ARecKey]rec_kv.IRecKvFix // Словарь для хранения данных
 }
 

v4/lev2/lsi/store_ent/dict_rec/dict_rec.go

@@ -53,7 +53,7 @@ func (sf *DictRec) Get(key rec_key.IRecKeyFix) mL0.IOption[rec_kv.IRecKvFix] {
 // Set -- установка значения по ключу.
 func (sf *DictRec) Set(rec rec_kv.IRecKvFix) mL0.IResult[core_spec.EBool] {
 	if rec == nil {
-		err:=defs.NewErr("DictRec.Set(): rec is nil")
+		err := defs.NewErr("DictRec.Set(): rec is nil")
 		return mL0.NewErr[core_spec.EBool](err)
 	}
 	sf.block.Lock()

v4/lev2/lsi/store_ent/dict_rec/dict_rec_test.go

@@ -52,7 +52,7 @@ func (sf *tester) set_good1() {
 // Возвращает новую запись для тестов.
 func (sf *tester) new_rec(key rec_key.ARecKey) rec_kv.IRecKvFix {
 	_key := rec_key.NewRecKey(key)
-	val := rec_val.NewRecVal([]byte(key+"_val"))
+	val := rec_val.NewRecVal([]byte(key + "_val"))
 	rec := rec_kv.NewRecKv(_key, val)
 	return rec
 }

v4/lev2/lsi/store_ent/rec_meta/rec_meta.go

@@ -31,11 +31,11 @@ type IRecMeta interface {
 // Даже если ключ содержит пробелы или экранированное форматирование
 // JSON их экранирует внутри.
 type RecMeta struct {
-	Key_       rec_key.ARecKey `json:"key"`       // Ключ
-	Vers_      int64               `json:"vers"`      // Версия записи
-	Operation_ string              `json:"operation"` // Тип операции над записью
-	createdAt_ core_spec.ITime     `voc:"created_at"` // Дата создания записи
-	updateAt_  core_spec.ITimeMut  `voc:"update_at"`  // Дата последнего обновления
+	Key_       rec_key.ARecKey    `json:"key"`       // Ключ
+	Vers_      int64              `json:"vers"`      // Версия записи
+	Operation_ string             `json:"operation"` // Тип операции над записью
+	createdAt_ core_spec.ITime    `voc:"created_at"` // Дата создания записи
+	updateAt_  core_spec.ITimeMut `voc:"update_at"`  // Дата последнего обновления
 
 	// Хеш мета-информации записи (вместе с значением, но без этого поля разумеется)
 	Sha_    string `json:"sha"`

v4/lev2/lti/bus_ent/handler_name/handler_name.go

@@ -33,7 +33,6 @@ func NewHandlerName(val AHandlerName) *HandlerName {
 	return sf
 }
 
-
 // Get -- получить значение.
 func (sf *HandlerName) Get() AHandlerName {
 	return AHandlerName(sf.AStr)

v4/lev2/lti/bus_mock/mock_hand_sub_local/mock_hand_sub.go

@@ -21,7 +21,7 @@ type MockHandlerSub struct {
 func NewMockHandlerSub(topic bus_ent.ITopicFix, localHook string) *MockHandlerSub {
 	mKh.Hassert(topic != nil, "NewMockHandlerSub(): topic is nil")
 	mKh.Hassert(localHook != "", "NewMockHandlerSub(): name is empty")
-	handlerName:=bus_ent.NewHandlerNameFix(bus_ent.AHandlerName(localHook + "_" + rand.Text()))
+	handlerName := bus_ent.NewHandlerNameFix(bus_ent.AHandlerName(localHook + "_" + rand.Text()))
 	sf := &MockHandlerSub{
 		Topic_: topic,
 		Name_:  handlerName,

v4/lev2/lti/dot/msg_serve/msg_serve.go

@@ -10,7 +10,7 @@ import (
 // ServeReq -- входящий запрос на обслуживание.
 type ServeReq struct {
 	Topic_  bus_ent.ATopic `json:"topic"`
-	Uuid_   defs.AStr         `json:"uuid"`
+	Uuid_   defs.AStr      `json:"uuid"`
 	BinReq_ []byte         `json:"req"`
 }
 
@@ -24,7 +24,7 @@ func (sf *ServeReq) SelfCheck() {
 type ServeResp struct {
 	Status_  defs.AStr `json:"status"`
 	Uuid_    defs.AStr `json:"uuid"`
-	BinResp_ []byte `json:"resp"`
+	BinResp_ []byte    `json:"resp"`
 }
 
 // SelfCheck -- проверяет правильность своих полей.

v4/lev2/lti/kbus/dict_sub_hook/dict_sub_hook.go

@@ -33,7 +33,7 @@ func (sf *dictSubHook) Unsubscribe(handler bus_spec.IBusHandlerSubscribe) {
 	sf.block.Lock()
 	defer sf.block.Unlock()
 	if handler == nil {
-		err:=defs.NewErr("dictSubHook.Unsubscribe(): handler==nil")
+		err := defs.NewErr("dictSubHook.Unsubscribe(): handler==nil")
 		sf.kCtx.Log().Err(err)
 		return
 	}

v4/lev2/lti/kbus/dict_topic_serve/dict_topic_serve.go

@@ -56,7 +56,7 @@ func (sf *dictServe) Unregister(handler bus_spec.IBusHandlerServe) {
 	sf.Lock()
 	defer sf.Unlock()
 	if handler == nil {
-		err:= defs.NewErr("dictServe.Unregister(): IBusHandlerSubscribe==nil")
+		err := defs.NewErr("dictServe.Unregister(): IBusHandlerSubscribe==nil")
 		sf.kCtx.Log().Err(err)
 		return
 	}

v4/lev2/lti/kbus_base/kbus_base.go

@@ -111,7 +111,7 @@ func (sf *KBusBase) SendRequest(topic bus_ent.ITopicFix, binReq []byte) mL0.IRes
 // RegisterServe -- регистрирует обработчики входящих запросов.
 func (sf *KBusBase) RegisterServe(handler bus_spec.IBusHandlerServe) mL0.IResult[core_spec.EBool] {
 	if handler == nil {
-		err:=defs.NewErr("KBusBase.RegisterServe(): IBusHandlerServe==nil")
+		err := defs.NewErr("KBusBase.RegisterServe(): IBusHandlerServe==nil")
 		return mL0.NewErr[core_spec.EBool](err)
 	}
 	sf.log.Debug("KBusBase.RegisterServe(): handler='%v'", handler.Name())

v4/lev2/lti/kbus_http/client_bus_http/client_bus_http.go

@@ -86,12 +86,12 @@ func (sf *ClientBusHttp) Unsubscribe(handler bus_spec.IBusHandlerSubscribe) {
 	resp := &dot.UnsubResp{}
 	err = json.Unmarshal(resBody.Ok(), resp)
 	if err != nil {
-		err:=defs.NewErr("Unsubscribe(): in unmarshal response, err=\n\t%v", err)
+		err := defs.NewErr("Unsubscribe(): in unmarshal response, err=\n\t%v", err)
 		sf.log.Err(err)
 		return
 	}
 	if resp.Status_ != "ok" {
-		err:=defs.NewErr("Unsubscribe(): resp!='ok', err=\n\t%v", resp.Status_)
+		err := defs.NewErr("Unsubscribe(): resp!='ok', err=\n\t%v", resp.Status_)
 		sf.log.Err(err)
 	}
 	if resp.Uuid_ != req.Uuid_ {
@@ -180,7 +180,7 @@ func (sf *ClientBusHttp) SendRequest(topic bus_ent.ITopicFix, binReq []byte) mL0
 // RegisterServe -- регистрирует в локальной шине обработчик.
 func (sf *ClientBusHttp) RegisterServe(handler bus_spec.IBusHandlerServe) mL0.IResult[mKs.EBool] {
 	if handler == nil {
-		err:=defs.NewErr("ClientBusHttp.RegisterServe(): handler==nil")
+		err := defs.NewErr("ClientBusHttp.RegisterServe(): handler==nil")
 		return mL0.NewErr[mKs.EBool](err)
 	}
 	res := sf.bus.RegisterServe(handler)

v4/lev2/lti/kbus_http/kbus_http.go

@@ -79,7 +79,7 @@ func (sf *kBusHttp) postSub(ctx fiber.Ctx) error {
 		}
 		resp.SelfCheck()
 		ctx.Response().SetStatusCode(http.StatusBadRequest)
-		err:=defs.NewErr("kBusHttp.postSub(): in body parser, status=%q", resp.Status_)
+		err := defs.NewErr("kBusHttp.postSub(): in body parser, status=%q", resp.Status_)
 		sf.log.Err(err)
 		return ctx.JSON(resp)
 	}
@@ -121,7 +121,7 @@ func (sf *kBusHttp) postPublish(ctx fiber.Ctx) error {
 		}
 		resp.SelfCheck()
 		ctx.Response().SetStatusCode(http.StatusBadRequest)
-		err:=defs.NewErr("postPublish(): in body parser, status=%v", resp.Status_)
+		err := defs.NewErr("postPublish(): in body parser, status=%v", resp.Status_)
 		sf.log.Err(err)
 		return ctx.JSON(resp)
 	}
@@ -161,7 +161,7 @@ func (sf *kBusHttp) postSendRequest(ctx fiber.Ctx) error {
 		}
 		resp.SelfCheck()
 		ctx.Response().SetStatusCode(http.StatusBadRequest)
-		err:=defs.NewErr("kBusHttp.postSendRequest(): in body parser, status=%v", resp.Status_)
+		err := defs.NewErr("kBusHttp.postSendRequest(): in body parser, status=%v", resp.Status_)
 		sf.log.Err(err)
 		return ctx.JSON(resp)
 	}
@@ -202,7 +202,7 @@ func (sf *kBusHttp) postUnsub(ctx fiber.Ctx) error {
 		}
 		resp.SelfCheck()
 		ctx.Response().SetStatusCode(http.StatusBadRequest)
-		err:=defs.NewErr("kBusHttp.postUnsub(): in body parser, status=%q", resp.Status_)
+		err := defs.NewErr("kBusHttp.postUnsub(): in body parser, status=%q", resp.Status_)
 		sf.log.Err(err)
 		return ctx.JSON(resp)
 	}

v4/lev3/mod_ent/module_name/module_name.go

@@ -62,4 +62,4 @@ func (sf *ModuleName) Rune() []rune {
 // Len -- длина строки.
 func (sf *ModuleName) Len() defs.Int {
 	return defs.Int(len(sf.name))
-}
+}