json

package module

Go to main page

Versions in this module

v1

v1.4.1

May 7, 2026

Changes in this version

+ func GetWithContext(ctx context.Context, jsonStr, path string, cfg ...Config) (any, error)

type ParsedJSON

+ func (p *ParsedJSON) Release()

type Processor

+ func (p *Processor) GetWithContext(ctx context.Context, jsonStr, path string, cfg ...Config) (any, error)

v1.4.0

Apr 13, 2026

Changes in this version

+ func DeleteClean(jsonStr, path string, cfg ...Config) (string, error)

+ func ForeachFile(filePath string, fn func(key any, item *IterableValue) error) error

+ func ForeachFileChunked(filePath string, chunkSize int, fn func(chunk []*IterableValue) error) error

+ func ForeachFileNested(filePath string, fn func(key any, item *IterableValue) error) error

+ func ForeachFileWithPath(filePath, path string, fn func(key any, item *IterableValue) error) error

+ func ForeachJSONL(reader io.Reader, fn func(lineNum int, item *IterableValue) error) error

+ func ForeachNestedWithError(jsonStr string, fn func(key any, item *IterableValue) error) error

+ func ForeachWithError(jsonStr, path string, fn func(key any, item *IterableValue) error) error

+ func LoadFromReader(reader io.Reader, cfg ...Config) (string, error)

+ func MapJSONL(reader io.Reader, fn func(lineNum int, item *IterableValue) (any, error)) ([]any, error)

+ func MergeMany(jsons []string, cfg ...Config) (string, error)

+ func ParseAny(jsonStr string, cfg ...Config) (any, error)

+ func RedactedPath(path string) string

+ func ReduceJSONL(reader io.Reader, initial any, fn func(acc any, item *IterableValue) any) (any, error)

+ func SafeError(err error) string

+ func SetCreate(jsonStr, path string, value any, cfg ...Config) (string, error)

+ func SetMultipleCreate(jsonStr string, updates map[string]any, cfg ...Config) (string, error)

+ func StreamJSONL(reader io.Reader, fn func(lineNum int, item *IterableValue) error) error

+ func StreamJSONLChunked(reader io.Reader, chunkSize int, fn func(chunk []*IterableValue) error) error

+ func StreamJSONLFile(filename string, fn func(lineNum int, item *IterableValue) error) error

+ func StreamJSONLParallel(reader io.Reader, workers int, fn func(lineNum int, item *IterableValue) error) error

+ func StreamJSONLParallelWithContext(ctx context.Context, reader io.Reader, workers int, ...) error

+ func ValidWithConfig(jsonStr string, cfg ...Config) (bool, error)

type AccessResult

+ func SafeGet(jsonStr, path string, cfg ...Config) AccessResult

+ type CompiledPath = internal.CompiledPath

type Config

+ BufferSize int

+ ChunkSize int64

+ JSONLBufferSize int

+ JSONLChunkSize int

+ JSONLContinueOnErr bool

+ JSONLMaxLineSize int

+ JSONLMaxMemory int64

+ JSONLSkipComments bool

+ JSONLSkipEmpty bool

+ JSONLWorkers int

+ MaxMemory int64

+ MergeMode MergeMode

+ SampleSize int

+ SamplingEnabled bool

type IterableValue

+ func CollectJSONL(reader io.Reader) ([]*IterableValue, error)

+ func FilterJSONL(reader io.Reader, predicate func(item *IterableValue) bool) ([]*IterableValue, error)

+ func FirstJSONL(reader io.Reader, predicate func(item *IterableValue) bool) (*IterableValue, bool, error)

type Iterator

+ func (it *Iterator) Reset()

+ func (it *Iterator) ResetWith(data any)

type Processor

+ func (p *Processor) CollectJSONL(reader io.Reader) ([]*IterableValue, error)

+ func (p *Processor) FilterJSONL(reader io.Reader, predicate func(item *IterableValue) bool) ([]*IterableValue, error)

+ func (p *Processor) FirstJSONL(reader io.Reader, predicate func(item *IterableValue) bool) (*IterableValue, bool, error)

+ func (p *Processor) ForeachFile(filePath string, fn func(key any, item *IterableValue) error) error

+ func (p *Processor) ForeachFileChunked(filePath string, chunkSize int, fn func(chunk []*IterableValue) error) error

+ func (p *Processor) ForeachFileNested(filePath string, fn func(key any, item *IterableValue) error) error

+ func (p *Processor) ForeachFileWithPath(filePath, path string, fn func(key any, item *IterableValue) error) error

+ func (p *Processor) ForeachJSONL(reader io.Reader, fn func(lineNum int, item *IterableValue) error) error

+ func (p *Processor) ForeachNestedWithError(jsonStr string, fn func(key any, item *IterableValue) error) error

+ func (p *Processor) ForeachWithError(jsonStr, path string, fn func(key any, item *IterableValue) error) error

+ func (p *Processor) HTMLEscape(dst *bytes.Buffer, src []byte, cfg ...Config)

+ func (p *Processor) Indent(dst *bytes.Buffer, src []byte, prefix, indent string, cfg ...Config) error

+ func (p *Processor) MapJSONL(reader io.Reader, fn func(lineNum int, item *IterableValue) (any, error)) ([]any, error)

+ func (p *Processor) ReduceJSONL(reader io.Reader, initial any, fn func(acc any, item *IterableValue) any) (any, error)

+ func (p *Processor) StreamJSONL(reader io.Reader, fn func(lineNum int, item *IterableValue) error) error

+ func (p *Processor) StreamJSONLChunked(reader io.Reader, chunkSize int, fn func(chunk []*IterableValue) error) error

+ func (p *Processor) StreamJSONLFile(filename string, fn func(lineNum int, item *IterableValue) error) error

+ func (p *Processor) StreamJSONLParallel(reader io.Reader, workers int, fn func(lineNum int, item *IterableValue) error) error

+ func (p *Processor) StreamJSONLParallelWithContext(ctx context.Context, reader io.Reader, workers int, ...) error

type SchemaConfig

+ func DefaultSchemaConfig() SchemaConfig

v1.3.0

Mar 30, 2026

Changes in this version

+ const LargeStringHashThreshold

+ const MergeDifference

+ const MergeIntersection

+ const MergeUnion

+ var ErrInternalError = errors.New("internal error")

+ func As[T any](r AccessResult) (T, error)

+ func ClearDangerousPatterns()

+ func CompareJSON(json1, json2 string) (bool, error)

+ func EncodeWithConfig(value any, cfg ...Config) (string, error)

+ func GetBoolOr(jsonStr, path string, defaultValue bool, cfg ...Config) bool

+ func GetFloat(jsonStr, path string, cfg ...Config) (float64, error)

+ func GetFloatOr(jsonStr, path string, defaultValue float64, cfg ...Config) float64

+ func GetIntOr(jsonStr, path string, defaultValue int, cfg ...Config) int

+ func GetKeyInternCacheSize() int

+ func GetStringOr(jsonStr, path string, defaultValue string, cfg ...Config) string

+ func GetTypedOr[T any](jsonStr, path string, defaultValue T, cfg ...Config) T

+ func IsDeletedMarker(v any) bool

+ func IsEmptyOrZero(v any) bool

+ func MergeJSON(json1, json2 string, mode ...MergeMode) (string, error)

+ func MergeJSONMany(mode MergeMode, jsons ...string) (string, error)

+ func Parse(jsonStr string, cfg ...Config) (any, error)

+ func Prettify(jsonStr string, cfg ...Config) (string, error)

+ func RegisterDangerousPattern(pattern DangerousPattern)

+ func SaveToWriter(writer io.Writer, data any, cfg ...Config) error

+ func UnregisterDangerousPattern(pattern string)

+ type AccessResult struct

+ Exists bool

+ Type string

+ Value any

+ func NewAccessResult(value any, exists bool) AccessResult

+ func (r AccessResult) AsBool() (bool, error)

+ func (r AccessResult) AsFloat64() (float64, error)

+ func (r AccessResult) AsInt() (int, error)

+ func (r AccessResult) AsString() (string, error)

+ func (r AccessResult) AsStringConverted() (string, error)

+ func (r AccessResult) Ok() bool

+ func (r AccessResult) Unwrap() any

+ func (r AccessResult) UnwrapOr(defaultValue any) any

+ type CachedPathParser interface

+ ClearPathCache func()

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

type Config

+ AdditionalDangerousPatterns []DangerousPattern

+ CacheResults bool

+ Context context.Context

+ ContinueOnError bool

+ CustomEncoder CustomEncoder

+ CustomEscapes map[rune]string

+ CustomPathParser PathParser

+ CustomTypeEncoders map[reflect.Type]TypeEncoder

+ CustomValidators []Validator

+ DisableDefaultPatterns bool

+ DisableEscaping bool

+ DisallowUnknown bool

+ EscapeHTML bool

+ EscapeNewlines bool

+ EscapeSlash bool

+ EscapeTabs bool

+ EscapeUnicode bool

+ FloatPrecision int

+ FloatTruncate bool

+ Hooks []Hook

+ IncludeNulls bool

+ Indent string

+ MaxDepth int

+ Prefix string

+ Pretty bool

+ SkipValidation bool

+ SortKeys bool

+ ValidateUTF8 bool

+ func PrettyConfig() Config

+ func SecurityConfig() Config

+ func (c *Config) AddDangerousPattern(pattern DangerousPattern)

+ func (c *Config) AddHook(hook Hook)

+ func (c *Config) AddValidator(validator Validator)

+ func (c *Config) GetFloatPrecision() int

+ func (c *Config) GetIndent() string

+ func (c *Config) GetMaxDepth() int

+ func (c *Config) GetPrefix() string

+ func (c *Config) IsDisallowUnknownEnabled() bool

+ func (c *Config) IsHTMLEscapeEnabled() bool

+ func (c *Config) IsPrettyEnabled() bool

+ func (c *Config) IsSortKeysEnabled() bool

+ func (c *Config) IsTruncateFloatEnabled() bool

+ func (c *Config) ShouldEscapeNewlines() bool

+ func (c *Config) ShouldEscapeSlash() bool

+ func (c *Config) ShouldEscapeTabs() bool

+ func (c *Config) ShouldEscapeUnicode() bool

+ func (c *Config) ShouldIncludeNulls() bool

+ func (c *Config) ShouldValidateUTF8() bool

+ func (c *Config) ValidateWithWarnings() []ConfigWarning

+ type ConfigWarning struct

+ Field string

+ NewValue any

+ OldValue any

+ Reason string

+ type DangerousPattern struct

+ Level PatternLevel

+ Name string

+ Pattern string

+ func GetCriticalPatterns() []DangerousPattern

+ func GetDefaultPatterns() []DangerousPattern

+ func ListDangerousPatterns() []DangerousPattern

type Encoder

+ func NewEncoderWithOpts(w io.Writer, opts *Config) *Encoder

+ type EncoderConfig interface

+ GetFloatPrecision func() int

+ GetIndent func() string

+ GetMaxDepth func() int

+ GetPrefix func() string

+ IsDisallowUnknownEnabled func() bool

