Versions in this module Expand all Collapse all v1 v1.0.1 Dec 23, 2023 Changes in this version + const AppTypeCron + const AppTypeGrpc + const AppTypeHttp + const AppTypeQueue + const HttpMetadataHandleTime + const HttpMetadataPowerBy + const HttpMetadataRequestId + const HttpMetadataResponseTime + const HttpMetadataServiceName + const HttpMetadataServiceNode + const RPCMetadataHandleTime + const RPCMetadataPowerBy + const RPCMetadataRequestId + const RPCMetadataResponseTime + const RPCMetadataServiceName + const RPCMetadataServiceNode + const ResponseTimeLayout + const Version + var AccessLogger log.LoggerContextIface + var AliRocketMQSetting *setting.AliRocketMQSettingS + var AppCloseCh <-chan struct + var AppName string + var AppTypeText = map[int32]string + var BusinessLogger log.LoggerContextIface + var ErrLogger log.LoggerContextIface + var EventServerAliRocketMQ *event.EventServer + var FrameworkLogger log.LoggerContextIface + var G2CacheEngine *g2cache.G2Cache + var G2CacheSetting *setting.G2CacheSettingS + var GORM_DBEngine *gorm.DB + var GPool *goroutine.Pool + var GPoolSetting *setting.GPoolSettingS + var HttpRateLimitSetting *setting.HttpRateLimitSettingS + var HttpServerSetting *setting.HttpServerSettingS + var JwtSetting *setting.JwtSettingS + var LoggerSetting *setting.LoggerSettingS + var MongoDBClient *qmgo.QmgoClient + var MongoDBSetting *setting.MongoDBSettingS + var MysqlSetting *setting.MysqlSettingS + var PIDFile string + var QueueAMQPSetting *setting.QueueAMQPSettingS + var QueueAliAMQPSetting *setting.QueueAliAMQPSettingS + var QueueRedisSetting *setting.QueueRedisSettingS + var QueueServerAMQP *queue.MachineryQueue + var QueueServerAliAMQP *queue.MachineryQueue + var QueueServerRedis *queue.MachineryQueue + var QueueServerSetting *setting.QueueServerSettingS + var RPCAuthSetting *setting.RPCAuthSettingS + var RPCClientKeepaliveParamsSetting *setting.RPCClientKeepaliveParamsS + var RPCRateLimitSetting *setting.RPCRateLimitSettingS + var RPCServerKeepaliveEnforcementPolicySetting *setting.RPCServerKeepaliveEnforcementPolicyS + var RPCServerKeepaliveParamsSetting *setting.RPCServerKeepaliveParamsS + var RPCServerParamsSetting *setting.RPCServerParamsS + var RPCTransportBufferSetting *setting.RPCTransportBufferS + var RedisConn *redis.Pool + var RedisSetting *setting.RedisSettingS + var ServerSetting *setting.ServerSettingS + var XORM_DBEngine xorm.EngineInterface + type Application struct + Environment string + LoadConfig func() error + LoggerLevel string + LoggerRootPath string + Name string + SetupVars func() error + StopFunc func() error + Type int32 + type CronApplication struct + Cron *cron.Cron + GenCronJobs func() []*CronJob + RegisterEventHandler func(event.EventServerIface) error + RegisterEventProducer func(event.ProducerIface) error + var CronAppInstance *CronApplication + type CronJob struct + Job func() + Name string + Spec string + type GRPCApplication struct + GKelvinsLogger log.LoggerContextIface + GRPCServer *grpc.Server + GSysErrLogger log.LoggerContextIface + GatewayServeMux *runtime.ServeMux + HealthServer *GRPCHealthServer + HttpServer *http.Server + Mux *http.ServeMux + NumServerWorkers uint32 + Port int64 + RegisterEventHandler func(event.EventServerIface) error + RegisterEventProducer func(event.ProducerIface) error + RegisterGRPCHealthHandle func(*GRPCHealthServer) + RegisterGRPCServer func(*grpc.Server) error + RegisterGateway func(context.Context, *runtime.ServeMux, string, []grpc.DialOption) error + RegisterHttpRoute func(*http.ServeMux) error + ServerOptions []grpc.ServerOption + StreamServerInterceptors []grpc.StreamServerInterceptor + TlsConfig *tls.Config + UnaryServerInterceptors []grpc.UnaryServerInterceptor + var GRPCAppInstance *GRPCApplication + type GRPCHealthServer struct + func (a *GRPCHealthServer) AuthFuncOverride(ctx context.Context, fullMethodName string) (context.Context, error) + type HTTPApplication struct + HttpServer *http.Server + Mux *http.ServeMux + Port int64 + RegisterEventHandler func(event.EventServerIface) error + RegisterEventProducer func(event.ProducerIface) error + RegisterHttpGinRoute func(*gin.Engine) + RegisterHttpRoute func(*http.ServeMux) error + TlsConfig *tls.Config + var HttpAppInstance *HTTPApplication + type QueueApplication struct + GetNamedTaskFuncs func() map[string]interface{} + QueueServerToWorker map[*queue.MachineryQueue][]*machinery.Worker + RegisterEventHandler func(event.EventServerIface) error + RegisterEventProducer func(event.ProducerIface) error + var QueueAppInstance *QueueApplication