model

Sep 21, 2025

Changes in this version

+ var ErrCacheRuleNotFound = errors.New("cache rule not found")

+ func IsCacheRuleNotFoundErr(err error) bool

+ func MatchCacheRule(cfg config.Config, path []byte) (*config.Rule, error)

type CacheItem

+ CacheRule func() *config.Rule

type Entry

+ func FromBytes(data []byte, cfg config.Config) (*Entry, error)

+ func (e *Entry) CacheRule() *config.Rule

+ func (e *Entry) ToMap() map[string]any

+ func (e *Entry) UntouchRefreshedAt()

Sep 18, 2025

Changes in this version

type CacheItem

+ FreshAt func() int64

+ IsProbablyExpired func(cfg config.Config) bool

type Entry

+ func (e *Entry) FreshAt() int64

+ func (e *Entry) IsExpired(cfg config.Config) (must bool)

+ func (e *Entry) IsProbablyExpired(cfg config.Config) bool

Sep 12, 2025

Changes in this version

+ var ErrCorruptedQueriesSection = errors.New("corrupted queries section")

+ var ErrCorruptedRequestHeadersSection = errors.New("corrupted request headers section")

+ var ErrCorruptedResponseBodySection = errors.New("corrupted response body section")

+ var ErrCorruptedResponseHeadersSection = errors.New("corrupted response headers section")

+ var ErrCorruptedStatusCodeSection = errors.New("corrupted status code section")

+ var ErrMalformedOrNilPayload = errors.New("malformed or nil payload")

type CacheItem

+ ClearRefreshQueued func()

+ IsTheSamePayload func(another *Entry) bool

+ Key func() uint64

+ RequestPayload func() (queries, headers *[][2][]byte, releaser RequestDecoderReleaser, err error)

+ ResponsePayload func() (headers *[][2][]byte, body []byte, code int, releaser ResponseDecoderReleaser, ...)

+ type DecoderReleaser func(queries, requestHeaders, responseHeaders *[][2][]byte)

type Entry

+ func NewMockEntryWithPayload(req *fasthttp.Request, resp *fasthttp.Response) (*Entry, error)

+ func (e *Entry) ClearRefreshQueued()

+ func (e *Entry) IsTheSameFingerprint(in *Entry) bool

+ func (e *Entry) IsTheSamePayload(another *Entry) bool

+ func (e *Entry) Key() uint64

+ func (e *Entry) RequestPayload() (queries, headers *[][2][]byte, releaser RequestDecoderReleaser, err error)

+ func (e *Entry) ResponsePayload() (headers *[][2][]byte, body []byte, code int, releaser ResponseDecoderReleaser, ...)

+ func (e *Entry) TryMarkRefreshQueued() bool

+ func (e *Entry) UnTouchRefreshedAt()

+ func (e *Entry) UnpackOffsets(data []byte) (queriesOffset, reqHdrsOffset, statusOffset, rspHdrsOffset, bodyOffset int)

+ func (e *Entry) WalkQuery(fn func(key, value []byte) bool) error

+ type RequestDecoderReleaser func(queries, headers *[][2][]byte)

+ type ResponseDecoderReleaser func(headers *[][2][]byte)

Aug 26, 2025

Changes in this version

type CacheItem

+ Touch func()

+ TouchRefreshedAt func()

+ TouchedAt func() int64

type Entry

+ func (e *Entry) Touch()

+ func (e *Entry) TouchRefreshedAt()

+ func (e *Entry) TouchedAt() int64

Aug 21, 2025

Changes in this version

+ var ErrMalformedPayload = errors.New("malformed payload")

type Entry

+ func (e *Entry) Detach()

+ func (e *Entry) ReleasePayload()

Aug 15, 2025

Changes in this version

+ func WetherAnErrIsTheRuleNotFound(err error) bool

+ type CacheItem interface

+ Fingerprint func() [16]byte

+ IsSameFingerprint func(another [16]byte) bool

+ IsSamePayload func(another *Entry) bool

+ LruListElement func() *list.Element[*Entry]

+ MapKey func() uint64

+ Payload func() (req *fasthttp.Request, resp *fasthttp.Response, releaser Releaser, err error)

+ RefreshedAt func() int64

+ Rule func() *config.Rule

+ SetLruListElement func(el *list.Element[*Entry])

+ SetPayload func(req *fasthttp.Request, resp *fasthttp.Response) *Entry

+ ShardKey func() uint64

+ ShouldBeRefreshed func(cfg config.Config) bool

+ SwapPayloads func(another *Entry)

+ ToBytes func() (data []byte, releaseFn func())

+ Weight func() int64

type Entry

+ func NewEntry(cfg config.Config, r *fasthttp.RequestCtx) (*Entry, error)

+ func NewEntryWithPayload(cfg config.Config, req *fasthttp.Request, resp *fasthttp.Response) (*Entry, error)

+ func (e *Entry) RefreshedAt() int64

+ func (e *Entry) SetMapKeyForTests(key uint64) *Entry

Aug 13, 2025

Changes in this version

+ var ErrPayloadIsEmpty = fmt.Errorf("payload is empty")

type Entry

+ func NewMockEntry(cfg config.Config, req *fasthttp.Request, resp *fasthttp.Response) (*Entry, error)

Jul 31, 2025

Changes in this version

+ func IsRouteWasNotFound(err error) bool

type Entry

+ func (e *Entry) DumpBuffer(r *fasthttp.RequestCtx)

+ func (e *Entry) IsSamePayload(another *Entry) bool

+ func (e *Entry) SwapPayloads(another *Entry)

+ func (e *Entry) TouchUpdatedAt()

Jul 23, 2025

Changes in this version

type Entry

+ func (e *Entry) UpdateAt() int64

Jul 21, 2025

