proxy

Documentation

Index

• type ProxyElasticSearch
  • func NewProxyElasticSearch() *ProxyElasticSearch
  • func (proxy *ProxyElasticSearch) Store(client *elasticsearch.Client)
• type ProxyGrpc
  • func NewProxyGrpc() *ProxyGrpc
  • func (proxy *ProxyGrpc) Store(client *grpc.ClientConn)
• type ProxyMongoDB
  • func NewProxyMongoDB() *ProxyMongoDB
  • func (proxy *ProxyMongoDB) Store(client *mongodb.MongoDB)
• type ProxyPool
  • func NewProxyPool() *ProxyPool
  • func (proxypool *ProxyPool) LoadElasticSearch(group string) *elasticsearch.Client
  • func (proxypool *ProxyPool) LoadGrpc(group string) *grpc.ClientConn
  • func (proxypool *ProxyPool) LoadMongoDB(group string) *mongodb.MongoDB
  • func (proxypool *ProxyPool) LoadRedis(group string) *redis.Client
  • func (proxypool *ProxyPool) LoadSQL(group string) *ProxySQL
  • func (proxypool *ProxyPool) StoreElasticSearch(group string, proxy *ProxyElasticSearch)
  • func (proxypool *ProxyPool) StoreGrpc(group string, proxy *ProxyGrpc)
  • func (proxypool *ProxyPool) StoreMongoDB(group string, proxy *ProxyMongoDB)
  • func (proxypool *ProxyPool) StoreRedis(group string, proxy *ProxyRedis)
  • func (proxypool *ProxyPool) StoreSQL(group string, proxy *ProxySQL)
• type ProxyRedis
  • func NewProxyRedis() *ProxyRedis
  • func (proxy *ProxyRedis) Store(client *redis.Client)
• type ProxySQL
  • func NewProxySQL() *ProxySQL
  • func (proxy *ProxySQL) Read() *query.QueryDb
  • func (proxy *ProxySQL) SetRead(query *query.QueryDb)
  • func (proxy *ProxySQL) SetWrite(query *query.QueryDb)
  • func (proxy *ProxySQL) Write() *query.QueryDb

Types

type ProxyElasticSearch

type ProxyElasticSearch struct {
	*elasticsearch.Client
}

func NewProxyElasticSearch

func NewProxyElasticSearch() *ProxyElasticSearch

NewProxyElasticSearch 缓存

func (*ProxyElasticSearch) Store

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

Store 设置写库

type ProxyGrpc

type ProxyGrpc struct {
	*grpc.ClientConn
}

func NewProxyGrpc

func NewProxyGrpc() *ProxyGrpc

NewProxyGrpc 缓存

func (*ProxyGrpc) Store

func (proxy *ProxyGrpc) Store(client *grpc.ClientConn)

Store 设置写库

type ProxyMongoDB

type ProxyMongoDB struct {
	*mongodb.MongoDB
}

func NewProxyMongoDB

func NewProxyMongoDB() *ProxyMongoDB

NewProxyMongoDB 缓存

func (*ProxyMongoDB) Store

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

Store 设置写库

type ProxyPool

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

ProxyPool 代理池

func NewProxyPool

func NewProxyPool() *ProxyPool

NewProxyPool 代理池

func (*ProxyPool) LoadElasticSearch

func (proxypool *ProxyPool) LoadElasticSearch(group string) *elasticsearch.Client

LoadEs 获取分组

func (*ProxyPool) LoadGrpc

func (proxypool *ProxyPool) LoadGrpc(group string) *grpc.ClientConn

Load 获取分组

func (*ProxyPool) LoadMongoDB

func (proxypool *ProxyPool) LoadMongoDB(group string) *mongodb.MongoDB

LoadNoSQL 获取分组

func (*ProxyPool) LoadRedis

func (proxypool *ProxyPool) LoadRedis(group string) *redis.Client

LoadCache 获取分组

func (*ProxyPool) LoadSQL

func (proxypool *ProxyPool) LoadSQL(group string) *ProxySQL

LoadSQL 获取分组

func (*ProxyPool) StoreElasticSearch

func (proxypool *ProxyPool) StoreElasticSearch(group string, proxy *ProxyElasticSearch)

StoreEs 设置组

func (*ProxyPool) StoreGrpc

func (proxypool *ProxyPool) StoreGrpc(group string, proxy *ProxyGrpc)

Store 设置组

func (*ProxyPool) StoreMongoDB

func (proxypool *ProxyPool) StoreMongoDB(group string, proxy *ProxyMongoDB)

StoreNoSQL 设置组

func (*ProxyPool) StoreRedis

func (proxypool *ProxyPool) StoreRedis(group string, proxy *ProxyRedis)

StoreCache 设置组

func (*ProxyPool) StoreSQL

func (proxypool *ProxyPool) StoreSQL(group string, proxy *ProxySQL)

StoreSQL 设置组

type ProxyRedis

type ProxyRedis struct {
	*redis.Client
}

func NewProxyRedis

func NewProxyRedis() *ProxyRedis

NewProxyRedis 缓存

func (*ProxyRedis) Store

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

Store 设置写库

type ProxySQL

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

Proxy 代理

func NewProxySQL

func NewProxySQL() *ProxySQL

NewProxySQL 代理池

func (*ProxySQL) Read

func (proxy *ProxySQL) Read() *query.QueryDb

Read 获取读库

func (*ProxySQL) SetRead

func (proxy *ProxySQL) SetRead(query *query.QueryDb)

SetRead 设置读库

func (*ProxySQL) SetWrite

func (proxy *ProxySQL) SetWrite(query *query.QueryDb)

SetWrite 设置写库

func (*ProxySQL) Write

func (proxy *ProxySQL) Write() *query.QueryDb

Write 获取写库