runnable

type GroupRunner struct {
	ShutdownTimeout time.Duration
	// contains filtered or unexported fields
}

type Logger interface {
	// Warnf logs with a warning level.
	Warnf(format string, args ...interface{})

	// Infof logs with an info level.
	Infof(format string, args ...interface{})

	// Debugf logs with a debug level.
	Debugf(format string, args ...interface{})
}

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

type PeriodicOptions struct {
	Period time.Duration
}

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

type RestartOptions struct {
	RestartLimit int // Number of restart after which the runnable will not be restarted.
	CrashLimit   int // Number of crash after which the runnable will not be restarted.

	BackoffSleep      time.Duration // Time to wait before restarting.
	CrashBackoffSleep time.Duration // Time to wait before restarting after a crash

}

type Runnable interface {
	Run(context.Context) error
}