internal

package

Go to main page

Versions in this module

v1

v1.4.1

May 7, 2026

v1.4.0

Apr 13, 2026

Changes in this version

+ const MaxPoolBufferSize

+ const MaxPoolBuilderCap

+ const MaxPoolMapSize

+ const MaxPoolSliceSize

+ const MinPoolBufferSize

+ const MinPoolBuilderCap

+ const MinPoolMapSize

+ const MinPoolSliceSize

+ func ClearStructEncoderCache()

+ func EncodeFastWithHTMLEscape(v any, buf *bytes.Buffer, htmlEscape bool) bool

+ func GetBatchResultsMap(hint int) map[string]any

+ func GetByteSliceWithHint(hint int) *[]byte

+ func HTMLEscapeBytes(data []byte) []byte

+ func HasEscapeSequence(path string) bool

+ func MarshalJSONToBytes(value any, pretty bool, prefix, indent string) ([]byte, error)

+ func NeedsHTMLEscapeBytes(data []byte) bool

+ func PutBatchResultsMap(m map[string]any)

+ func PutHTMLEscapeBytes(b []byte)

+ func SetErrorSentinels(pathNotFound, typeMismatch, invalidPath error)

+ func UnescapePathSegment(segment string) string

type CompiledPathError

+ func (e *CompiledPathError) Is(target error) bool

type FastEncoder

+ func (e *FastEncoder) SetHTMLEscape(enabled bool)

type ParallelProcessor

+ func (pp *ParallelProcessor) Stop()

v1.3.0

Mar 30, 2026

Changes in this version

+ const ArrayIndexInvalid

+ const CacheHighWatermarkPercent

+ const DefaultMaxCacheMemory

+ const FNVOffsetBasis

+ const FNVPrime

+ const LargeStringHashThreshold

+ const MaxSensitiveDataDepth

+ const PathFlagFlat

+ const PathFlagHasEnd

+ const PathFlagHasStart

+ const PathFlagHasStep

+ const PathFlagNegative

+ const PathFlagWildcard

+ func CleanupNullValues(data any, compactArrays bool) any

+ func ConvertNumbersToFloat(data any) any

+ func DeepMergeWithMode(base, override any, mode MergeMode) any

+ func GetErrorSlice() *[]error

+ func GetFlattenedSlice() *[]any

+ func GetPathSegmentSlice(hint int) *[]PathSegment

+ func GetResultsSlice(hint int) *[]any

+ func GetStreamingMap(hint int) map[string]any

+ func GetStreamingSlice(hint int) *[]any

+ func GetStringBuilder() *strings.Builder

+ func HTMLEscape(s string) string

+ func HTMLEscapeTo(dst *bytes.Buffer, s string)

+ func HashBool(h uint64, v bool) uint64

+ func HashBytesFNV1a(b []byte) uint64

+ func HashBytesFNV1aSecure(b []byte) uint64

+ func HashInt(h uint64, v int) uint64

+ func HashInt64(h uint64, v int64) uint64

+ func HashString(h uint64, s string) uint64

+ func HashStringFNV1a(s string) uint64

+ func HashStringFNV1aSampled(s string) uint64

+ func HashStringFNV1aSecure(s string) uint64

+ func HashUint64(h, v uint64) uint64

+ func IsExtractionSegment(segment PathSegment) bool

+ func IsSliceType(data any) bool

+ func IsValidCacheKey(key string) bool

+ func NeedsHTMLEscape(s string) bool

+ func PutByteSliceSecure(b *[]byte)

+ func PutEncoderBufferSecure(buf *bytes.Buffer)

+ func PutErrorSlice(s *[]error)

+ func PutFlattenedSlice(s *[]any)

+ func PutPathSegmentSlice(s *[]PathSegment)

+ func PutResultsSlice(s *[]any)

+ func PutStreamingMap(m map[string]any)

+ func PutStreamingSlice(s *[]any)

+ func PutStringBuilder(sb *strings.Builder)

type KeyIntern

+ func (ki *KeyIntern) Size() int

+ type MergeMode int

+ const MergeDifference

+ const MergeIntersection

+ const MergeUnion

type PathSegment

