Documentation
¶
Index ¶
- Constants
- Variables
- type Bucket
- func (b *Bucket) Cursor(opts ...kv.CursorHint) (kv.Cursor, error)
- func (b *Bucket) Delete(key []byte) error
- func (b *Bucket) ForwardCursor(seek []byte, opts ...kv.CursorOption) (kv.ForwardCursor, error)
- func (b *Bucket) Get(key []byte) ([]byte, error)
- func (b *Bucket) GetBatch(keys ...[]byte) ([][]byte, error)
- func (b *Bucket) Put(key []byte, value []byte) error
- type ForwardCursor
- type KVStore
- func (s *KVStore) Backup(ctx context.Context, w io.Writer) error
- func (s *KVStore) Buckets(ctx context.Context) [][]byte
- func (s *KVStore) CreateBucket(ctx context.Context, name []byte) error
- func (s *KVStore) DeleteBucket(ctx context.Context, name []byte) error
- func (s *KVStore) Flush(ctx context.Context)
- func (s *KVStore) RLock()
- func (s *KVStore) RUnlock()
- func (s *KVStore) Restore(ctx context.Context, r io.Reader) error
- func (s *KVStore) Update(ctx context.Context, fn func(kv.Tx) error) error
- func (s *KVStore) View(ctx context.Context, fn func(kv.Tx) error) error
- type Service
- func (s *Service) DefaultSource(ctx context.Context) (*platform.Source, error)
- func (s *Service) FindSourceByID(ctx context.Context, id platform2.ID) (*platform.Source, error)
- func (s *Service) FindSources(ctx context.Context, opt platform.FindOptions) ([]*platform.Source, int, error)
- func (s *Service) Flush()
- func (s *Service) PutSource(ctx context.Context, src *platform.Source) error
- type SessionStore
- type Tx
Constants ¶
const ( // DefaultSourceID it the default source identifier DefaultSourceID = "020f755c3c082000" // DefaultSourceOrganizationID is the default source's organization identifier DefaultSourceOrganizationID = "50616e67652c206c" )
const OpPrefix = "inmem/"
OpPrefix is the op prefix.
Variables ¶
var DefaultSource = platform.Source{ Default: true, Name: "autogen", Type: platform.SelfSourceType, }
DefaultSource is the default source.
Functions ¶
This section is empty.
Types ¶
type Bucket ¶
type Bucket struct {
// contains filtered or unexported fields
}
Bucket is a btree that implements kv.Bucket.
func (*Bucket) ForwardCursor ¶
func (b *Bucket) ForwardCursor(seek []byte, opts ...kv.CursorOption) (kv.ForwardCursor, error)
ForwardCursor returns a directional cursor which starts at the provided seeked key
type ForwardCursor ¶
type ForwardCursor struct {
// contains filtered or unexported fields
}
ForwardCursor is a kv.ForwardCursor which iterates over an in-memory btree
func (*ForwardCursor) Close ¶
func (c *ForwardCursor) Close() error
Close releases the producing goroutines for the forward cursor. It blocks until the producing goroutine exits.
func (*ForwardCursor) Err ¶
func (c *ForwardCursor) Err() error
Err returns a non-nil error when an error occurred during cursor iteration.
func (*ForwardCursor) Next ¶
func (c *ForwardCursor) Next() ([]byte, []byte)
Next returns the next key/value pair in the cursor
type KVStore ¶
type KVStore struct {
// contains filtered or unexported fields
}
KVStore is an in memory btree backed kv.Store.
func (*KVStore) CreateBucket ¶
CreateBucket creates a bucket with the provided name if one does not exist.
func (*KVStore) DeleteBucket ¶
DeleteBucket creates a bucket with the provided name if one does not exist.
type Service ¶
type Service struct {
TokenGenerator platform.TokenGenerator
IDGenerator platform2.IDGenerator
platform.TimeGenerator
// contains filtered or unexported fields
}
Service implements various top level services.
func (*Service) DefaultSource ¶
DefaultSource retrieves the default source.
func (*Service) FindSourceByID ¶
FindSourceByID retrieves a source by id.
func (*Service) FindSources ¶
func (s *Service) FindSources(ctx context.Context, opt platform.FindOptions) ([]*platform.Source, int, error)
FindSources retrieves all sources that match an arbitrary source filter. Filters using ID, or OrganizationID and source Name should be efficient. Other filters will do a linear scan across all sources searching for a match.
type SessionStore ¶
type SessionStore struct {
// contains filtered or unexported fields
}
func NewSessionStore ¶
func NewSessionStore() *SessionStore
func (*SessionStore) Delete ¶
func (s *SessionStore) Delete(key string) error
type Tx ¶
type Tx struct {
// contains filtered or unexported fields
}
Tx is an in memory transaction. TODO: make transactions actually transactional
func (*Tx) WithContext ¶
WithContext sets the context for the transaction.
Source Files