engine

package

v1.0.0 Latest Latest Go to latest Published: Jun 3, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Engine - abstract data storage engine.

func New(options ...Option) *Engine

New - creates a new instance of Engine.

func (e *Engine) Del(ctx context.Context, key string) error

Del - removes a key-value pair from memory.

func (e *Engine) ForEachExpired(action func(key string))

ForEachExpired - scans engine partitions for retrieve expired keys.

func (e *Engine) Get(ctx context.Context, key string) (string, bool)

Get - retrieves the value associated with a key.

func (e *Engine) Set(ctx context.Context, key, value string, ttl int64)

Set - set stores a key-value pair in memory.

func (e *Engine) Watch(ctx context.Context, key string) pkgsync.FutureString

Watch - watches the key and returns the value if it has changed.

type Option func(*Engine)

Option - options for configuring Engine.

func WithPartitionNum(partnum int) Option

WithPartitionNum - configures Engine with a partition number.