runtime

Documentation

Index

• type Application
  • func NewConfig() *Application
  • func (a *Application) ArpcClientRegistry() reg.IRegistry[*arpc.Client]
  • func (a *Application) ArpcServerRegistry() reg.IRegistry[*arpc.Server]
  • func (a *Application) BotRegistry() reg.IRegistry[*telebot.Bot]
  • func (a *Application) CacheRegistry() reg.IRegistry[cacheLib.ICache]
  • func (a *Application) CasBinRegistry() reg.IRegistry[*casbin.SyncedEnforcer]
  • func (a *Application) Config(ctx context.Context, key string) *gvar.Var
  • func (a *Application) ConfigRegister() reg.IRegistry[*gcfg.Config]
  • func (a *Application) CronRegistry() reg.IRegistry[cron.ICron]
  • func (a *Application) ErlangNodeRegistry() reg.IRegistry[*erlang.Node]
  • func (a *Application) GetQueueMessage(id, routingKey string, value map[string]interface{}) (messageLib.IMessage, error)
  • func (a *Application) GrpcRegistry() reg.IRegistry[*grpcx.GrpcServer]
  • func (a *Application) JwtRegister() reg.IRegistry[*jwt.GfJWTMiddleware]
  • func (a *Application) Lang(ctx context.Context, langKey string) string
  • func (a *Application) LanguageRegister() reg.IRegistry[*gi18n.Manager]
  • func (a *Application) LockerRegistry() reg.IRegistry[lockerLib.ILocker]
  • func (a *Application) MemoryTaskRegister() reg.IRegistry[task.MemoryService]
  • func (a *Application) MetricsRegister() reg.IRegistry[*metrics.Monitor]
  • func (a *Application) QueueRegistry() reg.IRegistry[queueLib.IQueue]
  • func (a *Application) RabbitTaskRegister() reg.IRegistry[task.RabbitMqService]
  • func (a *Application) RiakRegister() reg.IRegistry[*goriak.Session]
  • func (a *Application) RocketTaskRegister() reg.IRegistry[task.RocketMqService]
  • func (a *Application) SenderRegistry() reg.IRegistry[send.ISender[send.ISendMsg]]
  • func (a *Application) ServerRegistry() reg.IRegistry[*ghttp.Server]
  • func (a *Application) StateRegistry() reg.IRegistry[bucket.IState]
  • func (a *Application) TaskRegister() reg.IRegistry[task.TasksService]
  • func (a *Application) TusUploaderRegister() reg.IRegistry[*tus.Uploader]
  • func (a *Application) WebSocketRegister() reg.IRegistry[*ws.Instance]

Types

type Application

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

func NewConfig

func NewConfig() *Application

NewConfig 默认值

func (*Application) ArpcClientRegistry

func (a *Application) ArpcClientRegistry() reg.IRegistry[*arpc.Client]

func (*Application) ArpcServerRegistry

func (a *Application) ArpcServerRegistry() reg.IRegistry[*arpc.Server]

func (*Application) BotRegistry

func (a *Application) BotRegistry() reg.IRegistry[*telebot.Bot]

func (*Application) CacheRegistry

func (a *Application) CacheRegistry() reg.IRegistry[cacheLib.ICache]

func (*Application) CasBinRegistry

func (a *Application) CasBinRegistry() reg.IRegistry[*casbin.SyncedEnforcer]

func (*Application) Config

func (a *Application) Config(ctx context.Context, key string) *gvar.Var

func (*Application) ConfigRegister

func (a *Application) ConfigRegister() reg.IRegistry[*gcfg.Config]

func (*Application) CronRegistry

func (a *Application) CronRegistry() reg.IRegistry[cron.ICron]

func (*Application) ErlangNodeRegistry

func (a *Application) ErlangNodeRegistry() reg.IRegistry[*erlang.Node]

func (*Application) GetQueueMessage

func (a *Application) GetQueueMessage(id, routingKey string, value map[string]interface{}) (messageLib.IMessage, error)

GetQueueMessage 获取队列需要用的message

func (*Application) GrpcRegistry

func (a *Application) GrpcRegistry() reg.IRegistry[*grpcx.GrpcServer]

func (*Application) JwtRegister

func (a *Application) JwtRegister() reg.IRegistry[*jwt.GfJWTMiddleware]

func (*Application) Lang

func (a *Application) Lang(ctx context.Context, langKey string) string

func (*Application) LanguageRegister

func (a *Application) LanguageRegister() reg.IRegistry[*gi18n.Manager]

func (*Application) LockerRegistry

func (a *Application) LockerRegistry() reg.IRegistry[lockerLib.ILocker]

func (*Application) MemoryTaskRegister

func (a *Application) MemoryTaskRegister() reg.IRegistry[task.MemoryService]

func (*Application) MetricsRegister

func (a *Application) MetricsRegister() reg.IRegistry[*metrics.Monitor]

func (*Application) QueueRegistry

func (a *Application) QueueRegistry() reg.IRegistry[queueLib.IQueue]

func (*Application) RabbitTaskRegister

func (a *Application) RabbitTaskRegister() reg.IRegistry[task.RabbitMqService]

func (*Application) RiakRegister

func (a *Application) RiakRegister() reg.IRegistry[*goriak.Session]

func (*Application) RocketTaskRegister

func (a *Application) RocketTaskRegister() reg.IRegistry[task.RocketMqService]

func (*Application) SenderRegistry

func (a *Application) SenderRegistry() reg.IRegistry[send.ISender[send.ISendMsg]]

func (*Application) ServerRegistry

func (a *Application) ServerRegistry() reg.IRegistry[*ghttp.Server]

func (*Application) StateRegistry

func (a *Application) StateRegistry() reg.IRegistry[bucket.IState]

func (*Application) TaskRegister

func (a *Application) TaskRegister() reg.IRegistry[task.TasksService]

func (*Application) TusUploaderRegister

func (a *Application) TusUploaderRegister() reg.IRegistry[*tus.Uploader]

func (*Application) WebSocketRegister

func (a *Application) WebSocketRegister() reg.IRegistry[*ws.Instance]