utils

Apr 29, 2025

Changes in this version

+ func MapUnmarshalValidate(src SerializedObject, dst any) (err gperr.Error)

+ func UnmarshalValidateYAMLXSync[V any](data []byte) (_ functional.Map[string, V], err gperr.Error)

+ func UnmarshalValidateYAML[T any](data []byte, target *T) gperr.Error

Apr 25, 2025

Changes in this version

+ var TimeNow = DefaultTimeNow

+ func DefaultTimeNow() time.Time

+ func MockTimeNow(t time.Time)

Mar 29, 2025

Changes in this version

+ func CopyClose(dst *ContextWriter, src *ContextReader) (err error)

+ func CopyCloseWithContext(ctx context.Context, dst io.Writer, src io.Reader) (err error)

type ContextReader

+ func NewContextReader(ctx context.Context, r io.Reader) *ContextReader

type ContextWriter

+ func NewContextWriter(ctx context.Context, w io.Writer) *ContextWriter

Feb 23, 2025

Changes in this version

+ var ErrInvalidType = E.New("invalid type")

+ var ErrNilValue = E.New("nil")

+ var ErrUnknownField = E.New("unknown field")

+ var ErrUnsettable = E.New("unsettable")

+ var ErrUnsupportedConversion = E.New("unsupported conversion")

+ var ErrValidationError = E.New("validation error")

+ func Convert(src reflect.Value, dst reflect.Value) E.Error

+ func ConvertString(src string, dst reflect.Value) (convertible bool, convErr E.Error)

+ func Copy(dst *ContextWriter, src *ContextReader) (err error)

+ func Copy2(ctx context.Context, dst io.Writer, src io.Reader) error

+ func Deserialize(src SerializedObject, dst any) (err E.Error)

+ func DeserializeYAMLMap[V any](data []byte) (_ functional.Map[string, V], err E.Error)

+ func DeserializeYAML[T any](data []byte, target *T) E.Error

+ func Intersect[T comparable, Slice ~[]T](slice1 Slice, slice2 Slice) Slice

+ func ListFiles(dir string, maxDepth int, hideHidden ...bool) ([]string, error)

+ func LoadJSONIfExist[T any](path string, dst *T) error

+ func MustRegisterValidation(tag string, fn validator.Func)

+ func NearestField(input string, s any) string

+ func New(t reflect.Type) reflect.Value

+ func RegisterDefaultValueFactory[T any](factory func() *T)

+ func SaveJSON[T any](path string, src *T, perm os.FileMode) error

+ func Slice[T any](slice []T, n int) []T

+ func ValidateWithCustomValidator(v reflect.Value) E.Error

+ func ValidateWithFieldTags(s any) E.Error

+ func Validator() *validator.Validate

+ type BidirectionalPipe struct

+ func NewBidirectionalPipe(ctx context.Context, rw1 io.ReadWriteCloser, rw2 io.ReadWriteCloser) BidirectionalPipe

+ func (p BidirectionalPipe) Start() E.Error

+ type ContextReader struct

+ func (r *ContextReader) Read(p []byte) (int, error)

+ type ContextWriter struct

+ func (w *ContextWriter) Write(p []byte) (int, error)

+ type CustomValidator interface

+ Validate func() E.Error

+ type FileReader struct

+ Path string

+ type MapUnmarshaller interface

+ UnmarshalMap func(m map[string]any) E.Error

+ type NoCopy struct

+ func (*NoCopy) Lock()

+ func (*NoCopy) Unlock()

+ type Pipe struct

+ func NewPipe(ctx context.Context, r io.ReadCloser, w io.WriteCloser) *Pipe

+ func (p *Pipe) Start() (err error)

+ type RefCount struct

+ func NewRefCounter() *RefCount

+ func (rc *RefCount) Add()

+ func (rc *RefCount) Sub()

+ func (rc *RefCount) Zero() <-chan struct{}

+ type SerializedObject = map[string]any