+ func NewExtractSegmentWithFlat(key string, flat bool) PathSegment

+ func NewRecursiveSegment() PathSegment

+ func NewWildcardSegment() PathSegment

+ type PathSegmentFlags uint8

type PathSegmentType

+ const AppendSegment

v1.2.2

Mar 4, 2026

Changes in this version

type CacheManager

+ func (cm *CacheManager) Close()

type ParallelConfig

+ MaxWorkers int

type WorkerPool

+ func (wp *WorkerPool) SubmitWait(task func()) error

v1.2.1

Feb 26, 2026

v1.2.0

Feb 25, 2026

Changes in this version

+ const FlagHasEnd

+ const FlagHasStart

+ const FlagHasStep

+ const FlagIsFlat

+ const FlagIsNegative

+ const FlagIsWildcard

+ const MaxCacheKeyLength

+ const MaxDeepMergeDepth

+ const MaxNestingDepth

+ const MaxPathLength

+ const MaxPathParseDepth

+ var DefaultParallelProcessor = NewParallelProcessor(DefaultParallelConfig())

+ var ErrInvalidPath = errors.New("invalid path")

+ var ErrPathNotFound = errors.New("path not found")

+ var ErrTypeMismatch = errors.New("type mismatch")

+ var FastBufferPool = sync.Pool

+ var GlobalKeyIntern = NewKeyIntern()

+ var GlobalPathIntern = NewPathIntern(50000)

+ var GlobalStringIntern = NewStringIntern(10 * 1024 * 1024)

+ func ArrayItemKey(item any) string

+ func BatchIntern(strings []string) []string

+ func BatchInternKeys(keys []string) []string

+ func BytesToString(b []byte) string

+ func ChunkArrayOptimized(arr []any, chunkSize int) [][]any

+ func CompactArrayOptimized(arr []any) []any

+ func ContainsAnyByte(s, chars string) bool

+ func CreatePathError(path string, operation string, err error) error

+ func DeepMerge(base, override any) any

+ func EncodeFast(v any, buf *bytes.Buffer) bool

+ func FastMarshal(v any) ([]byte, error)

+ func FastMarshalToString(v any) (string, error)

+ func FastParseFloat(b []byte) (float64, error)

+ func FastParseInt(b []byte) (int64, error)

+ func FilterArrayOptimized(arr []any, predicate func(any) bool) []any

+ func FlattenArray(arr []any) []any

+ func FlattenArrayOptimized(arr []any) []any

+ func FormatNumberForDedup(f float64) string

+ func GetByteSlice() *[]byte

+ func GetEncoderBuffer() *bytes.Buffer

+ func GetFastBuffer() *bytes.Buffer

+ func GetPooledSlice() *[]any

+ func HasComplexSegments(segments []PathSegment) bool

+ func IndexIgnoreCase(s, pattern string) int

+ func IntToStringFast(n int) string

+ func InternKey(key string) string

+ func InternKeyBytes(b []byte) string

+ func InternString(s string) string

+ func InternStringBytes(b []byte) string

+ func IsArrayPath(path string) bool

+ func IsArrayType(data any) bool

+ func IsComplexPath(path string) bool

+ func IsDigit(c byte) bool

+ func IsDistributedOperationPath(path string) bool

+ func IsDistributedOperationSegment(segment PathSegment) bool

+ func IsDotNotationPath(path string) bool

+ func IsExtractionPath(path string) bool

+ func IsJSONArray(data any) bool

+ func IsJSONObject(data any) bool

+ func IsJSONPointerPath(path string) bool

+ func IsJSONPrimitive(data any) bool

+ func IsMapType(data any) bool

+ func IsMatchPatternIgnoreCase(s, pattern string) bool

+ func IsNilOrEmpty(data any) bool

+ func IsObjectType(data any) bool

+ func IsSlicePath(path string) bool

+ func IsSpace(c byte) bool

+ func IsValidArrayIndex(index string) bool

+ func IsValidJSONNumber(s string) bool

+ func IsValidJSONPrimitive(s string) bool

+ func IsValidNumberString(s string) bool

+ func IsValidPropertyName(name string) bool

+ func IsValidSliceRange(rangeStr string) bool

