runnable

type CloserOptions struct {
	Delay time.Duration
}

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 ManagerOptions struct {
	ShutdownTimeout time.Duration
}

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
}

type RunnableCleanup interface {
	Runnable
	Cleanup(context.Context) error
}

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

type RunnableInit interface {
	Runnable
	Init(context.Context) error
}

type RunnableInitCleanup interface {
	Runnable
	Init(context.Context) error
	Cleanup(context.Context) error
}

type ServerWithShutdown interface {
	ListenAndServe() error
	Shutdown(ctx context.Context) error
}