boat

func AtomicRequest ¶

func AtomicRequest(h http.Handler) http.Handler

func Bootstrap ¶

func Bootstrap(db *sql.DB) error

It must return error or panics as all other?..

func Check ¶

func Check(err error)

func Delete ¶

func Delete(docId int, collection string, tx *sql.Tx)

func DropTenant ¶

func DropTenant(tenantId int, tx *sql.Tx)

func EnsureCollection ¶

func EnsureCollection(name string, tx *sql.Tx)

EnsureCollection checks existance of a collection and creates it, if it is not exist.

func EnsureGINIndex ¶

func EnsureGINIndex(tableName string, tx *sql.Tx)

EnsureGINIndex checks existance of a GIN index on doc fileld for table tableName and creates it, if it is not exist.

func EnsureSchema ¶

func EnsureSchema(name string, tx *sql.Tx)

EnsureSchema checks existance of a schema and creates it, if it is not exist.

func EnsureTenant ¶

func EnsureTenant(tenant *Tenant, tenantInit func(tx *sql.Tx), tx *sql.Tx)

func Find ¶

func Find(docId int, collection string, doc interface{}, tx *sql.Tx) (found bool)

func FindTenantByName ¶

func FindTenantByName(tenantName string, tenant *Tenant, tx *sql.Tx) (tenantId int, found bool)

func GetTx ¶

func GetTx(r *http.Request) *sql.Tx

func Insert ¶

func Insert(doc interface{}, collection string, tx *sql.Tx) (docId int)

func Open ¶

func Open(connectionURL string) (*sql.DB, error)

connectionURL like "postgres://pqgotest:password@localhost/pqgotest?sslmode=verify-full" Boat uses Postgres only.

func Update ¶

func Update(doc interface{}, docId int, collection string, tx *sql.Tx)

func Use ¶

func Use(tenantId int, tx *sql.Tx)

func UseMaster ¶

func UseMaster(h http.Handler) http.Handler

func UseTenantBySubdomain ¶

func UseTenantBySubdomain(h http.Handler) http.Handler