+ func IsValidUTF8(b []byte) bool

+ func IsWordChar(c byte) bool

+ func MapArrayOptimized(arr []any, transform func(any) any) []any

+ func MarshalJSON(value any, pretty bool, prefix, indent string) (string, error)

+ func MergeObjects(obj1, obj2 map[string]any) map[string]any

+ func NeedsDotBefore(prevChar rune) bool

+ func NeedsDotBeforeByte(prevChar byte) bool

+ func NeedsPathPreprocessing(path string) bool

+ func NewPathError(path, message string, err error) error

+ func NormalizePathSeparators(path string) string

+ func ParseIntFast(s string) (int, bool)

+ func PreprocessPath(path string, sb *strings.Builder) string

+ func PutByteSlice(b *[]byte)

+ func PutEncoder(e *FastEncoder)

+ func PutEncoderBuffer(buf *bytes.Buffer)

+ func PutFastBuffer(buf *bytes.Buffer)

+ func PutPooledSlice(s *[]any)

+ func ReconstructPath(segments []PathSegment) string

+ func ReverseArray(arr []any)

+ func ReverseArrayOptimized(arr []any)

+ func StringToBytes(s string) []byte

+ func TakeFirst(arr []any, n int) []any

+ func TakeLast(arr []any, n int) []any

+ func TryConvertToArray(m map[string]any) ([]any, bool)

+ func UniqueArray(arr []any) []any

+ func UniqueArrayOptimized(arr []any) []any

+ func WrapError(err error, context string) error

+ type ChunkProcessor struct

+ func NewChunkProcessor(chunkSize int) *ChunkProcessor

+ func (cp *ChunkProcessor) ProcessMap(m map[string]any, fn func(chunk map[string]any) error) error

+ func (cp *ChunkProcessor) ProcessSlice(arr []any, fn func(chunk []any) error) error

+ type CompiledPath struct

+ func CompilePath(path string) (*CompiledPath, error)

+ func CompilePathUnsafe(path string) (*CompiledPath, error)

+ func (cp *CompiledPath) Exists(data any) bool

+ func (cp *CompiledPath) Get(data any) (any, error)

+ func (cp *CompiledPath) GetFromRaw(raw []byte) (any, error)

+ func (cp *CompiledPath) Hash() uint64

+ func (cp *CompiledPath) IsEmpty() bool

+ func (cp *CompiledPath) Len() int

+ func (cp *CompiledPath) Path() string

+ func (cp *CompiledPath) Release()

+ func (cp *CompiledPath) Segments() []PathSegment

+ func (cp *CompiledPath) String() string

+ type CompiledPathCache struct

+ func GetGlobalCompiledPathCache() *CompiledPathCache

+ func NewCompiledPathCache(max int) *CompiledPathCache

+ func (c *CompiledPathCache) Clear()

+ func (c *CompiledPathCache) Get(path string) (*CompiledPath, error)

+ func (c *CompiledPathCache) Size() int

+ type CompiledPathError struct

+ Err error

+ Message string

+ Path string

+ func (e *CompiledPathError) Error() string

+ func (e *CompiledPathError) Unwrap() error

+ type ExtractionGroup struct

+ Segments []PathSegment

+ func DetectConsecutiveExtractions(segments []PathSegment) []ExtractionGroup

+ type FastEncoder struct

+ func GetEncoder() *FastEncoder

+ func GetEncoderWithSize(hint int) *FastEncoder

+ func (e *FastEncoder) Bytes() []byte

+ func (e *FastEncoder) EncodeArray(arr []any) error

+ func (e *FastEncoder) EncodeBase64(b []byte)

+ func (e *FastEncoder) EncodeBool(b bool)

+ func (e *FastEncoder) EncodeFloat(n float64, bits int)

+ func (e *FastEncoder) EncodeFloat32Slice(arr []float32)

+ func (e *FastEncoder) EncodeFloatSlice(arr []float64)

+ func (e *FastEncoder) EncodeInt(n int64)

+ func (e *FastEncoder) EncodeInt32Slice(arr []int32)

+ func (e *FastEncoder) EncodeInt64Slice(arr []int64)

+ func (e *FastEncoder) EncodeIntSlice(arr []int)