+ IsHTMLEscapeEnabled func() bool

+ IsPrettyEnabled func() bool

+ IsSortKeysEnabled func() bool

+ IsTruncateFloatEnabled func() bool

+ ShouldEscapeNewlines func() bool

+ ShouldEscapeSlash func() bool

+ ShouldEscapeTabs func() bool

+ ShouldEscapeUnicode func() bool

+ ShouldIncludeNulls func() bool

+ ShouldValidateUTF8 func() bool

+ type Hook interface

+ After func(ctx HookContext, result any, err error) (any, error)

+ Before func(ctx HookContext) error

+ func ErrorHook(handler func(ctx HookContext, err error) error) Hook

+ func LoggingHook(logger interface{ ... }) Hook

+ func TimingHook(recorder interface{ ... }) Hook

+ func ValidationHook(validator func(jsonStr, path string) error) Hook

+ type HookChain []Hook

+ func (hc HookChain) ExecuteAfter(ctx HookContext, result any, err error) (any, error)

+ func (hc HookChain) ExecuteBefore(ctx HookContext) error

+ type HookContext struct

+ Config *Config

+ JSONStr string

+ Operation string

+ Path string

+ StartTime time.Time

+ Value any

+ type HookFunc struct

+ AfterFn func(ctx HookContext, result any, err error) (any, error)

+ BeforeFn func(ctx HookContext) error

+ func (h *HookFunc) After(ctx HookContext, result any, err error) (any, error)

+ func (h *HookFunc) Before(ctx HookContext) error

type JSONLConfig

+ Processor *Processor

type JSONLStats

+ BytesWritten int64

type LazyParser

+ func (lp *LazyParser) Error() error

+ func (lp *LazyParser) GetObject() (map[string]any, error)

+ func (lp *LazyParser) Parse() (any, error)

+ func (lp *LazyParser) Parsed() any

+ type MergeMode = internal.MergeMode

type ParallelIterator

+ func (it *ParallelIterator) Close()

+ func (it *ParallelIterator) ForEachBatchWithContext(ctx context.Context, batchSize int, fn func(int, []any) error) error

+ func (it *ParallelIterator) ForEachWithContext(ctx context.Context, fn func(int, any) error) error

+ type PathSecurityChecker struct

+ func NewPathSecurityChecker(maxPathLength int) *PathSecurityChecker

+ func (pc *PathSecurityChecker) Validate(path string) error

type PathSegment

+ func NewAppendSegment() PathSegment

+ func NewArrayIndexSegment(index int) PathSegment

+ func NewArraySliceSegment(start, end, step int, hasStart, hasEnd, hasStep bool) PathSegment

+ func NewExtractSegment(key string, flat bool) PathSegment

+ func NewPropertySegment(key string) PathSegment

+ func NewRecursiveSegment() PathSegment

+ func NewWildcardSegment() PathSegment

+ type PathSegmentFlags = internal.PathSegmentFlags

+ const PathFlagFlat

+ const PathFlagHasEnd

+ const PathFlagHasStart

+ const PathFlagHasStep

+ const PathFlagNegative

+ const PathFlagWildcard

+ type PathSegmentType = internal.PathSegmentType

+ const PathSegmentAppend

+ const PathSegmentArrayIndex

+ const PathSegmentArraySlice

+ const PathSegmentExtract

+ const PathSegmentFilter

+ const PathSegmentProperty

+ const PathSegmentRecursive

+ const PathSegmentWildcard

+ type PathValidator interface

+ ValidatePath func(path string) error

+ type PatternChecker struct

+ func NewPatternChecker(fullSecurityScan bool) *PatternChecker

+ func (pc *PatternChecker) Check(jsonStr string) error

+ type PatternLevel int

+ const PatternLevelCritical

+ const PatternLevelInfo

+ const PatternLevelWarning

+ func (pl PatternLevel) String() string

+ type PatternRegistry interface

+ Add func(pattern DangerousPattern)

+ Clear func()

+ List func() []DangerousPattern

+ ListByLevel func(level PatternLevel) []DangerousPattern

+ Remove func(pattern string)

type Processor

+ func (p *Processor) AddHook(hook Hook)

+ func (p *Processor) CompactBytes(dst *bytes.Buffer, src []byte) error

+ func (p *Processor) CompactString(jsonStr string, opts ...Config) (string, error)

+ func (p *Processor) DeleteClean(jsonStr, path string, opts ...Config) (string, error)

+ func (p *Processor) GetBoolOr(jsonStr, path string, defaultValue bool, opts ...Config) bool

+ func (p *Processor) GetFloat(jsonStr, path string, opts ...Config) (float64, error)

+ func (p *Processor) GetFloatOr(jsonStr, path string, defaultValue float64, opts ...Config) float64

+ func (p *Processor) GetIntOr(jsonStr, path string, defaultValue int, opts ...Config) int

+ func (p *Processor) GetStringOr(jsonStr, path string, defaultValue string, opts ...Config) string

+ func (p *Processor) IndentBytes(dst *bytes.Buffer, src []byte, prefix, indent string) error

+ func (p *Processor) ParseAny(jsonStr string, opts ...Config) (any, error)

+ func (p *Processor) Prettify(jsonStr string, opts ...Config) (string, error)

+ func (p *Processor) SetCreate(jsonStr, path string, value any, opts ...Config) (string, error)

+ func (p *Processor) SetMultipleCreate(jsonStr string, updates map[string]any, opts ...Config) (string, error)

+ type Result struct

+ Error error

+ Exists bool

+ Value T

+ func NewResult[T any](value T, exists bool, err error) Result[T]

+ func (r Result[T]) Ok() bool

+ func (r Result[T]) Unwrap() T

+ func (r Result[T]) UnwrapOr(defaultValue T) T

type Schema

+ func NewSchemaWithConfig(cfg SchemaConfig) *Schema

+ type SchemaConfig struct

+ AdditionalProperties *bool

+ Const any

+ Default any

+ Description string

+ Enum []any

+ Examples []any

+ ExclusiveMaximum *bool

+ ExclusiveMinimum *bool

+ Format string

+ Items *Schema

+ MaxItems *int

+ MaxLength *int

+ Maximum *float64

+ MinItems *int

+ MinLength *int

+ Minimum *float64

+ MultipleOf *float64

+ Pattern string

+ Properties map[string]*Schema

+ Required []string

+ Title string

+ Type string

+ UniqueItems bool

type SecurityValidator

+ ValidateContent func(content string) error

type StreamingProcessor

+ func (sp *StreamingProcessor) Close() error

+ type StructureValidator struct

+ func NewStructureValidator(maxNestingDepth int64) *StructureValidator

+ func (sv *StructureValidator) ValidateNesting(jsonStr string) error

+ func (sv *StructureValidator) ValidateStructure(jsonStr string) error

+ type TypeEncoder interface

+ Encode func(v reflect.Value) (string, error)

+ type ValidationChain []Validator

+ func (vc ValidationChain) Validate(jsonStr string) error

type Validator

+ Validate func(jsonStr string) error

v1.2.2

Mar 4, 2026

Changes in this version

+ func CompactString(jsonStr string, opts ...*ProcessorOptions) (string, error)

+ func EncodeWithOptions(value any, config *EncodeConfig, opts ...*ProcessorOptions) (string, error)

+ func PutEncodeConfig(cfg *EncodeConfig)

+ func ValidString(jsonStr string) bool

+ func ValidWithOptions(jsonStr string, opts ...*ProcessorOptions) (bool, error)

type Config

+ func FastConfig() *Config

+ func MinimalConfig() *Config

+ func WebAPIConfig() *Config

type LazyParser

+ func (lp *LazyParser) GetValue() (any, error)

+ func (lp *LazyParser) IsArray() bool

+ func (lp *LazyParser) IsObject() bool

v1.2.1

Feb 26, 2026

Changes in this version

type EncodeConfig

+ FloatTruncate bool

v1.2.0

Feb 25, 2026

Changes in this version

+ const LargeJSONCacheLimit

+ const MediumJSONCacheLimit

+ func ClearKeyInternCache()

+ func EstimateArraySize(jsonBytes []byte) int

+ func EstimateMapSize(jsonBytes []byte) int

+ func FastToBool(value any) (bool, bool)

+ func FastToFloat64(value any) (float64, bool)

+ func FastToInt(value any) (int, bool)

+ func FastToString(value any) (string, bool)

+ func FastTypeSwitch[T any](value any) (T, bool)

+ func GetEncodeBuffer() []byte

+ func GetResultBuffer() *[]byte

+ func InternKey(key string) string

+ func InternMapKeys(m map[string]any)

+ func KeyInternCacheSize() int

+ func NewMapWithEstimatedSize(jsonBytes []byte) map[string]any

+ func NewSliceWithEstimatedSize(jsonBytes []byte) []any

+ func ParseJSONL(data []byte) ([]any, error)

+ func ParseJSONLInto[T any](data []byte) ([]T, error)

+ func PrintE(data any) error

+ func PrintPrettyE(data any) error

+ func PutEncodeBuffer(buf []byte)

+ func PutPooledDecoder(dec *Decoder)

+ func PutResultBuffer(buf *[]byte)

+ func StreamArrayCount(reader io.Reader) (int, error)

+ func StreamArrayFilter(reader io.Reader, predicate func(any) bool) ([]any, error)

+ func StreamArrayFirst(reader io.Reader, predicate func(any) bool) (any, bool, error)

+ func StreamArrayForEach(reader io.Reader, fn func(int, any) error) error

+ func StreamArrayMap(reader io.Reader, transform func(any) any) ([]any, error)

+ func StreamArrayReduce(reader io.Reader, initial any, reducer func(any, any) any) (any, error)

+ func StreamArraySkip(reader io.Reader, n int) ([]any, error)

+ func StreamArrayTake(reader io.Reader, n int) ([]any, error)

+ func StreamLinesIntoWithConfig[T any](reader io.Reader, config JSONLConfig, fn func(lineNum int, data T) error) ([]T, error)

+ func StreamLinesInto[T any](reader io.Reader, fn func(lineNum int, data T) error) ([]T, error)

+ func ToJSONL(data []any) ([]byte, error)

+ func ToJSONLString(data []any) (string, error)

+ func WarmupPathCache(commonPaths []string)

+ func WarmupPathCacheWithProcessor(processor *Processor, commonPaths []string)

+ type BatchIterator struct

+ func NewBatchIterator(data []any, batchSize int) *BatchIterator

+ func (it *BatchIterator) CurrentIndex() int

+ func (it *BatchIterator) HasNext() bool

+ func (it *BatchIterator) NextBatch() []any

+ func (it *BatchIterator) Remaining() int

+ func (it *BatchIterator) Reset()

+ func (it *BatchIterator) TotalBatches() int

+ type BulkProcessor struct

+ func NewBulkProcessor(processor *Processor, batchSize int) *BulkProcessor

+ func (bp *BulkProcessor) BulkGet(jsonStr string, paths []string) (map[string]any, error)

+ type ChunkedReader struct

+ func NewChunkedReader(reader io.Reader, chunkSize int) *ChunkedReader

