dataext

Documentation

Index

• Variables
• func ObjectMerge[T1 any, T2 any](base T1, override T2) T1
• func StructHash(dat any, opt ...StructHashOptions) (r []byte, err error)
• type BufferedReadCloser
  • func NewBufferedReadCloser(sub io.ReadCloser) BufferedReadCloser
• type LRUMap
  • func NewLRUMap[TKey comparable, TData any](size int) *LRUMap[TKey, TData]
  • func (c *LRUMap[TKey, TData]) Put(key TKey, value TData)
  • func (c *LRUMap[TKey, TData]) Size() int
  • func (c *LRUMap[TKey, TData]) TryGet(key TKey) (TData, bool)
• type Stack
  • func NewStack[T any](threadsafe bool, initialCapacity int) *Stack[T]
  • func (s *Stack[T]) Empty() bool
  • func (s *Stack[T]) Length() int
  • func (s *Stack[T]) OptPeek() *T
  • func (s *Stack[T]) OptPop() *T
  • func (s *Stack[T]) Peek() (T, error)
  • func (s *Stack[T]) Pop() (T, error)
  • func (s *Stack[T]) Push(v T)
• type StructHashOptions
• type SyncSet
  • func (s *SyncSet[TData]) Add(value TData) bool
  • func (s *SyncSet[TData]) AddAll(values []TData)
  • func (s *SyncSet[TData]) Contains(value TData) bool
  • func (s *SyncSet[TData]) Get() []TData

Variables

var ErrEmptyStack = errors.New("stack is empty")

Functions

func ObjectMerge

func ObjectMerge[T1 any, T2 any](base T1, override T2) T1

func StructHash

func StructHash(dat any, opt ...StructHashOptions) (r []byte, err error)

Types

type BufferedReadCloser

type BufferedReadCloser interface {
	io.ReadCloser
	BufferedAll() ([]byte, error)
	Reset() error
}

func NewBufferedReadCloser

func NewBufferedReadCloser(sub io.ReadCloser) BufferedReadCloser

type LRUMap

type LRUMap[TKey comparable, TData any] struct {
	// contains filtered or unexported fields
}

func NewLRUMap

func NewLRUMap[TKey comparable, TData any](size int) *LRUMap[TKey, TData]

func (*LRUMap[TKey, TData]) Put

func (c *LRUMap[TKey, TData]) Put(key TKey, value TData)

func (*LRUMap[TKey, TData]) Size

func (c *LRUMap[TKey, TData]) Size() int

func (*LRUMap[TKey, TData]) TryGet

func (c *LRUMap[TKey, TData]) TryGet(key TKey) (TData, bool)

type Stack

type Stack[T any] struct {
	// contains filtered or unexported fields
}

func NewStack

func NewStack[T any](threadsafe bool, initialCapacity int) *Stack[T]

func (*Stack[T]) Empty

func (s *Stack[T]) Empty() bool

func (*Stack[T]) Length

func (s *Stack[T]) Length() int

func (*Stack[T]) OptPeek

func (s *Stack[T]) OptPeek() *T

func (*Stack[T]) OptPop

func (s *Stack[T]) OptPop() *T

func (*Stack[T]) Peek

func (s *Stack[T]) Peek() (T, error)

func (*Stack[T]) Pop

func (s *Stack[T]) Pop() (T, error)

func (*Stack[T]) Push

func (s *Stack[T]) Push(v T)

type StructHashOptions

type StructHashOptions struct {
	HashAlgo    hash.Hash
	Tag         *string
	SkipChannel bool
	SkipFunc    bool
}

type SyncSet

type SyncSet[TData comparable] struct {
	// contains filtered or unexported fields
}

func (*SyncSet[TData]) Add

func (s *SyncSet[TData]) Add(value TData) bool

func (*SyncSet[TData]) AddAll

func (s *SyncSet[TData]) AddAll(values []TData)

func (*SyncSet[TData]) Contains

func (s *SyncSet[TData]) Contains(value TData) bool

func (*SyncSet[TData]) Get

func (s *SyncSet[TData]) Get() []TData