cache

package

v1.10.0 Latest Latest Go to latest Published: Sep 8, 2024 License: MIT Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

func Middleware(cache ICache, skipper middleware.Skipper) echo.MiddlewareFunc

type CacheEntry struct {
	Header     http.Header
	StatusCode int
	Body       []byte
}

func (c *CacheEntry) Decode(b []byte) error

func (c *CacheEntry) Encode() ([]byte, error)

func (c *CacheEntry) Replay(w http.ResponseWriter) error

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

func (m *CacheMiddleware) Handler(next echo.HandlerFunc) echo.HandlerFunc

type Config struct {
	MaxEntitiesCount int
}

type ICache interface {
	Get(key string) ([]byte, bool)
	Set(key string, data []byte)
	Clear()
}

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

func NewObservableCache(cfg Config, observer *bus.Observer) *ObservableCache

func (c *ObservableCache) Clear()

func (c *ObservableCache) Close() error

func (c *ObservableCache) Get(key string) ([]byte, bool)

func (c *ObservableCache) Set(key string, data []byte)

func (c *ObservableCache) Start(ctx context.Context)

type ResponseRecorder struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

func NewResponseRecorder(w http.ResponseWriter) *ResponseRecorder

func (r *ResponseRecorder) Result() *CacheEntry

func (w *ResponseRecorder) Write(b []byte) (int, error)

func (w *ResponseRecorder) WriteHeader(statusCode int)

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

func NewTTLCache(expiration time.Duration) (*TTLCache, error)

func (c *TTLCache) Clear()

func (c *TTLCache) Close() error

func (c *TTLCache) Get(key string) (data []byte, found bool)

func (c *TTLCache) Set(key string, data []byte)