run

Apr 9, 2020

Changes in this version

+ func CadenceWorkerActor(worker CadenceWorker) (execute func() error, interrupt func(error))

+ func TemporalWorkerActor(worker TemporalWorker) (execute func() error, interrupt func(error))

+ type TemporalWorker interface

+ Start func() error

+ Stop func()

Feb 24, 2020

Changes in this version

+ func CadenceWorkerRun(worker CadenceWorker) (execute func() error, interrupt func(error))

+ type CadenceWorker interface

+ Start func() error

+ Stop func()

Jan 22, 2020

Changes in this version

+ func HTTPServe(server HTTPServer, lis net.Listener, shutdownTimeout time.Duration) (execute func() error, interrupt func(error))

+ type HTTPServer interface

+ Serve func(lis net.Listener) error

+ Shutdown func(ctx context.Context) error

+ type ServeLogger interface

+ Info func(msg string, fields ...map[string]interface{})

+ type Wrapper func(execute func() error, interrupt func(error)) (func() error, func(error))

+ func LogServe(logger ServeLogger) Wrapper

Jan 13, 2020

Changes in this version

+ func GRPCServe(server GRPCServer, lis net.Listener) (execute func() error, interrupt func(error))

+ func GracefulRestart(ctx context.Context, upg Upgrader) (execute func() error, interrupt func(error))

+ type GRPCServer interface

+ GracefulStop func()

+ Serve func(lis net.Listener) error

+ type Upgrader interface

+ Exit func() <-chan struct{}

+ Ready func() error

+ Stop func()