store

package

Go to main page

Versions in this module

v0

v0.1.10

Feb 21, 2020

Changes in this version

type Config

+ LowMem bool

type Option

+ func WithLowMem(low bool) Option

v0.1.9

Feb 14, 2020

v0.1.8

Feb 13, 2020

v0.1.7

Feb 10, 2020

v0.1.6

Jan 22, 2020

Changes in this version

+ var ErrNoIndexFound = errors.New("No index found")

+ var ErrNotIndexable = errors.New("Value not indexable")

+ var ErrUniqueExists = errors.New("Unique constraint violation")

+ func DefaultDecode(data []byte, value interface{}) error

+ func DefaultEncode(value interface{}) ([]byte, error)

+ type DecodeFunc func(data []byte, value interface{}) error

+ type EncodeFunc func(value interface{}) ([]byte, error)

+ type Index struct

+ IndexFunc func(name string, value []byte) (ds.Key, error)

+ Unique bool

+ type IndexConfig struct

+ Path string

+ Unique bool

+ type Indexer interface

+ BaseKey func() ds.Key

+ Indexes func() map[string]Index

type JSONQuery

+ Index string

+ func (q *JSONQuery) UseIndex(path string) *JSONQuery

+ type MarshaledResult struct

+ MarshaledValue map[string]interface{}

type Model

+ func (m *Model) AddIndex(path string, unique bool) error

+ func (m *Model) BaseKey() ds.Key

+ func (m *Model) Indexes() map[string]Index

type ServiceConfig

+ GRPCOptions []grpc.ServerOption

type ServiceOption

+ func WithServiceGRPCOptions(opts ...grpc.ServerOption) ServiceOption

v0.1.5

Jan 11, 2020

v0.1.4

Jan 7, 2020

v0.1.3

Jan 4, 2020

v0.1.2

Jan 3, 2020

Changes in this version

+ const Eq

+ const Ge

+ const Gt

+ const Le

+ const Lt

+ const Ne

+ var ErrInvalidModel = errors.New("the model is invalid")

+ var ErrInvalidModelType = errors.New("the model type should be a non-nil pointer to a struct")

+ var ErrInvalidSchemaInstance = errors.New("instance doesn't correspond to schema")

+ var ErrInvalidSliceType = errors.New("slice type doesn't correspond to model type")

+ var ErrInvalidSortingField = errors.New("sorting field doesn't correspond to instance type")

+ var ErrNotFound = errors.New("instance not found")

+ var ErrReadonlyTx = errors.New("read only transaction")

+ func NewSimpleTx(ds datastore.Datastore) datastore.Txn

+ type Action struct

+ ID core.EntityID

+ Model string

+ Type ActionType

+ type ActionType int

+ const ActionCreate

+ const ActionDelete

+ const ActionSave

+ type Comparer interface

+ Compare func(other interface{}) (int, error)

+ type Config struct

+ Datastore ds.TxnDatastore

+ Debug bool

+ EventCodec core.EventCodec

+ JsonMode bool

+ RepoPath string

+ type Criterion struct

+ func Where(field string) *Criterion

+ func (c *Criterion) Eq(value interface{}) *Query

+ func (c *Criterion) Fn(mf MatchFunc) *Query

+ func (c *Criterion) Ge(value interface{}) *Query

+ func (c *Criterion) Gt(value interface{}) *Query

+ func (c *Criterion) Le(value interface{}) *Query

+ func (c *Criterion) Lt(value interface{}) *Query

+ func (c *Criterion) Ne(value interface{}) *Query

+ type Datastore struct

+ func (d *Datastore) NewTransaction(readOnly bool) (ds.Txn, error)

+ type JSONCriterion struct

+ FieldPath string

+ Operation JSONOperation

+ Value JSONValue

+ func JSONWhere(field string) *JSONCriterion

+ func (c *JSONCriterion) Eq(value interface{}) *JSONQuery

+ func (c *JSONCriterion) Ge(value interface{}) *JSONQuery

+ func (c *JSONCriterion) Gt(value interface{}) *JSONQuery

+ func (c *JSONCriterion) Le(value interface{}) *JSONQuery

+ func (c *JSONCriterion) Lt(value interface{}) *JSONQuery

+ func (c *JSONCriterion) Ne(value interface{}) *JSONQuery

+ type JSONOperation int

+ type JSONQuery struct

+ Ands []*JSONCriterion

+ Ors []*JSONQuery

+ Sort JSONSort

+ func JSONOrderBy(field string) *JSONQuery

+ func JSONOrderByDesc(field string) *JSONQuery

+ func (q *JSONQuery) JSONAnd(field string) *JSONCriterion

+ func (q *JSONQuery) JSONOr(orQuery *JSONQuery) *JSONQuery

+ func (q *JSONQuery) JSONOrderBy(field string) *JSONQuery

+ func (q *JSONQuery) JSONOrderByDesc(field string) *JSONQuery

+ type JSONSort struct

+ Desc bool

+ FieldPath string

+ type JSONValue struct

