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

v4/lev0/defs/def_int/def_int.go

@@ -3,7 +3,7 @@ package def_int
 
 import "gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/def_spec"
 
-type Int struct{
+type Int struct {
 	val def_spec.Int
 }
 

v4/lev0/defs/def_spec/def_err.go

@@ -6,4 +6,4 @@ type IErr interface {
 	ITxtFix
 	// IsErr -- возвращает true, если ошибка.
 	IsErr() bool
-}
+}

v4/lev0/defs/def_spec/def_option.go

@@ -16,4 +16,4 @@ type IOption[T any] interface {
 	Hassert(msgFormat ATxt, args ...any) T
 	// Assert -- проверяет, что нет ошибки (с паникой только на локальном стенде).
 	Assert(msgFormat ATxt, args ...any) T
-}
+}

v4/lev0/defs/def_spec/def_result.go

@@ -20,4 +20,4 @@ type IResult[T any] interface {
 	Hassert(msgFormat ATxt, args ...any) T
 	// Assert -- проверяет, что нет ошибки (с паникой только на локальном стенде).
 	Assert(msgFormat ATxt, args ...any) T
-}
+}

v4/lev0/defs/def_spec/def_spec.go

@@ -1,7 +1,7 @@
 // package def_spec -- внутренние спецификации типы
 package def_spec
 
-import(
+import (
 	"fmt"
 )
 

v4/lev0/defs/def_spec/def_txt.go

@@ -24,4 +24,4 @@ type ITxtMut interface {
 	ITxtFix
 	// Set -- устанавливает внутреннюю строку
 	Set(ATxt)
-}
+}

v4/lev0/defs/def_txt/def_txt.go

@@ -15,7 +15,6 @@ type KTxt struct {
 	val def_spec.ATxt
 }
 
