Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNodeShuttingDown = errors.New("node is shutting down") ErrSomeRequestsAreStillRunning = errors.New("some requests are still running") )
Functions ¶
This section is empty.
Types ¶
type GracefulStop ¶
type GracefulStop struct {
// contains filtered or unexported fields
}
func NewGracefulStop ¶
func NewGracefulStop() *GracefulStop
func (*GracefulStop) Acquire ¶
func (s *GracefulStop) Acquire() (Release, error)
func (*GracefulStop) CloseAndWait ¶
func (s *GracefulStop) CloseAndWait() error
func (*GracefulStop) GrpcStreamServerInterceptor ¶
func (s *GracefulStop) GrpcStreamServerInterceptor() grpc.StreamServerInterceptor
func (*GracefulStop) GrpcUnaryServerInterceptor ¶
func (s *GracefulStop) GrpcUnaryServerInterceptor() grpc.UnaryServerInterceptor
Source Files
Click to show internal directories.
Click to hide internal directories.