kkdaemon

Nov 29, 2021

Changes in this version

+ func StartDaemon(name string) error

+ func StopDaemon(name string, sig os.Signal) error

type DaemonService

+ func (s *DaemonService) StartDaemon(entity *DaemonEntity) kkpanic.Caught

+ func (s *DaemonService) StopDaemon(entity *DaemonEntity, sig os.Signal) kkpanic.Caught

Nov 28, 2021

Changes in this version

type Interval

+ func (c Interval) Duration() time.Duration

Nov 28, 2021

Changes in this version

+ const StateStart

+ func RegisterSimpleDaemon(name string, startFunc func(), stopFunc func(sig os.Signal)) error

+ func ShutdownFuture() concurrent.Future

+ func UnregisterDaemon(name string) error

+ type CronSyntax string

+ func (c CronSyntax) Next(from time.Time) time.Time

type DaemonEntity

+ Next time.Time

+ func GetDaemon(name string) *DaemonEntity

+ type DaemonService struct

+ DaemonMap sync.Map

+ StopWhenKill bool

+ func NewDaemonService() *DaemonService

+ func (s *DaemonService) GetDaemon(name string) *DaemonEntity

+ func (s *DaemonService) IsShutdown() bool

+ func (s *DaemonService) RegisterDaemon(daemon Daemon) error

+ func (s *DaemonService) ShutdownFuture() concurrent.Future

+ func (s *DaemonService) ShutdownGracefully()

+ func (s *DaemonService) Start()

+ func (s *DaemonService) Stop(sig os.Signal)

+ func (s *DaemonService) UnregisterDaemon(name string) error

+ type DefaultSchedulerDaemon struct

+ func (d *DefaultSchedulerDaemon) Loop() error

+ func (d *DefaultSchedulerDaemon) When() CronSyntax

+ type Interval time.Duration

+ func (c Interval) Next(from time.Time) time.Time

+ type Looper interface

+ Loop func() error

+ type SchedulerDaemon interface

+ When func() CronSyntax

Nov 19, 2021

Changes in this version

+ const StateRun

+ const StateStop

+ const StateWait

+ func ShutdownDone() concurrent.Future

type Daemon

+ State func() int32

type DefaultDaemon

+ func (d *DefaultDaemon) State() int32

type DefaultTimerDaemon

+ func (d *DefaultTimerDaemon) Interval() time.Duration

type TimerDaemon

+ Interval func() time.Duration

Sep 3, 2021

Changes in this version

type DefaultDaemon

+ Params map[string]interface{}

+ type DefaultTimerDaemon struct

+ func (d *DefaultTimerDaemon) FireLoopAtStart() bool

+ func (d *DefaultTimerDaemon) Loop() error

+ func (d *DefaultTimerDaemon) LoopInterval() time.Duration

+ func (d *DefaultTimerDaemon) LoopStop(sig os.Signal)

+ type TimerDaemon interface

+ FireLoopAtStart func() bool

+ Loop func() error

+ LoopInterval func() time.Duration

+ LoopStop func(sig os.Signal)

Sep 3, 2021

Changes in this version

+ var AutoStopWhenKill = true

+ func ShutdownGracefully()

+ func WaitShutdown()

Sep 3, 2021

Changes in this version

type Daemon

+ Name func() string

type DefaultDaemon

+ func (d *DefaultDaemon) Name() string

Sep 2, 2021

Changes in this version

type Daemon

+ Registered func()

type DefaultDaemon

+ func (s *DefaultDaemon) Registered()

Aug 24, 2021

Changes in this version

+ func IsShutdown() bool

Aug 24, 2021

Changes in this version

+ func Shutdown(signal os.Signal)

Aug 24, 2021

Changes in this version

+ var StopWhenKillDone = make(chan int)

Aug 11, 2021

Changes in this version

+ var DaemonMap = sync.Map

+ func RegisterDaemon(name string, order int, daemon Daemon) error

+ type Daemon interface

+ Info func() string

+ Restart func()

+ Start func()

+ Stop func(sig os.Signal)

+ type DaemonEntity struct

+ Daemon Daemon

+ Name string

+ Order int

+ type DefaultDaemon struct

+ func (s *DefaultDaemon) Info() string

+ func (s *DefaultDaemon) Restart()

+ func (s *DefaultDaemon) Start()

+ func (s *DefaultDaemon) Stop(sig os.Signal)

type PanicResult

+ Daemon Daemon

Aug 10, 2021

Changes in this version

type DefaultService

+ ServiceName string

+ ServiceOrder int

Aug 5, 2021

Changes in this version

+ func RegisterServiceInline(name string, order int, startFunc func(), stopFunc func(sig os.Signal)) error

Aug 5, 2021

Changes in this version

+ var StopWhenKill = true

Aug 3, 2021

Changes in this version

+ var ServiceMap = sync.Map

+ func RegisterService(service Service) error

+ func Start()

+ func Stop()

+ type DefaultService struct

+ func (s *DefaultService) Info() string

+ func (s *DefaultService) Name() string

+ func (s *DefaultService) Order() int

+ func (s *DefaultService) Restart()

+ func (s *DefaultService) Start()

+ func (s *DefaultService) Stop()

+ type PanicResult struct

+ Caught kkpanic.Caught

+ Service Service

+ type Service interface

+ Info func() string

+ Name func() string

+ Order func() int

+ Restart func()

+ Start func()

+ Stop func()

+ func GetService(name string) Service