+ func (e *FastEncoder) EncodeMap(m map[string]any) error

+ func (e *FastEncoder) EncodeMapStringFloat64(m map[string]float64) error

+ func (e *FastEncoder) EncodeMapStringInt(m map[string]int) error

+ func (e *FastEncoder) EncodeMapStringInt64(m map[string]int64) error

+ func (e *FastEncoder) EncodeMapStringString(m map[string]string) error

+ func (e *FastEncoder) EncodeString(s string)

+ func (e *FastEncoder) EncodeStringSlice(arr []string)

+ func (e *FastEncoder) EncodeTime(t time.Time)

+ func (e *FastEncoder) EncodeUint(n uint64)

+ func (e *FastEncoder) EncodeUint64Slice(arr []uint64)

+ func (e *FastEncoder) EncodeValue(v any) error

+ func (e *FastEncoder) Reset()

+ type InternStats struct

+ Entries int

+ Evictions int64

+ Hits int64

+ Misses int64

+ Size int64

+ type KeyIntern struct

+ func NewKeyIntern() *KeyIntern

+ func (ki *KeyIntern) Clear()

+ func (ki *KeyIntern) GetStats() KeyInternStats

+ func (ki *KeyIntern) Intern(key string) string

+ func (ki *KeyIntern) InternBytes(b []byte) string

+ type KeyInternStats struct

+ HotKeyCount int64

+ ShardCount int

+ type ParallelConfig struct

+ BatchSize int

+ MinParallel int

+ Workers int

+ func DefaultParallelConfig() ParallelConfig

+ type ParallelMapResult struct

+ Index int

+ Key string

+ Value any

+ type ParallelProcessor struct

+ func NewParallelProcessor(config ParallelConfig) *ParallelProcessor

+ func (pp *ParallelProcessor) ParallelFilter(arr []any, predicate func(value any) bool) []any

+ func (pp *ParallelProcessor) ParallelForEach(arr []any, fn func(index int, value any) error) error

+ func (pp *ParallelProcessor) ParallelForEachMap(m map[string]any, fn func(key string, value any) error) error

+ func (pp *ParallelProcessor) ParallelMap(m map[string]any, fn func(key string, value any) (any, error)) (map[string]any, error)

+ func (pp *ParallelProcessor) ParallelSlice(arr []any, fn func(index int, value any) (any, error)) ([]any, error)

+ func (pp *ParallelProcessor) ParallelTransform(arr []any, transform func(value any) any) []any

+ type ParallelSliceResult struct

+ Index int

+ Value any

+ type PathIntern struct

+ func NewPathIntern(maxSize int) *PathIntern

+ func (pi *PathIntern) Clear()

+ func (pi *PathIntern) Get(path string) ([]PathSegment, bool)

+ func (pi *PathIntern) Set(path string, segments []PathSegment)

type PathSegment

+ Flags uint8

+ func ParseArraySegment(part string, segments []PathSegment) []PathSegment

+ func ParseExtractionSegment(part string, segments []PathSegment) []PathSegment

+ func ParsePathSegment(part string, segments []PathSegment) []PathSegment

+ func SplitPathIntoSegments(path string, segments []PathSegment) []PathSegment

+ func (ps *PathSegment) GetEnd() (int, bool)

+ func (ps *PathSegment) GetStart() (int, bool)

+ func (ps *PathSegment) GetStep() (int, bool)

+ func (ps *PathSegment) HasEnd() bool

+ func (ps *PathSegment) HasStart() bool

+ func (ps *PathSegment) HasStep() bool

+ func (ps *PathSegment) IsFlatExtract() bool

+ func (ps *PathSegment) IsNegativeIndex() bool

+ func (ps *PathSegment) IsWildcardSegment() bool

+ type StringIntern struct

+ func NewStringIntern(maxSize int64) *StringIntern

+ func (si *StringIntern) Clear()

+ func (si *StringIntern) GetStats() InternStats

+ func (si *StringIntern) Intern(s string) string

+ func (si *StringIntern) InternBytes(b []byte) string

+ type StructFieldInfo struct

+ EncodeFn func(*FastEncoder, reflect.Value) error

+ Index int

+ IsPointer bool

+ Name string

+ Offset uintptr

+ OmitEmpty bool

+ Type reflect.Type

+ func GetStructEncoder(t reflect.Type) []StructFieldInfo

+ type WorkerPool struct

+ func NewWorkerPool(workers int) *WorkerPool

+ func (wp *WorkerPool) Stop()

+ func (wp *WorkerPool) Submit(task func())

+ func (wp *WorkerPool) Wait()

v1.1.0

Feb 5, 2026

Changes in this version

+ func EscapeJSONPointer(s string) string

+ func ParseAndValidateArrayIndex(s string, arrayLength int) (int, bool)

+ func UnescapeJSONPointer(s string) string

type CacheStats

+ Entries int64

+ MemoryEfficiency float64

+ ShardCount int

+ TotalMemory int64

v1.0.10

Jan 20, 2026

Changes in this version

+ type CacheConfig interface

+ GetCacheTTL func() time.Duration

+ GetMaxCacheSize func() int

+ IsCacheEnabled func() bool

v1.0.9

Jan 12, 2026

v1.0.8

Jan 12, 2026

v1.0.7

Jan 8, 2026

Changes in this version

+ func GetSafeArrayElement(arr []any, index int) (any, bool)

+ func IsValidIndex(index, length int) bool

+ func NormalizeIndex(index, length int) int

+ func NormalizeSlice(start, end, length int) (int, int)

+ func ParseArrayIndex(property string) (int, bool)

+ func ParseSliceComponents(slicePart string) (start, end, step *int, err error)

+ func PerformArraySlice(arr []any, start, end, step *int) []any

+ func ValidatePath(path string) error

+ type HealthCheckerConfig struct

+ MaxErrorRatePercent float64

+ MaxMemoryBytes uint64

type PathSegment

+ func ParseComplexSegment(part string) ([]PathSegment, error)

+ func ParsePath(path string) ([]PathSegment, error)

+ func (ps PathSegment) GetValue() string

v1.0.6

Dec 24, 2025

Changes in this version

+ type BasicMetrics struct

+ AvgProcessingTime time.Duration

+ CacheHits int64

+ CacheMisses int64

+ CurrentMemoryUsage int64

+ Enabled bool

+ FailedOps int64

+ MaxProcessingTime time.Duration

+ PeakMemoryUsage int64

+ SuccessfulOps int64

+ TotalOperations int64

+ Uptime time.Duration

type CacheManager

+ func (cm *CacheManager) Clear()

+ func (cm *CacheManager) Delete(key string)

type MetricsCollector

+ func (mc *MetricsCollector) GetBasicMetrics() BasicMetrics

+ func (mc *MetricsCollector) UpdateMemoryUsage(current int64)

v1.0.5

Dec 1, 2025

v1.0.4

Nov 29, 2025

Changes in this version

+ func OptimizedCacheKey(op, jsonStr, path string) string

+ type OptimizedCacheManager struct

+ func NewOptimizedCacheManager(config ConfigInterface) *OptimizedCacheManager

+ func (ocm *OptimizedCacheManager) CleanExpiredCache()

+ func (ocm *OptimizedCacheManager) ClearCache()

+ func (ocm *OptimizedCacheManager) Get(key string) (any, bool)

+ func (ocm *OptimizedCacheManager) GetCacheSize() int64

+ func (ocm *OptimizedCacheManager) GetStats() CacheStats

+ func (ocm *OptimizedCacheManager) SecureHash(input string) string

+ func (ocm *OptimizedCacheManager) Set(key string, value any)

v1.0.3

Oct 3, 2025

v1.0.2

Oct 2, 2025

v1.0.1

Sep 28, 2025

v1.0.0

Sep 12, 2025

Changes in this version

+ type ArrayLocation struct

+ ArrayFieldName string

+ ContainerPath string

+ ContainerRef any

+ type ArrayUtils struct

+ func NewArrayUtils() *ArrayUtils

+ func (au *ArrayUtils) GetSafeArrayElement(arr []any, index int) (any, bool)

+ func (au *ArrayUtils) IsValidIndex(index, length int) bool

+ func (au *ArrayUtils) NormalizeIndex(index, length int) int

