app

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 26, 2022 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrDiscoveryUnavailable        = errors.New("discovery: the client unavailable")
	ErrMysqlInstanceAlreadyExisted = errors.New("mysql: the instance already existed")
	ErrMongoInstanceAlreadyExisted = errors.New("mongo: the instance already existed")
	ErrRedisInstanceAlreadyExisted = errors.New("redis: the instance already existed")
)

Functions

This section is empty.

Types

type App 

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

func New 

func New() *App

func (*App) Close 

func (a *App) Close()

func (*App) Config 

func (a *App) Config(key string) interface{}

func (*App) ConfigCenter 

func (a *App) ConfigCenter(namespaceId string, nodes []*ConfigCenterNote) error

func (*App) ConfigRegister 

func (a *App) ConfigRegister(key string, name string, path string, loadLocal bool, obj interface{}, rc *RegisterCenter) error

func (*App) Context 

func (a *App) Context() context.Context

func (*App) DBMongoAllClose 

func (a *App) DBMongoAllClose()

func (*App) DBMongoInstance 

func (a *App) DBMongoInstance(name ...string) *mongo.Client

func (*App) DBMongoRegister 

func (a *App) DBMongoRegister(name string,
	user string, password string,
	addr []string, dbName string,
	replicaSet string, connTimeout int,
	active int, idle int, idleTimeout int) error

func (*App) DBMySqlAllClose 

func (a *App) DBMySqlAllClose()

func (*App) DBMySqlInstance 

func (a *App) DBMySqlInstance(name ...string) *mysql.Client

func (*App) DBMySqlRegister 

func (a *App) DBMySqlRegister(name string,
	user string, password string,
	addr string, port uint16, dbName string,
	charset string, connTimeout string, parseTime bool, loc string,
	active int, idle int, idleTimeout int) error

func (*App) DBRedisAllClose 

func (a *App) DBRedisAllClose()

func (*App) DBRedisInstance 

func (a *App) DBRedisInstance(name ...string) *redis.Client

func (*App) DBRedisRegister 

func (a *App) DBRedisRegister(name string,
	password string, addr string, port uint16, db int,
	active int, idle int, idleTimeout int) error

func (*App) Discovery 

func (a *App) Discovery(namespaceId string, nodes []*DiscoveryNode) error

func (*App) DiscoveryCancel 

func (a *App) DiscoveryCancel() error

func (*App) DiscoveryClose 

func (a *App) DiscoveryClose()

func (*App) DiscoveryClusterName 

func (a *App) DiscoveryClusterName() string

func (*App) DiscoveryRegister 

func (a *App) DiscoveryRegister() error

func (*App) DiscoveryStart 

func (a *App) DiscoveryStart(ws *sync.WaitGroup) bool

func (*App) Logger 

func (a *App) Logger(path string, level logs.Level, json bool, callerSkip int) error

func (*App) MQConsumerAllClose 

func (a *App) MQConsumerAllClose()

func (*App) MQConsumerAllStart 

func (a *App) MQConsumerAllStart(ws *sync.WaitGroup) bool

func (*App) MQConsumerInstance 

func (a *App) MQConsumerInstance(name ...string) mq.Consumer

func (*App) MQConsumerRegister 

func (a *App) MQConsumerRegister(name string, accessKey string, secretKey string, nameServer []string, namespace string, groupId string, broadCastModel bool, batchSize int, subscribes []*MQConsumerSubscribe) error

func (*App) MQProducerAllClose 

func (a *App) MQProducerAllClose()

func (*App) MQProducerAllStart 

func (a *App) MQProducerAllStart(ws *sync.WaitGroup) bool

func (*App) MQProducerInstance 

func (a *App) MQProducerInstance(name ...string) mq.Producer

func (*App) MQProducerRegister 

func (a *App) MQProducerRegister(name string, accessKey string, secretKey string, nameServer []string, namespace string, groupId string) error

func (*App) NetHttpAllClose 

func (a *App) NetHttpAllClose()

func (*App) NetHttpAllStart 

func (a *App) NetHttpAllStart(ws *sync.WaitGroup) bool

func (*App) NetHttpRegister 

func (a *App) NetHttpRegister(name string, ip string, port uint16, discoverySoftState *bool, handler http.Handler) error

func (*App) NetRpcAllClose 

func (a *App) NetRpcAllClose()

func (*App) NetRpcAllStart 

