database

Documentation

Index

• Constants
• func InitElasticDatabase()
• func InitMYSQLDatabase()
• func InitPostgresDatabase()
• func InitRedisDatabase(observers ...RedisKeyspaceExpiredObserver)
• type DataSource
  • func (cp *DataSource) Connect() *sql.DB
  • func (cp *DataSource) Transaction() *sql.Tx
• 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 RedisKeeper
• type RedisKeyspaceExpiredObserver

Constants

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

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

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

Functions

func InitElasticDatabase

func InitElasticDatabase()

func InitMYSQLDatabase

func InitMYSQLDatabase()

func InitPostgresDatabase

func InitPostgresDatabase()

func InitRedisDatabase

func InitRedisDatabase(observers ...RedisKeyspaceExpiredObserver)

Types

type DataSource

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

func (*DataSource) Connect

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

func (*DataSource) Transaction

func (cp *DataSource) 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 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
}