+ func (cr *ChunkedReader) ReadArray(fn func(item any) bool) error

+ func (cr *ChunkedReader) ReadObject(fn func(key string, value any) bool) error

+ type ChunkedWriter struct

+ func NewChunkedWriter(writer io.Writer, chunkSize int, isArray bool) *ChunkedWriter

+ func (cw *ChunkedWriter) Count() int

+ func (cw *ChunkedWriter) Flush(final bool) error

+ func (cw *ChunkedWriter) WriteItem(item any) error

+ func (cw *ChunkedWriter) WriteKeyValue(key string, value any) error

type Config

+ FullSecurityScan bool

type Decoder

+ func GetPooledDecoder(r io.Reader) *Decoder

type IterableValue

+ func NewPooledIterableValue(data any) *IterableValue

+ func (iv *IterableValue) GetData() any

+ func (iv *IterableValue) Release()

+ type JSONLConfig struct

+ BufferSize int

+ ContinueOnErr bool

+ MaxLineSize int

+ SkipComments bool

+ SkipEmpty bool

+ func DefaultJSONLConfig() JSONLConfig

+ type JSONLProcessor struct

+ func NewJSONLProcessor(reader io.Reader) *JSONLProcessor

+ func NewJSONLProcessorWithConfig(reader io.Reader, config JSONLConfig) *JSONLProcessor

+ func (j *JSONLProcessor) Err() error

+ func (j *JSONLProcessor) GetStats() JSONLStats

+ func (j *JSONLProcessor) Release()

+ func (j *JSONLProcessor) Stop()

+ func (j *JSONLProcessor) StreamLines(fn func(lineNum int, data any) bool) error

+ func (j *JSONLProcessor) StreamLinesParallel(fn func(lineNum int, data any) error, workers int) error

+ type JSONLStats struct

+ BytesRead int64

+ CurrentLine int

+ LinesProcessed int64

+ type JSONLWriter struct

+ func NewJSONLWriter(writer io.Writer) *JSONLWriter

+ func (w *JSONLWriter) Err() error

+ func (w *JSONLWriter) Stats() JSONLStats

+ func (w *JSONLWriter) Write(data any) error

+ func (w *JSONLWriter) WriteAll(data []any) error

+ func (w *JSONLWriter) WriteRaw(line []byte) error

+ type LargeFileConfig struct

+ BufferSize int

+ ChunkSize int64

+ MaxMemory int64

+ SampleSize int

+ SamplingEnabled bool

+ func DefaultLargeFileConfig() LargeFileConfig

+ type LargeFileProcessor struct

+ func NewLargeFileProcessor(config LargeFileConfig) *LargeFileProcessor

+ func (lfp *LargeFileProcessor) ProcessFile(filename string, fn func(item any) error) error

+ func (lfp *LargeFileProcessor) ProcessFileChunked(filename string, chunkSize int, fn func(chunk []any) error) error

+ type LazyJSON struct

+ func NewLazyJSON(data []byte) *LazyJSON

+ func (lj *LazyJSON) Error() error

+ func (lj *LazyJSON) Get(path string) (any, error)

+ func (lj *LazyJSON) IsParsed() bool

+ func (lj *LazyJSON) Parse() (any, error)

+ func (lj *LazyJSON) Parsed() any

+ func (lj *LazyJSON) Raw() []byte

+ type LazyJSONDecoder struct

+ func NewLazyJSONDecoder(data []byte) *LazyJSONDecoder

+ func (l *LazyJSONDecoder) GetPath(path string) (any, error)

+ func (l *LazyJSONDecoder) Parse() (any, error)

+ func (l *LazyJSONDecoder) Raw() []byte

+ type LazyParser struct

+ func NewLazyParser(data []byte) *LazyParser

+ func (lp *LazyParser) Get(path string) (any, error)

+ func (lp *LazyParser) GetAll() (map[string]any, error)

+ func (lp *LazyParser) IsParsed() bool

+ func (lp *LazyParser) Raw() []byte

+ type NDJSONProcessor struct

+ func NewNDJSONProcessor(bufferSize int) *NDJSONProcessor

+ func (np *NDJSONProcessor) ProcessFile(filename string, fn func(lineNum int, obj map[string]any) error) error

+ func (np *NDJSONProcessor) ProcessReader(reader io.Reader, fn func(lineNum int, obj map[string]any) error) error

+ type ParallelIterator struct

+ func NewParallelIterator(data []any, workers int) *ParallelIterator

+ func (it *ParallelIterator) Filter(predicate func(int, any) bool) []any

+ func (it *ParallelIterator) ForEach(fn func(int, any) error) error

+ func (it *ParallelIterator) ForEachBatch(batchSize int, fn func(int, []any) error) error

+ func (it *ParallelIterator) Map(transform func(int, any) (any, error)) ([]any, error)

+ type ParsedJSON struct

+ func (p *ParsedJSON) Data() any

+ type PathType int

+ const PathTypeComplex

+ const PathTypeSimple

+ func GetPathType(path string) PathType

+ type PooledMapIterator struct

+ func NewPooledMapIterator(m map[string]any) *PooledMapIterator

+ func (it *PooledMapIterator) Key() string

+ func (it *PooledMapIterator) Next() bool

+ func (it *PooledMapIterator) Release()

+ func (it *PooledMapIterator) Value() any

+ type PooledSliceIterator struct

+ func NewPooledSliceIterator(data []any) *PooledSliceIterator

+ func (it *PooledSliceIterator) Index() int

+ func (it *PooledSliceIterator) Next() bool

+ func (it *PooledSliceIterator) Release()

+ func (it *PooledSliceIterator) Value() any

type Processor

+ func (p *Processor) BatchDeleteOptimized(jsonStr string, paths []string) (string, error)

+ func (p *Processor) BatchSetOptimized(jsonStr string, updates map[string]any) (string, error)

+ func (p *Processor) CompilePath(path string) (*internal.CompiledPath, error)

+ func (p *Processor) FastDelete(jsonStr, path string) (string, error)

+ func (p *Processor) FastGetMultiple(jsonStr string, paths []string) (map[string]any, error)

+ func (p *Processor) FastSet(jsonStr, path string, value any) (string, error)

+ func (p *Processor) GetCompiled(jsonStr string, cp *internal.CompiledPath) (any, error)

+ func (p *Processor) GetCompiledExists(data any, cp *internal.CompiledPath) bool

+ func (p *Processor) GetCompiledFromParsed(data any, cp *internal.CompiledPath) (any, error)

+ func (p *Processor) GetFromParsed(parsed *ParsedJSON, path string, opts ...*ProcessorOptions) (any, error)

+ func (p *Processor) GetFromParsedData(data any, path string) (any, error)

+ func (p *Processor) PreParse(jsonStr string, opts ...*ProcessorOptions) (*ParsedJSON, error)

+ func (p *Processor) SetFromParsed(parsed *ParsedJSON, path string, value any, opts ...*ProcessorOptions) (*ParsedJSON, error)

type ProcessorOptions

+ SkipValidation bool

+ func DefaultOptionsClone() *ProcessorOptions

type ResourceManagerStats

+ AllocatedMaps int64

+ AllocatedOptions int64

+ type SamplingReader struct

+ func NewSamplingReader(reader io.Reader, sampleSize int) *SamplingReader

+ func (sr *SamplingReader) Sample(fn func(index int, item any) bool) error

+ func (sr *SamplingReader) TotalRead() int64

+ type StreamIterator struct

+ func NewStreamIterator(reader io.Reader) *StreamIterator

+ func NewStreamIteratorWithConfig(reader io.Reader, config StreamIteratorConfig) *StreamIterator

+ func (si *StreamIterator) Err() error

+ func (si *StreamIterator) Index() int

+ func (si *StreamIterator) Next() bool

+ func (si *StreamIterator) Value() any

+ type StreamIteratorConfig struct

+ BufferSize int

+ ReadAhead bool

+ type StreamObjectIterator struct

+ func NewStreamObjectIterator(reader io.Reader) *StreamObjectIterator

+ func (soi *StreamObjectIterator) Err() error

+ func (soi *StreamObjectIterator) Key() string

+ func (soi *StreamObjectIterator) Next() bool

+ func (soi *StreamObjectIterator) Value() any

+ type StreamingProcessor struct

+ func NewStreamingProcessor(reader io.Reader, bufferSize int) *StreamingProcessor

+ func (sp *StreamingProcessor) GetStats() StreamingStats

+ func (sp *StreamingProcessor) StreamArray(fn func(index int, item any) bool) error

+ func (sp *StreamingProcessor) StreamArrayChunked(chunkSize int, fn func([]any) error) error

+ func (sp *StreamingProcessor) StreamObject(fn func(key string, value any) bool) error

+ func (sp *StreamingProcessor) StreamObjectChunked(chunkSize int, fn func(map[string]any) error) error

+ type StreamingStats struct

+ BytesProcessed int64

+ Depth int

+ ItemsProcessed int64

type TypeSafeAccessResult

+ func (r TypeSafeAccessResult) AsFloat64() (float64, error)

+ func (r TypeSafeAccessResult) AsStringConverted() (string, error)

type UnifiedResourceManager

+ func (urm *UnifiedResourceManager) GetMap() map[string]any

+ func (urm *UnifiedResourceManager) GetOptions() *ProcessorOptions

+ func (urm *UnifiedResourceManager) PutMap(m map[string]any)

+ func (urm *UnifiedResourceManager) PutOptions(opts *ProcessorOptions)

v1.1.0

Feb 5, 2026

Changes in this version

+ func ClearCache()

+ func CompactBuffer(dst *bytes.Buffer, src []byte, opts ...*ProcessorOptions) error

+ func EncodeBatch(pairs map[string]any, pretty bool, opts ...*ProcessorOptions) (string, error)

+ func EncodeFields(value any, fields []string, pretty bool, opts ...*ProcessorOptions) (string, error)

+ func EncodeStream(values any, pretty bool, opts ...*ProcessorOptions) (string, error)

+ func ForeachWithPathAndIterator(jsonStr, path string, ...) error

+ func HTMLEscapeBuffer(dst *bytes.Buffer, src []byte, opts ...*ProcessorOptions)

+ func IndentBuffer(dst *bytes.Buffer, src []byte, prefix, indent string, ...) error

+ func Print(data any)

+ func PrintPretty(data any)

type BatchResult

+ func ProcessBatch(operations []BatchOperation, opts ...*ProcessorOptions) ([]BatchResult, error)

type HealthStatus

+ func GetHealthStatus() HealthStatus

type Processor

+ func (p *Processor) CompactBuffer(dst *bytes.Buffer, src []byte, opts ...*ProcessorOptions) error

+ func (p *Processor) DeleteWithCleanNull(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) Encode(value any, config ...*EncodeConfig) (string, error)

+ func (p *Processor) EncodePretty(value any, config ...*EncodeConfig) (string, error)

+ func (p *Processor) FormatCompact(jsonStr string, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) GetArray(jsonStr, path string, opts ...*ProcessorOptions) ([]any, error)

