Documentation ¶
Index ¶
- Variables
- func NewFxPrinter() fx.Printer
- type FxPrinter
- type ServiceStatus
- func (s *ServiceStatus) IsRunning() bool
- func (s *ServiceStatus) MWHandleStopped(stoppedHandler gin.HandlerFunc) gin.HandlerFunc
- func (s *ServiceStatus) NewStatusAwareHandler(handler http.Handler, stoppedHandler http.Handler) http.Handler
- func (s *ServiceStatus) Register(lc fx.Lifecycle)
- func (s *ServiceStatus) Start()
- func (s *ServiceStatus) Stop()
- type SysSchema
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultGRPCConnectParams = grpc.ConnectParams{ Backoff: backoff.Config{ BaseDelay: 100 * time.Millisecond, Multiplier: 1.6, Jitter: 0.2, MaxDelay: 3 * time.Second, }, MinConnectTimeout: 5 * time.Second, } DefaultGRPCKeepaliveParams = keepalive.ClientParameters{ Time: 10 * time.Second, Timeout: 3 * time.Second, PermitWithoutStream: false, } )
View Source
var DefaultGRPCDialOptions = []grpc.DialOption{ grpc.WithConnectParams(DefaultGRPCConnectParams), }
Functions ¶
func NewFxPrinter ¶
Types ¶
type ServiceStatus ¶
type ServiceStatus int32
func NewServiceStatus ¶
func NewServiceStatus() *ServiceStatus
func (*ServiceStatus) IsRunning ¶
func (s *ServiceStatus) IsRunning() bool
func (*ServiceStatus) MWHandleStopped ¶
func (s *ServiceStatus) MWHandleStopped(stoppedHandler gin.HandlerFunc) gin.HandlerFunc
func (*ServiceStatus) NewStatusAwareHandler ¶
func (*ServiceStatus) Register ¶
func (s *ServiceStatus) Register(lc fx.Lifecycle)
func (*ServiceStatus) Start ¶
func (s *ServiceStatus) Start()
func (*ServiceStatus) Stop ¶
func (s *ServiceStatus) Stop()
type SysSchema ¶
type SysSchema struct {
// contains filtered or unexported fields
}
func NewSysSchema ¶
func NewSysSchema() *SysSchema
func ProvideSysSchema ¶
Click to show internal directories.
Click to hide internal directories.