memorykv

Documentation

Index

• type Driver
  • func NewInMemoryDriver(log *slog.Logger, tracer *sdktrace.TracerProvider) *Driver
  • func (d *Driver) Clear(_ context.Context) error
  • func (d *Driver) Delete(ctx context.Context, keys ...string) error
  • func (d *Driver) Get(ctx context.Context, key string) ([]byte, error)
  • func (d *Driver) Has(ctx context.Context, keys ...string) (map[string]bool, error)
  • func (d *Driver) MExpire(ctx context.Context, items ...kv.Item) error
  • func (d *Driver) MGet(ctx context.Context, keys ...string) (map[string][]byte, error)
  • func (d *Driver) Set(ctx context.Context, items ...kv.Item) error
  • func (d *Driver) Stop(_ context.Context)
  • func (d *Driver) TTL(ctx context.Context, keys ...string) (map[string]string, error)
• type Item
  • func (i *Item) Key() string
  • func (i *Item) Timeout() string
  • func (i *Item) Value() []byte

Types

type Driver

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

func NewInMemoryDriver

func NewInMemoryDriver(log *slog.Logger, tracer *sdktrace.TracerProvider) *Driver

func (*Driver) Clear

func (d *Driver) Clear(_ context.Context) error

func (*Driver) Delete

func (d *Driver) Delete(ctx context.Context, keys ...string) error

func (*Driver) Get

func (d *Driver) Get(ctx context.Context, key string) ([]byte, error)

func (*Driver) Has

func (d *Driver) Has(ctx context.Context, keys ...string) (map[string]bool, error)

func (*Driver) MExpire

func (d *Driver) MExpire(ctx context.Context, items ...kv.Item) error

MExpire sets the expiration time to the key If key already has the expiration time, it will be overwritten

func (*Driver) MGet

func (d *Driver) MGet(ctx context.Context, keys ...string) (map[string][]byte, error)

func (*Driver) Set

func (d *Driver) Set(ctx context.Context, items ...kv.Item) error

func (*Driver) Stop

func (d *Driver) Stop(_ context.Context)

func (*Driver) TTL

func (d *Driver) TTL(ctx context.Context, keys ...string) (map[string]string, error)

type Item

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

func (*Item) Key

func (i *Item) Key() string

func (*Item) Timeout

func (i *Item) Timeout() string

func (*Item) Value

func (i *Item) Value() []byte