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

v4/Taskfile.yml

@@ -24,7 +24,6 @@ tasks:
     desc: "Обновление зависимостей"
     cmds:
       - clear
-      - go fmt ./...
       - go mod tidy -compat=1.26.4
       - go mod vendor
       - go fmt ./...

v4/kern.go

@@ -14,7 +14,6 @@ import (
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmonolit"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kserv_http"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kspec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev2/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/lsi/kstore_kv"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/lti/bus_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/lti/kbus_http"
@@ -28,7 +27,7 @@ import (
 )
 
 // GetKernelCtx -- возвращает контекст ядра.
-func GetKernelCtx() mKs.IKernelCtx {
+func GetKernelCtx() kspec.IKernelCtx {
 	ctx := kctx.GetKernelCtx()
 	return ctx
 }
@@ -49,13 +48,13 @@ func WrapErr[T any](res mL0.IResult[T], err error) mL0.IResult[T] {
 }
 
 // GetKernelStoreKv -- возвращает быстрое key-value хранилище ядра.
-func GetKernelStoreKv() mKs.IKernelStoreKv {
+func GetKernelStoreKv() kspec.IKernelStoreKv {
 	store := kstore_kv.GetKernelStore()
 	return store
 }
 
 // GetKernelServerHttp -- возвращает веб-сервер ядра.
-func GetKernelServerHttp() mKs.IKernelServerHttp {
+func GetKernelServerHttp() kspec.IKernelServerHttp {
 	kernServHttp := kserv_http.GetKernelServHttp()
 	return kernServHttp
 }
@@ -88,7 +87,7 @@ func SleepMs() {
 }
 
 // GetMonolitLocal -- возвращает монолит с локальной шиной.
-func GetMonolitLocal(name string) mKs.IKernelMonolit {
+func GetMonolitLocal(name string) kspec.IKernelMonolit {
 	kCtx := kctx.GetKernelCtx()
 	kCtx.Set("isLocal", true, "bus type")
 	for {
@@ -104,7 +103,7 @@ func GetMonolitLocal(name string) mKs.IKernelMonolit {
 }
 
 // GetMonolitHttp -- возвращает монолит с локальной шиной поверх HTTP.
-func GetMonolitHttp(name string) mKs.IKernelMonolit {
+func GetMonolitHttp(name string) kspec.IKernelMonolit {
 	kCtx := kctx.GetKernelCtx()
 	_ = kbus_http.GetKernelBusHttp()
 	kCtx.Set("isLocal", false, "bus type")
@@ -120,7 +119,7 @@ func GetMonolitHttp(name string) mKs.IKernelMonolit {
 }
 
 // NewKernelModule -- возвращает новый модуль на ядре.
-func NewKernelModule(name *module_name.AModuleName) mKs.IKernelModule {
+func NewKernelModule(name *module_name.AModuleName) kspec.IKernelModule {
 	resMod := kmodule.NewKernelModule(name)
 	return resMod
 }
@@ -144,71 +143,87 @@ func GetModuleServHttp() kspec.IKernelModule {
 }
 
 // GetModuleKernelCtx -- возвращает модуль для IKernelCtx.
-func GetModuleKernelCtx() mKs.IKernelModule {
+func GetModuleKernelCtx() kspec.IKernelModule {
 	kModCtx := mod_kctx.GetModuleKernelCtx()
 	return kModCtx
 }
 
 // GetModuleKernelKeeper -- возвращает модуль для IKernelKeeper.
-func GetModuleKernelKeeper() mKs.IKernelModule {
+func GetModuleKernelKeeper() kspec.IKernelModule {
 	modKernelKeeper := mod_keeper.GetModuleKeeper()
 	return modKernelKeeper
 }
 
 // GetModuleWui -- возвращает модуль для WUI.
-func GetModuleWui() mKs.IKernelModule {
+func GetModuleWui() kspec.IKernelModule {
 	modWui := mod_wui.GetModuleWui()
 	return modWui
 }
 
-// ILogBuf -- буферизованный лог
+// ILogBuf -- буферизованный лог.
 type ILogBuf = comp_spec.ILogBuf
 
 // LogBufParam -- параметры для создания нового буферизованного лога.
 type LogBufParam = mL1.LogBufParam
 
 // NewLogBuf -- возвращает новый буферизованный лог.
+//
+//go:fix inline
 func NewLogBuf(param *LogBufParam) ILogBuf {
 	log := mL1.NewLogBuf(param)
 	return log
 }
 
 // NewSafeBoolReact -- возвращает новую потокобезопасную реактивную булеву переменную.
+//
+//go:fix inline
 func NewSafeBoolReact() core_spec.ISafeBoolReact {
 	val := mL1.NewSafeBoolReact()
 	return val
 }
 
 // NewSafeInt -- возвращает новую потокобезопасную целочисленную переменную.
+//
+//go:fix inline
 func NewSafeInt(val int) core_spec.ISafeInt {
 	val_ := mL1.NewSafeInt(val)
 	return val_
 }
 
 // NewInt -- возвращает новую целочисленную переменную.
+//
+//go:fix inline
 func NewInt(val int) core_spec.Int {
 	val_ := mL1.NewInt(val)
 	return val_
 }
 
 // NewLocalCtx -- возвращает новый локальный контекст.
+//
+//go:fix inline
 func NewLocalCtx(ctx context.Context) comp_spec.ILocalCtx {
 	lCtx := mL1.NewLocalCtx(ctx)
 	return lCtx
 }
 
 // NewSafeString -- возвращает новую потокобезопасную строку.
+//
+//go:fix inline
 func NewSafeString() core_spec.ISafeString {
 	str := mL1.NewSafeString()
 	return str
 }
 
 // NewSome -- возвращает новый не пустой результат операции.
+//
+//go:fix inline
 func NewSome[T any](some T) mL0.IOption[T] {
 	return mL0.NewSome(some)
 }
 
 // NewNone -- возвращает новый пустой результат операции.
+//
+//go:fix inline
 func NewNone[T any]() mL0.IOption[T] {
 	return mL0.NewNone[T]()
 }
@@ -217,6 +232,8 @@ func NewNone[T any]() mL0.IOption[T] {
 type FnHassert = mL1.FnHassert
 
 // Hassert -- возвращает ссылку на функцию Hassert.
+//
+//go:fix inline
 func Hassert() FnHassert {
 	return mL1.Hassert()
 }
@@ -225,6 +242,8 @@ func Hassert() FnHassert {
 type FnAssert = mL1.FnAssert
 
 // Assert -- возвращает ссылку на функцию Hassert.
+//
+//go:fix inline
 func Assert() FnAssert {
 	return mL1.Assert()
 }

v4/lev0/core_spec/ichan.go

@@ -1,15 +1,15 @@
 package core_spec
 
-// IChan -- умный канал
+// IChan -- умный канал.
 type IChan[T any] interface {
-	// Read -- читает сообщение из канала
+	// Read -- читает сообщение из канала.
 	Read() IResult[T]
-	// Limit -- лимит канала
+	// Limit -- лимит канала.
 	Limit() int
-	// Len -- количество сообщений в канале
+	// Len -- количество сообщений в канале.
 	Len() int
-	// Close -- закрыть канал
+	// Close -- закрыть канал.
 	Close()
-	// IsClosed -- проверяет закрыт ли канал
+	// IsClosed -- проверяет закрыт ли канал.
 	IsClosed() bool
 }

v4/lev0/etypes/ebool/ebool.go

@@ -30,16 +30,22 @@ func NewEBoolMut(val bool) mKs.EBoolMut {
 }
 
 // IsNot -- проверяет на false.
+//
+//go:fix inline
 func (sf *EBool) IsNot() bool {
-	return sf.val == false
+	return !sf.val
 }
 
 // IsOk -- проверяет на true.
+//
+//go:fix inline
 func (sf *EBool) IsOk() bool {
-	return sf.val == true
+	return sf.val
 }
 
 // IsMut -- возвращает признак мутабельности.
+//
+//go:fix inline
 func (sf *EBool) IsMut() bool {
 	return sf.isMut
 }

v4/lev1/local_ctx/ctx_value/ctx_value.go

@@ -6,7 +6,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/voc/etime"
 )
 
@@ -29,9 +28,9 @@ type ICtxValue interface {
 type CtxValue struct {
 	sync.RWMutex
 	key       string
-	createAt  mKs.ITime
+	createAt  core_spec.ITime
 	Val_      any
-	UpdateAt_ mKs.ITimeMut
+	UpdateAt_ core_spec.ITimeMut
 	Comment_  string
 }
 
@@ -61,14 +60,14 @@ func (sf *CtxValue) Val() any {
 }
 
 // UpdateAt -- возвращает время обновления значения.
-func (sf *CtxValue) UpdateAt() mKs.ITimeMut {
+func (sf *CtxValue) UpdateAt() core_spec.ITimeMut {
 	sf.RLock()
 	defer sf.RUnlock()
 	return sf.UpdateAt_
 }
 
 // CreateAt -- возвращает время создания значения.
-func (sf *CtxValue) CreateAt() mKs.ITime {
+func (sf *CtxValue) CreateAt() core_spec.ITime {
 	return sf.createAt
 }
 

v4/lev1/log_buf/log_buf.go

@@ -7,7 +7,6 @@ import (
 	"sync"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/log_buf/log_msg"
 )
@@ -40,10 +39,10 @@ var (
 	hassert = helpers.Hassert
 )
 
-// LogBufParam -- параметры логирующего буфера
+// LogBufParam -- параметры логирующего буфера.
 type LogBufParam struct {
-	Prefix_ string        // Префикс для сообщений
-	IsTerm_ mKs.ISafeBool // Признак вывода в терминал
+	Prefix_ string              // Префикс для сообщений
+	IsTerm_ core_spec.ISafeBool // Признак вывода в терминал
 }
 
 // SelfCheck -- проверяет корректность параметров.
@@ -73,7 +72,7 @@ func NewLogBuf(param *LogBufParam) ILogBuf {
 }
 
 // IsTerm -- возвращает признак логирования.
-func (sf *LogBuf) IsTerm() mKs.ISafeBool {
+func (sf *LogBuf) IsTerm() core_spec.ISafeBool {
 	return sf.IsTerm_
 }
 

v4/lev1/safe_bool/safe_bool.go

@@ -9,7 +9,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 )
 
@@ -20,7 +19,7 @@ type safeBool struct {
 }
 
 // NewSafeBool -- возвращает новый потокобезопасный булевый признак.
-func NewSafeBool(val bool) mKs.ISafeBool {
+func NewSafeBool(val bool) core_spec.ISafeBool {
 	sf := &safeBool{
 		val: val,
 	}
@@ -28,23 +27,23 @@ func NewSafeBool(val bool) mKs.ISafeBool {
 }
 
 // NewSafeBoolFromStr -- возвращает новое потокобезопасное булево из строки.
-func NewSafeBoolFromStr(strVal string) mL0.IResult[mKs.ISafeBool] {
+func NewSafeBoolFromStr(strVal string) mL0.IResult[core_spec.ISafeBool] {
 	sf := NewSafeBool(false)
 	res := sf.FromStr(strVal)
 	if res.IsErr() {
 		err := fmt.Errorf("NewSafeBoolFromStr(): in parse str(%v), err=\n\t%w", strVal, res.Err())
-		return mL0.NewErr[mKs.ISafeBool](err)
+		return mL0.NewErr[core_spec.ISafeBool](err)
 	}
 	return mL0.NewOk(sf)
 }
 
 // NewSafeBoolGetenv -- возвращает новое потокобезопасное целое из окружения.
-func NewSafeBoolGetenv(env string) mL0.IResult[mKs.ISafeBool] {
+func NewSafeBoolGetenv(env string) mL0.IResult[core_spec.ISafeBool] {
 	sf := NewSafeBool(false)
 	res := sf.Getenv(env)
 	if res.IsErr() {
 		err := fmt.Errorf("NewSafeBoolGetenv(): in parse env(%v), err=\n\t%w", env, res.Err())
-		return mL0.NewErr[mKs.ISafeBool](err)
+		return mL0.NewErr[core_spec.ISafeBool](err)
 	}
 	return mL0.NewOk(sf)
 }

v4/lev1/safe_bool_react/safe_bool_react.go

@@ -9,7 +9,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 )
 
@@ -21,7 +20,7 @@ type safeBoolReact struct {
 }
 
 // NewSafeBoolReact -- возвращает новый потокобезопасный булевый признак с реакцией на своё изменение.
-func NewSafeBoolReact() mKs.ISafeBoolReact {
+func NewSafeBoolReact() core_spec.ISafeBoolReact {
 	sf := &safeBoolReact{
 		dict: map[string]func(core_spec.EBoolMut){},
 	}
@@ -29,23 +28,23 @@ func NewSafeBoolReact() mKs.ISafeBoolReact {
 }
 
 // NewSafeBoolReactFromStr -- возвращает новое потокобезопасное булево с реакцией из строки.
-func NewSafeBoolReactFromStr(strVal string) mL0.IResult[mKs.ISafeBoolReact] {
+func NewSafeBoolReactFromStr(strVal string) mL0.IResult[core_spec.ISafeBoolReact] {
 	sf := NewSafeBoolReact()
 	res := sf.FromStr(strVal)
 	if res.IsErr() {
 		err := fmt.Errorf("NewSafeBoolReactFromStr(): in parse str(%v), err=\n\t%w", strVal, res.Err())
-		return mL0.NewErr[mKs.ISafeBoolReact](err)
+		return mL0.NewErr[core_spec.ISafeBoolReact](err)
 	}
 	return mL0.NewOk(sf)
 }
 
 // NewSafeBoolGetenv -- возвращает новое потокобезопасное целое с реакцией из окружения.
-func NewSafeBoolGetenv(env string) mL0.IResult[mKs.ISafeBoolReact] {
+func NewSafeBoolGetenv(env string) mL0.IResult[core_spec.ISafeBoolReact] {
 	sf := NewSafeBoolReact()
 	res := sf.Getenv(env)
 	if res.IsErr() {
 		err := fmt.Errorf("NewSafeBoolGetenv(): in parse env(%v), err=\n\t%w", env, res.Err())
-		return mL0.NewErr[mKs.ISafeBoolReact](err)
+		return mL0.NewErr[core_spec.ISafeBoolReact](err)
 	}
 	return mL0.NewOk(sf)
 }

v4/lev1/safe_bool_react/safe_bool_react_test.go

@@ -5,12 +5,11 @@ import (
 	"testing"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	. "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 )
 
 type tester struct {
 	t   *testing.T
-	sbr ISafeBoolReact
+	sbr core_spec.ISafeBoolReact
 	val core_spec.EBoolMut
 }
 

v4/lev2/kchan/kchan.go

@@ -15,7 +15,7 @@ var (
 	hassert = mL0.Hassert
 )
 
-// KChanParam -- параметры умного канала
+// KChanParam -- параметры умного канала.
 type KChanParam[T any] struct {
 	Limit_   int                 // лимит на размер канала, не может быть пустым
 	OnWrite_ func(T)             // Обратный вызов при записи в канал
@@ -25,7 +25,7 @@ type KChanParam[T any] struct {
 	Ctx_     comp_spec.ILocalCtx // Локальный контекст для контроля создателя
 }
 
-// SelfCheck -- проверка корректности правильности параметров умного канала
+// SelfCheck -- проверка корректности правильности параметров умного канала.
 func (sf *KChanParam[T]) SelfCheck() {
 	hassert(sf.Limit_ > 0, "KChanParam[T].SelfCheck(): limit=%v, канал должен иметь положительный лимит")
 	hassert(sf.Ctx_ != nil, "KChanParam[T]: ctx==nil")
@@ -49,7 +49,7 @@ type KChan[T any] struct {
 	lstMsg   []T
 }
 
-// NewKChan -- создаёт новый безопасный умный канал
+// NewKChan -- создаёт новый безопасный умный канал.
 func NewKChan[T any](param *KChanParam[T]) core_spec.IChan[T] {
 	hassert(param != nil, "NewKChan: param==nil")
 	param.SelfCheck()
@@ -61,7 +61,7 @@ func NewKChan[T any](param *KChanParam[T]) core_spec.IChan[T] {
 	return sf
 }
 
-// Read -- возвращает первый элемент очереди (если есть)
+// Read -- возвращает первый элемент очереди (если есть).
 func (sf *KChan[T]) Read() core_spec.IResult[T] {
 	sf.block.Lock()
 	defer sf.block.Unlock()
@@ -75,33 +75,33 @@ func (sf *KChan[T]) Read() core_spec.IResult[T] {
 	return mL0.NewOk(msg)
 }
 
-// Limit -- ограничение размера канала
+// Limit -- ограничение размера канала.
 func (sf *KChan[T]) Limit() int {
 	sf.block.RLock()
 	defer sf.block.RUnlock()
 	return len(sf.lstMsg)
 }
 
-// Len -- возвращает количество элементов в канале
+// Len -- возвращает количество элементов в канале.
 func (sf *KChan[T]) Len() int {
 	sf.block.RLock()
 	defer sf.block.RUnlock()
 	return len(sf.lstMsg)
 }
 
-// IsClosed -- возвращает признак закрытия канала
+// IsClosed -- возвращает признак закрытия канала.
 func (sf *KChan[T]) IsClosed() bool {
 	return sf.isClosed.Get()
 }
 
-// Close -- закрывает канал
+// Close -- закрывает канал.
 func (sf *KChan[T]) Close() {
 	sf.block.Lock()
 	defer sf.block.Unlock()
 	sf.isClosed.Set()
 }
 
-// Ожидает закрытия канала по контексту
+// Ожидает закрытия канала по контексту.
 func (sf *KChan[T]) close() {
 	sf.Ctx_.Wait()
 	sf.isClosed.Set()

v4/lev2/kmodule/kmodule.go

@@ -6,7 +6,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/module_name"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
@@ -25,8 +24,8 @@ type kModule struct {
 	ctx       comp_spec.ILocalCtx
 	name      *module_name.AModuleName
 	bus       bus_spec.IKernelBus
-	timePhase mKs.ISafeInt
-	strLive   mKs.ISafeString
+	timePhase core_spec.ISafeInt
+	strLive   core_spec.ISafeString
 	stat      kspec.IModuleStat
 }
 
@@ -73,7 +72,7 @@ func (sf *kModule) Name() *module_name.AModuleName {
 }
 
 // IsWork -- возвращает признак состояния работы.
-func (sf *kModule) IsWork() mKs.EBool {
+func (sf *kModule) IsWork() core_spec.EBool {
 	mL0.Hassert(false, "kModule.IsWork(): module='%v', parent not realized this method", sf.name)
 	return ebool.NewEBool(false)
 }

v4/lev2/kmonolit/kmonolit.go

@@ -7,7 +7,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/module_name"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
@@ -24,8 +23,8 @@ type kMonolit struct {
 	log     comp_spec.ILogBuf
 	name    string
 	isLocal core_spec.EBool
-	isWork  mKs.ISafeBool
-	isEnd   mKs.ISafeBool
+	isWork  core_spec.ISafeBool
+	isEnd   core_spec.ISafeBool
 	dict    map[*module_name.AModuleName]kspec.IKernelModule // Словарь модулей монолита
 }
 

v4/lev2/kwg/kwg.go

@@ -9,7 +9,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/stream_name"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
@@ -25,7 +24,7 @@ type kernelWg struct {
 	sync.RWMutex
 	ctx        context.Context
 	dictStream map[*stream_name.AStreamName]bool // Словарь имён потоков с признаком работы
-	isWork     mKs.ISafeBool
+	isWork     core_spec.ISafeBool
 	log        comp_spec.ILogBuf
 }
 

v4/lev2/lsi/kstore_kv/kstore_kv.go

@@ -11,7 +11,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/stream_name"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
@@ -36,7 +35,7 @@ type kStoreKv struct {
 	wg        kspec.IKernelWg
 	storePath string
 	db        *badger.DB
-	isWork    mKs.ISafeBool
+	isWork    core_spec.ISafeBool
 }
 
 var (

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

@@ -7,39 +7,38 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/store_key"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 )
 
 // DictRec -- потокобезопасный словарь KV-бакета.
 type DictRec struct {
-	dict  map[*store_key.AStoreKey]mKs.IRecKv
+	dict  map[*store_key.AStoreKey]core_spec.IRecKv
 	block sync.RWMutex
 }
 
 // NewDictRec -- создание нового потокобезопасного словаря KV.
 func NewDictRec() *DictRec {
 	sf := &DictRec{
-		dict: map[*store_key.AStoreKey]mKs.IRecKv{},
+		dict: map[*store_key.AStoreKey]core_spec.IRecKv{},
 	}
-	_ = mKs.IDictRec(sf)
+	_ = core_spec.IDictRec(sf)
 	return sf
 }
 
 // Get -- получение значения по ключу.
-func (sf *DictRec) Get(key *store_key.AStoreKey) mL0.IOption[mKs.IRecKv] {
+func (sf *DictRec) Get(key *store_key.AStoreKey) mL0.IOption[core_spec.IRecKv] {
 	sf.block.RLock()
 	defer sf.block.RUnlock()
 	rec, isOk := sf.dict[key]
 	if !isOk {
-		return mL0.NewNone[mKs.IRecKv]()
+		return mL0.NewNone[core_spec.IRecKv]()
 	}
 	return mL0.NewSome(rec)
 }
 
 // Set -- установка значения по ключу.
-func (sf *DictRec) Set(rec mKs.IRecKv) mL0.IResult[core_spec.EBool] {
+func (sf *DictRec) Set(rec core_spec.IRecKv) mL0.IResult[core_spec.EBool] {
 	if rec == nil {
 		return mL0.NewErr[core_spec.EBool](fmt.Errorf("DictRec.Set(): rec is nil"))
 	}

v4/lev2/lti/bus_ent/topic/topic.go

@@ -4,10 +4,10 @@ import (
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
 )
 
-// ATopic -- имя топика в шине
+// ATopic -- имя топика в шине.
 type ATopic string
 
-// ITopicFix -- неизменяемое имя топика в шине
+// ITopicFix -- неизменяемое имя топика в шине.
 type ITopicFix interface {
 	// Get -- возвращает имя топика
 	Get() ATopic
@@ -15,7 +15,7 @@ type ITopicFix interface {
 	String() string
 }
 
-// ITopicMut -- изменяемое имя топика в шине
+// ITopicMut -- изменяемое имя топика в шине.
 type ITopicMut interface {
 	ITopicFix
 	// Set -- устанавливает имя топика

v4/lev2/lti/kbus_base/kbus_base.go

@@ -7,7 +7,6 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
-	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/stream_name"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/ebool"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
@@ -84,7 +83,7 @@ func (sf *KBusBase) Unsubscribe(handler bus_spec.IBusHandlerSubscribe) {
 }
 
 // Subscribe -- подписывает обработчик на топик.
-func (sf *KBusBase) Subscribe(handler bus_spec.IBusHandlerSubscribe) mKs.IResult[core_spec.EBool] {
+func (sf *KBusBase) Subscribe(handler bus_spec.IBusHandlerSubscribe) core_spec.IResult[core_spec.EBool] {
 	sf.log.Debug("KBusBase.Subscribe(): handler='%v'", handler.Name())
 	mL0.Hassert(!sf.IsWork_.Get(), "KBusBase.Subscribe():  handler='%v', bus already closed", handler.Name())
 	sf.dictSub.Subscribe(handler)

v4/lev2/lti/kbus_base/kbus_base_test.go

@@ -18,6 +18,7 @@ type tester struct {
 }
 
 var (
+	//go:fix inline
 	qNameSub   = bus_ent.NewTopicFix("topic_hand_sub")
 	qNameServe = bus_ent.NewTopicFix("topic_hand_serv")
 )

v4/lev2/lti/kbus_local/client_bus_local/client_bus_local_test.go

@@ -19,13 +19,11 @@ func TestClientBusLocal(t *testing.T) {
 	sf.new()
 }
 
-var (
-	qTopicLocal = bus_ent.NewTopicFix("local_topic")
-)
-
 // Создание нового клиента.
 func (sf *tester) new() {
 	sf.t.Log("new")
+	//go:fix inline
+	qTopicLocal := bus_ent.NewTopicFix("local_topic")
 	sf.lClient = NewClientBusLocal()
 	if sf.lClient == nil {
 		sf.t.Fatalf("new(): client==nil")

v4/lev2/lti/kbus_local/kbus_local_test.go

@@ -16,12 +16,9 @@ type tester struct {
 	handServ *mock_hand_serve.MockHandlerServe
 }
 
-var (
-	qTopicSub  = bus_ent.NewTopicFix("topic_hand_sub")
-	qTopicServ = bus_ent.NewTopicFix("topic_hand_serv")
-)
-
 func TestKernelBusLocal(t *testing.T) {
+	qTopicSub := bus_ent.NewTopicFix("topic_hand_sub")
+	qTopicServ := bus_ent.NewTopicFix("topic_hand_serv")
 	sf := &tester{
 		t:        t,
 		handSub:  mock_hand_sub_local.NewMockHandlerSub(qTopicSub, "mock_hand_sub"),