database

Documentation

Index

• type ConnectOption
  • func WithAddress(host string, port int) ConnectOption
  • func WithCredentials(username string, password string) ConnectOption
  • func WithName(name string) ConnectOption
• type Rethink
  • func New(options ...ConnectOption) *Rethink
  • func (db *Rethink) Changes(table string) (*r.Cursor, error)
  • func (db *Rethink) Connect() error
  • func (db *Rethink) CreateDatabase(name string) error
  • func (db *Rethink) CreateTable(name string) error
  • func (db *Rethink) Delete(table string, id string) error
  • func (db *Rethink) Disconnect() error
  • func (db *Rethink) DropDatabase(name string) error
  • func (db *Rethink) DropTable(name string) error
  • func (db *Rethink) FetchOne(table string, value interface{}) error
  • func (db *Rethink) Filter(table string, filterFunc interface{}) (*r.Cursor, error)
  • func (db *Rethink) Get(table string, id string, value interface{}) error
  • func (db *Rethink) GetCursor(table string) (*r.Cursor, error)
  • func (db *Rethink) Insert(table string, document interface{}) (string, error)
  • func (db *Rethink) ListTable(name string, value interface{}) error
  • func (db *Rethink) SetTags(tags ...string)
  • func (db *Rethink) Update(table string, id string, value interface{}) error

Types

type ConnectOption

type ConnectOption func(*r.ConnectOpts)

func WithAddress

func WithAddress(host string, port int) ConnectOption

func WithCredentials

func WithCredentials(username string, password string) ConnectOption

func WithName

func WithName(name string) ConnectOption

type Rethink

type Rethink struct {
	*r.Session
	// contains filtered or unexported fields
}

func New

func New(options ...ConnectOption) *Rethink

func (*Rethink) Changes

func (db *Rethink) Changes(table string) (*r.Cursor, error)

func (*Rethink) Connect

func (db *Rethink) Connect() error

func (*Rethink) CreateDatabase

func (db *Rethink) CreateDatabase(name string) error

func (*Rethink) CreateTable

func (db *Rethink) CreateTable(name string) error

func (*Rethink) Delete

func (db *Rethink) Delete(table string, id string) error

func (*Rethink) Disconnect

func (db *Rethink) Disconnect() error

func (*Rethink) DropDatabase

func (db *Rethink) DropDatabase(name string) error

func (*Rethink) DropTable

func (db *Rethink) DropTable(name string) error

func (*Rethink) FetchOne

func (db *Rethink) FetchOne(table string, value interface{}) error

func (*Rethink) Filter

func (db *Rethink) Filter(table string, filterFunc interface{}) (*r.Cursor, error)

func (*Rethink) Get

func (db *Rethink) Get(table string, id string, value interface{}) error

func (*Rethink) GetCursor

func (db *Rethink) GetCursor(table string) (*r.Cursor, error)

func (*Rethink) Insert

func (db *Rethink) Insert(table string, document interface{}) (string, error)

func (*Rethink) ListTable

func (db *Rethink) ListTable(name string, value interface{}) error

func (*Rethink) SetTags

func (db *Rethink) SetTags(tags ...string)

func (*Rethink) Update

func (db *Rethink) Update(table string, id string, value interface{}) error