database

Documentation

Index

• Constants
• func InitCustomMysqlDatabase(registerName, prefix string)
• func InitCustomOracleDatabase(registerName, hostname string, hostport int, servOsid, dbname, password string)
• func InitCustomPostgresDatabase(registerName, prefix string)
• func InitElasticDatabase()
• func InitMYSQLDatabase()
• func InitOracleDatabase()
• func InitPostgresDatabase()
• func InitRedisDatabase(observers ...RedisKeyspaceExpiredObserver)
• type DataSource
• type EQueryRequest
  • func (query *EQueryRequest) Append() error
  • func (query *EQueryRequest) Delete() error
  • func (query *EQueryRequest) DeleteByQuery() error
  • func (query *EQueryRequest) Get() (*EQueryResponse, error)
  • func (query *EQueryRequest) Init(indexName string, documentID string, deleteQuery bool)
  • func (query *EQueryRequest) InitIndex(indexName string)
  • func (query *EQueryRequest) Search() (*EQueryResponse, error)
  • func (query *EQueryRequest) Update() error
• type EQueryResponse
  • func (qresp *EQueryResponse) ParserData(resp *http.Response) error
  • func (qresp *EQueryResponse) ParserError(resp *http.Response) error
• type EQuerySearch
• type GormDataSource
  • func (cp *GormDataSource) Connect() *sql.DB
  • func (cp *GormDataSource) Transaction() *sql.Tx
• type RedisKeeper
• type RedisKeyspaceExpiredObserver

Constants

const (
	DATABASE_MYSQL = "zero.database.mysql"
)

const (
	DATABASE_ORACLE = "zero.database.oracle"
)

const (
	DATABASE_POSTGRES = "zero.database.postgres"
)

const (
	DATABASE_REDIS = "zero.database.redis"
)

Functions

func InitCustomMysqlDatabase

func InitCustomMysqlDatabase(registerName, prefix string)

func InitCustomOracleDatabase

func InitCustomOracleDatabase(registerName, hostname string, hostport int, servOsid, dbname, password string)

func InitCustomPostgresDatabase

func InitCustomPostgresDatabase(registerName, prefix string)

func InitElasticDatabase

func InitElasticDatabase()

func InitMYSQLDatabase

func InitMYSQLDatabase()

func InitOracleDatabase

func InitOracleDatabase()

func InitPostgresDatabase

func InitPostgresDatabase()

func InitRedisDatabase

func InitRedisDatabase(observers ...RedisKeyspaceExpiredObserver)

Types

type DataSource

type DataSource interface {
	Connect() *sql.DB
	Transaction() *sql.Tx
}

type EQueryRequest

type EQueryRequest struct {
	Query interface{} `json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*EQueryRequest) Append

func (query *EQueryRequest) Append() error

func (*EQueryRequest) Delete

func (query *EQueryRequest) Delete() error

func (*EQueryRequest) DeleteByQuery

func (query *EQueryRequest) DeleteByQuery() error

func (*EQueryRequest) Get

func (query *EQueryRequest) Get() (*EQueryResponse, error)

func (*EQueryRequest) Init

func (query *EQueryRequest) Init(indexName string, documentID string, deleteQuery bool)

func (*EQueryRequest) InitIndex

func (query *EQueryRequest) InitIndex(indexName string)

func (*EQueryRequest) Search

func (query *EQueryRequest) Search() (*EQueryResponse, error)

func (*EQueryRequest) Update

func (query *EQueryRequest) Update() error

type EQueryResponse

type EQueryResponse struct {
	Datas []interface{}
	Total int
	Error string
}

func (*EQueryResponse) ParserData

func (qresp *EQueryResponse) ParserData(resp *http.Response) error

func (*EQueryResponse) ParserError

func (qresp *EQueryResponse) ParserError(resp *http.Response) error

type EQuerySearch

type EQuerySearch struct {
	Source         []string      `json:"_source,omitempty"`
	Size           int           `json:"size,omitempty"`
	From           int           `json:"from,omitempty"`
	Sort           []interface{} `json:"sort,omitempty"`
	Query          interface{}   `json:"query,omitempty"`
	TrackTotalHits int           `json:"track_total_hits,omitempty"`
}

type GormDataSource

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

func (*GormDataSource) Connect

func (cp *GormDataSource) Connect() *sql.DB

func (*GormDataSource) Transaction

func (cp *GormDataSource) Transaction() *sql.Tx

type RedisKeeper

type RedisKeeper interface {
	Client() *redis.Client
	Del(...string) error
	Set(string, string) error
	SetEx(string, string, int) error
	Get(string) (string, error)
}

type RedisKeyspaceExpiredObserver

type RedisKeyspaceExpiredObserver interface {
	OnMessage(*redis.Message) error
}