+ func (au *ArrayUtils) NormalizeSlice(start, end, length int) (int, int)

+ func (au *ArrayUtils) ParseArrayIndex(property string) int

+ func (au *ArrayUtils) ParseSliceComponents(slicePart string) (start, end, step *int, err error)

+ func (au *ArrayUtils) ParseSliceFromSegment(segmentValue string) (start, end, step int)

+ func (au *ArrayUtils) ParseSliceParameters(segmentValue string, arrayLength int) (start, end, step int, err error)

+ func (au *ArrayUtils) PerformArraySlice(arr []any, start, end, step *int) []any

+ type CacheInterface interface

+ ClearCache func()

+ Get func(key string) (any, bool)

+ GetStats func() interface{}

+ Set func(key string, value any)

+ type CacheManager struct

+ func NewCacheManager(config ConfigInterface) *CacheManager

+ func (cm *CacheManager) CleanExpiredCache()

+ func (cm *CacheManager) ClearCache()

+ func (cm *CacheManager) Get(key string) (any, bool)

+ func (cm *CacheManager) GetCacheSize() int64

+ func (cm *CacheManager) GetStats() CacheStats

+ func (cm *CacheManager) SecureHash(input string) string

+ func (cm *CacheManager) Set(key string, value any)

+ type CacheStats struct

+ Evictions int64

+ HitCount int64

+ HitRatio float64

+ Memory int64

+ MissCount int64

+ Size int64

+ type CheckResult struct

+ Healthy bool

+ Message string

+ type ConfigInterface interface

+ AllowComments func() bool

+ AreResourcePoolsEnabled func() bool

+ GetCacheTTL func() time.Duration

+ GetMaxCacheSize func() int

+ GetMaxConcurrency func() int

+ GetMaxJSONSize func() int64

+ GetMaxNestingDepth func() int

+ GetMaxPathDepth func() int

+ GetMaxPoolSize func() int

+ GetPoolCleanupInterval func() time.Duration

+ GetRateLimitPerSec func() int

+ IsCacheEnabled func() bool

+ IsHealthCheckEnabled func() bool

+ IsMetricsEnabled func() bool

+ IsRateLimitEnabled func() bool

+ IsStrictMode func() bool

+ PreserveNumbers func() bool

+ ShouldCleanupNulls func() bool

+ ShouldCompactArrays func() bool

+ ShouldCreatePaths func() bool

+ ShouldValidateFilePath func() bool

+ ShouldValidateInput func() bool

+ type EncodeConfigInterface interface

+ GetBufferSize func() int

+ GetFloatPrecision func() int

+ GetIndent func() string

+ GetMaxDepth func() int

+ GetPrefix func() string

+ GetQuoteStyle func() int

+ HasTrailingComma func() bool

+ IsCompactOutput func() bool

+ IsPretty func() bool

+ ShouldEscapeHTML func() bool

+ ShouldEscapeUnicode func() bool

+ ShouldIncludeNulls func() bool

+ ShouldOmitEmpty func() bool

+ ShouldPreserveNumbers func() bool

+ ShouldSortKeys func() bool

+ ShouldValidateUTF8 func() bool

+ type HealthChecker struct

+ func NewHealthChecker(processor interface{}, metrics *MetricsCollector) *HealthChecker

+ func (hc *HealthChecker) CheckHealth() HealthStatus

+ type HealthCheckerInterface interface

+ CheckHealth func() interface{}

+ type HealthStatus struct

+ Checks map[string]CheckResult

+ Healthy bool

+ Timestamp time.Time

+ func (hs *HealthStatus) GetFailedChecks() []string

+ func (hs *HealthStatus) GetSummary() string

+ func (hs *HealthStatus) IsHealthy() bool

+ type MappingInfo struct

+ ArrayFieldName string

+ OriginalContainers []any

+ TargetIndices []int

+ type Metrics struct

+ ActiveConcurrentOps int64

+ AvgProcessingTime time.Duration

+ CacheHits int64

+ CacheMisses int64

+ CurrentMemoryUsage int64

+ ErrorsByType map[string]int64

+ FailedOps int64

+ MaxConcurrentOps int64

+ MaxProcessingTime time.Duration