+ func (p *Processor) GetArrayWithDefault(jsonStr, path string, defaultValue []any, opts ...*ProcessorOptions) []any

+ func (p *Processor) GetBool(jsonStr, path string, opts ...*ProcessorOptions) (bool, error)

+ func (p *Processor) GetBoolWithDefault(jsonStr, path string, defaultValue bool, opts ...*ProcessorOptions) bool

+ func (p *Processor) GetFloat64(jsonStr, path string, opts ...*ProcessorOptions) (float64, error)

+ func (p *Processor) GetFloat64WithDefault(jsonStr, path string, defaultValue float64, opts ...*ProcessorOptions) float64

+ func (p *Processor) GetInt(jsonStr, path string, opts ...*ProcessorOptions) (int, error)

+ func (p *Processor) GetIntWithDefault(jsonStr, path string, defaultValue int, opts ...*ProcessorOptions) int

+ func (p *Processor) GetObject(jsonStr, path string, opts ...*ProcessorOptions) (map[string]any, error)

+ func (p *Processor) GetObjectWithDefault(jsonStr, path string, defaultValue map[string]any, opts ...*ProcessorOptions) map[string]any

+ func (p *Processor) GetString(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) GetStringWithDefault(jsonStr, path, defaultValue string, opts ...*ProcessorOptions) string

+ func (p *Processor) GetWithDefault(jsonStr, path string, defaultValue any, opts ...*ProcessorOptions) any

+ func (p *Processor) HTMLEscapeBuffer(dst *bytes.Buffer, src []byte, opts ...*ProcessorOptions)

+ func (p *Processor) IndentBuffer(dst *bytes.Buffer, src []byte, prefix, indent string, ...) error

+ func (p *Processor) LoadFromFileAsData(filePath string, opts ...*ProcessorOptions) (any, error)

+ func (p *Processor) LoadFromReaderAsData(reader io.Reader, opts ...*ProcessorOptions) (any, error)

+ func (p *Processor) SetMultipleWithAdd(jsonStr string, updates map[string]any, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) SetWithAdd(jsonStr, path string, value any, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) ValidBytes(data []byte) bool

type Stats

+ func GetStats() Stats

type WarmupResult

+ func WarmupCache(jsonStr string, paths []string, opts ...*ProcessorOptions) (*WarmupResult, error)

v1.0.10

Jan 20, 2026

Changes in this version

+ func GetErrorSuggestion(err error) string

+ func IsRetryable(err error) bool

+ func IsSecurityRelated(err error) bool

+ func IsUserError(err error) bool

+ func IsValidJSON(jsonStr string) bool

type Config

+ func (c *Config) IsCommentsAllowed() bool

+ func (c *Config) ShouldPreserveNumbers() bool

type ConfigInterface

+ IsCommentsAllowed func() bool

+ ShouldPreserveNumbers func() bool

type PropertyAccessResult

+ Error error

+ Path string

v1.0.9

Jan 12, 2026

Changes in this version

type Processor

+ func (p *Processor) ForeachNested(jsonStr string, fn func(key any, item *IterableValue))

+ func (p *Processor) ForeachWithPathAndControl(jsonStr, path string, fn func(key any, value any) IteratorControl) error

+ func (p *Processor) ForeachWithPathAndIterator(jsonStr, path string, ...) error

v1.0.8

Jan 12, 2026

Changes in this version

+ func ForeachWithPathAndControl(jsonStr, path string, fn func(key any, value any) IteratorControl) error

+ type ExtractionGroup struct

+ Segments []PathSegment

type IterableValue

+ func (iv *IterableValue) IsEmptyData() bool

+ func (iv *IterableValue) IsNullData() bool

type Iterator

+ func (it *Iterator) HasNext() bool

+ func (it *Iterator) Next() (any, bool)

v1.0.7

Jan 8, 2026

Changes in this version

+ const CacheKeyHashLength

+ const EstimatedKeyOverhead

+ const LargeJSONKeyOverhead

+ const MaxCacheKeyLength

+ const MediumJSONThreshold

+ const SmallJSONCacheLimit

+ const SmallJSONThreshold

+ const ValidationBOMPrefix

+ func ParseArrayIndexGlobal(indexStr string) int

+ type ArrayHelper struct

+ func (ah *ArrayHelper) ClampIndex(index, length int) int

+ func (ah *ArrayHelper) CompactArray(arr []any) []any

+ func (ah *ArrayHelper) ExtendArray(arr []any, targetLength int) []any

+ func (ah *ArrayHelper) GetElement(arr []any, index int) (any, bool)

+ func (ah *ArrayHelper) NormalizeIndex(index, length int) int

+ func (ah *ArrayHelper) ParseArrayIndex(indexStr string) int

+ func (ah *ArrayHelper) PerformSlice(arr []any, start, end, step int) []any

+ func (ah *ArrayHelper) SetElement(arr []any, index int, value any) bool

+ func (ah *ArrayHelper) ValidateBounds(index, length int) bool

+ type ConfigInterface interface

+ AllowComments func() bool

+ GetCacheTTL func() time.Duration

+ GetMaxCacheSize func() int

+ GetMaxConcurrency func() int

+ GetMaxJSONSize func() int64

+ GetMaxNestingDepth func() int

+ GetMaxPathDepth func() int

+ IsCacheEnabled func() bool

+ IsMetricsEnabled func() bool

+ IsStrictMode func() bool

+ PreserveNumbers func() bool

+ ShouldCleanupNulls func() bool

+ ShouldCompactArrays func() bool

+ ShouldCreatePaths func() bool

+ ShouldValidateInput func() bool

type ErrorClassifier

+ func (ec *ErrorClassifier) IsSecurityRelated(err error) bool

type SecurityValidator

+ func (sv *SecurityValidator) ValidateAll(jsonStr, path string) error

v1.0.6

Dec 24, 2025

Changes in this version

+ const ErrCodeOperationFailed

+ func FastValidateJSON(jsonStr string) bool

+ func FastValidatePath(path string) bool

+ func MarshalToFile(path string, data any, pretty ...bool) error

+ func UnmarshalFromFile(path string, v any) error

+ func WrapError(err error, op, message string) error

+ func WrapPathError(err error, op, path, message string) error

type Config

+ func (c *Config) Clone() *Config

+ func (c *Config) Validate() error

+ type ErrorClassifier struct

+ func NewErrorClassifier() *ErrorClassifier

+ func (ec *ErrorClassifier) GetErrorSuggestion(err error) string

+ func (ec *ErrorClassifier) IsRetryable(err error) bool

+ func (ec *ErrorClassifier) IsSecurityError(err error) bool

+ func (ec *ErrorClassifier) IsUserError(err error) bool

type Processor

+ func (p *Processor) MarshalToFile(path string, data any, pretty ...bool) error

+ func (p *Processor) UnmarshalFromFile(path string, v any, opts ...*ProcessorOptions) error

+ type ProcessorConfigAdapter struct

+ func NewProcessorConfigAdapter(config *ProcessorConfig) *ProcessorConfigAdapter

+ func (pca *ProcessorConfigAdapter) AllowComments() bool

+ func (pca *ProcessorConfigAdapter) GetCacheTTL() time.Duration

+ func (pca *ProcessorConfigAdapter) GetMaxCacheSize() int

+ func (pca *ProcessorConfigAdapter) GetMaxConcurrency() int

+ func (pca *ProcessorConfigAdapter) GetMaxJSONSize() int64

+ func (pca *ProcessorConfigAdapter) GetMaxNestingDepth() int

+ func (pca *ProcessorConfigAdapter) GetMaxPathDepth() int

+ func (pca *ProcessorConfigAdapter) IsCacheEnabled() bool

+ func (pca *ProcessorConfigAdapter) IsHealthCheckEnabled() bool

+ func (pca *ProcessorConfigAdapter) IsMetricsEnabled() bool

+ func (pca *ProcessorConfigAdapter) IsStrictMode() bool

+ func (pca *ProcessorConfigAdapter) PreserveNumbers() bool

+ func (pca *ProcessorConfigAdapter) ShouldCleanupNulls() bool

+ func (pca *ProcessorConfigAdapter) ShouldCompactArrays() bool

+ func (pca *ProcessorConfigAdapter) ShouldCreatePaths() bool

+ func (pca *ProcessorConfigAdapter) ShouldValidateFilePath() bool

+ func (pca *ProcessorConfigAdapter) ShouldValidateInput() bool

+ type ResourceManagerStats struct

+ AllocatedBuffers int64

+ AllocatedBuilders int64

+ AllocatedSegments int64

+ LastCleanup int64

+ type SecurityValidator struct

+ func NewSecurityValidator(maxJSONSize int64, maxPathLength, maxNestingDepth int) *SecurityValidator

+ func (sv *SecurityValidator) ValidateJSONInput(jsonStr string) error

+ func (sv *SecurityValidator) ValidatePathInput(path string) error

+ type SimpleCacheImpl struct

+ func NewSimpleCacheImpl(config internal.ConfigInterface) *SimpleCacheImpl

+ func (sc *SimpleCacheImpl) Clear()

+ func (sc *SimpleCacheImpl) Get(key CacheKey) (any, bool)

+ func (sc *SimpleCacheImpl) Set(key CacheKey, value any, ttl time.Duration)

+ func (sc *SimpleCacheImpl) Size() int

+ type UnifiedResourceManager struct

+ func GetGlobalResourceManager() *UnifiedResourceManager

+ func NewUnifiedResourceManager() *UnifiedResourceManager

+ func (urm *UnifiedResourceManager) GetBuffer() []byte

+ func (urm *UnifiedResourceManager) GetPathSegments() []PathSegment

+ func (urm *UnifiedResourceManager) GetStats() ResourceManagerStats

+ func (urm *UnifiedResourceManager) GetStringBuilder() *strings.Builder

+ func (urm *UnifiedResourceManager) PerformMaintenance()

+ func (urm *UnifiedResourceManager) PutBuffer(buf []byte)

+ func (urm *UnifiedResourceManager) PutPathSegments(segments []PathSegment)

+ func (urm *UnifiedResourceManager) PutStringBuilder(sb *strings.Builder)

+ type Validator struct

+ func NewValidator(maxJSONSize int64, maxPathLength, maxNestingDepth int) *Validator

+ func (v *Validator) ValidateJSONInput(jsonStr string) error

+ func (v *Validator) ValidatePathInput(path string) error

v1.0.5

Dec 1, 2025

v1.0.4

Nov 29, 2025

Changes in this version

+ const AcquireSlotRetryDelay

+ const BaseRetryDelay

+ const CacheCleanupInterval

+ const CacheCleanupKeepSize

+ const DeadlockCheckInterval

+ const DeadlockThreshold

+ const DefaultBufferSize

+ const DefaultCacheSize

+ const DefaultCacheTTL

+ const DefaultMaxArrayElements

+ const DefaultMaxBatchSize

+ const DefaultMaxConcurrency

+ const DefaultMaxJSONSize

+ const DefaultMaxNestingDepth

+ const DefaultMaxObjectKeys

+ const DefaultMaxPathDepth

+ const DefaultMaxSecuritySize