-
 // Txt -- создать новую строку.
 func Txt[T def_spec.TxtConstraint](msg T, arg ...any) *KTxt {
 	_msg := def_spec.Sprintf(msg, arg...)
@@ -87,9 +86,9 @@ func (sf KTxt) String() string {
 
 // Atoi -- возвращает возможное число.
 func (sf KTxt) Atoi() def_spec.IResult[def_spec.Int] {
-	iRes,err:=strconv.Atoi(sf.String())
-	if err!=nil{
-		err:=fmt.Errorf("KTxt.Atot(): val(%q) not int, err=\n\t%w", sf.val, err)
+	iRes, err := strconv.Atoi(sf.String())
+	if err != nil {
+		err := fmt.Errorf("KTxt.Atot(): val(%q) not Int, err=\n\t%w", sf.val, err)
 		return result.NewErr[def_spec.Int](err)
 	}
 	return result.NewOk(def_spec.Int(iRes))

v4/lev0/defs/stream_name/stream_name.go

@@ -18,4 +18,3 @@ func NewAStreamName(val defs.ITxtFix) *AStreamName {
 	}
 	return sf
 }
-

v4/lev0/result/result.go

@@ -13,8 +13,8 @@ import (
 //
 // Может быть либо только полезное значение, либо только ошибка.
 type Result[T any] struct {
-	val     T             // Полезное значение
-	isCheck bool          // Если проверено
+	val     T     // Полезное значение
+	isCheck bool  // Если проверено
 	err     error // Ошибка
 }
 

v4/lev1/local_ctx/ctx_value/ctx_value_test.go

@@ -27,7 +27,7 @@ func (sf *tester) new() {
 	if sf.val == nil {
 		sf.t.Fatalf("new(): val==nil")
 	}
-	if val := sf.val.Val().(int); val != 5 {
+	if val := sf.val.Val().(defs.Int); val != 5 {
 		sf.t.Fatalf("new(): val(%v)!=5", val)
 	}
 	create := sf.val.CreateAt()

v4/lev1/local_ctx/local_ctx_test.go

@@ -43,7 +43,7 @@ func (sf *tester) get() {
 	sf.t.Log("get")
 	optRes := sf.lCtx.Get(defs.TxtFix("count"))
 	ctxVal := optRes.Hassert("get()")
-	count := ctxVal.Val().(int)
+	count := ctxVal.Val().(defs.Int)
 	if count == 15 {
 		return
 	}

v4/lev1/log_buf/log_buf.go

@@ -86,7 +86,7 @@ func (sf *LogBuf) GetErr(num defs.Int) log_msg.ILogMsg {
 		msg := sf.Prefix_.Get() + "not error msg"
 		return log_msg.NewLogMsg(log_msg.DEBUG, defs.TxtFix(msg))
 	}
-	if int(num) >= len(sf.lstErr) {
+	if num >= defs.Int(len(sf.lstErr)) {
 		return sf.lstErr[len(sf.lstErr)-1]
 	}
 	if num <= 0 {
@@ -103,7 +103,7 @@ func (sf *LogBuf) Get(num defs.Int) log_msg.ILogMsg {
 	if len(sf.lst) == 0 {
 		return log_msg.NewLogMsg(log_msg.DEBUG, defs.TxtFix(msg))
 	}
-	if int(num) >= len(sf.lst) {
+	if num >= defs.Int(len(sf.lst)) {
 		return log_msg.NewLogMsg(log_msg.DEBUG, defs.TxtFix(msg))
 	}
 	if num <= 0 {

v4/lev1/log_buf/log_msg/log_msg.go

@@ -36,7 +36,7 @@ type logMsg struct {
 }
 
 // NewLogMsg -- возвращает новое сообщение логгера.
-func NewLogMsg(level int, msg defs.ITxtFix) ILogMsg {
+func NewLogMsg(level defs.Int, msg defs.ITxtFix) ILogMsg {
 	sf := &logMsg{
 		createdAt: etime.NewETimeAuto(),
 		msg:       msg,
@@ -67,7 +67,7 @@ func (sf *logMsg) CreateAt() core_spec.ITime {
 }
 
 // Проверяет правильность своего состава.
-func (sf *logMsg) check(level int) {
+func (sf *logMsg) check(level defs.Int) {
 	switch level {
 	case DEBUG:
 		sf.level.Set("DEBU")

v4/lev1/lst_sort/lst_sort.go

@@ -5,6 +5,7 @@ import (
 	"sort"
 	"sync"
 
+	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/helpers"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
 )
@@ -50,18 +51,18 @@ func (sf *LstSort) List() []comp_spec.ICtxValue {
 }
 
 // Size -- возвращает длину списка.
-func (sf *LstSort) Size() int {
+func (sf *LstSort) Size() defs.Int {
 	sf.RLock()
 	defer sf.RUnlock()
-	return len(sf.lstVal)
+	return defs.Int(len(sf.lstVal))
 }
 
 // Get -- возвращает по индексу.
-func (sf *LstSort) Get(ind int) comp_spec.ICtxValue {
+func (sf *LstSort) Get(ind defs.Int) comp_spec.ICtxValue {
 	sf.RLock()
 	defer sf.RUnlock()
 	helpers.Hassert(ind >= 0, "LstSort.Get(): ind(%v)<0", []any{ind})
-	helpers.Hassert(ind < len(sf.lstVal), "LstSort.Get(): ind(%v)>=len(%v)", []any{ind, len(sf.lstVal)})
+	helpers.Hassert(ind < defs.Int(len(sf.lstVal)), "LstSort.Get(): ind(%v)>=len(%v)", []any{ind, len(sf.lstVal)})
 	return sf.lstVal[ind]
 }
 

v4/lev2/kchan/kchan.go

@@ -17,7 +17,7 @@ var (
 
 // KChanParam -- параметры умного канала.
 type KChanParam[T any] struct {
-	Limit_   int                 // лимит на размер канала, не может быть пустым
+	Limit_   defs.Int            // лимит на размер канала, не может быть пустым
 	OnWrite_ func(T)             // Обратный вызов при записи в канал
 	OnRead_  func(T)             // Обратный вызов при чтении из канала
 	OnClose_ func()              // Обратный вызов при закрытии канала

v4/lev2/kctx/kctx_test.go

@@ -38,7 +38,7 @@ func (sf *tester) new() {
 	}
 	res := kCtx.Get(counter)
 	ctxVal := res.Hassert("new()")
-	val := ctxVal.Val().(int)
+	val := ctxVal.Val().(defs.Int)
 	if val != 5 {
 		sf.t.Fatalf("new(): counter(%v)!=5", val)
 	}

v4/lev2/kmodule/mod_stat/mod_stat_minute/mod_stat_minute.go

@@ -16,24 +16,24 @@ import (
 // ModStatMinutes -- статистика модуля за первые 60 мин.
 type ModStatMinutes struct {
 	sync.RWMutex
-	lst    []int // Список значений за последние 60 мин
+	lst    []defs.Int // Список значений за последние 60 мин
 	bufSvg *bytes.Buffer
 }
 
 // NewModStatMinute -- возвращает новую статистику модуля за последние 60 мин.
 func NewModStatMinute() *ModStatMinutes {
 	sf := &ModStatMinutes{
-		lst:    []int{},
+		lst:    []defs.Int{},
 		bufSvg: bytes.NewBufferString(""),
 	}
 	return sf
 }
 
 // Sum -- возвращает сумму элементов по требованию.
-func (sf *ModStatMinutes) Sum() int {
+func (sf *ModStatMinutes) Sum() defs.Int {
 	sf.RLock()
 	defer sf.RUnlock()
-	sum := 0
+	sum := defs.Int(0)
 	for _, val := range sf.lst {
 		sum += val
 	}
@@ -41,7 +41,7 @@ func (sf *ModStatMinutes) Sum() int {
 }
 
 // Add -- добавляет значение в часовой срез.
-func (sf *ModStatMinutes) Add(val int) {
+func (sf *ModStatMinutes) Add(val defs.Int) {
 	sf.Lock()
 	defer sf.Unlock()
 
@@ -66,8 +66,8 @@ func (sf *ModStatMinutes) Svg() defs.ITxtFix {
 	cnv.Desc("Graphic of last 60 minute")
 	cnv.Text(20, 20, "Last 60 minute", "")
 	var (
-		valMin = math.MaxInt64
-		valMax = math.MinInt64
+		valMin = defs.Int(math.MaxInt64)
+		valMax = defs.Int(math.MinInt64)
 	)
 	fnGetMinMax := func() { // Вычисляет максимальное и минимальное значение в графике
 		for _, val := range sf.lst {
@@ -91,7 +91,7 @@ func (sf *ModStatMinutes) Svg() defs.ITxtFix {
 	return defs.TxtFix(strOut)
 }
 
-func (sf *ModStatMinutes) drawNet(valMin, valMax int, cnv *svg.SVG) {
+func (sf *ModStatMinutes) drawNet(valMin, valMax defs.Int, cnv *svg.SVG) {
 	// Метки величины
 	if valMin == math.MaxInt64 || valMin == math.MinInt64 {
 		valMin = 0

v4/lev2/kspec/ikernel_wg.go

@@ -2,6 +2,7 @@ package kspec
 
 import (
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/core_spec"
+	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev0/defs/stream_name"
 	"gitp78su.ipnodns.ru/svi/kern/v4/lev1/comp_spec"
 )
@@ -19,7 +20,7 @@ type IKernelWg interface {
 	// List -- возвращает список имён потоков на ожидании
 	List() []*stream_name.AStreamName
 	// Len -- возвращает размер списка потоков ожидания
-	Len() int
+	Len() defs.Int
 	// Log -- возвращает логгер ожидателя групп
 	Log() comp_spec.ILogBuf
 }

v4/lev2/kwg/kwg.go

@@ -66,10 +66,10 @@ func (sf *kernelWg) Log() comp_spec.ILogBuf {
 }
 
 // Len -- возвращает размер списка ожидания потоков.
-func (sf *kernelWg) Len() int {
+func (sf *kernelWg) Len() defs.Int {
 	sf.RLock()
 	defer sf.RUnlock()
-	return len(sf.dictStream)
+	return defs.Int(len(sf.dictStream))
 }
 
 // IsWork -- возвращает признак работы ядра.

v4/lev2/lsi/kstore_kv/kstore_kv.go

@@ -193,7 +193,7 @@ func (sf *kStoreKv) open() {
 
 // Выполняет периодическую сборку мусора в файле.
 func (sf *kStoreKv) clean() {
-	chRun := make(chan int, 2)
+	chRun := make(chan defs.Int, 2)
 	defer close(chRun)
 	fnClean := func() {
 		sf.Lock()
@@ -213,7 +213,7 @@ func (sf *kStoreKv) clean() {
 }
 
 // Ожидает последнего потока под отдельной блокировкой.
-func (sf *kStoreKv) wait(chWait chan int) {
+func (sf *kStoreKv) wait(chWait chan defs.Int) {
 	for {
 		time.Sleep(time.Millisecond * 5)
 		if sf.wg.Len() <= 1 {
@@ -231,7 +231,7 @@ func (sf *kStoreKv) close() {
 	if !sf.isWork.Get() {
 		return
 	}
-	chWait := make(chan int, 2)
+	chWait := make(chan defs.Int, 2)
 	go sf.wait(chWait)
 	<-chWait
 	sf.isWork.Reset()

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

@@ -29,7 +29,7 @@ type KvBucketBase struct {
 	SizeLimit_ int64                                `json:"size_limit"` // Лимит размера бакета
 	CreatedAt_ core_spec.ITime                      `json:"created_at"` // Время создания бакета
 	UpdatedAt_ core_spec.ITimeMut                   `json:"updated_at"` // Время обновления бакета
-	Vers_      int                                  `json:"vers"`       // Версия бакета
+	Vers_      defs.Int                             `json:"vers"`       // Версия бакета
 	dictRec    map[rec_key.ARecKey]rec_kv.IRecKvFix // Словарь для хранения данных
 }
 

v4/lev2/lti/kbus_base/kbus_base_test.go

@@ -26,8 +26,8 @@ var (
 
 func TestKernelBusLocal(t *testing.T) {
 	sf := &tester{
-		t:        t,
-		handSub:  mock_hand_sub_local.NewMockHandlerSub(qNameSub,
+		t: t,
+		handSub: mock_hand_sub_local.NewMockHandlerSub(qNameSub,
 			defs.TxtFix("mock_hand_sub")),
 		handServ: mock_hand_serve.NewMockHandlerServe(qNameServe,
 			"mock_hand_serv"),

v4/lev2/lti/kbus_http/kbus_http_test.go

@@ -38,8 +38,8 @@ var (
 
 func TestKernelBusHttp(t *testing.T) {
 	sf := &tester{
-		t:        t,
-		handSub:  mock_hand_sub_local.NewMockHandlerSub(qNameSub,
+		t: t,
+		handSub: mock_hand_sub_local.NewMockHandlerSub(qNameSub,
 			defs.TxtFix("http://localhost:18200/bus/pub")),
 		handServ: mock_hand_serve.NewMockHandlerServe(qNameServ, "name_serv"),
 	}

v4/lev2/wui/hx_vals/hx_vals.go

@@ -26,10 +26,10 @@ func NewHxVals() *HxVals {
 }
 
 // Len -- возвращает размер словаря.
-func (sf *HxVals) Len() int {
+func (sf *HxVals) Len() defs.Int {
 	sf.RLock()
 	defer sf.RUnlock()
-	return len(sf.dict)
+	return defs.Int(len(sf.dict))
 }
 
 // Del -- удаляет ключ словаря.

v4/lev2/wui/wui_types/ihx_vals.go

@@ -27,5 +27,5 @@ type IHxVals interface {
 	// Clear -- очищает весь словарь
 	Clear()
 	// Len -- возвращает размер словаря
-	Len() int
+	Len() defs.Int
 }