database

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 15, 2019 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TYPE        = "db"
	TYPE_STORM  = "storm"
	TYPE_BADGER = "badger"
	TYPE_MONGO  = "mongo"
	TYPE_PGSQL  = "pgsql"
)

Variables

This section is empty.

Functions

func Close 

func Close()

func Init 

func Init(name string, cfg *common.Jason) error

func Put 

func Put(name string, db *Database)

Types

type BadgerDB 

type BadgerDB struct {
	Path string
	DB   *badger.DB
}

func NewBadgerDB 

func NewBadgerDB() (*BadgerDB, error)

func (*BadgerDB) CreateSchema 

func (db *BadgerDB) CreateSchema([]interface{}) error

func (*BadgerDB) DeleteBucket 

func (db *BadgerDB) DeleteBucket(field string, value interface{}, id int, options *Options) error

func (*BadgerDB) DeleteClass 

func (db *BadgerDB) DeleteClass(field string, value interface{}, id int, options *Options) error

func (*BadgerDB) DeleteUser 

func (db *BadgerDB) DeleteUser(field string, value interface{}, id int, options *Options) error

func (*BadgerDB) Init 

func (db *BadgerDB) Init(cfg *common.Jason) error

func (*BadgerDB) LoadBucket 

func (db *BadgerDB) LoadBucket(field string, value interface{}, document *models.Bucket, options *Options) error

func (*BadgerDB) LoadClass 

func (db *BadgerDB) LoadClass(field string, value interface{}, class *models.Class, options *Options) error

func (*BadgerDB) LoadUser 

func (db *BadgerDB) LoadUser(field string, value interface{}, user *models.User, options *Options) error

func (*BadgerDB) SaveBucket 

func (db *BadgerDB) SaveBucket(document *models.Bucket, options *Options) error

func (*BadgerDB) SaveClass 

func (db *BadgerDB) SaveClass(class *models.Class, options *Options) error

func (*BadgerDB) SaveUser 

func (db *BadgerDB) SaveUser(user *models.User, options *Options) error

func (*BadgerDB) Start 

func (db *BadgerDB) Start() error

func (*BadgerDB) Stop 

func (db *BadgerDB) Stop() error

type Database 

type Database interface {
	Init(*common.Jason) error
	Start() error
	Stop() error

	CreateSchema([]interface{}) error

	SaveBucket(doc *models.Bucket, options *Options) error
	LoadBucket(field string, value interface{}, doc *models.Bucket, options *Options) error
	DeleteBucket(field string, value interface{}, id int, options *Options) error

	SaveUser(user *models.User, options *Options) error
	LoadUser(field string, value interface{}, user *models.User, options *Options) error
	DeleteUser(field string, value interface{}, id int, options *Options) error
}

func Get 

func Get(name string) *Database

type MongoDB 

type MongoDB struct {
	Name           string
	URL            string
	Client         *mongo.Client
	Ctx            context.Context
	ConnectTimeout int
}

func NewMongoDB 

func NewMongoDB() (*MongoDB, error)

func (*MongoDB) CreateSchema 

func (db *MongoDB) CreateSchema([]interface{}) error

func (*MongoDB) DeleteBucket 

func (db *MongoDB) DeleteBucket(field string, value interface{}, id int, options *Options) error

func (*MongoDB) DeleteClass 

func (db *MongoDB) DeleteClass(field string, value interface{}, id int, options *Options) error

func (*MongoDB) DeleteUser 

func (db *MongoDB) DeleteUser(field string, value interface{}, id int, options *Options) error

func (*MongoDB) Init 

func (db *MongoDB) Init(cfg *common.Jason) error

func (*MongoDB) LoadBucket 

func (db *MongoDB) LoadBucket(field string, value interface{}, document *models.Bucket, options *Options) error

func (*MongoDB) LoadClass 

func (db *MongoDB) LoadClass(field string, value interface{}, class *models.Class, options *Options) error

func (*MongoDB) LoadUser 

func (db *MongoDB) LoadUser(field string, value interface{}, user *models.User, options *Options) error

func (*MongoDB) SaveBucket 

func (db *MongoDB) SaveBucket(document *models.Bucket, options *Options) error

func (*MongoDB) SaveClass 

func (db *MongoDB) SaveClass(class *models.Class, options *Options) error

func (*MongoDB) SaveUser 

func (db *MongoDB) SaveUser(user *models.User, options *Options) error

func (*MongoDB) Start 

func (db *MongoDB) Start() error

func (*MongoDB) Stop 

func (db *MongoDB) Stop() error

type Options 

type Options struct {
}

type PgsqlDB 

type PgsqlDB struct {
	Username string
	Password string
	Host     string
	Port     int
	Database string
	DB       *pg.DB
}

func NewPgsqlDB 

func NewPgsqlDB() (*PgsqlDB, error)

func (*PgsqlDB) CreateSchema 

func (db *PgsqlDB) CreateSchema(models []interface{}) error

func (*PgsqlDB) DeleteBucket 

func (db *PgsqlDB) DeleteBucket(field string, value interface{}, id int, options *Options) error

func (*PgsqlDB) DeleteClass 

func (db *PgsqlDB) DeleteClass(field string, value interface{}, id int, options *Options) error

func (*PgsqlDB) DeleteUser 

func (db *PgsqlDB) DeleteUser(field string, value interface{}, id int, options *Options) error

func (*PgsqlDB) Init 

func (db *PgsqlDB) Init(cfg *common.Jason) error

func (*PgsqlDB) LoadBucket 

func (db *PgsqlDB) LoadBucket(field string, value interface{}, document *models.Bucket, options *Options) error

func (*PgsqlDB) LoadClass 

func (db *PgsqlDB) LoadClass(field string, value interface{}, class *models.Class, options *Options) error

func (*PgsqlDB) LoadUser 

func (db *PgsqlDB) LoadUser(field string, value interface{}, user *models.User, options *Options) error

func (*PgsqlDB) SaveBucket 

func (db *PgsqlDB) SaveBucket(document *models.Bucket, options *Options) error

func (*PgsqlDB) SaveClass 

func (db *PgsqlDB) SaveClass(class *models.Class, options *Options) error

func (*PgsqlDB) SaveUser 

func (db *PgsqlDB) SaveUser(user *models.User, options *Options) error

func (*PgsqlDB) Start 

func (db *PgsqlDB) Start() error

func (*PgsqlDB) Stop 

func (db *PgsqlDB) Stop() error

type StormDB 

type StormDB struct {
	Path string
	DB   *storm.DB
}

func NewStormDB 

func NewStormDB() (*StormDB, error)

func (*StormDB) CreateSchema 

func (db *StormDB) CreateSchema([]interface{}) error

func (*StormDB) DeleteBucket 

func (db *StormDB) DeleteBucket(field string, value interface{}, id int, options *Options) error

func (*StormDB) DeleteClass 

func (db *StormDB) DeleteClass(field string, value interface{}, id int, options *Options) error

func (*StormDB) DeleteUser 

func (db *StormDB) DeleteUser(field string, value interface{}, id int, options *Options) error

func (*StormDB) Init 

func (db *StormDB) Init(cfg *common.Jason) error

func (*StormDB) LoadBucket 

func (db *StormDB) LoadBucket(field string, value interface{}, document *models.Bucket, options *Options) error

func (*StormDB) LoadClass 

func (db *StormDB) LoadClass(field string, value interface{}, class *models.Class, options *Options) error

func (*StormDB) LoadUser 

func (db *StormDB) LoadUser(field string, value interface{}, user *models.User, options *Options) error

func (*StormDB) SaveBucket 

func (db *StormDB) SaveBucket(document *models.Bucket, options *Options) error

func (*StormDB) SaveClass 

func (db *StormDB) SaveClass(class *models.Class, options *Options) error

func (*StormDB) SaveUser 

func (db *StormDB) SaveUser(user *models.User, options *Options) error

func (*StormDB) Start 

func (db *StormDB) Start() error

func (*StormDB) Stop 

func (db *StormDB) Stop() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.