cube

README

cube

All my golang pkgs.

Documentation

Index

• Variables
• func Abs[T Numeric](x T) T
• func AllNamedEnums[T IEnum](min T, max T) []T
• func ExecAllDeathHooks()
• func FillEnum[T IEnum](sp *[]T, min T, max T)
• func Fly(fnc func())
• func FuncName(act any) string
• func GetFreePort() (int, error)
• func IsDeathing() bool
• func JsonStreamZeroCopy(fp string) (iter.Seq2[json.RawMessage, error], error)
• func MarshalJSON(val any) ([]byte, error)
• func MarshalJSONString(val any) (string, error)
• func Must[T any](val T, err error) T
• func MustJsonMarshalIndent(v any) []byte
• func MustJsonMarshalIndentString(v any) string
• func MustJsonMarshalString(v any) string
• func MustMarshalJSON(v any) []byte
• func OnDeath(fn func(wg *sync.WaitGroup))
• func Peek[T IJsonValue](mapv map[string]any, keys ...string) (T, bool)
• func RandAsciiBytes(length int) []byte
• func RandBytes(pool []byte, length int) []byte
• func RandLowerAsciiBytes(length int) []byte
• func ReadDirStream(dir string) (iter.Seq2[os.FileInfo, error], error)
• func ReadStack(skip int, size int) string
• func UnmarshalJSON(bytes []byte, dest any) error
• func UnmarshalJSONString(txt string, dest any) error
• func WalkStream(root string, opts *WalkOptions) (iter.Seq2[*FileInfoWithDir, error], error)
• type FileInfoWithDir
  • func (fi *FileInfoWithDir) Fullpath() string
  • func (fi *FileInfoWithDir) String() string
• type IEnum
• type IJsonValue
• type ITaskItem
• type IntType
• type Numeric
• type Set
  • func (s Set[T]) Add(v T)
  • func (s Set[T]) Clear() Set[T]
  • func (s Set[T]) Del(v T)
  • func (s Set[T]) Has(v T) bool
  • func (s Set[T]) Len() int
• type SingedInt
• type TaskFuncType
  • func (t TaskFuncType) Exec(ctx context.Context)
• type TaskPool
  • func NewTaskPool(opts *TaskPoolOptions) *TaskPool
  • func (pool *TaskPool) Add(task ITaskItem) (err error)
  • func (pool *TaskPool) AddFunc(f func(ctx context.Context)) error
  • func (pool *TaskPool) Close(wait bool)
  • func (pool *TaskPool) Wait()
• type TaskPoolOptions
• type UnsignedInt
• type WalkOptions

Variables

var (
	ErrTaskPoolQueueFull = errors.New("rrscpkgs.taskpool: queue full")
	ErrTaskPoolClosed    = errors.New("rrscpkgs.taskpool: closed")
)

var (
	DEATH_SIGNALS = []os.Signal{
		syscall.SIGINT,
		syscall.SIGTERM,
		syscall.SIGQUIT,
		syscall.SIGHUP,
	}
)

var (
	ErrJsonStreamBadElement = errors.New("json stream: bad element, required '{'")
)

Functions

func Abs

func Abs[T Numeric](x T) T

func AllNamedEnums

func AllNamedEnums[T IEnum](min T, max T) []T

func ExecAllDeathHooks

func ExecAllDeathHooks()

func FillEnum

func FillEnum[T IEnum](sp *[]T, min T, max T)

func Fly

func Fly(fnc func())

func FuncName

func FuncName(act any) string

func GetFreePort

func GetFreePort() (int, error)

func IsDeathing

func IsDeathing() bool

func JsonStreamZeroCopy

func JsonStreamZeroCopy(fp string) (iter.Seq2[json.RawMessage, error], error)

func MarshalJSON

func MarshalJSON(val any) ([]byte, error)

func MarshalJSONString

func MarshalJSONString(val any) (string, error)

func Must

func Must[T any](val T, err error) T

func MustJsonMarshalIndent

func MustJsonMarshalIndent(v any) []byte

func MustJsonMarshalIndentString

func MustJsonMarshalIndentString(v any) string

func MustJsonMarshalString

func MustJsonMarshalString(v any) string

func MustMarshalJSON

func MustMarshalJSON(v any) []byte

func OnDeath

func OnDeath(fn func(wg *sync.WaitGroup))

func Peek

func Peek[T IJsonValue](mapv map[string]any, keys ...string) (T, bool)

func RandAsciiBytes

func RandAsciiBytes(length int) []byte

func RandBytes

func RandBytes(pool []byte, length int) []byte

func RandLowerAsciiBytes

func RandLowerAsciiBytes(length int) []byte

func ReadDirStream

func ReadDirStream(dir string) (iter.Seq2[os.FileInfo, error], error)

func ReadStack

func ReadStack(skip int, size int) string

func UnmarshalJSON

func UnmarshalJSON(bytes []byte, dest any) error

func UnmarshalJSONString

func UnmarshalJSONString(txt string, dest any) error

func WalkStream

func WalkStream(root string, opts *WalkOptions) (iter.Seq2[*FileInfoWithDir, error], error)

Types

type FileInfoWithDir

type FileInfoWithDir struct {
	os.FileInfo
	Dir string
}

func (*FileInfoWithDir) Fullpath

func (fi *FileInfoWithDir) Fullpath() string

func (*FileInfoWithDir) String

func (fi *FileInfoWithDir) String() string

type IEnum

type IEnum interface {
	IntType
	fmt.Stringer
}

type IJsonValue

type IJsonValue interface {
	~int64 | ~bool | ~string | ~float64
}

type ITaskItem

type ITaskItem interface {
	Exec(ctx context.Context)
}

type IntType

type IntType interface {
	SingedInt | UnsignedInt
}

type Numeric

type Numeric interface {
	constraints.Signed | constraints.Float
}

type Set

type Set[T comparable] map[T]struct{}

func (Set[T]) Add

func (s Set[T]) Add(v T)

func (Set[T]) Clear

func (s Set[T]) Clear() Set[T]

func (Set[T]) Del

func (s Set[T]) Del(v T)

func (Set[T]) Has

func (s Set[T]) Has(v T) bool

func (Set[T]) Len

func (s Set[T]) Len() int

type SingedInt

type SingedInt interface {
	~int | ~int8 | ~int16 | ~int32 | ~int64
}

type TaskFuncType

type TaskFuncType func(ctx context.Context)

func (TaskFuncType) Exec

func (t TaskFuncType) Exec(ctx context.Context)

type TaskPool

type TaskPool struct {
	// contains filtered or unexported fields
}

func NewTaskPool

func NewTaskPool(opts *TaskPoolOptions) *TaskPool

func (*TaskPool) Add

func (pool *TaskPool) Add(task ITaskItem) (err error)

func (*TaskPool) AddFunc

func (pool *TaskPool) AddFunc(f func(ctx context.Context)) error

func (*TaskPool) Close

func (pool *TaskPool) Close(wait bool)

func (*TaskPool) Wait

func (pool *TaskPool) Wait()

type TaskPoolOptions

type TaskPoolOptions struct {
	Context      context.Context
	OnPanic      func(ctx context.Context, item ITaskItem, err any)
	Workers      int
	MaxQueueSize int
}

type UnsignedInt

type UnsignedInt interface {
	~uint | ~uint8 | ~uint16 | ~uint32 | ~uint64
}

type WalkOptions

type WalkOptions struct {
	MaxDepth       int
	MatchPatterns  []string
	IgnorePatterns []string
	OnlyTestName   bool
	FollowLink     bool
	OnSlightError  func(error)
}