inmemory

Documentation

Overview

Package inmemory provides a in-memory implementation of graphstore.Service and keyvalue.DB.

Index

• type GraphStore
  • func (*GraphStore) Close(ctx context.Context) error
  • func (s *GraphStore) Read(ctx context.Context, req *spb.ReadRequest, f graphstore.EntryFunc) error
  • func (s *GraphStore) Scan(ctx context.Context, req *spb.ScanRequest, f graphstore.EntryFunc) error
  • func (s *GraphStore) Write(ctx context.Context, req *spb.WriteRequest) error
• type KeyValueDB
  • func NewKeyValueDB() *KeyValueDB
  • func (k *KeyValueDB) Close(context.Context) error
  • func (k *KeyValueDB) Get(ctx context.Context, key []byte, opts *keyvalue.Options) ([]byte, error)
  • func (k *KeyValueDB) NewSnapshot(ctx context.Context) keyvalue.Snapshot
  • func (k *KeyValueDB) ScanPrefix(ctx context.Context, prefix []byte, opts *keyvalue.Options) (keyvalue.Iterator, error)
  • func (k *KeyValueDB) ScanRange(ctx context.Context, r *keyvalue.Range, opts *keyvalue.Options) (keyvalue.Iterator, error)
  • func (k *KeyValueDB) Writer(ctx context.Context) (keyvalue.Writer, error)

Types

type GraphStore

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

GraphStore implements the graphstore.Service interface. A zero of this type is ready for use, and is safe for access by concurrent goroutines.

func (*GraphStore) Close

func (*GraphStore) Close(ctx context.Context) error

Close implements io.Closer. It never returns an error.

func (*GraphStore) Read

func (s *GraphStore) Read(ctx context.Context, req *spb.ReadRequest, f graphstore.EntryFunc) error

Read implements part of the graphstore.Service interface.

func (*GraphStore) Scan

func (s *GraphStore) Scan(ctx context.Context, req *spb.ScanRequest, f graphstore.EntryFunc) error

Scan implements part of the graphstore.Service interface.

func (*GraphStore) Write

func (s *GraphStore) Write(ctx context.Context, req *spb.WriteRequest) error

Write implements part of the graphstore.Service interface.

type KeyValueDB

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

KeyValueDB implements the keyvalue.DB interface backed by an in-memory map.

func NewKeyValueDB

func NewKeyValueDB() *KeyValueDB

NewKeyValueDB returns a keyvalue.DB backed by an in-memory data structure.

func (*KeyValueDB) Close

func (k *KeyValueDB) Close(context.Context) error

Close implements part of the keyvalue.DB interface.

func (*KeyValueDB) Get

func (k *KeyValueDB) Get(ctx context.Context, key []byte, opts *keyvalue.Options) ([]byte, error)

Get implements part of the keyvalue.DB interface.

func (*KeyValueDB) NewSnapshot

func (k *KeyValueDB) NewSnapshot(ctx context.Context) keyvalue.Snapshot

NewSnapshot implements part of the keyvalue.DB interface.

func (*KeyValueDB) ScanPrefix

func (k *KeyValueDB) ScanPrefix(ctx context.Context, prefix []byte, opts *keyvalue.Options) (keyvalue.Iterator, error)

ScanPrefix implements part of the keyvalue.DB interface.

func (*KeyValueDB) ScanRange

func (k *KeyValueDB) ScanRange(ctx context.Context, r *keyvalue.Range, opts *keyvalue.Options) (keyvalue.Iterator, error)

ScanRange implements part of the keyvalue.DB interface.

func (*KeyValueDB) Writer

func (k *KeyValueDB) Writer(ctx context.Context) (keyvalue.Writer, error)

Writer implements part of the keyvalue.DB interface.