kv

Documentation

Index

• Variables
• func Register(constructor KVConstructor, matcher Matcher)
• type KV
• type KVConstructor
• type KVManager
  • func NewKVManager() *KVManager
  • func (m *KVManager) Configure(name string, uri string) error
  • func (m *KVManager) GetKVMapper(vm *goja.Runtime, eventLoop *eventloop.EventLoop) *KVMapper
• type KVMapper
  • func (m *KVMapper) Delete(key string) bool
  • func (m *KVMapper) Get(key string) goja.Value
  • func (m *KVMapper) Has(key string) bool
  • func (m *KVMapper) Keys() []string
  • func (m *KVMapper) NativeObject() goja.Value
  • func (m *KVMapper) Reset()
  • func (m *KVMapper) Set(key string, val goja.Value) bool
  • func (m *KVMapper) WithIOContext(t *common.IOContext)
• type Matcher
• type NativeKVProxy
  • func (kv *NativeKVProxy) Delete(key string) bool
  • func (kv *NativeKVProxy) Get(key string) goja.Value
  • func (kv *NativeKVProxy) Has(key string) bool
  • func (kv *NativeKVProxy) Keys() []string
  • func (kv *NativeKVProxy) NativeObject() goja.Value
  • func (kv *NativeKVProxy) Set(key string, val goja.Value) bool

Variables

var (
	ErrKeyNotFound     = fmt.Errorf("kv: not found")
	ErrBackingNotFound = fmt.Errorf("kv: backing not found")
)

Functions

func Register

func Register(constructor KVConstructor, matcher Matcher)

Types

type KV

type KV interface {
	Get(ctx context.Context, key string) (val []byte, err error)
	Put(ctx context.Context, key string, val []byte) (err error)
	Del(ctx context.Context, key string) (deleted bool, err error)
}

type KVConstructor

type KVConstructor func(uri string) (KV, error)

type KVManager

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

func NewKVManager

func NewKVManager() *KVManager

func (*KVManager) Configure

func (m *KVManager) Configure(name string, uri string) error

func (*KVManager) GetKVMapper

func (m *KVManager) GetKVMapper(vm *goja.Runtime, eventLoop *eventloop.EventLoop) *KVMapper

type KVMapper

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

func (*KVMapper) Delete

func (m *KVMapper) Delete(key string) bool

func (*KVMapper) Get

func (m *KVMapper) Get(key string) goja.Value

func (*KVMapper) Has

func (m *KVMapper) Has(key string) bool

func (*KVMapper) Keys

func (m *KVMapper) Keys() []string

func (*KVMapper) NativeObject

func (m *KVMapper) NativeObject() goja.Value

func (*KVMapper) Reset

func (m *KVMapper) Reset()

func (*KVMapper) Set

func (m *KVMapper) Set(key string, val goja.Value) bool

func (*KVMapper) WithIOContext

func (m *KVMapper) WithIOContext(t *common.IOContext)

type Matcher

type Matcher func(uri string) bool

type NativeKVProxy

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

func (*NativeKVProxy) Delete

func (kv *NativeKVProxy) Delete(key string) bool

func (*NativeKVProxy) Get

func (kv *NativeKVProxy) Get(key string) goja.Value

func (*NativeKVProxy) Has

func (kv *NativeKVProxy) Has(key string) bool

func (*NativeKVProxy) Keys

func (kv *NativeKVProxy) Keys() []string

func (*NativeKVProxy) NativeObject

func (kv *NativeKVProxy) NativeObject() goja.Value

func (*NativeKVProxy) Set

func (kv *NativeKVProxy) Set(key string, val goja.Value) bool