+ const DefaultOperationTimeout

+ const DefaultParallelThreshold

+ const DefaultPathSegmentCap

+ const DefaultStringBuilderSize

+ const ErrCodeConcurrencyLimit

+ const ErrCodeDepthLimit

+ const ErrCodeInvalidJSON

+ const ErrCodePathNotFound

+ const ErrCodeProcessorClosed

+ const ErrCodeRateLimit

+ const ErrCodeSecurityViolation

+ const ErrCodeSizeLimit

+ const ErrCodeTimeout

+ const ErrCodeTypeMismatch

+ const InvalidArrayIndex

+ const MaxAllowedArrayElements

+ const MaxAllowedNestingDepth

+ const MaxAllowedObjectKeys

+ const MaxCacheEntries

+ const MaxConsecutiveBrackets

+ const MaxConsecutiveColons

+ const MaxExtractionDepth

+ const MaxPathLength

+ const MaxPathSegmentCap

+ const MaxPoolBufferSize

+ const MaxRetries

+ const MaxSecurityValidationSize

+ const MaxSegmentLength

+ const MemoryPressureCheckInterval

+ const MinPoolBufferSize

+ const PathTraversalMaxLength

+ const PoolResetInterval

+ const PoolResetIntervalPressure

+ const SlowOperationThreshold

+ var ErrIteratorControl = errors.New("iterator control signal")

+ func BuildPathWithPrefix(prefix, path string) string

+ func ConvertToBool(value any) (bool, bool)

+ func ConvertToFloat64(value any) (float64, bool)

+ func ConvertToInt(value any) (int, bool)

+ func ConvertToInt64(value any) (int64, bool)

+ func ConvertToString(value any) (string, bool)

+ func ConvertToUint64(value any) (uint64, bool)

+ func JoinPath(base, segment string) string

+ func OptimizedStringConcat(parts ...string) string

+ func RemovePathPrefix(path, prefix string) string

+ func SafeGo(f func())

+ func SafeGoWithContext(ctx context.Context, f func(context.Context))

+ func TruncateString(s string, maxLen int) string

+ func UnifiedTypeConversion[T any](value any) (T, bool)

+ type DOSConfig struct

+ FailureThreshold int64

+ MaxConcurrent int64

+ MaxDepth int

+ MaxRequestSize int64

+ RequestsPerSecond int64

+ ResetTimeout time.Duration

+ func DefaultDOSConfig() *DOSConfig

+ type DOSProtection struct

+ func NewDOSProtection(config *DOSConfig) *DOSProtection

+ func (dp *DOSProtection) CheckRequest(size int64, clientID string) error

+ func (dp *DOSProtection) GetStats() DOSStats

+ func (dp *DOSProtection) ReleaseRequest()

+ func (dp *DOSProtection) ValidateDepth(jsonStr string) error

+ type DOSStats struct

+ CircuitOpen bool

+ CurrentActive int64

+ FailureCount int64

+ MaxConcurrent int64

+ RequestsPerSecond int64

+ type GoroutineManager struct

+ func NewGoroutineManager(maxGoroutines int) *GoroutineManager

+ func (gm *GoroutineManager) GetActiveCount() int64

+ func (gm *GoroutineManager) Go(f func(ctx context.Context)) error

+ func (gm *GoroutineManager) Shutdown(timeout time.Duration) error

+ func (gm *GoroutineManager) Wait()

+ func (gm *GoroutineManager) WaitWithTimeout(timeout time.Duration) bool

+ type MemoryOptimizer struct

+ func NewMemoryOptimizer() *MemoryOptimizer

+ func (mo *MemoryOptimizer) CheckMemoryPressure() bool

+ func (mo *MemoryOptimizer) GetStats() MemoryOptimizerStats

+ func (mo *MemoryOptimizer) OptimizeMemory(force bool)

+ func (mo *MemoryOptimizer) RegisterPool(pool PoolCleaner)

+ type MemoryOptimizerStats struct

+ CurrentMemory int64

+ GCCount int64

+ LastGC int64

+ MemoryThreshold int64

+ NumGoroutines int64

+ SystemMemory int64

+ TotalAllocated int64

+ type OptimizedCache struct

+ func NewOptimizedCache(maxSize int, ttl time.Duration) *OptimizedCache

+ func (c *OptimizedCache) Clear()

+ func (c *OptimizedCache) Get(key uint64) (any, bool)

+ func (c *OptimizedCache) Set(key uint64, value any)

+ func (c *OptimizedCache) Stats() CacheStats

+ type PoolCleaner interface

+ Clean func()

+ type ProcessorEnhancements struct

+ func NewEnhancedProcessor(config *Config, enableDOS bool) *ProcessorEnhancements

+ func (pe *ProcessorEnhancements) Close() error

