Documentation
¶
Index ¶
- Variables
- func Signals(ctx context.Context) error
- func WaitContext(ctx context.Context, runners ...Runner) error
- type GRPCAttacher
- type GRPCOpt
- type Runner
- func GRPCRunner(attacher GRPCAttacher, opts ...GRPCOpt) Runner
- func ScheduleRunner(tasks ...Task) Runner
- func Server(router http.Handler, opts ...ServerOpt) Runner
- func Ticker(interval time.Duration, runner Runner, opts ...TickerOpt) Runner
- func Worker[T any](ch <-chan T, runner WorkerHandler[T], opts ...WorkerOpt) Runner
- type ServerOpt
- type Task
- type TickerOpt
- type WorkerHandler
- type WorkerOpt
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrShutdownBySignal = eris.New("shutdown by signal")
View Source
var ErrTickerFailure = eris.New("ticker failure")
View Source
var ErrWorkerFailure = eris.New("worker failure")
Functions ¶
Types ¶
type GRPCAttacher ¶ added in v2.0.3
type GRPCAttacher interface {
AttachToGRPC(grpc.ServiceRegistrar)
}
type GRPCOpt ¶ added in v2.0.3
type GRPCOpt func(*grpcSrv)
func WithConnectionTimeout ¶ added in v2.0.3
func WithGRPCPort ¶ added in v2.0.3
type Runner ¶
func GRPCRunner ¶ added in v2.0.3
func GRPCRunner(attacher GRPCAttacher, opts ...GRPCOpt) Runner
func ScheduleRunner ¶
Click to show internal directories.
Click to hide internal directories.