+ Bool *bool

+ Float *float64

+ String *string

+ type ListenActionType int

+ const ListenAll

+ const ListenCreate

+ const ListenDelete

+ const ListenSave

+ type ListenOption struct

+ ID core.EntityID

+ Model string

+ Type ListenActionType

+ type Listener interface

+ Channel func() <-chan Action

+ Close func()

+ type LocalEventListener struct

+ func (l *LocalEventListener) Channel() <-chan format.Node

+ func (l *LocalEventListener) Discard()

+ type Manager struct

+ func NewManager(ts service.Service, opts ...Option) (*Manager, error)

+ func (m *Manager) Close() error

+ func (m *Manager) GetStore(id uuid.UUID) *Store

+ func (m *Manager) NewStore() (id uuid.UUID, store *Store, err error)

+ type MatchFunc func(value interface{}) (bool, error)

+ type Model struct

+ func (m *Model) Create(vs ...interface{}) error

+ func (m *Model) Delete(ids ...core.EntityID) error

+ func (m *Model) Find(result interface{}, q *Query) error

+ func (m *Model) FindByID(id core.EntityID, v interface{}) error

+ func (m *Model) FindJSON(q *JSONQuery) (ret []string, err error)

+ func (m *Model) Has(ids ...core.EntityID) (exists bool, err error)

+ func (m *Model) ReadTxn(f func(txn *Txn) error) error

+ func (m *Model) Save(vs ...interface{}) error

+ func (m *Model) WriteTxn(f func(txn *Txn) error) error

+ type Option func(*Config) error

+ func WithDebug(enable bool) Option

+ func WithEventCodec(ec core.EventCodec) Option

+ func WithJsonMode(enabled bool) Option

+ func WithRepoPath(path string) Option

+ type Query struct

+ func OrderBy(field string) *Query

+ func OrderByDesc(field string) *Query

+ func (q *Query) And(field string) *Criterion

+ func (q *Query) Or(orQuery *Query) *Query

+ func (q *Query) OrderBy(field string) *Query

+ func (q *Query) OrderByDesc(field string) *Query

+ type Reducer interface

+ Reduce func(events []core.Event) error

+ type ServiceBoostrapper interface

+ Bootstrap func(addrs []peer.AddrInfo)

+ GetIpfsLite func() *ipfslite.Peer

+ func DefaultService(repoPath string, opts ...ServiceOption) (ServiceBoostrapper, error)

+ type ServiceConfig struct

+ Debug bool

+ HostAddr ma.Multiaddr

+ HostProxyAddr ma.Multiaddr

+ type ServiceOption func(c *ServiceConfig) error

+ func WithServiceDebug(enabled bool) ServiceOption

+ func WithServiceHostAddr(addr ma.Multiaddr) ServiceOption

+ func WithServiceHostProxyAddr(addr ma.Multiaddr) ServiceOption

+ type SimpleTx struct

+ func (bt *SimpleTx) Commit() error

+ func (bt *SimpleTx) Delete(key datastore.Key) error

+ func (bt *SimpleTx) Discard()

+ func (bt *SimpleTx) Get(k datastore.Key) ([]byte, error)

+ func (bt *SimpleTx) GetSize(k datastore.Key) (int, error)

+ func (bt *SimpleTx) Has(k datastore.Key) (bool, error)

+ func (bt *SimpleTx) Put(key datastore.Key, val []byte) error

+ func (bt *SimpleTx) Query(q query.Query) (query.Results, error)

+ type Store struct

+ func NewStore(ts service.Service, opts ...Option) (*Store, error)

+ func (s *Store) Close() error

+ func (s *Store) GetModel(name string) *Model

+ func (s *Store) Listen(los ...ListenOption) (Listener, error)

+ func (s *Store) Reduce(events []core.Event) error

+ func (s *Store) Register(name string, defaultInstance interface{}) (*Model, error)

+ func (s *Store) RegisterSchema(name string, schema string) (*Model, error)

+ func (s *Store) Service() service.Service

+ func (s *Store) Start() error

+ func (s *Store) StartFromAddr(addr ma.Multiaddr, followKey, readKey *symmetric.Key) error

+ func (s *Store) ThreadID() (thread.ID, bool, error)

+ type TxMapDatastore struct

+ func NewTxMapDatastore() *TxMapDatastore

+ func (d *TxMapDatastore) NewTransaction(readOnly bool) (datastore.Txn, error)

+ type Txn struct

+ func (t *Txn) Commit() error

+ func (t *Txn) Create(new ...interface{}) error

+ func (t *Txn) Delete(ids ...core.EntityID) error

+ func (t *Txn) Discard()

+ func (t *Txn) Find(res interface{}, q *Query) error

+ func (t *Txn) FindByID(id core.EntityID, v interface{}) error

+ func (t *Txn) FindJSON(q *JSONQuery) ([]string, error)

+ func (t *Txn) Has(ids ...core.EntityID) (bool, error)

+ func (t *Txn) Save(updated ...interface{}) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL