proxy

Documentation

Index

• type ElasticSearch
  • func NewElasticSearch() *ElasticSearch
  • func (proxy *ElasticSearch) Store(client *elasticsearch.Client)
• type MongoDB
  • func NewMongoDB() *MongoDB
  • func (proxy *MongoDB) Store(client *mongodb.MongoDB)
• type Proxy
  • func NewProxy() *Proxy
  • func (proxyPool *Proxy) LoadElasticSearch(group string) *elasticsearch.Client
  • func (proxyPool *Proxy) LoadMongoDB(group string) *mongodb.MongoDB
  • func (proxyPool *Proxy) LoadRedis(group string) *redis.Client
  • func (proxyPool *Proxy) LoadSQL(group string) *SQL
  • func (proxyPool *Proxy) StoreElasticSearch(group string, proxy *ElasticSearch)
  • func (proxyPool *Proxy) StoreMongoDB(group string, proxy *MongoDB)
  • func (proxyPool *Proxy) StoreRedis(group string, proxy *Redis)
  • func (proxyPool *Proxy) StoreSQL(group string, proxy *SQL)
• type Redis
  • func NewRedis() *Redis
  • func (proxy *Redis) Store(client *redis.Client)
• type SQL
  • func NewSQL() *SQL
  • func (proxy *SQL) Read() sql.SqlConn
  • func (proxy *SQL) SetRead(query sql.SqlConn)
  • func (proxy *SQL) SetWrite(query sql.SqlConn)
  • func (proxy *SQL) Write() sql.SqlConn

Types

type ElasticSearch

type ElasticSearch struct {
	*elasticsearch.Client
}

ElasticSearch ...

func NewElasticSearch

func NewElasticSearch() *ElasticSearch

NewElasticSearch 缓存

func (*ElasticSearch) Store

func (proxy *ElasticSearch) Store(client *elasticsearch.Client)

Store 设置写库

type MongoDB

type MongoDB struct {
	*mongodb.MongoDB
}

MongoDB ...

func NewMongoDB

func NewMongoDB() *MongoDB

NewMongoDB 缓存

func (*MongoDB) Store

func (proxy *MongoDB) Store(client *mongodb.MongoDB)

Store 设置写库

type Proxy

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

Proxy 代理池

func NewProxy

func NewProxy() *Proxy

NewProxy 代理池

func (*Proxy) LoadElasticSearch

func (proxyPool *Proxy) LoadElasticSearch(group string) *elasticsearch.Client

LoadElasticSearch LoadEs 获取分组

func (*Proxy) LoadMongoDB

func (proxyPool *Proxy) LoadMongoDB(group string) *mongodb.MongoDB

LoadMongoDB LoadNoSQL 获取分组

func (*Proxy) LoadRedis

func (proxyPool *Proxy) LoadRedis(group string) *redis.Client

LoadRedis LoadCache 获取分组

func (*Proxy) LoadSQL

func (proxyPool *Proxy) LoadSQL(group string) *SQL

LoadSQL 获取分组

func (*Proxy) StoreElasticSearch

func (proxyPool *Proxy) StoreElasticSearch(group string, proxy *ElasticSearch)

StoreElasticSearch StoreEs 设置组

func (*Proxy) StoreMongoDB

func (proxyPool *Proxy) StoreMongoDB(group string, proxy *MongoDB)

StoreMongoDB StoreNoSQL 设置组

func (*Proxy) StoreRedis

func (proxyPool *Proxy) StoreRedis(group string, proxy *Redis)

StoreRedis StoreCache 设置组

func (*Proxy) StoreSQL

func (proxyPool *Proxy) StoreSQL(group string, proxy *SQL)

StoreSQL 设置组

type Redis

type Redis struct {
	*redis.Client
}

Redis ...

func NewRedis

func NewRedis() *Redis

NewRedis 缓存

func (*Redis) Store

func (proxy *Redis) Store(client *redis.Client)

Store 设置写库

type SQL

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

SQL Proxy 代理

func NewSQL

func NewSQL() *SQL

NewSQL 代理池

func (*SQL) Read

func (proxy *SQL) Read() sql.SqlConn

Read 获取读库

func (*SQL) SetRead

func (proxy *SQL) SetRead(query sql.SqlConn)

SetRead 设置读库

func (*SQL) SetWrite

func (proxy *SQL) SetWrite(query sql.SqlConn)

SetWrite 设置写库

func (*SQL) Write

func (proxy *SQL) Write() sql.SqlConn

Write 获取写库