dmap

Dec 3, 2022

Changes in this version

+ var ErrEntryTooLarge = errors.New("entry too large for the configured table size")

type DMap

+ func (dm *DMap) IncrByFloat(ctx context.Context, key string, delta float64) (float64, error)

+ func (dm *DMap) Lease(ctx context.Context, key string, token []byte, timeout time.Duration) error

+ func (dm *DMap) Scan(partID, cursor uint64, sc *ScanConfig) ([]string, uint64, error)

+ func (dm *DMap) Unlock(ctx context.Context, key string, token []byte) error

+ type PutConfig struct

+ EX time.Duration

+ EXAT time.Duration

+ HasEX bool

+ HasEXAT bool

+ HasNX bool

+ HasPX bool

+ HasPXAT bool

+ HasXX bool

+ OnlyUpdateTTL bool

+ PX time.Duration

+ PXAT time.Duration

+ type ScanConfig struct

+ Count int

+ HasCount bool

+ HasMatch bool

+ Match string

+ Replica bool

+ type ScanOption func(*ScanConfig)

+ func Count(c int) ScanOption

+ func Match(s string) ScanOption

type Service

+ func (s *Service) RegisterHandlers()

Aug 17, 2021

Changes in this version

+ const IfFound

+ const IfNotFound

+ const NumConcurrentWorkers

+ var DeleteHits = stats.NewInt64Counter()

+ var DeleteMisses = stats.NewInt64Counter()

+ var EntriesTotal = stats.NewInt64Counter()

+ var ErrDMapNotFound = errors.New("dmap not found")

+ var ErrEndOfQuery = neterrors.New(protocol.StatusErrEndOfQuery, "end of query")

+ var ErrKeyFound = neterrors.New(protocol.StatusErrKeyFound, "key found")

+ var ErrKeyNotFound = neterrors.New(protocol.StatusErrKeyNotFound, "key not found")

+ var ErrKeyTooLarge = neterrors.New(protocol.StatusErrKeyTooLarge, "key too large")

+ var ErrLockNotAcquired = neterrors.New(protocol.StatusErrLockNotAcquired, "lock not acquired")

+ var ErrNoSuchLock = neterrors.New(protocol.StatusErrNoSuchLock, "no such lock")

+ var ErrReadQuorum = neterrors.New(protocol.StatusErrReadQuorum, "read quorum cannot be reached")

+ var ErrServerGone = errors.New("server is gone")

+ var ErrWriteQuorum = neterrors.New(protocol.StatusErrWriteQuorum, "write quorum cannot be reached")

+ var EvictedTotal = stats.NewInt64Counter()

+ var GetHits = stats.NewInt64Counter()

+ var GetMisses = stats.NewInt64Counter()

+ func NewService(e *environment.Environment) (service.Service, error)

+ type Cursor struct

+ func (c *Cursor) Close()

+ func (c *Cursor) Range(f func(key string, value interface{}) bool) error

+ type DMap struct

+ func (dm *DMap) Decr(key string, delta int) (int, error)

+ func (dm *DMap) Delete(key string) error

+ func (dm *DMap) Destroy() error

+ func (dm *DMap) Expire(key string, timeout time.Duration) error

+ func (dm *DMap) Get(key string) (interface{}, error)

+ func (dm *DMap) GetEntry(key string) (*Entry, error)

+ func (dm *DMap) GetPut(key string, value interface{}) (interface{}, error)

+ func (dm *DMap) Incr(key string, delta int) (int, error)

+ func (dm *DMap) Lock(key string, deadline time.Duration) (*LockContext, error)

+ func (dm *DMap) LockWithTimeout(key string, timeout, deadline time.Duration) (*LockContext, error)

+ func (dm *DMap) Name() string

+ func (dm *DMap) Put(key string, value interface{}) error

+ func (dm *DMap) PutEx(key string, value interface{}, timeout time.Duration) error

+ func (dm *DMap) PutIf(key string, value interface{}, flags int16) error

+ func (dm *DMap) PutIfEx(key string, value interface{}, timeout time.Duration, flags int16) error

+ func (dm *DMap) Query(q query.M) (*Cursor, error)

+ type Entry struct

+ Key string

+ TTL int64

+ Timestamp int64

+ Value interface{}

+ type LockContext struct

+ func (l *LockContext) Unlock() error

+ type QueryResponse map[string]interface

+ type Service struct

+ func (s *Service) NewDMap(name string) (*DMap, error)

+ func (s *Service) RegisterOperations(operations map[protocol.OpCode]func(w, r protocol.EncodeDecoder))

+ func (s *Service) Shutdown(ctx context.Context) error

+ func (s *Service) Start() error