graceful

Apr 30, 2024

Changes in this version

type Process

+ func FuncProcess(fn func(context.Context) error) Process

Jul 18, 2023

Changes in this version

+ const DefaultDelay

+ const DefaultGrace

+ var ErrUnexpectedEnd = errors.New("graceful: process ended unexpectedly")

+ func Run(ctx context.Context, process Process, options ...Option) error

+ type ConcurrentGroup []Process

+ func (procs ConcurrentGroup) Run(ctx context.Context) error

+ func (procs ConcurrentGroup) Shutdown(ctx context.Context) error

+ type Option interface

+ func WithDelay(delay time.Duration) Option

+ func WithGrace(grace time.Duration) Option

+ func WithLogger(log logr.Logger) Option

+ func WithNotifyFunc(notify func()) Option

+ type OrderedGroup []Process

+ func (procs OrderedGroup) Run(ctx context.Context) error

+ func (procs OrderedGroup) Shutdown(ctx context.Context) error

+ type Process interface

+ Run func(context.Context) error

+ Shutdown func(context.Context) error

+ func GRPCServerProcess(lis net.Listener, srv GRPCServer) Process

+ func HTTPServerProcess(lis net.Listener, srv *http.Server) Process

Feb 9, 2022

Changes in this version

+ type GRPCServer interface

+ GracefulStop func()

+ Serve func(net.Listener) error

+ Stop func()

type Server

+ func FromGRPC(srv GRPCServer) Server

+ func FromHTTP(srv *http.Server) Server

Mar 31, 2021

Changes in this version

type DualServerConfig

+ func (cfg *DualServerConfig) ShuttingDown() <-chan struct{}

type ServerConfig

+ func (cfg *ServerConfig) ShuttingDown() <-chan struct{}

Jan 20, 2021

Changes in this version

+ func Contexts(ctx context.Context, log logr.Logger, delay, grace time.Duration) (context.Context, context.Context)

+ type DualServerConfig struct

+ ExternalServer Server

+ InternalServer Server

+ Logger logr.Logger

+ ShutdownDelay time.Duration

+ ShutdownGrace time.Duration

+ func (cfg *DualServerConfig) ListenAndServe(ctx context.Context, intAddr, extAddr string) error

+ func (cfg *DualServerConfig) Serve(ctx context.Context, intLis, extLis net.Listener) error

+ type Server interface

+ GracefulShutdown func(context.Context) error

+ Serve func(net.Listener) error

+ func HTTPServer(srv *http.Server) Server

+ type ServerConfig struct

+ Logger logr.Logger

+ Server Server

+ ShutdownDelay time.Duration

+ ShutdownGrace time.Duration

+ func (cfg *ServerConfig) ListenAndServe(ctx context.Context, addr string) error

+ func (cfg *ServerConfig) Serve(ctx context.Context, lis net.Listener) error