+ MinProcessingTime time.Duration

+ PeakMemoryUsage int64

+ RuntimeMemStats runtime.MemStats

+ SuccessfulOps int64

+ TotalMemoryAllocated int64

+ TotalOperations int64

+ TotalProcessingTime time.Duration

+ Uptime time.Duration

+ type MetricsCollector struct

+ func NewMetricsCollector() *MetricsCollector

+ func (mc *MetricsCollector) EndConcurrentOperation()

+ func (mc *MetricsCollector) GetMetrics() Metrics

+ func (mc *MetricsCollector) GetSummary() string

+ func (mc *MetricsCollector) RecordCacheHit()

+ func (mc *MetricsCollector) RecordCacheMiss()

+ func (mc *MetricsCollector) RecordError(errorType string)

+ func (mc *MetricsCollector) RecordOperation(duration time.Duration, success bool, memoryUsed int64)

+ func (mc *MetricsCollector) Reset()

+ func (mc *MetricsCollector) StartConcurrentOperation()

+ type MetricsInterface interface

+ EndConcurrentOperation func()

+ GetMetrics func() interface{}

+ GetSummary func() string

+ RecordCacheHit func()

+ RecordCacheMiss func()

+ RecordError func(errorType string)

+ RecordOperation func(duration time.Duration, success bool, memoryUsed int64)

+ Reset func()

+ StartConcurrentOperation func()

+ type OperationContext struct

+ ExtractionPath string

+ OperationType string

+ TargetArrays []ArrayLocation

+ type PathParser struct

+ func NewPathParser() *PathParser

+ func (pp *PathParser) ParseComplexSegment(part string) ([]PathSegment, error)

+ func (pp *PathParser) ParsePath(path string) ([]PathSegment, error)

+ func (pp *PathParser) ValidatePath(path string) error

+ type PathParserInterface interface

+ ParsePath func(path string) ([]interface{}, error)

+ SplitPathIntoSegments func(path string) []interface{}

+ ValidatePath func(path string) error

+ type PathPatterns struct

+ NumericIndex *regexp.Regexp

+ SimpleProperty *regexp.Regexp

+ func NewPathPatterns() *PathPatterns

+ type PathSegment struct

+ End *int

+ Extract string

+ Index int

+ IsDistributed bool

+ IsFlat bool

+ IsNegative bool

+ IsSlice bool

+ IsWildcard bool

+ Key string

+ MappingInfo *MappingInfo

+ OperationContext *OperationContext

+ Start *int

+ Step *int

+ Type PathSegmentType

+ Value string

+ func NewArrayIndexSegment(index int) PathSegment

+ func NewArraySliceSegment(start, end, step *int) PathSegment

+ func NewExtractSegment(extract string) PathSegment

+ func NewLegacyPathSegment(typeStr, value string) PathSegment

+ func NewPropertySegment(key string) PathSegment

+ func (ps PathSegment) GetArrayIndex(arrayLength int) (int, error)

+ func (ps PathSegment) IsArrayAccess() bool

+ func (ps PathSegment) String() string

+ func (ps PathSegment) TypeString() string

+ type PathSegmentType int

+ const ArrayIndexSegment

+ const ArraySliceSegment

+ const ExtractSegment

+ const FilterSegment

+ const PropertySegment

+ const RecursiveSegment

+ const WildcardSegment

+ func (pst PathSegmentType) String() string

+ type ProcessorOptionsInterface interface

+ AllowComments func() bool

+ GetContext func() interface{}

+ GetMaxDepth func() int

+ IsStrictMode func() bool

+ PreserveNumbers func() bool

+ ShouldCacheResults func() bool

+ ShouldCleanupNulls func() bool

+ ShouldCompactArrays func() bool

+ ShouldCreatePaths func() bool

+ type StatsInterface interface

+ GetCacheMemory func() int64

+ GetCacheSize func() int64

+ GetCacheTTL func() time.Duration

+ GetErrorCount func() int64

+ GetHitCount func() int64

+ GetHitRatio func() float64

+ GetMaxCacheSize func() int

+ GetMissCount func() int64

+ GetOperationCount func() int64

+ IsCacheEnabled func() bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL