dataext

package
v0.0.516 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 25, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func ObjectMerge added in v0.0.20 

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

func StructHash added in v0.0.32 

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 CASMutex added in v0.0.446 

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

CASMutex is the struct implementing RWMutex with CAS mechanism.

func NewCASMutex added in v0.0.446 

func NewCASMutex() *CASMutex

func (*CASMutex) Lock added in v0.0.446 

func (m *CASMutex) Lock()

Lock acquires the lock. If it is currently held by others, Lock will wait until it has a chance to acquire it.

func (*CASMutex) RLock added in v0.0.446 

func (m *CASMutex) RLock()

RLock acquires the read lock. If it is currently held by others writing, RLock will wait until it has a chance to acquire it.

func (*CASMutex) RLocker added in v0.0.446 

func (m *CASMutex) RLocker() sync.Locker

RLocker returns a Locker interface that implements the Lock and Unlock methods by calling CASMutex.RLock and CASMutex.RUnlock.

func (*CASMutex) RTryLock added in v0.0.446 

func (m *CASMutex) RTryLock() bool

RTryLock attempts to acquire the read lock without blocking. Return false if someone is writing it now.

func (*CASMutex) RTryLockWithContext added in v0.0.446 

func (m *CASMutex) RTryLockWithContext(ctx context.Context) bool

RTryLockWithContext attempts to acquire the read lock, blocking until resources are available or ctx is done (timeout or cancellation).

func (*CASMutex) RTryLockWithTimeout added in v0.0.446 

func (m *CASMutex) RTryLockWithTimeout(duration time.Duration) bool

RTryLockWithTimeout attempts to acquire the read lock within a period of time. Return false if spending time is more than duration and no chance to acquire it.

func (*CASMutex) RUnlock added in v0.0.446 

func (m *CASMutex) RUnlock()

RUnlock releases the read lock.

func (*CASMutex) TryLock added in v0.0.446 

func (m *CASMutex) TryLock() bool

TryLock attempts to acquire the lock without blocking. Return false if someone is holding it now.

func (*CASMutex) TryLockWithContext added in v0.0.446 

func (m *CASMutex) TryLockWithContext(ctx context.Context) bool

TryLockWithContext attempts to acquire the lock, blocking until resources are available or ctx is done (timeout or cancellation).

func (*CASMutex) TryLockWithTimeout added in v0.0.446 

func (m *CASMutex) TryLockWithTimeout(duration time.Duration) bool

TryLockWithTimeout attempts to acquire the lock within a period of time. Return false if spending time is more than duration and no chance to acquire it.

func (*CASMutex) Unlock added in v0.0.446 

func (m *CASMutex) Unlock()

Unlock releases the lock.

type JsonOpt added in v0.0.419 

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

func (JsonOpt[T]) IfSet added in v0.0.516 

func (m JsonOpt[T]) IfSet(fn func(v T)) bool

func (JsonOpt[T]) IsSet added in v0.0.419 

func (m JsonOpt[T]) IsSet() bool

func (JsonOpt[T]) IsUnset added in v0.0.419 

func (m JsonOpt[T]) IsUnset() bool

func (JsonOpt[T]) MarshalJSON added in v0.0.419 

func (m JsonOpt[T]) MarshalJSON() ([]byte, error)

MarshalJSON returns m as the JSON encoding of m.

func (JsonOpt[T]) MustValue added in v0.0.419 

func (m JsonOpt[T]) MustValue() T

func (*JsonOpt[T]) UnmarshalJSON added in v0.0.419 

func (m *JsonOpt[T]) UnmarshalJSON(data []byte) error

UnmarshalJSON sets *m to a copy of data.

func (JsonOpt[T]) Value added in v0.0.419 

func (m JsonOpt[T]) Value() (T, bool)

func (JsonOpt[T]) ValueOrNil added in v0.0.419 

func (m JsonOpt[T]) ValueOrNil() *T

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 Nonuple added in v0.0.255 

