database

Nov 17, 2021

Changes in this version

+ const StorageTypeInjected

type Controller

+ func (c *Controller) Withdraw()

May 13, 2021

Changes in this version

type Controller

+ func (c *Controller) GetMeta(key string) (*record.Meta, error)

Feb 11, 2021

Changes in this version

type Interface

+ func (i *Interface) ClearCache()

+ func (i *Interface) FlushCache()

Nov 24, 2020

Changes in this version

type Interface

+ func (i *Interface) DelayedCacheWriter(ctx context.Context) error

type Options

+ DelayCachedWrites string

+ func (o *Options) HasAllPermissions() bool

Sep 25, 2020

Changes in this version

type Controller

+ func (c *Controller) Purge(ctx context.Context, q *query.Query, local, internal bool) (int, error)

type Database

+ ShadowDelete bool

type Interface

+ func (i *Interface) Purge(ctx context.Context, q *query.Query) (int, error)

Jul 15, 2020

Changes in this version

+ func EnableRegistryPersistence()

May 8, 2020

Changes in this version

type Controller

+ func (c *Controller) MaintainRecordStates(ctx context.Context, purgeDeletedBefore time.Time) error

Apr 15, 2020

Changes in this version

+ var ErrNotImplemented = errors.New("not implemented by this storage")

+ func InitializeWithPath(dirPath string) error

type Controller

+ func (c *Controller) PutMany() (chan<- record.Record, <-chan error)

type Interface

+ func (i *Interface) PutMany(dbName string) (put func(record.Record) error)

May 22, 2019

Changes in this version

+ var ErrNotFound = errors.New("database entry could not be found")

+ var ErrPermissionDenied = errors.New("access to database record denied")

+ var ErrReadOnly = errors.New("database is read only")

+ var ErrShuttingDown = errors.New("database system is shutting down")

+ func GetDatabaseRoot() string

+ func Initialize() error

+ func Maintain() (err error)

+ func MaintainRecordStates() error

+ func MaintainThorough() (err error)

+ func SetLocation(location string) (ok bool)

+ func Shutdown() (err error)

+ type Controller struct

+ func InjectDatabase(name string, storageInt storage.Interface) (*Controller, error)

+ func (c *Controller) Get(key string) (record.Record, error)

+ func (c *Controller) Injected() bool

+ func (c *Controller) Maintain() error

+ func (c *Controller) MaintainThorough() error

+ func (c *Controller) PushUpdate(r record.Record)

+ func (c *Controller) Put(r record.Record) (err error)

+ func (c *Controller) Query(q *query.Query, local, internal bool) (*iterator.Iterator, error)

+ func (c *Controller) ReadOnly() bool

+ func (c *Controller) Shutdown() error

+ type Database struct

+ Description string

+ LastLoaded time.Time

+ LastUpdated time.Time

+ Name string

+ PrimaryAPI string

+ Registered time.Time

+ StorageType string

+ func Register(new *Database) (*Database, error)

+ func (db *Database) Loaded()

+ func (db *Database) MigrateTo(newStorageType string) error

+ func (db *Database) Updated()

+ type Hook interface

+ PostGet func(r record.Record) (record.Record, error)

+ PreGet func(dbKey string) error

+ PrePut func(r record.Record) (record.Record, error)

+ UsesPostGet func() bool

+ UsesPreGet func() bool

+ UsesPrePut func() bool

+ type HookBase struct

+ func (b *HookBase) PostGet(r record.Record) (record.Record, error)

+ func (b *HookBase) PreGet(dbKey string) error

+ func (b *HookBase) PrePut(r record.Record) (record.Record, error)

+ func (b *HookBase) UsesPostGet() bool

+ func (b *HookBase) UsesPreGet() bool

+ func (b *HookBase) UsesPrePut() bool

+ type Interface struct

+ func NewInterface(opts *Options) *Interface

+ func (i *Interface) Delete(key string) error

+ func (i *Interface) Exists(key string) (bool, error)

+ func (i *Interface) Get(key string) (record.Record, error)

+ func (i *Interface) InsertValue(key string, attribute string, value interface{}) error

+ func (i *Interface) MakeCrownJewel(key string) error

+ func (i *Interface) MakeSecret(key string) error

+ func (i *Interface) Put(r record.Record) error

+ func (i *Interface) PutNew(r record.Record) error

+ func (i *Interface) Query(q *query.Query) (*iterator.Iterator, error)

+ func (i *Interface) SetAbsoluteExpiry(key string, time int64) error

+ func (i *Interface) SetRelativateExpiry(key string, duration int64) error

+ func (i *Interface) Subscribe(q *query.Query) (*Subscription, error)

+ type Options struct

+ AlwaysMakeCrownjewel bool

+ AlwaysMakeSecret bool

+ AlwaysSetAbsoluteExpiry int64

+ AlwaysSetRelativateExpiry int64

+ CacheSize int

+ Internal bool

+ Local bool

+ func (o *Options) Apply(r record.Record)

+ type RegisteredHook struct

+ func RegisterHook(q *query.Query, hook Hook) (*RegisteredHook, error)

+ func (h *RegisteredHook) Cancel() error

+ type Subscription struct

+ Err error

+ Feed chan record.Record

+ func (s *Subscription) Cancel() error