Changes in this version

type Entry

+ func (e *Entry) Acquire(expectedVersion uint64) bool

+ func (e *Entry) IsSameEntry(another *Entry) bool

+ func (e *Entry) Remove()

+ func (e *Entry) Version() uint64

+ type VersionPointer struct

+ func NewVersionPointer(entry *Entry) *VersionPointer

+ func (v *VersionPointer) Acquire() bool

+ func (v *VersionPointer) ShouldBeRefreshed(cfg *config.Cache) bool

+ func (v *VersionPointer) Version() uint64

Jul 14, 2025

Changes in this version

+ var EntriesPool = sync.Pool

+ func MatchRule(cfg *config.Cache, path []byte) *config.Rule

+ func MatchRuleStr(cfg *config.Cache, path string) *config.Rule

+ func NewEntryFastHttp(cfg *config.Cache, r *fasthttp.RequestCtx) (*Entry, Releaser, error)

+ func NewEntryManual(cfg *config.Cache, path, query []byte, headers [][2][]byte, ...) (*Entry, Releaser, error)

+ func NewEntryNetHttp(cfg *config.Cache, r *http.Request) (*Entry, Releaser, error)

+ type Entry struct

+ func EntryFromBytes(data []byte, cfg *config.Cache, backend repository.Backender) (*Entry, error)

+ func NewEntryFromField(key uint64, shard uint64, fingerprint [16]byte, payload []byte, ...) *Entry

+ func (e *Entry) DumpPayload()

+ func (e *Entry) Fingerprint() [16]byte

+ func (e *Entry) GetFilteredAndSortedKeyHeadersNetHttp(r *http.Request) (kvPairs [][2][]byte, releaseFn func())

+ func (e *Entry) GetFilteredAndSortedKeyQueriesNetHttp(r *http.Request) (kvPairs [][2][]byte, releaseFn func())

+ func (e *Entry) Init() *Entry

+ func (e *Entry) IsCompressed() bool

+ func (e *Entry) IsSame(another *Entry) bool

+ func (e *Entry) IsSameFingerprint(another [16]byte) bool

+ func (e *Entry) LruListElement() *list.Element[*Entry]

+ func (e *Entry) MapKey() uint64

+ func (e *Entry) Payload() (path []byte, query []byte, queryHeaders [][2][]byte, ...)

+ func (e *Entry) PayloadBytes() []byte

+ func (e *Entry) Release()

+ func (e *Entry) Revalidate() error

+ func (e *Entry) Rule() *config.Rule

+ func (e *Entry) SetLruListElement(el *list.Element[*Entry])

+ func (e *Entry) SetMapKey(key uint64) *Entry

+ func (e *Entry) SetPayload(path, query []byte, queryHeaders [][2][]byte, headers [][2][]byte, body []byte, ...)

+ func (e *Entry) SetRevalidator(revalidator Revalidator)

+ func (e *Entry) ShardKey() uint64

+ func (e *Entry) ShouldBeRefreshed(cfg *config.Cache) bool

+ func (e *Entry) ToBytes() (data []byte, releaseFn func())

+ func (e *Entry) Weight() int64

+ func (e *Entry) WillUpdateAt() int64

+ type Releaser func()

+ type Revalidator func(path []byte, query []byte, queryHeaders [][2][]byte) (status int, headers [][2][]byte, body []byte, releaseFn func(), err error)

Jul 3, 2025

Changes in this version

type Request

+ func (r *Request) Headers() [][2][]byte

+ func (r *Request) Rule() *config.Rule

type Response

+ func (r *Response) PrintDump()

Jun 27, 2025

Changes in this version

+ var RuleNotFoundError = errors.New("rule not found")

Jun 25, 2025

Changes in this version

type Request

+ func NewRequestFromNetHttp(cfg *config.Cache, r *http.Request) *Request

Jun 25, 2025

Changes in this version

+ var GzipBufferPool = &sync.Pool

+ var GzipWriterPool = &sync.Pool

+ type Data struct

+ func NewData(cfg *config.Cache, path []byte, statusCode int, headers http.Header, ...) *Data

+ func (d *Data) Body() []byte

+ func (d *Data) Headers() http.Header

+ func (d *Data) StatusCode() int

+ func (d *Data) Weight() int64

+ type Request struct

+ func NewRawRequest(cfg *config.Cache, key, shard uint64, query, path []byte) *Request

+ func NewRequest(cfg *config.Cache, path []byte, args map[string][]byte, ...) *Request

+ func NewRequestFromFasthttp(cfg *config.Cache, r *fasthttp.RequestCtx) *Request

+ func (r *Request) MapKey() uint64

+ func (r *Request) Path() []byte

+ func (r *Request) ShardKey() uint64

+ func (r *Request) ToQuery() []byte

+ func (r *Request) Weight() int64

+ type Response struct

+ func NewResponse(data *Data, req *Request, cfg *config.Cache, ...) (*Response, error)

+ func (r *Response) Body() []byte

+ func (r *Response) Data() *Data

+ func (r *Response) Headers() http.Header

+ func (r *Response) Init() *Response

+ func (r *Response) LruListElement() *list.Element[*Response]

+ func (r *Response) MapKey() uint64

+ func (r *Response) Request() *Request

+ func (r *Response) Revalidate(ctx context.Context) error

+ func (r *Response) RevalidatedAt() time.Time

+ func (r *Response) SetLruListElement(el *list.Element[*Response])

+ func (r *Response) SetUp(cfg *config.Cache, data *Data, req *Request, ...) *Response

+ func (r *Response) ShardKey() uint64

+ func (r *Response) ShouldBeRefreshed() bool

+ func (r *Response) ToQuery() []byte

+ func (r *Response) Touch() *Response

+ func (r *Response) Weight() int64