type Nonuple[T1 any, T2 any, T3 any, T4 any, T5 any, T6 any, T7 any, T8 any, T9 any] struct {
	V1 T1
	V2 T2
	V3 T3
	V4 T4
	V5 T5
	V6 T6
	V7 T7
	V8 T8
	V9 T9
}

func (Nonuple[T1, T2, T3, T4, T5, T6, T7, T8, T9]) TupleLength added in v0.0.255 

func (t Nonuple[T1, T2, T3, T4, T5, T6, T7, T8, T9]) TupleLength() int

func (Nonuple[T1, T2, T3, T4, T5, T6, T7, T8, T9]) TupleValues added in v0.0.255 

func (t Nonuple[T1, T2, T3, T4, T5, T6, T7, T8, T9]) TupleValues() []any

type Octuple added in v0.0.255 

type Octuple[T1 any, T2 any, T3 any, T4 any, T5 any, T6 any, T7 any, T8 any] struct {
	V1 T1
	V2 T2
	V3 T3
	V4 T4
	V5 T5
	V6 T6
	V7 T7
	V8 T8
}

func (Octuple[T1, T2, T3, T4, T5, T6, T7, T8]) TupleLength added in v0.0.255 

func (t Octuple[T1, T2, T3, T4, T5, T6, T7, T8]) TupleLength() int

func (Octuple[T1, T2, T3, T4, T5, T6, T7, T8]) TupleValues added in v0.0.255 

func (t Octuple[T1, T2, T3, T4, T5, T6, T7, T8]) TupleValues() []any

type Quadruple added in v0.0.255 

type Quadruple[T1 any, T2 any, T3 any, T4 any] struct {
	V1 T1
	V2 T2
	V3 T3
	V4 T4
}

func (Quadruple[T1, T2, T3, T4]) TupleLength added in v0.0.255 

func (t Quadruple[T1, T2, T3, T4]) TupleLength() int

func (Quadruple[T1, T2, T3, T4]) TupleValues added in v0.0.255 

func (t Quadruple[T1, T2, T3, T4]) TupleValues() []any

type Quintuple added in v0.0.255 

type Quintuple[T1 any, T2 any, T3 any, T4 any, T5 any] struct {
	V1 T1
	V2 T2
	V3 T3
	V4 T4
	V5 T5
}

func (Quintuple[T1, T2, T3, T4, T5]) TupleLength added in v0.0.255 

func (t Quintuple[T1, T2, T3, T4, T5]) TupleLength() int

func (Quintuple[T1, T2, T3, T4, T5]) TupleValues added in v0.0.255 

func (t Quintuple[T1, T2, T3, T4, T5]) TupleValues() []any

type Septuple added in v0.0.255 

type Septuple[T1 any, T2 any, T3 any, T4 any, T5 any, T6 any, T7 any] struct {
	V1 T1
	V2 T2
	V3 T3
	V4 T4
	V5 T5
	V6 T6
	V7 T7
}

func (Septuple[T1, T2, T3, T4, T5, T6, T7]) TupleLength added in v0.0.255 

func (t Septuple[T1, T2, T3, T4, T5, T6, T7]) TupleLength() int

func (Septuple[T1, T2, T3, T4, T5, T6, T7]) TupleValues added in v0.0.255 

func (t Septuple[T1, T2, T3, T4, T5, T6, T7]) TupleValues() []any

type Sextuple added in v0.0.255 

type Sextuple[T1 any, T2 any, T3 any, T4 any, T5 any, T6 any] struct {
	V1 T1
	V2 T2
	V3 T3
	V4 T4
	V5 T5
	V6 T6
}

func (Sextuple[T1, T2, T3, T4, T5, T6]) TupleLength added in v0.0.255 

func (t Sextuple[T1, T2, T3, T4, T5, T6]) TupleLength() int

func (Sextuple[T1, T2, T3, T4, T5, T6]) TupleValues added in v0.0.255 

func (t Sextuple[T1, T2, T3, T4, T5, T6]) TupleValues() []any

type Single added in v0.0.255 

type Single[T1 any] struct {
	V1 T1
}

func (Single[T1]) TupleLength added in v0.0.255 

func (s Single[T1]) TupleLength() int

func (Single[T1]) TupleValues added in v0.0.255 

func (s Single[T1]) TupleValues() []any

type Stack added in v0.0.61 

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

func NewStack added in v0.0.61 

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

func (*Stack[T]) Empty added in v0.0.63 

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

func (*Stack[T]) Length added in v0.0.62 

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

func (*Stack[T]) OptPeek added in v0.0.61 

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

func (*Stack[T]) OptPop added in v0.0.61 

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

func (*Stack[T]) Peek added in v0.0.61 

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

func (*Stack[T]) Pop added in v0.0.61 

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

func (*Stack[T]) Push added in v0.0.61 

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

type StructHashOptions added in v0.0.32 

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

type SyncMap added in v0.0.362 

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

func (*SyncMap[TKey, TData]) Contains added in v0.0.362 

func (s *SyncMap[TKey, TData]) Contains(key TKey) bool

func (*SyncMap[TKey, TData]) Delete added in v0.0.362 

func (s *SyncMap[TKey, TData]) Delete(key TKey) bool

func (*SyncMap[TKey, TData]) Get added in v0.0.362 

func (s *SyncMap[TKey, TData]) Get(key TKey) (TData, bool)

func (*SyncMap[TKey, TData]) GetAllKeys added in v0.0.362 

func (s *SyncMap[TKey, TData]) GetAllKeys() []TKey

func (*SyncMap[TKey, TData]) GetAllValues added in v0.0.362 

func (s *SyncMap[TKey, TData]) GetAllValues() []TData

func (*SyncMap[TKey, TData]) GetAndSetIfNotContains added in v0.0.446 

func (s *SyncMap[TKey, TData]) GetAndSetIfNotContains(key TKey, data TData) TData

func (*SyncMap[TKey, TData]) GetAndSetIfNotContainsFunc added in v0.0.447 

func (s *SyncMap[TKey, TData]) GetAndSetIfNotContainsFunc(key TKey, data func() TData) TData

func (*SyncMap[TKey, TData]) Set added in v0.0.362 

func (s *SyncMap[TKey, TData]) Set(key TKey, data TData)

func (*SyncMap[TKey, TData]) SetIfNotContains added in v0.0.362 

func (s *SyncMap[TKey, TData]) SetIfNotContains(key TKey, data TData) bool

func (*SyncMap[TKey, TData]) SetIfNotContainsFunc added in v0.0.447 

func (s *SyncMap[TKey, TData]) SetIfNotContainsFunc(key TKey, data func() TData) bool

type SyncSet added in v0.0.43 

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

func (*SyncSet[TData]) Add added in v0.0.43 

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

Add adds `value` to the set returns true if the value was actually inserted returns false if the value already existed

func (*SyncSet[TData]) AddAll added in v0.0.43 

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

func (*SyncSet[TData]) Contains added in v0.0.43 

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

func (*SyncSet[TData]) Get added in v0.0.43 

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

type Triple added in v0.0.255 

type Triple[T1 any, T2 any, T3 any] struct {
	V1 T1
	V2 T2
	V3 T3
}

func (Triple[T1, T2, T3]) TupleLength added in v0.0.255 

func (t Triple[T1, T2, T3]) TupleLength() int

func (Triple[T1, T2, T3]) TupleValues added in v0.0.255 

func (t Triple[T1, T2, T3]) TupleValues() []any

type Tuple added in v0.0.255 

type Tuple[T1 any, T2 any] struct {
	V1 T1
	V2 T2
}

func (Tuple[T1, T2]) TupleLength added in v0.0.255 

func (t Tuple[T1, T2]) TupleLength() int

func (Tuple[T1, T2]) TupleValues added in v0.0.255 

func (t Tuple[T1, T2]) TupleValues() []any

type ValueGroup added in v0.0.255 

type ValueGroup interface {
	TupleLength() int
	TupleValues() []any
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.