dataext

Documentation

Index

• 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 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

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 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