+ func (pe *ProcessorEnhancements) Delete(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ func (pe *ProcessorEnhancements) Get(jsonStr, path string, opts ...*ProcessorOptions) (any, error)

+ func (pe *ProcessorEnhancements) GetDOSStats() DOSStats

+ func (pe *ProcessorEnhancements) GetProcessor() *Processor

+ func (pe *ProcessorEnhancements) Set(jsonStr, path string, value any, opts ...*ProcessorOptions) (string, error)

+ type SmartCache struct

+ func NewSmartCache(maxSize int, optimizer *MemoryOptimizer) *SmartCache

+ func (sc *SmartCache) Clean()

+ func (sc *SmartCache) Clear()

+ func (sc *SmartCache) Get(key string) (any, bool)

+ func (sc *SmartCache) Set(key string, value any)

+ type StringBuilderPool struct

+ func NewStringBuilderPool(initialCapacity int) *StringBuilderPool

+ func (p *StringBuilderPool) Get() *strings.Builder

+ func (p *StringBuilderPool) Put(sb *strings.Builder)

type TypeSafeResult

+ func (r TypeSafeResult[T]) UnwrapOrPanic() T

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

+ var DeletedMarker = &struct{ ... }

+ var ErrCacheDisabled = errors.New("cache is disabled")

+ var ErrCacheFull = errors.New("cache is full")

+ var ErrCircuitOpen = errors.New("circuit breaker is open")

+ var ErrConcurrencyLimit = errors.New("concurrency limit exceeded")

+ var ErrDeadlockDetected = errors.New("potential deadlock detected")

+ var ErrDepthLimit = errors.New("depth limit exceeded")

+ var ErrIndexOutOfBounds = &ProcessorError

+ var ErrInvalidJSON = errors.New("invalid JSON format")

+ var ErrInvalidJSONNew = &ProcessorError

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

+ var ErrInvalidPathNew = &ProcessorError

+ var ErrOperationFailed = errors.New("operation failed")

+ var ErrOperationTimeout = errors.New("operation timeout")

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

+ var ErrPathNotFoundNew = &ProcessorError

+ var ErrProcessorClosed = errors.New("processor is closed")

+ var ErrRateLimitExceeded = errors.New("rate limit exceeded")

+ var ErrRateLimitNew = &ProcessorError

+ var ErrResourceExhausted = errors.New("system resources exhausted")

+ var ErrSecurityViolation = errors.New("security violation detected")

+ var ErrSizeLimit = errors.New("size limit exceeded")

+ var ErrTimeoutNew = &ProcessorError

+ var ErrTypeConversionNew = &ProcessorError

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

+ var ErrUnsupportedPath = errors.New("unsupported path operation")

+ func ClampIndex(index, length int) int

+ func Compact(dst *bytes.Buffer, src []byte) error

+ func CompareJson(json1, json2 string) (bool, error)

+ func ConvertFromScientific(s string) (string, error)

+ func CreateEmptyContainer(containerType string) any

+ func DeepCopy(data any) (any, error)

+ func Delete(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ func DeleteWithCleanNull(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ func Encode(value any, config ...*EncodeConfig) (string, error)

+ func EncodeCompact(value any, config ...*EncodeConfig) (string, error)

+ func EncodePretty(value any, config ...*EncodeConfig) (string, error)

+ func EscapeJSONPointer(s string) string

+ func Foreach(jsonStr string, callback ForeachCallback, opts ...*ProcessorOptions) error

+ func ForeachNested(jsonStr string, callback ForeachCallback, opts ...*ProcessorOptions) error

+ func ForeachReturn(jsonStr string, callback ForeachCallback, opts ...*ProcessorOptions) (string, error)

+ func ForeachReturnNested(jsonStr string, callback ForeachCallback, opts ...*ProcessorOptions) (string, error)

+ func ForeachWithIterator(jsonStr string, callback ForeachCallbackWithIterator, ...) error

+ func ForeachWithIteratorNested(jsonStr string, callback ForeachCallbackWithIterator, ...) error

+ func ForeachWithPath(jsonStr string, path string, callback ForeachCallback, ...) error

+ func ForeachWithPathNested(jsonStr string, path string, callback ForeachCallback, ...) error

+ func FormatCompact(jsonStr string, opts ...*ProcessorOptions) (string, error)

+ func FormatNumber(value any) string

+ func FormatPretty(jsonStr string, opts ...*ProcessorOptions) (string, error)

+ func Get(jsonStr, path string, opts ...*ProcessorOptions) (any, error)

+ func GetArray(jsonStr, path string, opts ...*ProcessorOptions) ([]any, error)

+ func GetArrayWithDefault(jsonStr, path string, defaultValue []any, opts ...*ProcessorOptions) []any

+ func GetBool(jsonStr, path string, opts ...*ProcessorOptions) (bool, error)

+ func GetBoolWithDefault(jsonStr, path string, defaultValue bool, opts ...*ProcessorOptions) bool

+ func GetContainerSize(data any) int

+ func GetFloat64(jsonStr, path string, opts ...*ProcessorOptions) (float64, error)

+ func GetFloat64WithDefault(jsonStr, path string, defaultValue float64, opts ...*ProcessorOptions) float64

+ func GetInt(jsonStr, path string, opts ...*ProcessorOptions) (int, error)

+ func GetIntWithDefault(jsonStr, path string, defaultValue int, opts ...*ProcessorOptions) int

+ func GetIterableValueWithDefault[T any](iv *IterableValue, path string, defaultValue T) T

+ func GetIterableValue[T any](iv *IterableValue, path string) (T, error)

+ func GetJSONValue[T JSONValue](jsonStr, path string, opts ...*ProcessorOptions) (T, error)

+ func GetMultiple(jsonStr string, paths []string, opts ...*ProcessorOptions) (map[string]any, error)

+ func GetNumeric[T Numeric](jsonStr, path string, opts ...*ProcessorOptions) (T, error)

+ func GetObject(jsonStr, path string, opts ...*ProcessorOptions) (map[string]any, error)

+ func GetObjectWithDefault(jsonStr, path string, defaultValue map[string]any, opts ...*ProcessorOptions) map[string]any

+ func GetOrdered[T Ordered](jsonStr, path string, defaultValue T, opts ...*ProcessorOptions) T

+ func GetString(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ func GetStringWithDefault(jsonStr, path, defaultValue string, opts ...*ProcessorOptions) string

+ func GetTypedWithDefault[T any](jsonStr, path string, defaultValue T, opts ...*ProcessorOptions) T

+ func GetTypedWithProcessor[T any](processor *Processor, jsonStr, path string, opts ...*ProcessorOptions) (T, error)

+ func GetTyped[T any](jsonStr, path string, opts ...*ProcessorOptions) (T, error)

+ func GetWithDefault(jsonStr, path string, defaultValue any, opts ...*ProcessorOptions) any

+ func HTMLEscape(dst *bytes.Buffer, src []byte)

+ func Indent(dst *bytes.Buffer, src []byte, prefix, indent string) error

+ func IsContainer(data any) bool

+ func IsInteger(s string) bool

+ func IsLargeNumber(numStr string) bool

+ func IsNumeric(s string) bool

+ func IsScientificNotation(s string) bool

+ func IsValidIndex(index, length int) bool

+ func IsValidJson(jsonStr string) bool

+ func IsValidPath(path string) bool

+ func LoadFromFile(filename string) (string, error)

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

+ func MarshalIndent(v any, prefix, indent string) ([]byte, error)

+ func MergeJson(json1, json2 string) (string, error)

+ func MustTypeAssert[T any](value any, context string) T

+ func NormalizeIndex(index, length int) int

+ func ParseBool(s string) (bool, error)

+ func ParseFloat(s string) (float64, error)

+ func ParseInt(s string) (int, error)

+ func PreservingUnmarshal(data []byte, v any, preserveNumbers bool) error

+ func SafeConvertToInt64(value any) (int64, error)

+ func SafeConvertToUint64(value any) (uint64, error)

+ func SafeTypeAssert[T any](value any) (T, bool)

+ func SanitizeKey(key string) string

+ func SaveToFile(filePath string, data any, pretty ...bool) error

+ func Set(jsonStr, path string, value any, opts ...*ProcessorOptions) (string, error)

+ func SetGlobalProcessor(processor *Processor)

+ func SetMultiple(jsonStr string, updates map[string]any, opts ...*ProcessorOptions) (string, error)

+ func SetMultipleWithAdd(jsonStr string, updates map[string]any, opts ...*ProcessorOptions) (string, error)

+ func SetWithAdd(jsonStr, path string, value any) (string, error)

+ func ShutdownGlobalProcessor()

+ func SmartNumberConversion(value any) any

+ func TestProcessorResourcePools(processor *Processor) bool

+ func TypeSafeConvert[T any](value any) (T, error)

+ func UnescapeJSONPointer(s string) string

+ func Unmarshal(data []byte, v any) error

+ func Valid(data []byte) bool

+ func ValidateConfig(config *Config) error

+ func ValidateOptions(options *ProcessorOptions) error

+ func ValidatePath(path string) error

+ type ArrayExtensionError struct

+ CurrentLength int

+ ExtendedArray []any

+ Message string

+ RequiredLength int

+ TargetIndex int

+ Value any

+ func (e *ArrayExtensionError) Error() string

+ type ArrayExtensionNeededError struct

+ CurrentLength int

+ End int

+ RequiredLength int

+ Start int

+ Step int

+ Value any

+ func (e *ArrayExtensionNeededError) Error() string

+ type ArrayOperations interface

+ ExtendArray func(arr []any, targetLength int) []any

+ HandleArrayAccess func(data any, index int) NavigationResult

+ HandleArraySlice func(data any, start, end, step int) NavigationResult

+ HandleNegativeIndex func(index, length int) int

+ ParseArrayIndex func(indexStr string) int

+ SetArrayElement func(arr []any, index int, value any) error

+ ValidateArrayBounds func(index, length int) bool

+ func NewArrayOperations(utils ProcessorUtils) ArrayOperations

+ type BatchOperation struct

+ ID string

+ JSONStr string

+ Path string

+ Type string

+ Value any

+ type BatchResult struct

+ Error error

+ ID string

+ Result any

+ type BenchmarkHelper struct

+ func NewBenchmarkHelper(b *testing.B) *BenchmarkHelper

+ func (bh *BenchmarkHelper) MeasureMemory(fn func())

+ type CacheKey struct

+ JSONStr string

+ Operation string

+ Options string

+ Path string

+ type CacheStats struct

+ Evictions int64

+ HitCount int64

+ HitRatio float64

+ MemoryEfficiency float64

+ MissCount int64

+ ShardCount int

+ ShardStats []ShardStats

+ TotalMemory int64

+ type CheckResult struct

+ Healthy bool

+ Message string

+ type ComplexDeleteProcessor struct

+ func NewComplexDeleteProcessor(p *Processor) *ComplexDeleteProcessor

+ func (cdp *ComplexDeleteProcessor) DeleteWithReverseMapping(data any, path string) error

+ type ConcurrencyManager struct

+ func NewConcurrencyManager(maxConcurrency int, operationsPerSecond int) *ConcurrencyManager

+ func (cm *ConcurrencyManager) DetectDeadlocks() []DeadlockInfo

+ func (cm *ConcurrencyManager) ExecuteWithConcurrencyControl(ctx context.Context, operation func() error, timeout time.Duration) error

+ func (cm *ConcurrencyManager) GetStats() ConcurrencyStats

+ type ConcurrencyStats struct

+ AverageWaitTime time.Duration

+ CircuitOpen bool

+ CurrentOperations int64

+ FailureCount int64

+ MaxConcurrency int

+ OperationsPerSecond int64

+ TotalOperations int64

+ type ConcurrencyTester struct

+ func NewConcurrencyTester(t *testing.T, concurrency, iterations int) *ConcurrencyTester

+ func (ct *ConcurrencyTester) Run(operation func(workerID, iteration int) error)

+ type Config struct

+ AllowCommentsFlag bool

+ CacheTTL time.Duration

+ CleanupNulls bool

+ CompactArrays bool

+ CreatePaths bool

+ EnableCache bool

+ EnableHealthCheck bool

+ EnableMetrics bool

+ EnableRateLimit bool

+ EnableResourcePools bool

+ EnableValidation bool

+ MaxArrayElements int

+ MaxBatchSize int

+ MaxCacheSize int

+ MaxConcurrency int

+ MaxJSONSize int64

+ MaxNestingDepth int

+ MaxNestingDepthSecurity int

+ MaxObjectKeys int

+ MaxPathDepth int

+ MaxPoolSize int

+ MaxSecurityValidationSize int64

+ ParallelThreshold int

+ PoolCleanupInterval time.Duration

+ PreserveNumbersFlag bool

+ RateLimitPerSec int

+ StrictMode bool

+ ValidateFilePath bool

+ ValidateInput bool

+ func DefaultConfig() *Config

+ func HighSecurityConfig() *Config

+ func LargeDataConfig() *Config

+ func (c *Config) AllowComments() bool

+ func (c *Config) AreResourcePoolsEnabled() bool

+ func (c *Config) GetCacheTTL() time.Duration

+ func (c *Config) GetMaxCacheSize() int

+ func (c *Config) GetMaxConcurrency() int

+ func (c *Config) GetMaxJSONSize() int64

+ func (c *Config) GetMaxNestingDepth() int

+ func (c *Config) GetMaxPathDepth() int

+ func (c *Config) GetMaxPoolSize() int

+ func (c *Config) GetPoolCleanupInterval() time.Duration

+ func (c *Config) GetRateLimitPerSec() int

+ func (c *Config) GetSecurityLimits() map[string]interface{}

+ func (c *Config) IsCacheEnabled() bool

+ func (c *Config) IsHealthCheckEnabled() bool

+ func (c *Config) IsMetricsEnabled() bool

+ func (c *Config) IsRateLimitEnabled() bool

+ func (c *Config) IsStrictMode() bool

+ func (c *Config) PreserveNumbers() bool

+ func (c *Config) ShouldCleanupNulls() bool

+ func (c *Config) ShouldCompactArrays() bool

+ func (c *Config) ShouldCreatePaths() bool

+ func (c *Config) ShouldValidateFilePath() bool

+ func (c *Config) ShouldValidateInput() bool

+ type ConsecutiveExtractionGroup struct

+ EndIndex int

+ Segments []PathSegment

+ StartIndex int

+ type CustomEncoder struct

+ func NewCustomEncoder(config *EncodeConfig) *CustomEncoder

+ func (e *CustomEncoder) Close()

+ func (e *CustomEncoder) Encode(value any) (string, error)

+ type DeadlockInfo struct

+ Duration time.Duration

+ GoroutineID uint64

+ StartTime time.Time

+ type Decoder struct

+ func NewDecoder(r io.Reader) *Decoder

+ func (dec *Decoder) Buffered() io.Reader

+ func (dec *Decoder) Decode(v any) error

+ func (dec *Decoder) DisallowUnknownFields()

+ func (dec *Decoder) InputOffset() int64

+ func (dec *Decoder) More() bool

+ func (dec *Decoder) Token() (Token, error)

+ func (dec *Decoder) UseNumber()

+ type DeepExtractionResult struct

+ Paths []string

+ Values []any

+ type DeleteOperations interface

+ CleanupDeletedValues func(data any) any

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

+ DeleteValue func(data any, path string) error

+ DeleteValueWithSegments func(data any, segments []PathSegmentInfo) error

+ MarkForDeletion func(data any, path string) error

+ func NewDeleteOperations(utils ProcessorUtils, pathParser PathParser, navigator Navigator, ...) DeleteOperations

+ type DeletionTarget struct

+ Container any

+ Key any

+ Path string

+ type Delim rune

+ func (d Delim) String() string

+ type DetailedStats struct

+ Stats Stats

+ type EncodeConfig struct

+ CustomEscapes map[rune]string

+ DisableEscaping bool

+ DisallowUnknown bool

+ EscapeHTML bool

+ EscapeNewlines bool

+ EscapeSlash bool

+ EscapeTabs bool

+ EscapeUnicode bool

+ FloatPrecision int

+ IncludeNulls bool

+ Indent string

+ MaxDepth int

+ OmitEmpty bool

+ Prefix string

+ PreserveNumbers bool

+ Pretty bool

+ SortKeys bool

+ ValidateUTF8 bool

+ func DefaultEncodeConfig() *EncodeConfig

+ func NewCleanConfig() *EncodeConfig

+ func NewCompactConfig() *EncodeConfig

+ func NewPrettyConfig() *EncodeConfig

+ func NewReadableConfig() *EncodeConfig

+ func NewWebSafeConfig() *EncodeConfig

+ func (c *EncodeConfig) Clone() *EncodeConfig

+ type Encoder struct

+ func NewEncoder(w io.Writer) *Encoder

+ func (enc *Encoder) Encode(v any) error

+ func (enc *Encoder) SetEscapeHTML(on bool)

+ func (enc *Encoder) SetIndent(prefix, indent string)

+ type ErrorType int

+ const ErrTypeBoundary

+ const ErrTypeConversion

+ const ErrTypeNavigation

+ const ErrTypeRateLimit

+ const ErrTypeTimeout

+ const ErrTypeValidation

+ type ExtractionContext struct

+ ArrayFieldName string

+ OperationType string

+ OriginalContainers []any

+ TargetIndices []int

+ type ExtractionOperations interface

+ CountExtractions func(path string) int

+ DetectConsecutiveExtractions func(segments []PathSegmentInfo) [][]PathSegmentInfo

+ ExtractFromArray func(arr []any, key string) []any

+ ExtractFromObject func(obj map[string]any, key string) (any, bool)

+ ExtractMultipleKeys func(data any, keys []string) (map[string]any, error)

+ FilterExtractionResults func(data any, predicate func(any) bool) []any

+ FlattenExtractionResults func(data any) []any

+ HandleConsecutiveExtractions func(data any, segments []PathSegmentInfo) (any, error)

+ HandleDeepExtraction func(data any, keys []string) (any, error)

+ HandleExtraction func(data any, key string) (any, error)

+ HandleMixedExtractionOperations func(data any, segments []PathSegmentInfo) (any, error)

+ IsExtractionPath func(path string) bool

+ ValidateExtractionSyntax func(path string) error

+ func NewExtractionOperations(utils ProcessorUtils) ExtractionOperations

+ type Float interface

+ type ForeachCallback func(key any, value *IterableValue)

+ type ForeachCallbackWithIterator func(key, value any, it *Iterator)

+ type HealthStatus struct

+ Checks map[string]CheckResult

+ Healthy bool

+ Timestamp time.Time

+ type InvalidUnmarshalError struct

+ Type reflect.Type

+ func (e *InvalidUnmarshalError) Error() string

+ type IterableValue struct

+ func NewIterableValue(data any, processor *Processor) *IterableValue

+ func NewIterableValueWithIterator(data any, processor *Processor, iterator *Iterator) *IterableValue

+ func (iv *IterableValue) Break()

+ func (iv *IterableValue) Continue()

+ func (iv *IterableValue) Delete(path string) error

+ func (iv *IterableValue) DeleteWithValidation(path string) error

+ func (iv *IterableValue) Exists(path string) bool

+ func (iv *IterableValue) ForeachNested(path string, callback ForeachCallback, opts ...*ProcessorOptions) error

+ func (iv *IterableValue) ForeachReturnNested(path string, callback ForeachCallback, opts ...*ProcessorOptions) error

+ func (iv *IterableValue) Get(path string) any

+ func (iv *IterableValue) GetArray(path string) []any

+ func (iv *IterableValue) GetArrayWithDefault(path string, defaultValue []any) []any

+ func (iv *IterableValue) GetBool(path string) bool

+ func (iv *IterableValue) GetBoolWithDefault(path string, defaultValue bool) bool

+ func (iv *IterableValue) GetFloat64(path string) float64

+ func (iv *IterableValue) GetFloat64WithDefault(path string, defaultValue float64) float64

+ func (iv *IterableValue) GetInt(path string) int

+ func (iv *IterableValue) GetInt64(path string) int64

+ func (iv *IterableValue) GetInt64WithDefault(path string, defaultValue int64) int64

+ func (iv *IterableValue) GetIntWithDefault(path string, defaultValue int) int

+ func (iv *IterableValue) GetObject(path string) map[string]any

+ func (iv *IterableValue) GetObjectWithDefault(path string, defaultValue map[string]any) map[string]any

+ func (iv *IterableValue) GetString(path string) string

+ func (iv *IterableValue) GetStringWithDefault(path, defaultValue string) string

+ func (iv *IterableValue) GetWithDefault(path string, defaultValue any) any

+ func (iv *IterableValue) IsEmpty(path string) bool

+ func (iv *IterableValue) IsNull(path string) bool

+ func (iv *IterableValue) Keys(path string) []string

+ func (iv *IterableValue) Length(path string) int

+ func (iv *IterableValue) Set(path string, value any) error

+ func (iv *IterableValue) SetMultiple(updates map[string]any) error

+ func (iv *IterableValue) SetWithAdd(path string, value any) error

+ func (iv *IterableValue) String() string

+ func (iv *IterableValue) Values(path string) []any

+ type Iterator struct

+ func NewIterator(processor *Processor, data any, opts *ProcessorOptions) *Iterator

+ func (it *Iterator) Break()

+ func (it *Iterator) Continue()

+ func (it *Iterator) Delete(path string) error

+ func (it *Iterator) Get(path string) (any, error)

+ func (it *Iterator) GetCurrentKey() any

+ func (it *Iterator) GetCurrentPath() string

+ func (it *Iterator) GetCurrentValue() any

+ func (it *Iterator) Set(path string, value any) error

+ type IteratorControl int

+ const IteratorBreak

+ const IteratorContinue

+ const IteratorNormal

+ type IteratorControlSignal struct

+ Type IteratorControl

+ func (ics IteratorControlSignal) Error() string

+ type JSONValue interface

+ type JsonsError struct

+ Context map[string]any

+ Err error

+ ErrorCode string

+ Message string

+ Op string

+ Path string

+ Suggestions []string

+ func (e *JsonsError) Error() string

+ func (e *JsonsError) ErrorWithSuggestion() string

+ func (e *JsonsError) GetDetailedInfo() map[string]any

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

+ func (e *JsonsError) Unwrap() error

+ func (e *JsonsError) WithContext(key string, value any) *JsonsError

+ func (e *JsonsError) WithErrorCode(code string) *JsonsError

+ func (e *JsonsError) WithSuggestion(suggestion string) *JsonsError

+ type Marshaler interface

+ MarshalJSON func() ([]byte, error)

+ type MarshalerError struct

+ Err error

+ Type reflect.Type

+ func (e *MarshalerError) Error() string

+ func (e *MarshalerError) Unwrap() error

+ type MemoryTracker struct

+ func NewMemoryTracker(name string) *MemoryTracker

+ func (mt *MemoryTracker) Report(t *testing.T)

+ type MetricsCollector interface

+ EndConcurrentOperation func()

+ GetStats func() map[string]any

+ RecordCacheHit func()

+ RecordCacheMiss func()

+ RecordOperation func(duration time.Duration, success bool, cacheHit int)

+ StartConcurrentOperation func()

+ type ModularProcessor interface

+ BatchProcess func(operations []BatchOperation, opts ...*ProcessorOptions) ([]BatchResult, error)

+ Close func() error

+ Delete func(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ Get func(jsonStr, path string, opts ...*ProcessorOptions) (any, error)

+ GetConfig func() *ProcessorConfig

+ GetMultiple func(jsonStr string, paths []string, opts ...*ProcessorOptions) (map[string]any, error)

+ IsClosed func() bool

+ Set func(jsonStr, path string, value any, opts ...*ProcessorOptions) (string, error)

+ SetConfig func(config *ProcessorConfig)

+ Valid func(jsonStr string, opts ...*ProcessorOptions) (bool, error)

+ func NewModularProcessor(config *ProcessorConfig) ModularProcessor

+ type NavigationResult struct

+ Error error

+ Exists bool

+ Value any

+ type Navigator interface

+ HandlePropertyAccess func(data any, property string) NavigationResult

+ NavigateToPath func(data any, segments []PathSegmentInfo) (any, error)

+ NavigateToSegment func(data any, segment PathSegmentInfo) (NavigationResult, error)

+ func NewNavigator(pathParser PathParser, utils ProcessorUtils) Navigator

+ type Number string

+ func (n Number) Float64() (float64, error)

+ func (n Number) Int64() (int64, error)

+ func (n Number) String() string

+ type NumberPreservingDecoder struct

+ func NewNumberPreservingDecoder(preserveNumbers bool) *NumberPreservingDecoder

+ func (d *NumberPreservingDecoder) DecodeToAny(jsonStr string) (any, error)

+ type NumberPreservingValue struct

+ Original string

+ Value any

+ func (npv NumberPreservingValue) IsNumber() bool

+ func (npv NumberPreservingValue) String() string

+ func (npv NumberPreservingValue) ToFloat64() (float64, error)

+ func (npv NumberPreservingValue) ToInt() (int, error)

+ type Numeric interface

+ type Operation int

+ const OpDelete

+ const OpGet

+ const OpSet

+ const OpValidate

+ func (op Operation) String() string

+ type OperationContext struct

+ Context context.Context

+ CreatePaths bool

+ Operation Operation

+ Options *ProcessorOptions

+ Path string

+ StartTime time.Time

+ Value any

+ type Ordered interface

+ type PathInfo struct

+ IsPointer bool

+ OriginalPath string

+ Segments []PathSegment

+ type PathParser interface

+ NeedsLegacyHandling func(path string) bool

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

+ PreprocessPath func(path string) string

+ SplitPathIntoSegments func(path string) []PathSegmentInfo

+ ValidatePath func(path string) error

+ func NewPathParser() PathParser

+ type PathSegment = internal.PathSegment

+ type PathSegmentInfo struct

+ End *int

+ Extract string

+ Index int

+ IsFlat bool

+ Key string

+ Start *int

+ Step *int

+ Type string

+ Value string

+ type Processor struct

+ func New(config ...*Config) *Processor

+ func (p *Processor) ClearCache()

+ func (p *Processor) Close() error

+ func (p *Processor) Compact(jsonStr string, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) Delete(jsonStr, path string, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) EncodeBatch(pairs map[string]any, pretty bool, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) EncodeFields(value any, fields []string, pretty bool, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) EncodeStream(values any, pretty bool, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) EncodeStreamWithOptions(values any, encOpts *EncodeConfig, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) EncodeWithConfig(value any, config *EncodeConfig, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) EncodeWithOptions(value any, encOpts *EncodeConfig, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) EncodeWithTags(value any, pretty bool, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) Foreach(jsonStr string, callback ForeachCallback, opts ...*ProcessorOptions) error

+ func (p *Processor) ForeachReturn(jsonStr string, callback ForeachCallback, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) ForeachWithIterator(jsonStr string, callback ForeachCallbackWithIterator, ...) error

+ func (p *Processor) ForeachWithPath(jsonStr string, path string, callback ForeachCallback, ...) error

+ func (p *Processor) FormatPretty(jsonStr string, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) Get(jsonStr, path string, opts ...*ProcessorOptions) (any, error)

+ func (p *Processor) GetConfig() *Config

+ func (p *Processor) GetHealthStatus() HealthStatus

+ func (p *Processor) GetMultiple(jsonStr string, paths []string, opts ...*ProcessorOptions) (map[string]any, error)

+ func (p *Processor) GetStats() Stats

+ func (p *Processor) IsClosed() bool

+ func (p *Processor) LoadFromFile(filePath string, opts ...*ProcessorOptions) (any, error)

+ func (p *Processor) LoadFromReader(reader io.Reader, opts ...*ProcessorOptions) (any, error)

+ func (p *Processor) Marshal(value any, opts ...*ProcessorOptions) ([]byte, error)

+ func (p *Processor) MarshalIndent(value any, prefix, indent string, opts ...*ProcessorOptions) ([]byte, error)

+ func (p *Processor) Parse(jsonStr string, target any, opts ...*ProcessorOptions) error

+ func (p *Processor) ProcessBatch(operations []BatchOperation, opts ...*ProcessorOptions) ([]BatchResult, error)

+ func (p *Processor) SafeGet(jsonStr, path string) TypeSafeAccessResult

+ func (p *Processor) SaveToFile(filePath string, data any, pretty ...bool) error

+ func (p *Processor) SaveToWriter(writer io.Writer, data any, pretty bool, opts ...*ProcessorOptions) error

+ func (p *Processor) Set(jsonStr, path string, value any, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) SetLogger(logger *slog.Logger)

+ func (p *Processor) SetMultiple(jsonStr string, updates map[string]any, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) ToJsonString(value any, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) ToJsonStringPretty(value any, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) ToJsonStringStandard(value any, opts ...*ProcessorOptions) (string, error)

+ func (p *Processor) Unmarshal(data []byte, v any, opts ...*ProcessorOptions) error

+ func (p *Processor) Valid(jsonStr string, opts ...*ProcessorOptions) (bool, error)

+ func (p *Processor) ValidateSchema(jsonStr string, schema *Schema, opts ...*ProcessorOptions) ([]ValidationError, error)

+ func (p *Processor) WarmupCache(jsonStr string, paths []string, opts ...*ProcessorOptions) (*WarmupResult, error)

+ type ProcessorCache interface

+ Clear func()

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

+ Set func(key CacheKey, value any, ttl time.Duration)

+ Size func() int

+ type ProcessorConfig struct

+ EnableCache bool

+ EnableMetrics bool

+ MaxConcurrency int

+ MaxDepth int

+ MaxPathLength int

+ RateLimitEnabled bool

+ RateLimitRPS int

+ Timeout time.Duration

+ func DefaultProcessorConfig() *ProcessorConfig

+ type ProcessorError struct

+ Cause error

+ Message string

+ Operation string

+ Path string

+ Type ErrorType

+ func (e *ProcessorError) Error() string

+ func (e *ProcessorError) Unwrap() error

+ type ProcessorMetrics struct

+ ActiveConcurrentOps int64

+ AverageProcessingTime time.Duration

+ CacheHitRate float64

+ CacheHits int64

+ CacheMisses int64

+ CurrentMemoryUsage int64

+ FailedOperations int64

+ MaxConcurrentOps int64

+ MaxProcessingTime time.Duration

+ MinProcessingTime time.Duration

+ PeakMemoryUsage int64

+ SuccessRate float64

+ SuccessfulOperations int64

+ TotalMemoryAllocated int64

+ TotalOperations int64

+ type ProcessorOptions struct

+ AllowComments bool

+ CacheResults bool

+ CleanupNulls bool

+ CompactArrays bool

+ Context context.Context

+ ContinueOnError bool

+ CreatePaths bool

+ MaxDepth int

+ PreserveNumbers bool

+ StrictMode bool

+ func DefaultOptions() *ProcessorOptions

+ func (opts *ProcessorOptions) Clone() *ProcessorOptions

+ type ProcessorUtils interface

+ ConvertToArray func(data any) ([]any, bool)

+ ConvertToMap func(data any) (map[string]any, bool)

+ ConvertToNumber func(value any) (float64, error)

+ ConvertToString func(value any) string

+ DeepCopy func(data any) (any, error)

+ GetDataType func(data any) string

+ IsArrayType func(data any) bool

+ IsEmptyContainer func(data any) bool

+ IsObjectType func(data any) bool

+ func NewProcessorUtils() ProcessorUtils

+ type PropertyAccessResult struct

+ Exists bool

+ Value any

+ type RateLimiter interface

+ Allow func() bool

+ Limit func() int

+ Wait func(ctx context.Context) error

+ type RecursiveProcessor struct

+ func NewRecursiveProcessor(p *Processor) *RecursiveProcessor

+ func (urp *RecursiveProcessor) ProcessRecursively(data any, path string, operation Operation, value any) (any, error)

+ func (urp *RecursiveProcessor) ProcessRecursivelyWithOptions(data any, path string, operation Operation, value any, createPaths bool) (any, error)

+ type ResourceMonitor struct

+ func NewResourceMonitor() *ResourceMonitor

+ func (rm *ResourceMonitor) CheckForLeaks() []string

+ func (rm *ResourceMonitor) GetMemoryEfficiency() float64

+ func (rm *ResourceMonitor) GetPoolEfficiency() float64

+ func (rm *ResourceMonitor) GetStats() ResourceStats

+ func (rm *ResourceMonitor) RecordAllocation(bytes int64)

+ func (rm *ResourceMonitor) RecordDeallocation(bytes int64)

+ func (rm *ResourceMonitor) RecordOperation(duration time.Duration)

+ func (rm *ResourceMonitor) RecordPoolEviction()

+ func (rm *ResourceMonitor) RecordPoolHit()

+ func (rm *ResourceMonitor) RecordPoolMiss()

+ func (rm *ResourceMonitor) Reset()

+ type ResourcePoolStats struct

+ PathSegmentPoolActive bool

+ StringBuilderPoolActive bool

+ type ResourceStats struct

+ AllocatedBytes int64

+ AvgResponseTime time.Duration

+ CurrentGoroutines int64

+ FreedBytes int64

+ MaxGoroutines int64

+ PeakMemoryUsage int64

+ PoolEvictions int64

+ PoolHits int64

+ PoolMisses int64

+ TotalOperations int64

+ type RootDataTypeConversionError struct

+ CurrentType string

+ RequiredSize int

+ RequiredType string

+ func (e *RootDataTypeConversionError) Error() string

+ type Schema struct

+ AdditionalProperties bool

+ Const any

+ Default any

+ Description string

+ Enum []any

+ Examples []any

+ ExclusiveMaximum bool

+ ExclusiveMinimum bool

+ Format string

+ Items *Schema

+ MaxItems int

+ MaxLength int

+ Maximum float64

+ MinItems int

+ MinLength int

+ Minimum float64

+ MultipleOf float64

+ Pattern string

+ Properties map[string]*Schema

+ Required []string

+ Title string

+ Type string

+ UniqueItems bool

+ func DefaultSchema() *Schema

+ func (s *Schema) HasMaxItems() bool

+ func (s *Schema) HasMaxLength() bool

+ func (s *Schema) HasMaximum() bool

+ func (s *Schema) HasMinItems() bool

+ func (s *Schema) HasMinLength() bool

+ func (s *Schema) HasMinimum() bool

+ func (s *Schema) SetExclusiveMaximum(exclusive bool) *Schema

+ func (s *Schema) SetExclusiveMinimum(exclusive bool) *Schema

+ func (s *Schema) SetMaxItems(maxItems int) *Schema

+ func (s *Schema) SetMaxLength(maxLength int) *Schema

+ func (s *Schema) SetMaximum(maximum float64) *Schema

+ func (s *Schema) SetMinItems(minItems int) *Schema

+ func (s *Schema) SetMinLength(minLength int) *Schema

+ func (s *Schema) SetMinimum(minimum float64) *Schema

+ type SetOperations interface

+ CreatePath func(data any, segments []PathSegmentInfo) error

+ HandleTypeConversion func(data any, requiredType string) (any, error)

+ SetValue func(data any, path string, value any, createPaths bool) error

+ SetValueWithSegments func(data any, segments []PathSegmentInfo, value any, createPaths bool) error

+ func NewSetOperations(utils ProcessorUtils, pathParser PathParser, navigator Navigator, ...) SetOperations

+ type ShardStats struct

+ Memory int64

+ Size int64

+ type Signed interface

+ type Stats struct

+ CacheEnabled bool

+ CacheMemory int64

+ CacheSize int64

+ CacheTTL time.Duration

+ ErrorCount int64

+ HitCount int64

+ HitRatio float64

+ IsClosed bool

+ MaxCacheSize int

+ MemoryEfficiency float64

+ MissCount int64

+ OperationCount int64

+ type SyntaxError struct

+ Offset int64

+ func (e *SyntaxError) Error() string

+ type TestDataGenerator struct

+ func NewTestDataGenerator() *TestDataGenerator

+ func (g *TestDataGenerator) GenerateArrayJSON() string

+ func (g *TestDataGenerator) GenerateComplexJSON() string

+ func (g *TestDataGenerator) GenerateInvalidJSON() []string

+ func (g *TestDataGenerator) GenerateSimpleJSON() string

+ type TestHelper struct

+ func NewTestHelper(t *testing.T) *TestHelper

+ func (h *TestHelper) AssertEqual(expected, actual any, msgAndArgs ...any)

+ func (h *TestHelper) AssertError(err error, msgAndArgs ...any)

+ func (h *TestHelper) AssertErrorContains(err error, contains string, msgAndArgs ...any)

+ func (h *TestHelper) AssertFalse(condition bool, msgAndArgs ...any)

+ func (h *TestHelper) AssertNil(value any, msgAndArgs ...any)

+ func (h *TestHelper) AssertNoError(err error, msgAndArgs ...any)

+ func (h *TestHelper) AssertNoPanic(fn func(), msgAndArgs ...any)

+ func (h *TestHelper) AssertNotEqual(expected, actual any, msgAndArgs ...any)

+ func (h *TestHelper) AssertNotNil(value any, msgAndArgs ...any)

+ func (h *TestHelper) AssertPanic(fn func(), msgAndArgs ...any)

+ func (h *TestHelper) AssertTrue(condition bool, msgAndArgs ...any)

+ type TextMarshaler interface

+ MarshalText func() (text []byte, err error)

+ type TextUnmarshaler interface

+ UnmarshalText func(text []byte) error

+ type Token any

+ type TypeSafeAccessResult struct

+ Exists bool

+ Type string

+ Value any

+ func (r TypeSafeAccessResult) AsBool() (bool, error)

+ func (r TypeSafeAccessResult) AsInt() (int, error)

+ func (r TypeSafeAccessResult) AsString() (string, error)

+ type TypeSafeResult struct

+ Error error

+ Exists bool

+ Value T

+ func SafeGetTypedWithProcessor[T any](p *Processor, jsonStr, path string) TypeSafeResult[T]

+ func (r TypeSafeResult[T]) Ok() bool

+ func (r TypeSafeResult[T]) Unwrap() T

+ func (r TypeSafeResult[T]) UnwrapOr(defaultValue T) T

+ type UnmarshalTypeError struct

+ Err error

+ Field string

+ Offset int64

+ Struct string

+ Type reflect.Type

+ Value string

+ func (e *UnmarshalTypeError) Error() string

+ func (e *UnmarshalTypeError) Unwrap() error

+ type Unmarshaler interface

+ UnmarshalJSON func([]byte) error

+ type Unsigned interface

+ type UnsupportedTypeError struct

+ Type reflect.Type

+ func (e *UnsupportedTypeError) Error() string

+ type UnsupportedValueError struct

+ Str string

+ Value reflect.Value

+ func (e *UnsupportedValueError) Error() string

+ type ValidationError struct

+ Message string

+ Path string

+ func ValidateSchema(jsonStr string, schema *Schema, opts ...*ProcessorOptions) ([]ValidationError, error)

+ func (ve *ValidationError) Error() string

+ type WarmupResult struct

+ Failed int

+ FailedPaths []string

+ SuccessRate float64

+ Successful int

+ TotalPaths int

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