SVI Переименование пакетов под более правильные имена

v4/lev0/defs/defs.go

@@ -1,4 +1,4 @@
-// package defs -- алиасы типов ядра.
+// package defs -- предметные типы ядра.
 package defs
 
 import (

v4/lev0/etypes/estr/estr.go

@@ -3,7 +3,7 @@ package estr
 
 import (
 	mHp "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // EStr -- расширенная строка.
@@ -50,7 +50,7 @@ func OptStrMut() FnOptStr {
 }
 
 // StrNew -- возвращает новую расширенную строку.
-func StrNew(opt ...FnOptStr) mKt.EStr {
+func StrNew(opt ...FnOptStr) mKs.EStr {
 	sf := &EStr{
 		lenMin: 0,
 		lenMax: 2_000_000_000,
@@ -63,7 +63,7 @@ func StrNew(opt ...FnOptStr) mKt.EStr {
 }
 
 // StrMutNew -- возвращает новую мутабельную расширенную строку.
-func StrMutNew(opt ...FnOptStr) mKt.EStrMut {
+func StrMutNew(opt ...FnOptStr) mKs.EStrMut {
 	sf := &EStr{
 		lenMin: 0,
 		lenMax: 2_000_000_000,

v4/lev0/etypes/etypes.go

@@ -1,16 +1,16 @@
-// package etypes --расширенные типы
+// package etypes -- расширенные типы
 package etypes
 
 import (
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes/estr"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // EStr - расширенная строка.
-type EStr = mKt.EStr
+type EStr = mKs.EStr
 
 // EStrMut - расширенная строка с признаком мутабельности.
-type EStrMut = mKt.EStrMut
+type EStrMut = mKs.EStrMut
 
 // FnOptStr -- опция для установки параметров расширенной строки.
 type FnOptStr = estr.FnOptStr

v4/lev0/kspec/ikernel_bus.go

@@ -1,15 +1,15 @@
 package kspec
 
 import (
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 )
 
 // IBusBaseHandler -- базовый обработчик обратного вызова.
 type IBusBaseHandler interface {
 	// Topic -- топик подписки обработчика
-	Topic() *mKa.Topic
+	Topic() *mKd.Topic
 	// Name -- уникальное имя обработчика
-	Name() *mKa.HandlerName
+	Name() *mKd.HandlerName
 }
 
 // IBusHandlerSubscribe -- объект обработчика подписки.
@@ -43,7 +43,7 @@ type IDictTopicSub interface {
 	// Subscribe -- подписывает подписчиков на любой из топиков
 	Subscribe(IBusHandlerSubscribe)
 	// Read -- читает сообщение для всех обработчиков подписки по приходу на любой из топиков
-	Read(topic *mKa.Topic, binMsg []byte)
+	Read(topic *mKd.Topic, binMsg []byte)
 	// Unsubscribe -- отписывает подписчиков от любого из топиков
 	Unsubscribe(IBusHandlerSubscribe)
 }
@@ -56,7 +56,7 @@ type IDictTopicServe interface {
 	// Register -- регистрирует единственный обработчик на единственный топик
 	Register(IBusHandlerServe) IResult[bool]
 	// SendRequest -- выполняет запрос по указанному топику
-	SendRequest(topic *mKa.Topic, binReq []byte) IResult[[]byte]
+	SendRequest(topic *mKd.Topic, binReq []byte) IResult[[]byte]
 	// Unregister -- удаляет единственный обработчик с единственного топика
 	Unregister(IBusHandlerServe)
 }
@@ -67,9 +67,9 @@ type IDictTopicServe interface {
 //	Подписка и обслуживание входящих запросов требует _обработчиков_.
 type IKernelBus interface {
 	// Publish -- публикует сообщение в шину
-	Publish(topic *mKa.Topic, binMsg []byte) IResult[bool]
+	Publish(topic *mKd.Topic, binMsg []byte) IResult[bool]
 	// SendRequest -- выполняет запрос по указанному топику
-	SendRequest(topic *mKa.Topic, binReq []byte) IResult[[]byte]
+	SendRequest(topic *mKd.Topic, binReq []byte) IResult[[]byte]
 
 	// Subscribe -- подписывает обработчик на топик
 	Subscribe(IBusHandlerSubscribe) IResult[bool]

v4/lev0/kspec/ikernel_module.go

@@ -1,7 +1,7 @@
 package kspec
 
 import (
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 )
 
 // IKernelModule -- интерфейс к модулю на основе ядра.
@@ -11,7 +11,7 @@ type IKernelModule interface {
 	// IsWork -- возвращает состояние модуля
 	IsWork() bool
 	// Name -- возвращает уникальное имя модуля
-	Name() *mKa.ModuleName
+	Name() *mKd.ModuleName
 	// Ctx -- возвращает контекст модуля
 	Ctx() ILocalCtx
 	// Log -- возвращает буферный лог модуля

v4/lev0/lev0.go

@@ -4,19 +4,19 @@ package lev0
 import (
 	mEt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/etypes"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/option"
 	mRes "gitp78su.ipnodns.ru/svi/kern/v4/lev0/result"
 )
 
 // ETime -- расширенное время
-type ETime = mKt.ITime
+type ETime = mKs.ITime
 
 // EStr -- расширенная строка.
-type EStr = mKt.EStr
+type EStr = mKs.EStr
 
 // EStrMut -- расширенная строка с признаком мутабельности.
-type EStrMut = mKt.EStrMut
+type EStrMut = mKs.EStrMut
 
 // FnOptStr -- опция для установки параметров расширенной строки.
 type FnOptStr = mEt.FnOptStr
@@ -52,7 +52,7 @@ func StrMutNew(opt ...FnOptStr) EStrMut {
 }
 
 // Result — обёртка вокруг результата с возможной ошибкой.
-type IResult[T any] = mKt.IResult[T]
+type IResult[T any] = mKs.IResult[T]
 
 // NewRes -- возвращает успешный Result с значением.
 func NewRes[T any](res T) IResult[T] {
@@ -70,7 +70,7 @@ func WrapErr[T any](res IResult[T], err error) IResult[T] {
 }
 
 // IOption — обёртка вокруг результата с возможной пустотой.
-type IOption[T any] = mKt.IOption[T]
+type IOption[T any] = mKs.IOption[T]
 
 // NewOpt -- возвращает новый не пустой результат операции.
 func NewOpt[T any](some T) IOption[T] {

v4/lev0/option/option.go

@@ -4,7 +4,7 @@ import (
 	"reflect"
 
 	mH "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // Option -- результат возможно содержащий nil.
@@ -13,7 +13,7 @@ type Option[T any] struct {
 }
 
 // NewSome - полезный результат.
-func NewSome[T any](value T) mKt.IOption[T] {
+func NewSome[T any](value T) mKs.IOption[T] {
 	// Для некоторых типов нужна дополнительная проверка через reflect
 	v := reflect.ValueOf(value)
 	switch v.Kind() {
@@ -25,7 +25,7 @@ func NewSome[T any](value T) mKt.IOption[T] {
 }
 
 // NewNone - нет результата в ответе.
-func NewNone[T any]() mKt.IOption[T] {
+func NewNone[T any]() mKs.IOption[T] {
 	return &Option[T]{
 		some: nil,
 	}

v4/lev0/result/result_test.go

@@ -5,7 +5,7 @@ import (
 	"runtime"
 	"testing"
 
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 type tester struct {
@@ -110,7 +110,7 @@ func (sf *tester) assert2() {
 	res.Assert("test assert2")
 }
 
-func (sf *tester) hassert2(res mKt.IResult[string]) {
+func (sf *tester) hassert2(res mKs.IResult[string]) {
 	sf.t.Log("hassert2")
 	defer func() {
 		if _panic := recover(); _panic == nil {
@@ -120,7 +120,7 @@ func (sf *tester) hassert2(res mKt.IResult[string]) {
 	res.Hassert("test hassert2")
 }
 
-func (sf *tester) hassert(res mKt.IResult[string]) {
+func (sf *tester) hassert(res mKs.IResult[string]) {
 	sf.t.Log("hassert")
 	defer func() {
 		if _panic := recover(); _panic == nil {
@@ -130,7 +130,7 @@ func (sf *tester) hassert(res mKt.IResult[string]) {
 	res.Hassert("test hassert")
 }
 
-func (sf *tester) unwrapErr(res mKt.IResult[string]) {
+func (sf *tester) unwrapErr(res mKs.IResult[string]) {
 	sf.t.Log("unwrapErr")
 	defer func() {
 		if _panic := recover(); _panic == nil {

v4/lev0/voc/etime/etime.go

@@ -7,7 +7,7 @@ import (
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // ETime -- метка времени.
@@ -19,7 +19,7 @@ type ETime struct {
 }
 
 // NewETime -- создает новый экземпляр ETime.
-func NewETime(val defs.Time) mKt.ITime {
+func NewETime(val defs.Time) mKs.ITime {
 	helpers.Hassert(val != "", "NewETime(): val is empty")
 	sf := &ETime{
 		val:    val,
@@ -29,7 +29,7 @@ func NewETime(val defs.Time) mKt.ITime {
 }
 
 // NewETimeAuto -- создаёт фиксированную авто-метку времени.
-func NewETimeAuto() mKt.ITime {
+func NewETimeAuto() mKs.ITime {
 	sf := &ETime{
 		isFill: true,
 	}
@@ -39,7 +39,7 @@ func NewETimeAuto() mKt.ITime {
 }
 
 // NewETimeAutoMut -- создаёт изменяемую авто-метку времени.
-func NewETimeAutoMut() mKt.ITimeMut {
+func NewETimeAutoMut() mKs.ITimeMut {
 	sf := &ETime{
 		isFill: true,
 		isMut:  true,

v4/lev0/voc/voc.go

@@ -3,27 +3,27 @@ package voc
 
 import (
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/voc/etime"
 )
 
 // NewETime -- создать новую метку времени.
 //
 //go:fix inline
-func NewETime(val defs.Time) mKt.ITime {
+func NewETime(val defs.Time) mKs.ITime {
 	return etime.NewETime(val)
 }
 
 // NewETimeAuto -- создать новую фиксированную авто-метку
 //
 //go:fix inline
-func NewETimeAuto() mKt.ITime {
+func NewETimeAuto() mKs.ITime {
 	return etime.NewETimeAuto()
 }
 
 // NewETimeAutoMut -- создать новую фиксированную авто-метку
 //
 //go:fix inline
-func NewETimeAutoMut() mKt.ITimeMut {
+func NewETimeAutoMut() mKs.ITimeMut {
 	return etime.NewETimeAutoMut()
 }

v4/lev1/ctx_value/ctx_value.go

@@ -5,7 +5,7 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/voc"
 )
 
@@ -13,14 +13,14 @@ import (
 type CtxValue struct {
 	sync.RWMutex
 	key       string
-	createAt  mKt.ITime
+	createAt  mKs.ITime
 	Val_      any
-	UpdateAt_ mKt.ITimeMut
+	UpdateAt_ mKs.ITimeMut
 	Comment_  string
 }
 
 // NewCtxValue -- возвращает новое потокобезопасное значение локального контекста.
-func NewCtxValue(key string, val any, comment string) mKt.ICtxValue {
+func NewCtxValue(key string, val any, comment string) mKs.ICtxValue {
 	mL0.Hassert(key != "", "NewCtxValue(): key is empty")
 	sf := &CtxValue{
 		key:       key,
@@ -45,14 +45,14 @@ func (sf *CtxValue) Val() any {
 }
 
 // UpdateAt -- возвращает время обновления значения.
-func (sf *CtxValue) UpdateAt() mKt.ITimeMut {
+func (sf *CtxValue) UpdateAt() mKs.ITimeMut {
 	sf.RLock()
 	defer sf.RUnlock()
 	return sf.UpdateAt_
 }
 
 // CreateAt -- возвращает время создания значения.
-func (sf *CtxValue) CreateAt() mKt.ITime {
+func (sf *CtxValue) CreateAt() mKs.ITime {
 	return sf.createAt
 }
 

v4/lev1/kbus_msg/msg_unsub/msg_unsub.go

@@ -2,13 +2,13 @@
 package msg_unsub
 
 import (
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
 )
 
 // UnsubReq -- запрос на отписку от топика.
 type UnsubReq struct {
-	Name_ *mKa.HandlerName `json:"name"` // Уникальная метка подписки
+	Name_ *mKd.HandlerName `json:"name"` // Уникальная метка подписки
 	Uuid_ string            `json:"uuid"`
 }
 

v4/lev1/kint/kint.go

@@ -9,7 +9,7 @@ import (
 	"strconv"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // Целочисленная переменная ядра.
@@ -18,7 +18,7 @@ type KernInt struct {
 }
 
 // NewInt -- возвращает новое целое ядра.
-func NewInt(val int) mKt.Int {
+func NewInt(val int) mKs.Int {
 	sf := &KernInt{
 		val: val,
 	}

v4/lev1/lev1.go

@@ -6,7 +6,7 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/kint"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/local_ctx"
@@ -40,41 +40,41 @@ func OptIsTerm(isTerm bool) OptionLogBuf {
 }
 
 // NewLogBuf -- возвращает новый буферизованный лог.
-func NewLogBuf(opts ...log_buf.OptionLogBuf) mKt.ILogBuf {
+func NewLogBuf(opts ...log_buf.OptionLogBuf) mKs.ILogBuf {
 	log := log_buf.NewLogBuf(opts...)
 	return log
 }
 
 // NewSafeString -- возвращает новую потокобезопасную строку.
-func NewSafeString() mKt.ISafeString {
+func NewSafeString() mKs.ISafeString {
 	str := safe_string.NewSafeString()
 	return str
 }
 
 // NewSafeIntFromStr -- возвращает новое потокобезопасное целое из строки.
-func NewSafeIntFromStr(strVal string) mL0.IResult[mKt.ISafeInt] {
+func NewSafeIntFromStr(strVal string) mL0.IResult[mKs.ISafeInt] {
 	return safe_int.NewSafeIntFromStr(strVal)
 }
 
 // NewSafeIntGetenv -- возвращает новое потокобезопасное целое из окружения.
-func NewSafeIntGetenv(env string) mL0.IResult[mKt.ISafeInt] {
+func NewSafeIntGetenv(env string) mL0.IResult[mKs.ISafeInt] {
 	return safe_int.NewSafeIntGetenv(env)
 }
 
 // NewSafeInt -- возвращает новую потокобезопасную целочисленную переменную.
-func NewSafeInt(val int) mKt.ISafeInt {
+func NewSafeInt(val int) mKs.ISafeInt {
 	val_ := safe_int.NewSafeInt(val)
 	return val_
 }
 
 // NewSafeBoolReact -- возвращает новую потокобезопасную реактивную булеву переменную.
-func NewSafeBoolReact() mKt.ISafeBoolReact {
+func NewSafeBoolReact() mKs.ISafeBoolReact {
 	val := safe_bool_react.NewSafeBoolReact()
 	return val
 }
 
 // NewSafeBool -- возвращает новый потокобезопасный булевый признак.
-func NewSafeBool() mKt.ISafeBool {
+func NewSafeBool() mKs.ISafeBool {
 	sb := safe_bool.NewSafeBool()
 	return sb
 }
@@ -101,13 +101,13 @@ func SleepMs() {
 }
 
 // NewInt -- возвращает новую целочисленную переменную.
-func NewInt(val int) mKt.Int {
+func NewInt(val int) mKs.Int {
 	val_ := kint.NewInt(val)
 	return val_
 }
 
 // NewLocalCtx -- возвращает новый локальный контекст.
-func NewLocalCtx(ctx context.Context) mKt.ILocalCtx {
+func NewLocalCtx(ctx context.Context) mKs.ILocalCtx {
 	lCtx := local_ctx.NewLocalCtx(ctx)
 	return lCtx
 }

v4/lev1/local_ctx/local_ctx.go

@@ -6,7 +6,7 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/voc"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/ctx_value"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/log_buf"
@@ -19,19 +19,19 @@ type LocalCtx struct {
 	ctx      context.Context // Отменяемый контекст
 	fnCancel func()          // Функция отмены контекста
 
-	dictVal map[string]mKt.ICtxValue // Словарь различных значений
+	dictVal map[string]mKs.ICtxValue // Словарь различных значений
 	lstSort *lst_sort.LstSort        // Сортированный список значений
-	log     mKt.ILogBuf              // Локальный буфер
+	log     mKs.ILogBuf              // Локальный буфер
 }
 
 // NewLocalCtx -- возвращает новый локальный контекст.
-func NewLocalCtx(ctx context.Context) mKt.ILocalCtx {
+func NewLocalCtx(ctx context.Context) mKs.ILocalCtx {
 	mL0.Hassert(ctx != nil, "NewLocalCtx(): ctx==nil")
 	_ctx, fnCancel := context.WithCancel(ctx)
 	sf := &LocalCtx{
 		ctx:      _ctx,
 		fnCancel: fnCancel,
-		dictVal:  map[string]mKt.ICtxValue{},
+		dictVal:  map[string]mKs.ICtxValue{},
 		lstSort:  lst_sort.NewLstSort(),
 		log: log_buf.NewLogBuf(
 			log_buf.OptIsTerm(true),
@@ -53,26 +53,26 @@ func (sf *LocalCtx) Size() int {
 }
 
 // SortedList -- возвращает сортированный список значений.
-func (sf *LocalCtx) SortedList() []mKt.ICtxValue {
+func (sf *LocalCtx) SortedList() []mKs.ICtxValue {
 	return sf.lstSort.List()
 }
 
 // Log -- возвращает локальный буферный лог.
-func (sf *LocalCtx) Log() mKt.ILogBuf {
+func (sf *LocalCtx) Log() mKs.ILogBuf {
 	return sf.log
 }
 
 // Get -- возвращает хранимое значение.
-func (sf *LocalCtx) Get(key string) mL0.IOption[mKt.ICtxValue] {
+func (sf *LocalCtx) Get(key string) mL0.IOption[mKs.ICtxValue] {
 	sf.RLock()
 	defer sf.RUnlock()
 	if key == "" {
-		return mL0.NewNone[mKt.ICtxValue]()
+		return mL0.NewNone[mKs.ICtxValue]()
 	}
 	sf.log.Debug("Get(): key='%v'", key)
 	val, isOk := sf.dictVal[key]
 	if !isOk {
-		return mL0.NewNone[mKt.ICtxValue]()
+		return mL0.NewNone[mKs.ICtxValue]()
 	}
 	return mL0.NewOpt(val)
 }

v4/lev1/log_buf/log_buf.go

@@ -7,7 +7,7 @@ import (
 	"sync"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/log_msg"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/safe_bool"
 )
@@ -15,10 +15,10 @@ import (
 // LogBuf -- потокобезопасный буфер лога.
 type LogBuf struct {
 	sync.RWMutex
-	isTerm mKt.ISafeBool // Признак вывода в стандартный поток
+	isTerm mKs.ISafeBool // Признак вывода в стандартный поток
 	prefix string        // Префикс для сообщений
-	lst    []mKt.ILogMsg
-	lstErr []mKt.ILogMsg
+	lst    []mKs.ILogMsg
+	lstErr []mKs.ILogMsg
 }
 
 // OptionLogBuf -- опция для конфигурирования ILogBuf.
@@ -41,11 +41,11 @@ func OptPrefix(prefix string) OptionLogBuf {
 }
 
 // NewLogBuf -- возвращает новый потокобезопасный буфер лога.
-func NewLogBuf(opts ...OptionLogBuf) mKt.ILogBuf {
+func NewLogBuf(opts ...OptionLogBuf) mKs.ILogBuf {
 	sf := &LogBuf{
 		isTerm: safe_bool.NewSafeBool(),
-		lst:    []mKt.ILogMsg{},
-		lstErr: []mKt.ILogMsg{},
+		lst:    []mKs.ILogMsg{},
+		lstErr: []mKs.ILogMsg{},
 	}
 
 	for _, opt := range opts {
@@ -55,12 +55,12 @@ func NewLogBuf(opts ...OptionLogBuf) mKt.ILogBuf {
 }
 
 // IsTerm -- возвращает признак логирования.
-func (sf *LogBuf) IsTerm() mKt.ISafeBool {
+func (sf *LogBuf) IsTerm() mKs.ISafeBool {
 	return sf.isTerm
 }
 
 // GetErr -- возвращает сообщение ошибки по номеру.
-func (sf *LogBuf) GetErr(num int) mKt.ILogMsg {
+func (sf *LogBuf) GetErr(num int) mKs.ILogMsg {
 	sf.RLock()
 	defer sf.RUnlock()
 	if len(sf.lstErr) == 0 {
@@ -76,7 +76,7 @@ func (sf *LogBuf) GetErr(num int) mKt.ILogMsg {
 }
 
 // Get -- возвращает сообщение по номеру.
-func (sf *LogBuf) Get(num int) mKt.ILogMsg {
+func (sf *LogBuf) Get(num int) mKs.ILogMsg {
 	sf.RLock()
 	defer sf.RUnlock()
 	if len(sf.lst) == 0 {
@@ -180,7 +180,7 @@ func (sf *LogBuf) checkLenErr() {
 }
 
 // Печатает сообщение в терминал, если разрешено.
-func (sf *LogBuf) printTerm(msg mKt.ILogMsg) {
+func (sf *LogBuf) printTerm(msg mKs.ILogMsg) {
 	if !sf.isTerm.Get() {
 		return
 	}

v4/lev1/log_dict_topic/log_dict_topic.go

@@ -7,17 +7,17 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 type LogDictTopic struct {
 	sync.RWMutex
 	dict   map[defs.Topic]bool
-	client mKt.IBusClient
+	client mKs.IBusClient
 }
 
 // NewLogDictTopic -- возвращает новый словарь топиков для логирования.
-func NewLogDictTopic(clientBus mKt.IBusClient) mL0.IResult[*LogDictTopic] {
+func NewLogDictTopic(clientBus mKs.IBusClient) mL0.IResult[*LogDictTopic] {
 	if clientBus == nil {
 		err := fmt.Errorf("NewLogDictTopic(): clientBus == nil")
 		return mL0.NewErr[*LogDictTopic](err)

v4/lev1/lst_sort/lst_sort.go

@@ -6,25 +6,25 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // LstSort -- сортированный список значений контекста.
 type LstSort struct {
 	sync.RWMutex
-	lstVal []mKt.ICtxValue // Сортированный список значений
+	lstVal []mKs.ICtxValue // Сортированный список значений
 }
 
 // NewLstSort -- возвращает новый сортированный список значений контекста.
 func NewLstSort() *LstSort {
 	sf := &LstSort{
-		lstVal: []mKt.ICtxValue{},
+		lstVal: []mKs.ICtxValue{},
 	}
 	return sf
 }
 
 // Add -- добавляет значение в список.
-func (sf *LstSort) Add(val mKt.ICtxValue) {
+func (sf *LstSort) Add(val mKs.ICtxValue) {
 	sf.Lock()
 	defer sf.Unlock()
 	mL0.Hassert(val != nil, "LstSort.Add(): ICtxValue==nil")
@@ -33,7 +33,7 @@ func (sf *LstSort) Add(val mKt.ICtxValue) {
 }
 
 // Del -- удаляет элемент из списка.
-func (sf *LstSort) Del(val mKt.ICtxValue) {
+func (sf *LstSort) Del(val mKs.ICtxValue) {
 	sf.Lock()
 	defer sf.Unlock()
 	if val == nil {
@@ -43,7 +43,7 @@ func (sf *LstSort) Del(val mKt.ICtxValue) {
 }
 
 // List -- возвращает сортированный список.
-func (sf *LstSort) List() []mKt.ICtxValue {
+func (sf *LstSort) List() []mKs.ICtxValue {
 	sf.RLock()
 	defer sf.RUnlock()
 	return sf.list()
@@ -57,7 +57,7 @@ func (sf *LstSort) Size() int {
 }
 
 // Get -- возвращает по индексу.
-func (sf *LstSort) Get(ind int) mKt.ICtxValue {
+func (sf *LstSort) Get(ind int) mKs.ICtxValue {
 	sf.RLock()
 	defer sf.RUnlock()
 	mL0.Hassert(ind >= 0, "LstSort.Get(): ind(%v)<0", ind)
@@ -66,10 +66,10 @@ func (sf *LstSort) Get(ind int) mKt.ICtxValue {
 }
 
 // удаляет элемент из списка.
-func (sf *LstSort) del(val mKt.ICtxValue) {
+func (sf *LstSort) del(val mKs.ICtxValue) {
 	var (
 		ind  int
-		_val mKt.ICtxValue
+		_val mKs.ICtxValue
 	)
 	for ind, _val = range sf.lstVal {
 		if val == _val {
@@ -81,7 +81,7 @@ func (sf *LstSort) del(val mKt.ICtxValue) {
 		return
 	}
 	lst0 := sf.lstVal[:ind]
-	lst1 := []mKt.ICtxValue{}
+	lst1 := []mKs.ICtxValue{}
 	if ind < len(sf.lstVal)-1 {
 		lst1 = sf.lstVal[ind+1:]
 	}
@@ -92,8 +92,8 @@ func (sf *LstSort) del(val mKt.ICtxValue) {
 }
 
 // возвращает сортированный список.
-func (sf *LstSort) list() []mKt.ICtxValue {
-	lst := make([]mKt.ICtxValue, 0, len(sf.lstVal))
+func (sf *LstSort) list() []mKs.ICtxValue {
+	lst := make([]mKs.ICtxValue, 0, len(sf.lstVal))
 	lst = append(lst, sf.lstVal...)
 	return lst
 }

v4/lev1/safe_bool/safe_bool.go

@@ -8,7 +8,7 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // safeBool -- потокобезопасный булевый признак.
@@ -18,29 +18,29 @@ type safeBool struct {
 }
 
 // NewSafeBool -- возвращает новый потокобезопасный булевый признак.
-func NewSafeBool() mKt.ISafeBool {
+func NewSafeBool() mKs.ISafeBool {
 	sf := &safeBool{}
 	return sf
 }
 
 // NewSafeBoolFromStr -- возвращает новое потокобезопасное булево из строки.
-func NewSafeBoolFromStr(strVal string) mL0.IResult[mKt.ISafeBool] {
+func NewSafeBoolFromStr(strVal string) mL0.IResult[mKs.ISafeBool] {
 	sf := NewSafeBool()
 	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[mKt.ISafeBool](err)
+		return mL0.NewErr[mKs.ISafeBool](err)
 	}
 	return mL0.NewRes(sf)
 }
 
 // NewSafeBoolGetenv -- возвращает новое потокобезопасное целое из окружения.
-func NewSafeBoolGetenv(env string) mL0.IResult[mKt.ISafeBool] {
+func NewSafeBoolGetenv(env string) mL0.IResult[mKs.ISafeBool] {
 	sf := NewSafeBool()
 	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[mKt.ISafeBool](err)
+		return mL0.NewErr[mKs.ISafeBool](err)
 	}
 	return mL0.NewRes(sf)
 }

v4/lev1/safe_bool_react/safe_bool_react.go

@@ -8,7 +8,7 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // safeBoolReact -- потокобезопасный булевый признак с реакцией на своё изменение.
@@ -19,7 +19,7 @@ type safeBoolReact struct {
 }
 
 // NewSafeBoolReact -- возвращает новый потокобезопасный булевый признак с реакцией на своё изменение.
-func NewSafeBoolReact() mKt.ISafeBoolReact {
+func NewSafeBoolReact() mKs.ISafeBoolReact {
 	sf := &safeBoolReact{
 		dict: map[string]func(bool){},
 	}
@@ -27,23 +27,23 @@ func NewSafeBoolReact() mKt.ISafeBoolReact {
 }
 
 // NewSafeBoolReactFromStr -- возвращает новое потокобезопасное булево с реакцией из строки.
-func NewSafeBoolReactFromStr(strVal string) mL0.IResult[mKt.ISafeBoolReact] {
+func NewSafeBoolReactFromStr(strVal string) mL0.IResult[mKs.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[mKt.ISafeBoolReact](err)
+		return mL0.NewErr[mKs.ISafeBoolReact](err)
 	}
 	return mL0.NewRes(sf)
 }
 
 // NewSafeBoolGetenv -- возвращает новое потокобезопасное целое с реакцией из окружения.
-func NewSafeBoolGetenv(env string) mL0.IResult[mKt.ISafeBoolReact] {
+func NewSafeBoolGetenv(env string) mL0.IResult[mKs.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[mKt.ISafeBoolReact](err)
+		return mL0.NewErr[mKs.ISafeBoolReact](err)
 	}
 	return mL0.NewRes(sf)
 }

v4/lev1/safe_int/safe_int.go

@@ -6,18 +6,18 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/kint"
 )
 
 // safeInt -- потокобезопасное целое.
 type safeInt struct {
 	sync.RWMutex
-	val mKt.Int
+	val mKs.Int
 }
 
 // NewSafeInt -- возвращает новое потокобезопасное целое.
-func NewSafeInt(val int) mKt.ISafeInt {
+func NewSafeInt(val int) mKs.ISafeInt {
 	sf := &safeInt{
 		val: kint.NewInt(val),
 	}
@@ -25,23 +25,23 @@ func NewSafeInt(val int) mKt.ISafeInt {
 }
 
 // NewSafeIntFromStr -- возвращает новое потокобезопасное целое из строки.
-func NewSafeIntFromStr(strVal string) mL0.IResult[mKt.ISafeInt] {
+func NewSafeIntFromStr(strVal string) mL0.IResult[mKs.ISafeInt] {
 	sf := NewSafeInt(0)
 	res := sf.FromStr(strVal)
 	if res.IsErr() {
 		err := fmt.Errorf("NewSafeIntFromStr(): in parse str(%v), err=\n\t%w", strVal, res.Err())
-		return mL0.NewErr[mKt.ISafeInt](err)
+		return mL0.NewErr[mKs.ISafeInt](err)
 	}
 	return mL0.NewRes(sf)
 }
 
 // NewSafeIntGetenv -- возвращает новое потокобезопасное целое из окружения.
-func NewSafeIntGetenv(env string) mL0.IResult[mKt.ISafeInt] {
+func NewSafeIntGetenv(env string) mL0.IResult[mKs.ISafeInt] {
 	sf := NewSafeInt(0)
 	res := sf.Getenv(env)
 	if res.IsErr() {
 		err := fmt.Errorf("NewSafeIntGetenv(): in parse env(%v), err=\n\t%w", env, res.Err())
-		return mL0.NewErr[mKt.ISafeInt](err)
+		return mL0.NewErr[mKs.ISafeInt](err)
 	}
 	return mL0.NewRes(sf)
 }

v4/lev1/safe_string/safe_string.go

@@ -7,7 +7,7 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // safeString -- потокобезопасная строка.
@@ -17,18 +17,18 @@ type safeString struct {
 }
 
 // NewSafeString -- возвращает новую потокобезопасную строку.
-func NewSafeString() mKt.ISafeString {
+func NewSafeString() mKs.ISafeString {
 	sf := &safeString{}
 	return sf
 }
 
 // NewSafeStringGetenv -- возвращает новую потокобезопасную строку из окружения.
-func NewSafeStringGetenv(env string) mL0.IResult[mKt.ISafeString] {
+func NewSafeStringGetenv(env string) mL0.IResult[mKs.ISafeString] {
 	sf := NewSafeString()
 	res := sf.Getenv(env)
 	if res.IsErr() {
 		err := fmt.Errorf("NewSafeStringGetenv(): in get from env(%v), err=\n\t%w", env, res.Err())
-		return mL0.NewErr[mKt.ISafeString](err)
+		return mL0.NewErr[mKs.ISafeString](err)
 	}
 	return mL0.NewRes(sf)
 }

v4/lev2/kbus/dict_sub_hook/dict_sub_hook.go

@@ -5,29 +5,29 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
 
 // dictSubHook -- словарь потребителей топика по подписке.
 type dictSubHook struct {
-	kCtx  mKt.IKernelCtx
-	dict  map[*mKa.HandlerName]bool // В качестве ключа -- URL веб-хука
+	kCtx  mKs.IKernelCtx
+	dict  map[*mKd.HandlerName]bool // В качестве ключа -- URL веб-хука
 	block sync.RWMutex
 }
 
 // NewDictSubHook -- возвращает новый словарь веб-хуков одного топика.
-func NewDictSubHook() mKt.IDictSubHook {
+func NewDictSubHook() mKs.IDictSubHook {
 	sf := &dictSubHook{
 		kCtx: kctx.GetKernelCtx(),
-		dict: map[*mKa.HandlerName]bool{},
+		dict: map[*mKd.HandlerName]bool{},
 	}
 	return sf
 }
 
 // Unsubscribe -- удаляет из словаря подписки обработчик.
-func (sf *dictSubHook) Unsubscribe(handler mKt.IBusHandlerSubscribe) {
+func (sf *dictSubHook) Unsubscribe(handler mKs.IBusHandlerSubscribe) {
 	sf.block.Lock()
 	defer sf.block.Unlock()
 	if handler == nil {
@@ -40,7 +40,7 @@ func (sf *dictSubHook) Unsubscribe(handler mKt.IBusHandlerSubscribe) {
 }
 
 // Subscribe -- добавляет в словарь подписки новый обработчик.
-func (sf *dictSubHook) Subscribe(handler mKt.IBusHandlerSubscribe) {
+func (sf *dictSubHook) Subscribe(handler mKs.IBusHandlerSubscribe) {
 	sf.block.Lock()
 	defer sf.block.Unlock()
 	mL0.Hassert(handler != nil, "dictSubHook.Subscribe(): handler==nil")
@@ -59,7 +59,7 @@ func (sf *dictSubHook) Read(binMsg []byte) {
 			sf.kCtx.Del(handlerName.Get())
 			continue
 		}
-		handler := optHand.Some().Val().(mKt.IBusHandlerSubscribe)
+		handler := optHand.Some().Val().(mKs.IBusHandlerSubscribe)
 		go handler.FnBack(binMsg)
 	}
 }

v4/lev2/kbus/dict_topic_serve/dict_topic_serve.go

@@ -8,8 +8,8 @@ import (
 	"time"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
 
@@ -18,21 +18,21 @@ import (
 // Допускается только один обработчик запросов на один топик.
 type dictServe struct {
 	sync.RWMutex
-	kCtx      mKt.IKernelCtx
-	dictServe map[*mKa.Topic]mKt.IBusHandlerServe
+	kCtx      mKs.IKernelCtx
+	dictServe map[*mKd.Topic]mKs.IBusHandlerServe
 }
 
 // NewDictServe -- возвращает потокобезопасный словарь обработчиков запросов.
 func NewDictServe() *dictServe {
 	sf := &dictServe{
 		kCtx:      kctx.GetKernelCtx(),
-		dictServe: map[*mKa.Topic]mKt.IBusHandlerServe{},
+		dictServe: map[*mKd.Topic]mKs.IBusHandlerServe{},
 	}
 	return sf
 }
 
 // Register -- регистрирует обработчик запросов.
-func (sf *dictServe) Register(handler mKt.IBusHandlerServe) mL0.IResult[bool] {
+func (sf *dictServe) Register(handler mKs.IBusHandlerServe) mL0.IResult[bool] {
 	sf.Lock()
 	defer sf.Unlock()
 	if handler == nil {
@@ -47,7 +47,7 @@ func (sf *dictServe) Register(handler mKt.IBusHandlerServe) mL0.IResult[bool] {
 }
 
 // Unregister -- удаляет обработчик запросов из словаря.
-func (sf *dictServe) Unregister(handler mKt.IBusHandlerServe) {
+func (sf *dictServe) Unregister(handler mKs.IBusHandlerServe) {
 	sf.Lock()
 	defer sf.Unlock()
 	if handler == nil {
@@ -58,7 +58,7 @@ func (sf *dictServe) Unregister(handler mKt.IBusHandlerServe) {
 }
 
 // SendRequest -- вызывает обработчик при поступлении запроса.
-func (sf *dictServe) SendRequest(topic *mKa.Topic, binReq []byte) mL0.IResult[[]byte] {
+func (sf *dictServe) SendRequest(topic *mKd.Topic, binReq []byte) mL0.IResult[[]byte] {
 	sf.RLock()
 	defer sf.RUnlock()
 	handler, isOk := sf.dictServe[topic]
@@ -89,7 +89,7 @@ func (sf *dictServe) SendRequest(topic *mKa.Topic, binReq []byte) mL0.IResult[[]
 var TimeoutDefault = 15000
 
 // регистрирует обработчик запросов.
-func (sf *dictServe) register(handler mKt.IBusHandlerServe) bool {
+func (sf *dictServe) register(handler mKs.IBusHandlerServe) bool {
 	topic := handler.Topic()
 	_, isOk := sf.dictServe[topic]
 	if isOk {

v4/lev2/kbus/dict_topic_sub/dict_topic_sub.go

@@ -5,35 +5,35 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus/dict_sub_hook"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
 
 type tReadReq struct {
-	topic  *mKa.Topic
+	topic  *mKd.Topic
 	binMsg []byte
 }
 
 // dictTopicSub -- потокобезопасный словарь подписчиков.
 type dictTopicSub struct {
 	sync.RWMutex
-	kCtx          mKt.IKernelCtx
-	dictTopicHook map[*mKa.Topic]mKt.IDictSubHook
+	kCtx          mKs.IKernelCtx
+	dictTopicHook map[*mKd.Topic]mKs.IDictSubHook
 }
 
 // NewDictTopicSub -- возвращает потокобезопасный словарь подписчиков.
 func NewDictTopicSub() *dictTopicSub {
 	sf := &dictTopicSub{
 		kCtx:          kctx.GetKernelCtx(),
-		dictTopicHook: map[*mKa.Topic]mKt.IDictSubHook{},
+		dictTopicHook: map[*mKd.Topic]mKs.IDictSubHook{},
 	}
 	return sf
 }
 
 // Read -- вызывает обработчики при поступлении события.
-func (sf *dictTopicSub) Read(topic *mKa.Topic, binMsg []byte) {
+func (sf *dictTopicSub) Read(topic *mKd.Topic, binMsg []byte) {
 	sf.RLock()
 	defer sf.RUnlock()
 	msg := &tReadReq{
@@ -48,7 +48,7 @@ func (sf *dictTopicSub) Read(topic *mKa.Topic, binMsg []byte) {
 }
 
 // Subscribe -- подписывает обработчик на топик.
-func (sf *dictTopicSub) Subscribe(handler mKt.IBusHandlerSubscribe) {
+func (sf *dictTopicSub) Subscribe(handler mKs.IBusHandlerSubscribe) {
 	sf.Lock()
 	defer sf.Unlock()
 	mL0.Hassert(handler != nil, "dictTopicSub.Subscribe(): handler==nil")
@@ -62,7 +62,7 @@ func (sf *dictTopicSub) Subscribe(handler mKt.IBusHandlerSubscribe) {
 }
 
 // Unsubscribe -- отписывает обработчик.
-func (sf *dictTopicSub) Unsubscribe(handler mKt.IBusHandlerSubscribe) {
+func (sf *dictTopicSub) Unsubscribe(handler mKs.IBusHandlerSubscribe) {
 	sf.Lock()
 	defer sf.Unlock()
 	mL0.Hassert(handler != nil, "dictTopicSub.Unsubscribe(): handler==nil")

v4/lev2/kbus_base/kbus_base.go

@@ -6,8 +6,8 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus/dict_topic_serve"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus/dict_topic_sub"
@@ -15,17 +15,17 @@ import (
 )
 
 var (
-	busBaseStreamName = mKa.NewStreamName("bus_base")
+	busBaseStreamName = mKd.NewStreamName("bus_base")
 )
 
 // KBusBase -- базовая часть шины данных.
 type KBusBase struct {
-	KCtx_     mKt.IKernelCtx
-	IsWork_   mKt.ISafeBool
-	lCtx      mKt.ILocalCtx
-	log       mKt.ILogBuf
-	dictSub   mKt.IDictTopicSub
-	dictServe mKt.IDictTopicServe
+	KCtx_     mKs.IKernelCtx
+	IsWork_   mKs.ISafeBool
+	lCtx      mKs.ILocalCtx
+	log       mKs.ILogBuf
+	dictSub   mKs.IDictTopicSub
+	dictServe mKs.IDictTopicServe
 }
 
 var (
@@ -55,12 +55,12 @@ func GetKernelBusBase() *KBusBase {
 	Bus_.IsWork_.Set()
 	Bus_.KCtx_.Wg().Add(busBaseStreamName)
 	Bus_.KCtx_.Set("kernBusBase", Bus_, "base of data bus")
-	_ = mKt.IKernelBus(Bus_)
+	_ = mKs.IKernelBus(Bus_)
 	return Bus_
 }
 
 // Log -- возвращает лог шины.
-func (sf *KBusBase) Log() mKt.ILogBuf {
+func (sf *KBusBase) Log() mKs.ILogBuf {
 	return sf.log
 }
 
@@ -72,13 +72,13 @@ func (sf *KBusBase) run() {
 }
 
 // Unsubscribe -- отписывает обработчик от топика.
-func (sf *KBusBase) Unsubscribe(handler mKt.IBusHandlerSubscribe) {
+func (sf *KBusBase) Unsubscribe(handler mKs.IBusHandlerSubscribe) {
 	sf.log.Debug("KBusBase.Unsubscribe(): handler='%v'", handler.Name())
 	sf.dictSub.Unsubscribe(handler)
 }
 
 // Subscribe -- подписывает обработчик на топик.
-func (sf *KBusBase) Subscribe(handler mKt.IBusHandlerSubscribe) mKt.IResult[bool] {
+func (sf *KBusBase) Subscribe(handler mKs.IBusHandlerSubscribe) mKs.IResult[bool] {
 	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)
@@ -86,7 +86,7 @@ func (sf *KBusBase) Subscribe(handler mKt.IBusHandlerSubscribe) mKt.IResult[bool
 }
 
 // SendRequest -- отправляет запрос в шину данных.
-func (sf *KBusBase) SendRequest(topic *mKa.Topic, binReq []byte) mL0.IResult[[]byte] {
+func (sf *KBusBase) SendRequest(topic *mKd.Topic, binReq []byte) mL0.IResult[[]byte] {
 	sf.log.Debug("KBusBase.SendRequest(): topic='%v'", topic)
 	if !sf.IsWork_.Get() {
 		err := fmt.Errorf("KBusBase.SendRequest():  topic='%v', bus already closed", topic)
@@ -103,7 +103,7 @@ func (sf *KBusBase) SendRequest(topic *mKa.Topic, binReq []byte) mL0.IResult[[]b
 }
 
 // RegisterServe -- регистрирует обработчики входящих запросов.
-func (sf *KBusBase) RegisterServe(handler mKt.IBusHandlerServe) mL0.IResult[bool] {
+func (sf *KBusBase) RegisterServe(handler mKs.IBusHandlerServe) mL0.IResult[bool] {
 	if handler == nil {
 		return mL0.NewErr[bool](fmt.Errorf("KBusBase.RegisterServe(): IBusHandlerServe==nil"))
 	}
@@ -118,7 +118,7 @@ func (sf *KBusBase) RegisterServe(handler mKt.IBusHandlerServe) mL0.IResult[bool
 }
 
 // Publish -- публикует сообщение в шину.
-func (sf *KBusBase) Publish(topic *mKa.Topic, binMsg []byte) mL0.IResult[bool] {
+func (sf *KBusBase) Publish(topic *mKd.Topic, binMsg []byte) mL0.IResult[bool] {
 	sf.log.Debug("KBusBase.Publish(): topic='%v'", topic)
 	if !sf.IsWork_.Get() {
 		err := fmt.Errorf("KBusBase.Publish(): topic='%v',bus already closed", topic)

v4/lev2/kbus_base/kbus_base_test.go

@@ -4,7 +4,7 @@ import (
 	"testing"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/mock_hand_serve"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/mock_hand_sub_local"
@@ -12,7 +12,7 @@ import (
 
 type tester struct {
 	t        *testing.T
-	kBus     mKt.IKernelBus
+	kBus     mKs.IKernelBus
 	handSub  *mock_hand_sub_local.MockHandlerSub
 	handServ *mock_hand_serve.MockHandlerServe
 }

v4/lev2/kbus_http/client_bus_http/client_bus_http.go

@@ -11,8 +11,8 @@ import (
 	"github.com/google/uuid"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/kbus_msg/msg_pub"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/kbus_msg/msg_serve"
@@ -25,16 +25,16 @@ import (
 
 // ClientBusHttp -- клиент HTTP-шины.
 type ClientBusHttp struct {
-	bus       mKt.IKernelBus
-	lCtx      mKt.ILocalCtx
-	log       mKt.ILogBuf
-	isWork    mKt.ISafeBool
+	bus       mKs.IKernelBus
+	lCtx      mKs.ILocalCtx
+	log       mKs.ILogBuf
+	isWork    mKs.ISafeBool
 	urlRemote string // URL дистанционной шины
 	urlLocal  string // URL локальной шины для веб-хуков
 }
 
 // NewClientBusHttp - -возвращает новый клиент HTTP-шины.
-func NewClientBusHttp(urlRemote string) mKt.IBusClient {
+func NewClientBusHttp(urlRemote string) mKs.IBusClient {
 	log := mL1.NewLogBuf(mL1.OptIsTerm(true), mL1.OptPrefix("ClientBusHttp"))
 	log.Debug("NewClientBusHttp()")
 	mL0.Hassert(urlRemote != "", "NewClientBusHttp(): urlRemote is empty")
@@ -55,7 +55,7 @@ func NewClientBusHttp(urlRemote string) mKt.IBusClient {
 }
 
 // Unsubscribe -- отписывается от топика в дистанционной шине.
-func (sf *ClientBusHttp) Unsubscribe(handler mKt.IBusHandlerSubscribe) {
+func (sf *ClientBusHttp) Unsubscribe(handler mKs.IBusHandlerSubscribe) {
 	_uuid, err := uuid.NewV6()
 	mL1.Hassert()(err == nil, "ClientBusHttp.Unsubscribe(): in generate UUID v6, err=\n\t%v", err)
 
@@ -90,7 +90,7 @@ func (sf *ClientBusHttp) Unsubscribe(handler mKt.IBusHandlerSubscribe) {
 }
 
 // Subscribe -- подписывается на топик в дистанционной шине.
-func (sf *ClientBusHttp) Subscribe(handler mKt.IBusHandlerSubscribe) mKt.IResult[bool] {
+func (sf *ClientBusHttp) Subscribe(handler mKs.IBusHandlerSubscribe) mKs.IResult[bool] {
 	_uuid, err := uuid.NewV6()
 	mL0.Hassert(err == nil, "ClientBusHttp.Subscribe(): in generate UUID v6, err=\n\t%v", err)
 	req := &msg_sub.SubscribeReq{
@@ -129,7 +129,7 @@ func (sf *ClientBusHttp) Subscribe(handler mKt.IBusHandlerSubscribe) mKt.IResult
 }
 
 // SendRequest -- отправляет в дистанционную шину запрос.
-func (sf *ClientBusHttp) SendRequest(topic *mKa.Topic, binReq []byte) mL0.IResult[[]byte] {
+func (sf *ClientBusHttp) SendRequest(topic *mKd.Topic, binReq []byte) mL0.IResult[[]byte] {
 	_uuid, err := uuid.NewV6()
 	mL1.Hassert()(err == nil, "ClientBusHttp.SendRequest(): in generate UUID v6, err=\n\t%v", err)
 	req := &msg_serve.ServeReq{
@@ -167,7 +167,7 @@ func (sf *ClientBusHttp) SendRequest(topic *mKa.Topic, binReq []byte) mL0.IResul
 }
 
 // RegisterServe -- регистрирует в локальной шине обработчик.
-func (sf *ClientBusHttp) RegisterServe(handler mKt.IBusHandlerServe) mL0.IResult[bool] {
+func (sf *ClientBusHttp) RegisterServe(handler mKs.IBusHandlerServe) mL0.IResult[bool] {
 	if handler == nil {
 		return mL0.NewErr[bool](fmt.Errorf("ClientBusHttp.RegisterServe(): handler==nil"))
 	}
@@ -180,7 +180,7 @@ func (sf *ClientBusHttp) RegisterServe(handler mKt.IBusHandlerServe) mL0.IResult
 }
 
 // Publish -- публикует сообщение в дистанционной шину.
-func (sf *ClientBusHttp) Publish(topic *mKa.Topic, binMsg []byte) mL0.IResult[bool] {
+func (sf *ClientBusHttp) Publish(topic *mKd.Topic, binMsg []byte) mL0.IResult[bool] {
 	_uuid, err := uuid.NewV6()
 	mL1.Hassert()(err == nil, "ClientBusHttp.Publish(): in generate UUID v6, err=\n\t%v", err)
 	req := &msg_pub.PublishReq{
@@ -218,7 +218,7 @@ func (sf *ClientBusHttp) Publish(topic *mKa.Topic, binMsg []byte) mL0.IResult[bo
 }
 
 // Единый обработчик запросов.
-func (sf *ClientBusHttp) makePost(hReq *http.Request) mKt.IResult[[]byte] {
+func (sf *ClientBusHttp) makePost(hReq *http.Request) mKs.IResult[[]byte] {
 	hReq.Header.Add("Content-Type", "application/json")
 	_resp, err := http.DefaultClient.Do(hReq)
 	if err != nil {
@@ -244,7 +244,7 @@ func (sf *ClientBusHttp) makePost(hReq *http.Request) mKt.IResult[[]byte] {
 }
 
 // Log -- возвращает локальный лог клиента.
-func (sf *ClientBusHttp) Log() mKt.ILogBuf {
+func (sf *ClientBusHttp) Log() mKs.ILogBuf {
 	return sf.log
 }
 

v4/lev2/kbus_http/client_bus_http/client_bus_http_test.go

@@ -8,7 +8,7 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus_base"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus_http"
@@ -26,7 +26,7 @@ const (
 type tester struct {
 	t        *testing.T
 	me       mL1.IMockEnv
-	kCtx     mKt.IKernelCtx
+	kCtx     mKs.IKernelCtx
 	cl       *ClientBusHttp
 	handSub  *mock_hand_sub_http.MockHandSubHttp
 	handServ *mock_hand_serve.MockHandlerServe

v4/lev2/kbus_http/kbus_http.go

@@ -8,7 +8,7 @@ import (
 
 	"github.com/gofiber/fiber/v3"
 
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/kbus_msg/msg_pub"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/kbus_msg/msg_serve"
@@ -23,7 +23,7 @@ import (
 // kBusHttp -- шина данных поверх HTTP.
 type kBusHttp struct {
 	*kbus_base.KBusBase
-	log mKt.ILogBuf
+	log mKs.ILogBuf
 }
 
 var (
@@ -32,7 +32,7 @@ var (
 )
 
 // GetKernelBusHttp -- возвращает шину HTTP.
-func GetKernelBusHttp() mKt.IKernelBus {
+func GetKernelBusHttp() mKs.IKernelBus {
 	block.Lock()
 	defer block.Unlock()
 	if Bus_ != nil {
@@ -215,7 +215,7 @@ func (sf *kBusHttp) processUnsubRequest(req *msg_unsub.UnsubReq) *msg_unsub.Unsu
 		resp.Status_ = fmt.Sprintf("kernelBusHttp.processUnsubRequest(): handler(%v) not exists", req.Name_)
 		return resp
 	}
-	hand := optHandler.Some().Val().(mKt.IBusHandlerSubscribe)
+	hand := optHandler.Some().Val().(mKs.IBusHandlerSubscribe)
 	sf.Unsubscribe(hand)
 	return resp
 }

v4/lev2/kbus_local/client_bus_local/client_bus_local.go

@@ -2,17 +2,17 @@
 package client_bus_local
 
 import (
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus_local"
 )
 
 // ClientBusLocal -- клиент локальной шины.
 type ClientBusLocal struct {
-	mKt.IKernelBus
+	mKs.IKernelBus
 }
 
 // NewClientBusLocal -- клиент локальной шины.
-func NewClientBusLocal() mKt.IBusClient {
+func NewClientBusLocal() mKs.IBusClient {
 	sf := &ClientBusLocal{
 		IKernelBus: kbus_local.GetKernelBusLocal(),
 	}

v4/lev2/kctx/kctx.go

@@ -5,7 +5,7 @@ import (
 	"context"
 	"sync"
 
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kernel_keeper"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kwg"
@@ -13,13 +13,13 @@ import (
 
 // kCtx -- контекст ядра.
 type kCtx struct {
-	mKt.ILocalCtx
-	log        mKt.ILogBuf
+	mKs.ILocalCtx
+	log        mKs.ILogBuf
 	ctxBg      context.Context   // Неотменяемый контекст ядра
 	ctx        context.Context   // Отменяемый контекст ядра
 	fnCancel   func()            // Функция отмены контекста ядра
-	kernKeeper mKt.IKernelKeeper // Встроенный сторож отмены контекста системным сигналом
-	kernWg     mKt.IKernelWg     // Встроенный ожидатель потока
+	kernKeeper mKs.IKernelKeeper // Встроенный сторож отмены контекста системным сигналом
+	kernWg     mKs.IKernelWg     // Встроенный ожидатель потока
 }
 
 var (
@@ -28,7 +28,7 @@ var (
 )
 
 // GetKernelCtx -- возвращает контекст ядра.
-func GetKernelCtx() mKt.IKernelCtx {
+func GetKernelCtx() mKs.IKernelCtx {
 	block.Lock()
 	defer block.Unlock()
 	if kernCtx != nil {
@@ -52,12 +52,12 @@ func GetKernelCtx() mKt.IKernelCtx {
 }
 
 // Keeper -- возвращает сторож системных сигналов.
-func (sf *kCtx) Keeper() mKt.IKernelKeeper {
+func (sf *kCtx) Keeper() mKs.IKernelKeeper {
 	return sf.kernKeeper
 }
 
 // Wg -- возвращает ожидатель потоков.
-func (sf *kCtx) Wg() mKt.IKernelWg {
+func (sf *kCtx) Wg() mKs.IKernelWg {
 	return sf.kernWg
 }
 

v4/lev2/kernel_keeper/kernel_keeper.go

@@ -10,7 +10,7 @@ import (
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 )
 
@@ -18,8 +18,8 @@ import (
 type kernelKeeper struct {
 	ctx      context.Context
 	fnCancel func()
-	wg       mKt.IKernelWg
-	log      mKt.ILogBuf
+	wg       mKs.IKernelWg
+	log      mKs.ILogBuf
 	chSys_   chan os.Signal
 }
 
@@ -31,7 +31,7 @@ var (
 
 // GetKernelKeeper -- возвращает новый сторож системных сигналов.
 func GetKernelKeeper(ctx context.Context, fnCancel func(),
-	wg mKt.IKernelWg) *kernelKeeper {
+	wg mKs.IKernelWg) *kernelKeeper {
 	block.Lock()
 	defer block.Unlock()
 	if kernKeep != nil {
@@ -53,12 +53,12 @@ func GetKernelKeeper(ctx context.Context, fnCancel func(),
 
 	go sf.run(sf.chSys_)
 	kernKeep = sf
-	_ = mKt.IKernelKeeper(sf)
+	_ = mKs.IKernelKeeper(sf)
 	return sf
 }
 
 // Log -- возвращает лог сторожа системных сигналов.
-func (sf *kernelKeeper) Log() mKt.ILogBuf {
+func (sf *kernelKeeper) Log() mKs.ILogBuf {
 	return sf.log
 }
 

v4/lev2/kmodule/kmodule.go

@@ -5,8 +5,8 @@ import (
 	"time"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kbus_local"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
@@ -15,17 +15,17 @@ import (
 
 // kModule -- модуль на основе ядра.
 type kModule struct {
-	kCtx      mKt.IKernelCtx
-	ctx       mKt.ILocalCtx
-	name      *mKa.ModuleName
-	bus       mKt.IKernelBus
-	timePhase mKt.ISafeInt
-	strLive   mKt.ISafeString
-	stat      mKt.IModuleStat
+	kCtx      mKs.IKernelCtx
+	ctx       mKs.ILocalCtx
+	name      *mKd.ModuleName
+	bus       mKs.IKernelBus
+	timePhase mKs.ISafeInt
+	strLive   mKs.ISafeString
+	stat      mKs.IModuleStat
 }
 
 // NewKernelModule -- возвращает новый модуль на основе ядра.
-func NewKernelModule(name *mKa.ModuleName) mKt.IKernelModule {
+func NewKernelModule(name *mKd.ModuleName) mKs.IKernelModule {
 	mL0.Hassert(name != nil, "NewKernelModule(): name==nil")
 	kCtx := kctx.GetKernelCtx()
 	sf := &kModule{
@@ -42,17 +42,17 @@ func NewKernelModule(name *mKa.ModuleName) mKt.IKernelModule {
 }
 
 // Stat -- возвращает статистику модуля.
-func (sf *kModule) Stat() mKt.IModuleStat {
+func (sf *kModule) Stat() mKs.IModuleStat {
 	return sf.stat
 }
 
 // Log -- возвращает буферный лог.
-func (sf *kModule) Log() mKt.ILogBuf {
+func (sf *kModule) Log() mKs.ILogBuf {
 	return sf.ctx.Log()
 }
 
 // Ctx -- возвращает контекст модуля.
-func (sf *kModule) Ctx() mKt.ILocalCtx {
+func (sf *kModule) Ctx() mKs.ILocalCtx {
 	return sf.ctx
 }
 
@@ -62,7 +62,7 @@ func (sf *kModule) Run() {
 }
 
 // Name -- возвращает уникальное имя модуля.
-func (sf *kModule) Name() *mKa.ModuleName {
+func (sf *kModule) Name() *mKd.ModuleName {
 	return sf.name
 }
 
@@ -80,7 +80,7 @@ func (sf *kModule) Live() string {
 // Сигнал жизни, каждые 5 сек публикует в шину метку.
 func (sf *kModule) sigLive() {
 	var (
-		topic  = mKa.NewTopic(sf.name.Get() + "_live")
+		topic  = mKd.NewTopic(sf.name.Get() + "_live")
 		iPhase = 0
 		res    mL0.IResult[bool]
 	)

v4/lev2/kmodule/mod_stat/mod_stat.go

@@ -11,9 +11,9 @@ package mod_stat
 import (
 	"time"
 
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule/mod_stat/mod_stat_day"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule/mod_stat/mod_stat_sec"
@@ -22,14 +22,14 @@ import (
 // ModStat -- статистика модуля.
 type ModStat struct {
 	statSec    *mod_stat_sec.ModStatSec // Объект статистики 60 секунд
-	timeMinute mKt.ISafeInt             // Интервал ожидания минутного таймера, мсек
+	timeMinute mKs.ISafeInt             // Интервал ожидания минутного таймера, мсек
 	statMin    *mod_stat_day.ModStatDay // Объект статистики 60 минут
 	statDay    *mod_stat_day.ModStatDay // Объект статистики за последние 24 часа
-	name       *mKa.ModuleName
+	name       *mKd.ModuleName
 }
 
 // NewModStat -- возвращает новую статистику модуля.
-func NewModStat(name *mKa.ModuleName) *ModStat {
+func NewModStat(name *mKd.ModuleName) *ModStat {
 	mKh.Hassert(name != nil, "NewModuleStat(): name==nil")
 	sf := &ModStat{
 		statSec:    mod_stat_sec.NewModStatSec(),

v4/lev2/kmonolit/kmonolit.go

@@ -6,23 +6,23 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
 
 // kMonolit -- объект модульного монолита.
 type kMonolit struct {
-	kCtx    mKt.IKernelCtx
-	lCtx    mKt.ILocalCtx
-	log     mKt.ILogBuf
+	kCtx    mKs.IKernelCtx
+	lCtx    mKs.ILocalCtx
+	log     mKs.ILogBuf
 	name    string
 	isLocal bool
-	isWork  mKt.ISafeBool
-	isEnd   mKt.ISafeBool
-	dict    map[*mKa.ModuleName]mKt.IKernelModule // Словарь модулей монолита
+	isWork  mKs.ISafeBool
+	isEnd   mKs.ISafeBool
+	dict    map[*mKd.ModuleName]mKs.IKernelModule // Словарь модулей монолита
 }
 
 var (
@@ -48,7 +48,7 @@ func GetMonolit(name string) *kMonolit {
 		kCtx:    kCtx,
 		lCtx:    lCtx,
 		name:    name,
-		dict:    map[*mKa.ModuleName]mKt.IKernelModule{},
+		dict:    map[*mKd.ModuleName]mKs.IKernelModule{},
 		isWork:  mL1.NewSafeBool(),
 		isEnd:   mL1.NewSafeBool(),
 		isLocal: isLocal,
@@ -57,17 +57,17 @@ func GetMonolit(name string) *kMonolit {
 	sf.kCtx.Set("monolitName", name, "name of monolit")
 	sf.kCtx.Set("monolit", sf, "monolit-app")
 	mon = sf
-	_ = mKt.IKernelMonolit(sf)
+	_ = mKs.IKernelMonolit(sf)
 	return sf
 }
 
 // Ctx -- возвращает контекст монолита.
-func (sf *kMonolit) Ctx() mKt.ILocalCtx {
+func (sf *kMonolit) Ctx() mKs.ILocalCtx {
 	return sf.lCtx
 }
 
 // Log -- возвращает лог монолита.
-func (sf *kMonolit) Log() mKt.ILogBuf {
+func (sf *kMonolit) Log() mKs.ILogBuf {
 	return sf.lCtx.Log()
 }
 
@@ -77,7 +77,7 @@ func (sf *kMonolit) Name() string {
 }
 
 // Add -- добавляет модуль в монолит.
-func (sf *kMonolit) Add(module mKt.IKernelModule) {
+func (sf *kMonolit) Add(module mKs.IKernelModule) {
 	sf.kCtx.RLock()
 	defer sf.kCtx.RUnlock()
 	mL0.Hassert(module != nil, "kMonolit.Add(): module==nil")

v4/lev2/kmonolit/kmonolit_test.go

@@ -5,8 +5,8 @@ import (
 	"testing"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/mock_env"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule"
@@ -20,7 +20,7 @@ const (
 type tester struct {
 	t   *testing.T
 	me  *mock_env.MockEnv
-	mon mKt.IKernelMonolit
+	mon mKs.IKernelMonolit
 }
 
 func TestKernMono(t *testing.T) {
@@ -60,10 +60,10 @@ func (sf *tester) add() {
 }
 
 type mod struct {
-	mKt.IKernelModule
+	mKs.IKernelModule
 }
 
-func newMod(name *mKa.ModuleName) mKt.IKernelModule {
+func newMod(name *mKd.ModuleName) mKs.IKernelModule {
 	sf := &mod{
 		IKernelModule: kmodule.NewKernelModule(name),
 	}
@@ -74,14 +74,14 @@ func (sf *mod) Run() {}
 
 func (sf *tester) addGood1() {
 	sf.t.Log("addGood1")
-	modName := mKa.NewModuleName("test_module")
+	modName := mKd.NewModuleName("test_module")
 	mod := newMod(modName)
 	sf.mon.Add(mod)
 }
 
 func (sf *tester) run() {
 	sf.t.Log("run")
-	modName := mKa.NewModuleName("test_mod1")
+	modName := mKd.NewModuleName("test_mod1")
 	mod := newMod(modName)
 	sf.mon.Add(mod)
 	sf.mon.Run()

v4/lev2/kserv_http/kserv_http.go

@@ -17,7 +17,7 @@ import (
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
@@ -28,13 +28,13 @@ var (
 
 // kServHttp -- встроенный HTTP-сервер.
 type kServHttp struct {
-	kCtx     mKt.IKernelCtx
-	lCtx     mKt.ILocalCtx
-	log      mKt.ILogBuf
+	kCtx     mKs.IKernelCtx
+	lCtx     mKs.ILocalCtx
+	log      mKs.ILogBuf
 	strUrl   string // URL, на котором слушает HTTP-сервер
 	fiberApp *fiber.App
-	isWork   mKt.ISafeBool
-	isEnd    mKt.ISafeBool
+	isWork   mKs.ISafeBool
+	isEnd    mKs.ISafeBool
 }
 
 //go:embed static/*
@@ -47,7 +47,7 @@ var (
 	hassert      = helpers.Hassert
 )
 
-func getParams() (string, mKt.ILogBuf, mKt.IKernelCtx) {
+func getParams() (string, mKs.ILogBuf, mKs.IKernelCtx) {
 	log := mL1.NewLogBuf(mL1.OptIsTerm(true), mL1.OptPrefix("kServHttp"))
 	log.Debug("GetKernelServHttp(): first run")
 	strLocalUrl := os.Getenv("LOCAL_HTTP_URL")
@@ -57,7 +57,7 @@ func getParams() (string, mKt.ILogBuf, mKt.IKernelCtx) {
 }
 
 // GetKernelServHttp -- возвращает  встроенный HTTP-сервер.
-func GetKernelServHttp() mKt.IKernelServerHttp {
+func GetKernelServHttp() mKs.IKernelServerHttp {
 	block.Lock()
 	defer block.Unlock()
 	if kernServHttp != nil {
@@ -108,7 +108,7 @@ func (sf *kServHttp) IsWork() bool {
 }
 
 // Log -- возвращает локальный лог.
-func (sf *kServHttp) Log() mKt.ILogBuf {
+func (sf *kServHttp) Log() mKs.ILogBuf {
 	return sf.log
 }
 

v4/lev2/kserv_http_std/kserv_http_std.go

@@ -8,15 +8,15 @@ import (
 	"time"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
 
 // kServHttpStd -- реализация HTTP-сервера на стандартной библиотеке.
 type kServHttpStd struct {
-	kCtx   mKt.IKernelCtx
-	log    mKt.ILogBuf
+	kCtx   mKs.IKernelCtx
+	log    mKs.ILogBuf
 	port   int
 	server *http.Server
 }

v4/lev2/kstore_kv/kstore_kv.go

@@ -12,7 +12,7 @@ import (
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
@@ -24,13 +24,13 @@ var (
 // kStoreKv -- локальное хранилище ядра.
 type kStoreKv struct {
 	sync.RWMutex
-	kCtx      mKt.IKernelCtx
-	lCtx      mKt.ILocalCtx
-	log       mKt.ILogBuf
-	wg        mKt.IKernelWg
+	kCtx      mKs.IKernelCtx
+	lCtx      mKs.ILocalCtx
+	log       mKs.ILogBuf
+	wg        mKs.IKernelWg
 	storePath string
 	db        *badger.DB
-	isWork    mKt.ISafeBool
+	isWork    mKs.ISafeBool
 }
 
 var (
@@ -39,7 +39,7 @@ var (
 )
 
 // GetKernelStore -- возвращает новое локальное хранилище ядра.
-func GetKernelStore() mKt.IKernelStoreKv {
+func GetKernelStore() mKs.IKernelStoreKv {
 	block.Lock()
 	defer block.Unlock()
 	if kernStore != nil {
@@ -62,7 +62,7 @@ func GetKernelStore() mKt.IKernelStoreKv {
 }
 
 // Log -- возвращает локальный лог.
-func (sf *kStoreKv) Log() mKt.ILogBuf {
+func (sf *kStoreKv) Log() mKs.ILogBuf {
 	return sf.log
 }
 

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

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

v4/lev2/kwg/kwg.go

@@ -8,9 +8,9 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	mL1 "gitp78su.ipnodns.ru/svi/kern/v4/lev1"
 )
 
@@ -18,9 +18,9 @@ import (
 type kernelWg struct {
 	sync.RWMutex
 	ctx        context.Context
-	dictStream map[*mKa.StreamName]bool // Словарь имён потоков с признаком работы
-	isWork     mKt.ISafeBool
-	log        mKt.ILogBuf
+	dictStream map[*mKd.StreamName]bool // Словарь имён потоков с признаком работы
+	isWork     mKs.ISafeBool
+	log        mKs.ILogBuf
 }
 
 var (
@@ -29,7 +29,7 @@ var (
 )
 
 // GetKernelWg -- возвращает новый именованный ожидатель потоков ядра.
-func GetKernelWg(ctx context.Context) mKt.IKernelWg {
+func GetKernelWg(ctx context.Context) mKs.IKernelWg {
 	block.Lock()
 	defer block.Unlock()
 	if kernWg != nil {
@@ -39,7 +39,7 @@ func GetKernelWg(ctx context.Context) mKt.IKernelWg {
 	mKh.Hassert(ctx != nil, "GetKernelWg(): ctx==nil")
 	sf := &kernelWg{
 		ctx:        ctx,
-		dictStream: map[*mKa.StreamName]bool{},
+		dictStream: map[*mKd.StreamName]bool{},
 		isWork:     mL1.NewSafeBool(),
 		log:        mL1.NewLogBuf(mL1.OptIsTerm(true), mL1.OptPrefix("kernelWg")),
 	}
@@ -51,7 +51,7 @@ func GetKernelWg(ctx context.Context) mKt.IKernelWg {
 }
 
 // Log -- возвращает лог ожидателя потоков.
-func (sf *kernelWg) Log() mKt.ILogBuf {
+func (sf *kernelWg) Log() mKs.ILogBuf {
 	return sf.log
 }
 
@@ -68,10 +68,10 @@ func (sf *kernelWg) IsWork() bool {
 }
 
 // List -- возвращает список имён потоков на ожидании.
-func (sf *kernelWg) List() []*mKa.StreamName {
+func (sf *kernelWg) List() []*mKd.StreamName {
 	sf.RLock()
 	defer sf.RUnlock()
-	lst := make([]*mKa.StreamName, 0, len(sf.dictStream))
+	lst := make([]*mKd.StreamName, 0, len(sf.dictStream))
 	for name := range sf.dictStream {
 		lst = append(lst, name)
 	}
@@ -79,7 +79,7 @@ func (sf *kernelWg) List() []*mKa.StreamName {
 }
 
 // Done -- удаляет поток из ожидания.
-func (sf *kernelWg) Done(name *mKa.StreamName) {
+func (sf *kernelWg) Done(name *mKd.StreamName) {
 	sf.Lock()
 	defer sf.Unlock()
 	delete(sf.dictStream, name)
@@ -98,7 +98,7 @@ func (sf *kernelWg) Wait() {
 }
 
 // Add -- добавляет поток в ожидание.
-func (sf *kernelWg) Add(name *mKa.StreamName) {
+func (sf *kernelWg) Add(name *mKd.StreamName) {
 	sf.Lock()
 	defer sf.Unlock()
 	sf.log.Debug("Add(): stream='%v'", name)

v4/lev2/log_topic/log_topic.go

@@ -5,18 +5,18 @@ import (
 	"fmt"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // LogTopic -- элемент лога шины.
 type LogTopic struct {
-	topic  *mKa.Topic    // Топик, куда публиковать лог
-	client mKt.IBusClient // С помощью чего публиковать лог
+	topic  *mKd.Topic    // Топик, куда публиковать лог
+	client mKs.IBusClient // С помощью чего публиковать лог
 }
 
 // NewLogTopic -- возвращает новый элемент лога.
-func NewLogTopic(topic *mKa.Topic, client mKt.IBusClient) mL0.IResult[*LogTopic] {
+func NewLogTopic(topic *mKd.Topic, client mKs.IBusClient) mL0.IResult[*LogTopic] {
 	mL0.Hassert(topic != nil, "NewLogTopic(): topic==nil")
 	if client == nil {
 		err := fmt.Errorf("NewLogTopic(): IBusClient==nil")

v4/lev2/mock_hand_serve/mock_hand_serve.go

@@ -6,31 +6,31 @@ import (
 	"sync"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/safe_bool"
 )
 
 // MockHandlerServe -- мок-обработчик входящих запросов.
 type MockHandlerServe struct {
-	IsBad_ mKt.ISafeBool     // Признак сбоя при вызове
+	IsBad_ mKs.ISafeBool     // Признак сбоя при вызове
 	Msg_   []byte            // Для обратного вызова
-	Name_  *mKa.HandlerName // Уникальное имя мок-обработчика подписки
-	Topic_ *mKa.Topic       // Имя топика подписки
+	Name_  *mKd.HandlerName // Уникальное имя мок-обработчика подписки
+	Topic_ *mKd.Topic       // Имя топика подписки
 	block  sync.Mutex
 }
 
 // NewMockHandlerServe -- возвращает новый обработчик подписки.
-func NewMockHandlerServe(topic *mKa.Topic, name string) *MockHandlerServe {
+func NewMockHandlerServe(topic *mKd.Topic, name string) *MockHandlerServe {
 	mKh.Hassert(topic.Get() != "", "NewMockHandlerServe(): topic is empty")
 	mKh.Hassert(name != "", "NewMockHandlerServe(): name is empty")
 	sf := &MockHandlerServe{
 		Topic_: topic,
-		Name_:  mKa.NewHandlerName(name),
+		Name_:  mKd.NewHandlerName(name),
 		IsBad_: safe_bool.NewSafeBool(),
 	}
-	_ = mKt.IBusHandlerServe(sf)
+	_ = mKs.IBusHandlerServe(sf)
 	return sf
 }
 
@@ -47,11 +47,11 @@ func (sf *MockHandlerServe) FnBack(binMsg []byte) mL0.IResult[[]byte] {
 }
 
 // Возвращает уникальное имя обработчика подписки.
-func (sf *MockHandlerServe) Topic() *mKa.Topic {
+func (sf *MockHandlerServe) Topic() *mKd.Topic {
 	return sf.Topic_
 }
 
 // Возвращает топик для обработчика подписки.
-func (sf *MockHandlerServe) Name() *mKa.HandlerName {
+func (sf *MockHandlerServe) Name() *mKd.HandlerName {
 	return sf.Name_
 }

v4/lev2/mock_hand_sub_http/mock_hand_sub_http.go

@@ -6,39 +6,39 @@ import (
 	"log"
 	"sync"
 
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // MockHandSubHttp -- обработчик подписки по HTTP.
 type MockHandSubHttp struct {
-	Name_    *mKa.HandlerName // Уникальное имя обработчика
-	Topic_   *mKa.Topic       // Имя топика, на который подписан обработчик
+	Name_    *mKd.HandlerName // Уникальное имя обработчика
+	Topic_   *mKd.Topic       // Имя топика, на который подписан обработчик
 	WebHook_ string            // Куда обращаться при запросах
 	BinMsg_  []byte            // Последнее бинарное сообщение
 	block    sync.RWMutex
 }
 
 // NewMockHandSubHttp -- возвращает новый обработчик подписки по HTTP.
-func NewMockHandSubHttp(topic *mKa.Topic, webHook string) mKt.IBusHandlerSubscribe {
+func NewMockHandSubHttp(topic *mKd.Topic, webHook string) mKs.IBusHandlerSubscribe {
 	mKh.Hassert(topic.Get() != "", "NewHandlerHttpSub(): topic is empty")
 	mKh.Hassert(webHook != "", "NewHandlerHttpSub(): webHook is empty")
 	sf := &MockHandSubHttp{
 		Topic_:   topic,
-		Name_:    mKa.NewHandlerName(webHook + "_" + rand.Text()),
+		Name_:    mKd.NewHandlerName(webHook + "_" + rand.Text()),
 		WebHook_: webHook,
 	}
 	return sf
 }
 
 // Topic -- возвращает имя топика, на который подписан обработчик.
-func (sf *MockHandSubHttp) Topic() *mKa.Topic {
+func (sf *MockHandSubHttp) Topic() *mKd.Topic {
 	return sf.Topic_
 }
 
 // SetName -- устанавливает имя обработчика.
-func (sf *MockHandSubHttp) SetName(name *mKa.HandlerName) {
+func (sf *MockHandSubHttp) SetName(name *mKd.HandlerName) {
 	sf.block.Lock()
 	defer sf.block.Unlock()
 	mKh.Hassert(name != nil, "HandlerHttpSub.SetName(): name is empty")
@@ -46,7 +46,7 @@ func (sf *MockHandSubHttp) SetName(name *mKa.HandlerName) {
 }
 
 // Name -- возвращает уникальное имя обработчика.
-func (sf *MockHandSubHttp) Name() *mKa.HandlerName {
+func (sf *MockHandSubHttp) Name() *mKd.HandlerName {
 	sf.block.RLock()
 	defer sf.block.RUnlock()
 	return sf.Name_

v4/lev2/mock_hand_sub_local/mock_hand_sub.go

@@ -5,27 +5,27 @@ import (
 	"crypto/rand"
 	"sync"
 
-	mKa "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
+	mKd "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 type MockHandlerSub struct {
 	Msg_   []byte            // Для обратного вызова
-	Name_  *mKa.HandlerName // Уникальное имя мок-обработчика подписки
-	Topic_ *mKa.Topic       // Имя топика подписки
+	Name_  *mKd.HandlerName // Уникальное имя мок-обработчика подписки
+	Topic_ *mKd.Topic       // Имя топика подписки
 	block  sync.RWMutex
 }
 
 // NewMockHandlerSub -- возвращает новый обработчик подписки.
-func NewMockHandlerSub(topic *mKa.Topic, localHook string) *MockHandlerSub {
+func NewMockHandlerSub(topic *mKd.Topic, localHook string) *MockHandlerSub {
 	mKh.Hassert(topic.Get() != "", "NewMockHandlerSub(): topic is empty")
 	mKh.Hassert(localHook != "", "NewMockHandlerSub(): name is empty")
 	sf := &MockHandlerSub{
 		Topic_: topic,
-		Name_:  mKa.NewHandlerName(localHook + "_" + rand.Text()),
+		Name_:  mKd.NewHandlerName(localHook + "_" + rand.Text()),
 	}
-	_ = mKt.IBusHandlerSubscribe(sf)
+	_ = mKs.IBusHandlerSubscribe(sf)
 	return sf
 }
 
@@ -44,11 +44,11 @@ func (sf *MockHandlerSub) FnBack(binMsg []byte) {
 }
 
 // Возвращает уникальное имя обработчика подписки.
-func (sf *MockHandlerSub) Topic() *mKa.Topic {
+func (sf *MockHandlerSub) Topic() *mKd.Topic {
 	return sf.Topic_
 }
 
 // Возвращает топик для обработчика подписки.
-func (sf *MockHandlerSub) Name() *mKa.HandlerName {
+func (sf *MockHandlerSub) Name() *mKd.HandlerName {
 	return sf.Name_
 }

v4/lev2/wui/wui_types/iwui_ctx.go

@@ -2,10 +2,10 @@
 package wui_types
 
 import (
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 )
 
 // IWuiCtx -- контекст веб-интерфейса.
 type IWuiCtx interface {
-	mKt.ILocalCtx
+	mKs.ILocalCtx
 }

v4/lev3/mod_kctx/mod_kctx.go

@@ -5,7 +5,7 @@ import (
 	"sync"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kserv_http"
@@ -16,10 +16,10 @@ import (
 
 // ModuleKernelCtx -- модуль контекста ядра.
 type ModuleKernelCtx struct {
-	mKt.IKernelModule
-	kCtx      mKt.IKernelCtx
-	kServHttp mKt.IKernelServerHttp
-	log       mKt.ILogBuf
+	mKs.IKernelModule
+	kCtx      mKs.IKernelCtx
+	kServHttp mKs.IKernelServerHttp
+	log       mKs.ILogBuf
 }
 
 var (

v4/lev3/mod_keeper/mod_keeper.go

@@ -5,7 +5,7 @@ import (
 	"sync"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kserv_http"
@@ -16,10 +16,10 @@ import (
 
 // ModuleKeeper -- модуль сторожа.
 type ModuleKeeper struct {
-	mKt.IKernelModule
-	kCtx      mKt.IKernelCtx
-	kServHttp mKt.IKernelServerHttp
-	log       mKt.ILogBuf
+	mKs.IKernelModule
+	kCtx      mKs.IKernelCtx
+	kServHttp mKs.IKernelServerHttp
+	log       mKs.ILogBuf
 }
 
 var (

v4/lev3/mod_serv_http/btn_modules/btn_modules.go

@@ -7,7 +7,7 @@ import (
 	"strings"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/wui"
 	mWt "gitp78su.ipnodns.ru/svi/kern/v4/lev2/wui/wui_types"
@@ -15,7 +15,7 @@ import (
 
 type BtnModules struct {
 	btn  mWt.IWuiButton
-	kCtx mKt.IKernelCtx
+	kCtx mKs.IKernelCtx
 }
 
 // NewBtnModules -- возвращает новую кнопку для показа модулей.
@@ -46,7 +46,7 @@ func (sf *BtnModules) clickMonolit(dict map[string]string) mL0.IResult[string] {
 		err := fmt.Errorf("clickMonolit(): monolit module not found")
 		return mL0.NewErr[string](err)
 	}
-	mon := optMonolit.Some().Val().(mKt.IKernelMonolit)
+	mon := optMonolit.Some().Val().(mKs.IKernelMonolit)
 	chLst := mon.Ctx().SortedList()
 	strOut := ``
 	for _, val := range chLst {
@@ -58,7 +58,7 @@ func (sf *BtnModules) clickMonolit(dict map[string]string) mL0.IResult[string] {
 		strRow := strBlockRow
 		strRow = strings.ReplaceAll(strRow, "{.id}", id)
 		strRow = strings.ReplaceAll(strRow, "{.key}", val.Key())
-		moduleName := val.Val().(mKt.IKernelModule).Name().Get()
+		moduleName := val.Val().(mKs.IKernelModule).Name().Get()
 		strRow = strings.ReplaceAll(strRow, "{.name}", moduleName)
 		type_ := fmt.Sprintf("%#T", val.Val())
 		type_ = strings.ReplaceAll(type_, ".", ".<br>")

v4/lev3/mod_serv_http/mod_serv_http.go

@@ -5,7 +5,7 @@ import (
 	"sync"
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kserv_http"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/http_api"
@@ -15,9 +15,9 @@ import (
 
 // ModuleServHttp -- модуль HTTP-сервера.
 type ModuleServHttp struct {
-	mKt.IKernelModule
-	kServHttp mKt.IKernelServerHttp
-	log       mKt.ILogBuf
+	mKs.IKernelModule
+	kServHttp mKs.IKernelServerHttp
+	log       mKs.ILogBuf
 }
 
 var (

v4/lev3/mod_serv_http/page_module/page_module.go

@@ -9,13 +9,13 @@ import (
 	"github.com/gofiber/fiber/v3"
 
 	mL0 "gitp78su.ipnodns.ru/svi/kern/v4/lev0"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 )
 
 // PageModule -- страница показа модуля.
 type PageModule struct {
-	ctx mKt.IKernelCtx
+	ctx mKs.IKernelCtx
 }
 
 var page *PageModule
@@ -226,15 +226,15 @@ func (sf *PageModule) postSvgSec(ctx fiber.Ctx) error {
 }
 
 // Возвращает модуль.
-func (sf *PageModule) getModule(id string) (mKt.IKernelModule, mKt.ICtxValue) {
+func (sf *PageModule) getModule(id string) (mKs.IKernelModule, mKs.ICtxValue) {
 	optMonolit := sf.ctx.Get("monolit")
 	if optMonolit.IsNone() {
 		return nil, nil
 	}
-	mon := optMonolit.Some().Val().(mKt.IKernelMonolit)
+	mon := optMonolit.Some().Val().(mKs.IKernelMonolit)
 	chLst := mon.Ctx().SortedList()
 	var (
-		val    mKt.ICtxValue
+		val    mKs.ICtxValue
 		isFind bool
 	)
 	for _, val = range chLst {
@@ -247,6 +247,6 @@ func (sf *PageModule) getModule(id string) (mKt.IKernelModule, mKt.ICtxValue) {
 	if !isFind {
 		return nil, nil
 	}
-	mod := val.Val().(mKt.IKernelModule)
+	mod := val.Val().(mKs.IKernelModule)
 	return mod, val
 }

v4/lev3/mod_serv_http/page_monolit/page_monolit.go

@@ -9,7 +9,7 @@ import (
 
 	"github.com/gofiber/fiber/v3"
 
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/btn_modules"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev3/mod_serv_http/btn_monolit"
@@ -17,7 +17,7 @@ import (
 
 // PageMonolit -- страница показа монолита.
 type PageMonolit struct {
-	kCtx       mKt.IKernelCtx
+	kCtx       mKs.IKernelCtx
 	btnMonolit *btn_monolit.BtnMonolit
 	btnModules *btn_modules.BtnModules
 }
@@ -66,7 +66,7 @@ func (sf *PageMonolit) postMonolitLog(ctx fiber.Ctx) error {
 		err := fmt.Errorf("PageMonolit.postMonolitLog(): mod='monolit', not found monolit in kernel ctx")
 		return err
 	}
-	mon := optMonolit.Some().Val().(mKt.IKernelMonolit)
+	mon := optMonolit.Some().Val().(mKs.IKernelMonolit)
 	_log := mon.Log()
 	strOut := ""
 	for i := range 100 {
@@ -93,7 +93,7 @@ func (sf *PageMonolit) postMonolitCtx(ctx fiber.Ctx) error {
 		err := fmt.Errorf("PageMonolit.postMonolitCtx(): mod='monolit', not found monolit in kernel ctx")
 		return err
 	}
-	mon := optMon.Some().Val().(mKt.IKernelMonolit)
+	mon := optMon.Some().Val().(mKs.IKernelMonolit)
 	chLst := mon.Ctx().SortedList()
 	strOut := ``
 	for _, val := range chLst {
@@ -124,7 +124,7 @@ func (sf *PageMonolit) postMonolitState(ctx fiber.Ctx) error {
 		return err
 	}
 	ctxMon := optMonolit.Some()
-	mon := ctxMon.Val().(mKt.IKernelMonolit)
+	mon := ctxMon.Val().(mKs.IKernelMonolit)
 	dictState["{.name}"] = mon.Name()
 	dictState["{.createAt}"] = ctxMon.CreateAt()
 	dictState["{.updateAt}"] = ctxMon.UpdateAt()

v4/lev3/mod_wui/mod_wui.go

@@ -12,7 +12,7 @@ import (
 
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	mKh "gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
-	mKt "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
+	mKs "gitp78su.ipnodns.ru/svi/kern/v4/lev0/kspec"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kctx"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kmodule"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev2/kserv_http"
@@ -25,11 +25,11 @@ import (
 
 // ModuleWui -- модуль WUI.
 type ModuleWui struct {
-	mKt.IKernelModule
-	kCtx      mKt.IKernelCtx
+	mKs.IKernelModule
+	kCtx      mKs.IKernelCtx
 	wCtx      mWt.IWuiCtx
-	kServHttp mKt.IKernelServerHttp
-	log       mKt.ILogBuf
+	kServHttp mKs.IKernelServerHttp
+	log       mKs.ILogBuf
 }
 
 var (
@@ -71,7 +71,7 @@ func (sf *ModuleWui) Run() {
 }
 
 // Log -- возвращает буферный лог.
-func (sf *ModuleWui) Log() mKt.ILogBuf {
+func (sf *ModuleWui) Log() mKs.ILogBuf {
 	return sf.log
 }