Documentation ¶
Index ¶
Constants ¶
const ( AppTypeGrpc = 1 AppTypeCron = 2 AppTypeQueue = 3 AppTypeHttp = 4 )
const (
Version = "1.2.2"
)
Variables ¶
var AccessLogger log.LoggerContextIface
AccessLogger is a global vars for application to log access log
var AliRocketMQSetting *setting.AliRocketMQSettingS
AliRocketMQSetting
var BusinessLogger log.LoggerContextIface
BusinessLogger is a global vars for application to log business log
var ErrLogger log.LoggerContextIface
ErrLogger is a global vars for application to log err msg.
var FrameworkLogger log.LoggerContextIface
FrameworkLogger is a global var for Framework log
var GORM_DBEngine *gorm.DB
GORM_DBEngine is a global vars for mysql connect.
var LoggerSetting *setting.LoggerSettingS
LoggerSetting log setting
var MongoDBClient *qmgo.QmgoClient
MongoDBClient is qmgo-client for mongodb.
var MongoDBSetting *setting.MongoDBSettingS
MongoDBSetting maps config section mongodb.
var MysqlSetting *setting.MysqlSettingS
MysqlSetting maps config section "kelvinsMysql.*" from apollo.
var QueueAMQPSetting *setting.QueueAMQPSettingS
QueueAMQPSetting maps config section
var QueueAliAMQPSetting *setting.QueueAliAMQPSettingS
QueueAliAMQPSetting maps config section "kelvinsQueueAliAMQP.*" from apollo.
var QueueRedisSetting *setting.QueueRedisSettingS
QueueRedisSetting maps config section "kelvinsQueueRedis.*" from apollo.
var QueueServerSetting *setting.QueueServerSettingS
QueueServerSetting maps config section "kelvinsQueueServer.*" from apollo.
var RedisConn *redis.Pool
RedisConn is a global vars for redis connect.
var RedisSetting *setting.RedisSettingS
MysqlSetting maps config section "kelvinsRedis.*" from apollo.
var ServerSetting *setting.ServerSettingS
ServerSetting maps config section "kelvinsServer.*" from apollo.
var XORM_DBEngine xorm.EngineInterface
XORM_DBEngine is a global vars for mysql connect.
Functions ¶
This section is empty.
Types ¶
type Application ¶
type Application struct { Name string Type int32 LoggerRootPath string LoggerLevel string LoadConfig func() error SetupVars func() error }
Application ...
type CronApplication ¶
type CronApplication struct { *Application CronLogger *log.LoggerContext Cron *cron.Cron GenCronJobs func() []*CronJob EventServer *event.EventServer RegisterEventHandler func(event.EventServerIface) error }
CronApplication ...
type CronJob ¶
type CronJob struct { Name string // Job unique name Spec string // Job specification Job func() // Job func }
CronJob warps job define.
type GRPCApplication ¶
type GRPCApplication struct { *Application Port int64 GRPCServer *grpc.Server GatewayServeMux *runtime.ServeMux Mux *http.ServeMux HttpServer *http.Server TlsConfig *tls.Config GKelvinsLogger *log.LoggerContext GSysErrLogger *log.LoggerContext UnaryServerInterceptors []grpc.UnaryServerInterceptor ServerOptions []grpc.ServerOption RegisterGRPCServer func(*grpc.Server) error RegisterGateway func(context.Context, *runtime.ServeMux, string, []grpc.DialOption) error RegisterHttpRoute func(*http.ServeMux) error EventServer *event.EventServer RegisterEventProducer func(event.ProducerIface) error }
GRPCApplication ...
type HTTPApplication ¶
type HTTPApplication struct { *Application Port int64 TraceLogger *log.LoggerContext TlsConfig *tls.Config Mux *http.ServeMux HttpServer *http.Server RegisterHttpRoute func(*http.ServeMux) error EventServer *event.EventServer RegisterEventProducer func(event.ProducerIface) error }
HTTPApplication ...
type QueueApplication ¶
type QueueApplication struct { *Application QueueLogger *log.LoggerContext QueueServer *queue.MachineryQueue EventServer *event.EventServer GetNamedTaskFuncs func() map[string]interface{} RegisterEventHandler func(event.EventServerIface) error }
QueueApplication ...