rethinkdb

Documentation

Index

• type RethinkDB
  • func (rdb *RethinkDB) Commit(its []*x.Instruction) error
  • func (rdb *RethinkDB) GetEntity(subject string) (result []x.Instruction, rerr error)
  • func (rdb *RethinkDB) Init(args ...string)
  • func (rdb *RethinkDB) IsNew(subject string) bool
  • func (rdb *RethinkDB) Iterate(fromId string, num int, ch chan x.Entity) (found int, last x.Entity, err error)
  • func (rdb *RethinkDB) SetSession(session *r.Session)

Types

type RethinkDB

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

func (*RethinkDB) Commit

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

func (*RethinkDB) GetEntity

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

func (*RethinkDB) Init

func (rdb *RethinkDB) Init(args ...string)

func (*RethinkDB) IsNew

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

func (*RethinkDB) Iterate

func (rdb *RethinkDB) Iterate(fromId string, num int, ch chan x.Entity) (found int, last x.Entity, err error)

func (*RethinkDB) SetSession

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