func (a *App) NetRpcAllStart(ws *sync.WaitGroup) bool

func (*App) NetRpcClient 

func (a *App) NetRpcClient(groupName string, name string, serviceName string, options ...NetRpcClientOptionFunc) (*netRpc.Client, error)

func (*App) NetRpcClientClose 

func (a *App) NetRpcClientClose()

func (*App) NetRpcClientWithHashSelector 

func (a *App) NetRpcClientWithHashSelector() NetRpcClientOptionFunc

func (*App) NetRpcClientWithSoftState 

func (a *App) NetRpcClientWithSoftState() NetRpcClientOptionFunc

func (*App) NetRpcRegister 

func (a *App) NetRpcRegister(name string, ip string, port uint16, groupName string, discoverySoftState *bool, service interface{}) error

func (*App) ProxyConfig 

func (a *App) ProxyConfig() proxy.Config

func (*App) ProxyDBMongo 

func (a *App) ProxyDBMongo() proxy.DBMongo

func (*App) ProxyDBMySQL 

func (a *App) ProxyDBMySQL() proxy.DBMySQL

func (*App) ProxyDBRedis 

func (a *App) ProxyDBRedis() proxy.DBRedis

func (*App) ProxyDiscovery 

func (a *App) ProxyDiscovery() proxy.Discovery

func (*App) ProxyMQ 

func (a *App) ProxyMQ() proxy.MQ

func (*App) ProxyRpcClient 

func (a *App) ProxyRpcClient(groupName ...string) proxy.RpcClientPool

func (*App) Run 

func (a *App) Run() error

func (*App) Signal 

func (a *App) Signal()

func (*App) SignalStart 

func (a *App) SignalStart(ws *sync.WaitGroup) bool

type ConfigCenterNote 

type ConfigCenterNote = config.RemoteNode

type DiscoveryNode 

type DiscoveryNode struct {
	Addr string
	Port uint16
}

type MQConsumerSubscribe 

type MQConsumerSubscribe struct {
	Topic   string
	Tag     string
	Handler func(context.Context, ...*message.Consumer) bool
}

type NetRpcClientOption 

type NetRpcClientOption struct {
	SelectMode netRpc.ClientSelectMode
}

type NetRpcClientOptionFunc 

type NetRpcClientOptionFunc func(*NetRpcClientOption)

type ProxyConfig 

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

func (*ProxyConfig) GetCfg 

func (pc *ProxyConfig) GetCfg(key ...string) interface{}

type ProxyDBMongo 

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

func (*ProxyDBMongo) GetDB 

func (pdm *ProxyDBMongo) GetDB(name ...string) *mongo.Database

type ProxyDBMySQL 

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

func (*ProxyDBMySQL) GetDB 

func (pdm *ProxyDBMySQL) GetDB(name ...string) *sql.DB

type ProxyDBRedis 

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

func (*ProxyDBRedis) GetDB 

func (pdr *ProxyDBRedis) GetDB(name ...string) redis.Conn

type ProxyDiscovery 

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

func (*ProxyDiscovery) ClusterName 

func (pd *ProxyDiscovery) ClusterName() string

func (*ProxyDiscovery) Instance 

func (pd *ProxyDiscovery) Instance() naming_client.INamingClient

type ProxyMQ 

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

func (*ProxyMQ) SendMsg 

func (pm *ProxyMQ) SendMsg(ctx context.Context, name string, topic string, msg []byte) error

func (*ProxyMQ) SendMsgSharding 

func (pm *ProxyMQ) SendMsgSharding(ctx context.Context, name string, key string, topic string, msg []byte) error

type ProxyRpcClientPool 

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

func (*ProxyRpcClientPool) GetClient 

func (prc *ProxyRpcClientPool) GetClient(name string, serviceName string) (proxy.RpcClient, error)

func (*ProxyRpcClientPool) GetClientHash 

func (prc *ProxyRpcClientPool) GetClientHash(name string, serviceName string) (proxy.RpcClient, error)

func (*ProxyRpcClientPool) GetClientSoftState 

func (prc *ProxyRpcClientPool) GetClientSoftState(name string, serviceName string) (proxy.RpcClient, error)

type RegisterCenter 

type RegisterCenter = config.RegisterCenter

Source Files

View all Source files

Directories

Path Synopsis
db
mongo
mysql
redis
mq
client/rocket
message
option
net
http
rpc
rpc/selector

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.