appmgr

package

Go to main page

Versions in this module

v0

v0.3.3

Jan 8, 2025

v0.3.2

Jan 8, 2025

v0.3.1

Jan 7, 2025

v0.3.0

Jul 10, 2024

Changes in this version

type App

+ GetIDGenerator func() uniqueid.Generator

type AppConfig

+ IDGenerator IDGeneratorConfig

+ type IDGeneratorConfig struct

+ Key string

+ ServiceID int

v0.2.3

Jul 9, 2024

Changes in this version

+ const DefaultBufferSize

+ const DefaultWindowSize

v0.2.2

Jun 4, 2024

v0.2.1

May 23, 2024

Changes in this version

+ const MaxMsgSize

v0.2.0

Apr 12, 2024

v0.1.0

Jul 28, 2023

Changes in this version

+ const KeepaliveMinTime

+ const KeepaliveTime

+ const KeepaliveTimeout

+ const ServerConnMaxAge

+ const ServerConnMaxAgeGrace

+ const ServerConnMaxIdle

+ func SetContextService(ctx context.Context, service Service) context.Context

+ func SetGinContextService(ctx *gin.Context, service Service)

+ type App interface

+ AddJob func(string, func(ctx context.Context) error)

+ GetCacheClient func(string) cache.Client

+ GetContext func() context.Context

+ GetDatabaseClient func(string) *gorm.DB

+ GetDatabaseSqlxClient func(string) *mssqlx.DBs

+ GetGrpcClientConn func(string) grpc.ClientConnInterface

+ GetGrpcClientConns func(string) []grpc.ClientConnInterface

+ GetPulsarClient func(string) pulsar.Client

+ GetService func(string) Service

+ Init func()

+ RegisterMiddleware func(string, Middleware)

+ Run func() error

+ RunOrExit func()

+ func NewApp(info *AppInfo) App

+ type AppConfig struct

+ Caches []cache.Config

+ Clients ClientsConfig

+ Databases []database.Config

+ Jobs []string

+ Name string

+ Observable ObservableConfig

+ Pulsars []pulsar.Config

+ Services []ServiceConfig

+ type AppInfo struct

+ Description string

+ Name string

+ Version string

+ type ClientManager interface

+ GetGrpcClientConn func(string) grpc.ClientConnInterface

+ GetGrpcClientConns func(string) []grpc.ClientConnInterface

+ type ClientsConfig struct

+ Grpc GrpcConfig

+ type DatabaseManager interface

+ GetDatabaseClient func(string) *gorm.DB

+ GetDatabaseSqlxClient func(string) *mssqlx.DBs

+ type EndpointsConfig struct

+ Grpc string

+ Http string

+ type GrpcConfig struct

+ Middlewares []interface{}

+ Servers []GrpcServerConfig

+ type GrpcSecurityConfig struct

+ Ca string

+ Cert string

+ Key string

+ func (c *GrpcSecurityConfig) Resolve()

+ type GrpcServerConfig struct

+ Endpoint string

+ Name string

+ Security GrpcSecurityConfig

+ type IContextGetter interface

+ Value func(key interface{}) interface{}

+ type Middleware interface

+ GinHandler func(map[string]interface{}) gin.HandlerFunc

+ GrpcClientInterceptor func(map[string]interface{}) (grpc.UnaryClientInterceptor, grpc.StreamClientInterceptor)

+ GrpcServerInterceptor func(map[string]interface{}) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)

+ func NewAccessControlMiddleware() Middleware

+ func NewCompressMiddleware() Middleware

+ func NewContextLoggerMiddleware() Middleware

+ func NewContextTagsMiddleware() Middleware

+ func NewCorsMiddleware() Middleware

+ func NewLogRequestMiddleware() Middleware

+ func NewMetricsMiddleware() Middleware

+ func NewOpenTracingMiddleware() Middleware

+ func NewRecoveryMiddleware() Middleware

+ func NewRequestValidationMiddleware() Middleware

+ func NewServiceContextMiddleware(service Service) Middleware

+ type ObservableConfig struct

+ Endpoints EndpointsConfig

+ Modules []string

+ type ObservableService interface

+ GetContext func() context.Context

+ Run func() error

+ Wait func()

+ type Service interface

+ AddHealthCheck func(name string, check health.CheckFunc)

+ GetApp func() App

+ GetContext func() context.Context

+ GetGinRouter func() gin.IRoutes

+ GetGrpcChannelClient func() grpc.ClientConnInterface

+ GetGrpcEndpoint func() string

+ GetGrpcServiceRegistrar func() grpc.ServiceRegistrar

+ GetHttpEndpoint func() string

+ GetName func() string

+ GetServeMux func() *runtime.ServeMux

+ Run func() error

+ Wait func()

+ func GetContextService(ctx IContextGetter) Service

+ type ServiceConfig struct

+ Endpoints EndpointsConfig

+ Middlewares []interface{}

+ Name string

+ Security ServiceSecurityConfig

+ type ServiceSecurityConfig struct

+ Grpc GrpcSecurityConfig

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL