proxy

Documentation

Index

• type ProxyElasticSearch
  • func NewProxyElasticSearch() *ProxyElasticSearch
  • func (proxy *ProxyElasticSearch) Store(client *elasticsearch.Client)
• type ProxyHbase
  • func NewProxyHbase() *ProxyHbase
  • func (proxy *ProxyHbase) Store(client *hbase.Client)
• type ProxyKafka
  • func NewProxyKafka() *ProxyKafka
  • func (proxy *ProxyKafka) Store(client *kafka.Clientkafka)
• type ProxyKylin
  • func NewProxyKylin() *ProxyKylin
  • func (proxy *ProxyKylin) Store(client *kylin.Client)
• 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) LoadHbase(group string) *hbase.Client
  • func (proxypool *ProxyPool) LoadKafka(group string) *kafka.Clientkafka
  • func (proxypool *ProxyPool) LoadKylin(group string) *kylin.Client
  • 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) StoreHbase(group string, proxy *ProxyHbase)
  • func (proxypool *ProxyPool) StoreKafka(group string, proxy *ProxyKafka)
  • func (proxypool *ProxyPool) StoreKylin(group string, proxy *ProxyKylin)
  • 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 ProxyHbase

type ProxyHbase struct {
	*hbase.Client
}

func NewProxyHbase

func NewProxyHbase() *ProxyHbase

NewProxyHbase 缓存

func (*ProxyHbase) Store

func (proxy *ProxyHbase) Store(client *hbase.Client)

Store 设置写库

type ProxyKafka

type ProxyKafka struct {
	*kafka.Clientkafka
}

func NewProxyKafka

func NewProxyKafka() *ProxyKafka

NewProxyKafka 缓存

func (*ProxyKafka) Store

func (proxy *ProxyKafka) Store(client *kafka.Clientkafka)

Store 设置写库

type ProxyKylin

type ProxyKylin struct {
	*kylin.Client
}

func NewProxyKylin

func NewProxyKylin() *ProxyKylin

NewProxyKylin 缓存

func (*ProxyKylin) Store

func (proxy *ProxyKylin) Store(client *kylin.Client)

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) LoadHbase

func (proxypool *ProxyPool) LoadHbase(group string) *hbase.Client

LoadEs 获取分组

func (*ProxyPool) LoadKafka

func (proxypool *ProxyPool) LoadKafka(group string) *kafka.Clientkafka

LoadEs 获取分组

func (*ProxyPool) LoadKylin

func (proxypool *ProxyPool) LoadKylin(group string) *kylin.Client

LoadEs 获取分组

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) StoreHbase

func (proxypool *ProxyPool) StoreHbase(group string, proxy *ProxyHbase)

StoreEs 设置组

func (*ProxyPool) StoreKafka

func (proxypool *ProxyPool) StoreKafka(group string, proxy *ProxyKafka)

StoreEs 设置组

func (*ProxyPool) StoreKylin

func (proxypool *ProxyPool) StoreKylin(group string, proxy *ProxyKylin)

StoreEs 设置组

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 获取写库