diff --git a/core/cdcs/cjson/writer.go b/core/cdcs/cjson/writer.go index def6ef1..f54ecef 100644 --- a/core/cdcs/cjson/writer.go +++ b/core/cdcs/cjson/writer.go @@ -24,8 +24,8 @@ package cjson import ( - "codecs/base32" - "codecs/base64" + "cdcs/base32" + "cdcs/base64" "math" "mems" "strconv" diff --git a/core/crps/active.go b/core/crps/active.go index f980072..ce2f1ec 100644 --- a/core/crps/active.go +++ b/core/crps/active.go @@ -21,7 +21,7 @@ // limitations under the License. // ------------------------------------------------------------------------ -package crypts +package crps import "errs" diff --git a/core/crps/crypter.go b/core/crps/crypter.go index 768b461..085f753 100644 --- a/core/crps/crypter.go +++ b/core/crps/crypter.go @@ -21,7 +21,7 @@ // limitations under the License. // ------------------------------------------------------------------------ -package crypts +package crps type ( diff --git a/core/crps/decrypter.go b/core/crps/decrypter.go index e46a6d4..1e50015 100644 --- a/core/crps/decrypter.go +++ b/core/crps/decrypter.go @@ -21,14 +21,14 @@ // limitations under the License. // ------------------------------------------------------------------------ -package crypts +package crps -import "results" +import "rsls" type ( Decrypter interface { - Decrypt (data []byte) results.Bytes + Decrypt (data []byte) rsls.Bytes } @@ -38,6 +38,6 @@ type ( -func (_ DecrypterNop) Decrypt (_ []byte) results.Bytes { - return results.MakeBytesError(G.ErrNotImplemented) } +func (_ DecrypterNop) Decrypt (_ []byte) rsls.Bytes { + return rsls.MakeBytesError(G.ErrNotImplemented) } diff --git a/core/crps/encrypter.go b/core/crps/encrypter.go index 7f45e8b..3cddfae 100644 --- a/core/crps/encrypter.go +++ b/core/crps/encrypter.go @@ -21,15 +21,15 @@ // limitations under the License. // ------------------------------------------------------------------------ -package crypts +package crps -import "results" +import "rsls" type ( Encrypter interface { - Encrypt (data []byte) results.Bytes + Encrypt (data []byte) rsls.Bytes } @@ -38,5 +38,5 @@ type ( ) -func (_ EncrypterNop) Encrypt (_ []byte) results.Bytes { - return results.MakeBytesError(G.ErrNotImplemented) } \ No newline at end of file +func (_ EncrypterNop) Encrypt (_ []byte) rsls.Bytes { + return rsls.MakeBytesError(G.ErrNotImplemented) } \ No newline at end of file diff --git a/core/dtes/bdates/byear.go b/core/dtes/bdates/byear.go index 3491d1a..d1d40b1 100644 --- a/core/dtes/bdates/byear.go +++ b/core/dtes/bdates/byear.go @@ -23,7 +23,7 @@ package bdates -import "times" +import "dtes" type ( diff --git a/core/rsls/bytes.go b/core/rsls/bytes.go index 6459b34..3a1c966 100644 --- a/core/rsls/bytes.go +++ b/core/rsls/bytes.go @@ -21,7 +21,7 @@ // limitations under the License. // ------------------------------------------------------------------------ -package results +package rsls type ( diff --git a/core/rsls/g_result.go b/core/rsls/g_result.go index a9bc2cf..0b57c11 100644 --- a/core/rsls/g_result.go +++ b/core/rsls/g_result.go @@ -21,7 +21,7 @@ // limitations under the License. // ------------------------------------------------------------------------ -package results +package rsls type ( diff --git a/core/rsls/int.go b/core/rsls/int.go index b2ac35c..380cfb5 100644 --- a/core/rsls/int.go +++ b/core/rsls/int.go @@ -21,7 +21,7 @@ // limitations under the License. // ------------------------------------------------------------------------ -package results +package rsls type ( diff --git a/core/rsls/result.go b/core/rsls/result.go index 1361a76..8cc681c 100644 --- a/core/rsls/result.go +++ b/core/rsls/result.go @@ -21,7 +21,7 @@ // limitations under the License. // ------------------------------------------------------------------------ -package results +package rsls type ( diff --git a/core/rsls/string.go b/core/rsls/string.go index c6b9993..ce75381 100644 --- a/core/rsls/string.go +++ b/core/rsls/string.go @@ -21,7 +21,7 @@ // limitations under the License. // ------------------------------------------------------------------------ -package results +package rsls type ( diff --git a/core/syns/ctasks/completion.go b/core/syns/ctasks/completion.go index e28418a..7370ff5 100644 --- a/core/syns/ctasks/completion.go +++ b/core/syns/ctasks/completion.go @@ -25,12 +25,13 @@ package ctasks import ( "context" + "crns" "opts" "sync" "sync/atomic" - "syncs/works" + "syns/works" "time" - cronus "timers" + ) type ( @@ -41,7 +42,7 @@ type ( wgr sync.WaitGroup parent Context - expiration *cronus.Expiration + expiration *crns.Expiration mode Mode state uint32 @@ -77,7 +78,7 @@ func NewCompletion (options ...CompletionFnc) (*Completion,error) { } } if c.expiration == nil { - c.expiration = cronus.NewExpiration(0,nil) + c.expiration = crns.NewExpiration(0,nil) } return c,nil } @@ -96,7 +97,7 @@ func (c *Completion) IsCompleted () bool { return c.State() > StateStarted } -func (c *Completion) Chrono () cronus.Chronometer { +func (c *Completion) Chrono () crns.Chronometer { return c.expiration.Chono() } func (c *Completion) Result () Result { @@ -147,7 +148,7 @@ func (c *Completion) complete (ctx context.Context, cctx Context, cid int) error // en tiempo de la completion en caso de que exista, o bien de la // completion padre o bien del contexto. // - var ex cronus.Expirer + var ex crns.Expirer if cctx != nil { c.parent = cctx @@ -330,7 +331,7 @@ func WithMode (mode Mode) opts.GOptionErrFnc[Completion] { // func WithTimeout (tmo time.Duration) opts.GOptionErrFnc[Completion] { return func(c *Completion) error { - c.expiration = cronus.NewExpiration(tmo,func(){ + c.expiration = crns.NewExpiration(tmo,func(){ c.notify(CompletionFromTimer, StateCanceled,nil,G.ErrCancelByTimer) }) return nil diff --git a/core/syns/queue/g_queue.go b/core/syns/queue/g_queue.go index 94cb4e6..c9e59bc 100644 --- a/core/syns/queue/g_queue.go +++ b/core/syns/queue/g_queue.go @@ -25,13 +25,13 @@ package queue import ( "sync" - "syncs" + "syns" ) type ( GQueue [T any]struct { - locker syncs.LockerRW + locker syns.LockerRW elems []T } @@ -39,11 +39,11 @@ type ( func NewGQueue [T any](safe bool) *GQueue[T] { - var lc syncs.LockerRW + var lc syns.LockerRW if safe { lc = &sync.RWMutex{} } else { - lc = syncs.NopLocker{} + lc = syns.NopLocker{} } return &GQueue[T]{ locker : lc } } diff --git a/core/syns/works/pool.go b/core/syns/works/pool.go index 2ff0429..3fa2522 100644 --- a/core/syns/works/pool.go +++ b/core/syns/works/pool.go @@ -28,7 +28,7 @@ import ( "runtime" "sync" "sync/atomic" - "syncs/pools" + "syns/pools" "time" ) diff --git a/go.work b/go.work index f410ea2..8423c3a 100644 --- a/go.work +++ b/go.work @@ -13,5 +13,11 @@ use ( ./core/opts ./core/syns ./core/typs + ./core/dtes + ./core/cdcs + ./core/crps + ./core/crns + ./core/rsls + ./core/ctxs )