app

Dec 20, 2022

Changes in this version

+ func Recover()

Mar 30, 2022

Changes in this version

+ var ConfigFilename = "config.json"

+ var DefaultAdminPort = "9000"

+ var DefaultGracePeriod = 3 * time.Second

+ var DefaultShutdownTimeout = 5 * time.Second

+ func ErrorPolicyString(p ErrorPolicy) string

+ func NewDefaultApp(ctx context.Context) (err error)

+ func RegisterShutdownHandler(sh *ShutdownHandler)

+ func RunAndWait(f MainLoopFunc)

+ func SetupConfig(config interface{})

+ func Shutdown(ctx context.Context) error

+ type App struct

+ GracePeriod time.Duration

+ Healthy ProbeGroup

+ Ready ProbeGroup

+ ShutdownTimeout time.Duration

+ func MustNew(ctx context.Context, adminPort string) *App

+ func New(ctx context.Context, adminPort string) (*App, error)

+ func (a *App) RegisterShutdownHandler(sh *ShutdownHandler)

+ func (a *App) RunAndWait(mainLoop MainLoopFunc)

+ func (a *App) Shutdown(ctx context.Context) (err error)

+ type ErrorPolicy int

+ const ErrorPolicyAbort

+ const ErrorPolicyFatal

+ const ErrorPolicyPanic

+ const ErrorPolicyWarn

+ type MainLoopFunc func() error

+ type Probe struct

+ func (p *Probe) IsOk() bool

+ func (p *Probe) Set(ok bool)

+ func (p *Probe) SetNotOk()

+ func (p *Probe) SetOk()

+ type ProbeGroup struct

+ func HealthinessProbeGroup() *ProbeGroup

+ func NewProbeGroup() ProbeGroup

+ func ReadinessProbeGoup() *ProbeGroup

+ func (m *ProbeGroup) CheckProbes() (bool, string)

+ func (m *ProbeGroup) MustNewProbe(name string, ok bool) Probe

+ func (m *ProbeGroup) NewProbe(name string, ok bool) (Probe, error)

+ type ShutdownFunc func(context.Context) error

+ type ShutdownHandler struct

+ Handler ShutdownFunc

+ Name string

+ Policy ErrorPolicy

+ Priority ShutdownPriority

+ Timeout time.Duration

+ func (sh *ShutdownHandler) Execute(ctx context.Context) error

+ type ShutdownPriority uint8