store

Documentation

Index

• type Cassandra
  • func (cs *Cassandra) Commit(_ string, its []*x.Instruction) error
  • func (cs *Cassandra) GetEntity(_ string, subject string) (result []x.Instruction, rerr error)
  • func (cs *Cassandra) Init(_, tablename string)
  • func (cs *Cassandra) IsNew(_ string, subject string) bool
  • func (cs *Cassandra) SetSession(session *gocql.Session)
• type Datastore
  • func (ds *Datastore) Commit(t string, its []*x.Instruction) error
  • func (ds *Datastore) GetEntity(t, subject string) (reply []x.Instruction, rerr error)
  • func (ds *Datastore) Init(_ string, project string)
  • func (ds *Datastore) IsNew(t, id string) bool
• type Leveldb
  • func (l *Leveldb) Commit(_ string, its []*x.Instruction) error
  • func (l *Leveldb) GetEntity(_, id string) (result []x.Instruction, rerr error)
  • func (l *Leveldb) Init(_ string, filepath string)
  • func (l *Leveldb) IsNew(_, id string) bool
  • func (l *Leveldb) SetBloomFilter(bits int)
• type RethinkDB
  • func (rdb *RethinkDB) Commit(_ string, its []*x.Instruction) error
  • func (rdb *RethinkDB) GetEntity(_ string, subject string) (result []x.Instruction, rerr error)
  • func (rdb *RethinkDB) Init(_ string, tablename string)
  • func (rdb *RethinkDB) IsNew(_ string, subject string) bool
  • func (rdb *RethinkDB) SetSession(session *r.Session)
• type Sql
  • func (s *Sql) Commit(_ string, its []*x.Instruction) error
  • func (s *Sql) GetEntity(_ string, subject string) (result []x.Instruction, rerr error)
  • func (s *Sql) Init(dbtype string, tablename string)
  • func (s *Sql) IsNew(_ string, subject string) bool
  • func (s *Sql) SetDb(db *sql.DB)
• type Store

Types

type Cassandra

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

func (*Cassandra) Commit

func (cs *Cassandra) Commit(_ string, its []*x.Instruction) error

func (*Cassandra) GetEntity

func (cs *Cassandra) GetEntity(_ string, subject string) (
	result []x.Instruction, rerr error)

func (*Cassandra) Init

func (cs *Cassandra) Init(_, tablename string)

func (*Cassandra) IsNew

func (cs *Cassandra) IsNew(_ string, subject string) bool

func (*Cassandra) SetSession

func (cs *Cassandra) SetSession(session *gocql.Session)

type Datastore

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

func (*Datastore) Commit

func (ds *Datastore) Commit(t string, its []*x.Instruction) error

func (*Datastore) GetEntity

func (ds *Datastore) GetEntity(t, subject string) (reply []x.Instruction, rerr error)

func (*Datastore) Init

func (ds *Datastore) Init(_ string, project string)

func (*Datastore) IsNew

func (ds *Datastore) IsNew(t, id string) bool

type Leveldb

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

func (*Leveldb) Commit

func (l *Leveldb) Commit(_ string, its []*x.Instruction) error

func (*Leveldb) GetEntity

func (l *Leveldb) GetEntity(_, id string) (result []x.Instruction, rerr error)

func (*Leveldb) Init

func (l *Leveldb) Init(_ string, filepath string)

func (*Leveldb) IsNew

func (l *Leveldb) IsNew(_, id string) bool

func (*Leveldb) SetBloomFilter

func (l *Leveldb) SetBloomFilter(bits int)

type RethinkDB

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

func (*RethinkDB) Commit

func (rdb *RethinkDB) Commit(_ string, its []*x.Instruction) error

func (*RethinkDB) GetEntity

func (rdb *RethinkDB) GetEntity(_ string, subject string) (
	result []x.Instruction, rerr error,
)

func (*RethinkDB) Init

func (rdb *RethinkDB) Init(_ string, tablename string)

func (*RethinkDB) IsNew

func (rdb *RethinkDB) IsNew(_ string, subject string) bool

func (*RethinkDB) SetSession

func (rdb *RethinkDB) SetSession(session *r.Session)

type Sql

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

func (*Sql) Commit

func (s *Sql) Commit(_ string, its []*x.Instruction) error

func (*Sql) GetEntity

func (s *Sql) GetEntity(_ string, subject string) (
	result []x.Instruction, rerr error)

func (*Sql) Init

func (s *Sql) Init(dbtype string, tablename string)

func (*Sql) IsNew

func (s *Sql) IsNew(_ string, subject string) bool

func (*Sql) SetDb

func (s *Sql) SetDb(db *sql.DB)

type Store

type Store interface {
	Init(dbtype string, tablename string)
	Commit(tablePrefix string, its []*x.Instruction) error
	IsNew(tablePrefix string, subject string) bool
	GetEntity(tablePrefix string, subject string) ([]x.Instruction, error)
}