relec

Nov 11, 2024

Changes in this version

+ func ConcurrentInGroup[T any](group *CxGroup, array []T, concurrency int, ...)

Oct 7, 2024

Changes in this version

+ type CxGroup struct

+ func NewCGroup(ctx context.Context) *CxGroup

+ func NewCGroupWithLimit(ctx context.Context, limit int) *CxGroup

+ func (g *CxGroup) Add(execute func(ctx context.Context) error)

+ func (g *CxGroup) Block() error

+ func (g *CxGroup) Close()

+ type Next struct

+ func (n *Next[T]) Close()

+ func (n *Next[T]) Next() bool

Sep 27, 2024

Changes in this version

+ func ConcurrentF(ctx context.Context, functions ...CtxFunc) error

+ type CtxFunc = func(ctx context.Context) error

Sep 17, 2024

Changes in this version

+ type Hashable interface

+ Hash func() string

+ type Identifier interface

+ ID func() string

+ type Set struct

+ func NewSet[T comparable](initial ...T) *Set[T]

+ func (this *Set[T]) Array() []T

+ func (this *Set[T]) Difference(set *Set[T]) *Set[T]

+ func (this *Set[T]) Exists(element T) bool

+ func (this *Set[T]) Hash(elem T) string

+ func (this *Set[T]) Insert(element T)

+ func (this *Set[T]) Intersection(set *Set[T]) *Set[T]

+ func (this *Set[T]) Len() int

+ func (this *Set[T]) MarshalJSON() ([]byte, error)

+ func (this *Set[T]) ProperSubsetOf(set *Set[T]) bool

+ func (this *Set[T]) Range(f func(T))

+ func (this *Set[T]) Remove(element T)

+ func (this *Set[T]) String() string

+ func (this *Set[T]) SubsetOf(set *Set[T]) bool

+ func (this *Set[T]) Union(set *Set[T]) *Set[T]

+ func (this *Set[T]) UnmarshalJSON(data []byte) error

+ func (this *Set[T]) WithHasher(f func(T) string) *Set[T]

Sep 17, 2024

Changes in this version

+ func ConcurrentC[T any](ctx context.Context, yield <-chan T, concurrency int, ...) error

+ func Yield[T any](generate func(channel chan<- T)) <-chan T

Sep 13, 2024

Changes in this version

+ func Absolute[T int | int8 | int16 | int32 | int64 | float32 | float64](value T) T

+ func ArrayContains[T ~string | int | int8 | int16 | int32 | int64 | float32 | float64](set []T, value T) bool

+ func CheckIfFilesExists(files ...string) error

+ func Concurrent[T any](ctx context.Context, array []T, concurrency int, execute func(one T) error) error

+ func FindInArray[T any](set []T, match func(elem T) bool) (int, bool)

+ func IsInstance(val any, typ reflect.Kind) bool

+ func IsOfType(object interface{}, decidingKey string) (bool, error)

+ func IsSubset[T comparable](setArray, subsetArray []T) bool

+ func MaxDate(v1, v2 time.Time) time.Time

+ func Unmarshal(from interface{}, object interface{}) error

+ func UnmarshalFile(file string, dest any) error

+ func Validate[T any](structure T) error

+ type Logger interface

+ Debug func(v ...interface{})

+ Debugf func(format string, v ...interface{})

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Fatal func(v ...interface{})

+ Fatalf func(format string, v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ Warn func(v ...interface{})

+ Warnf func(format string, v ...interface{})