server

Documentation

Index

• type Server
  • func New(log logrus.FieldLogger, wrapper wrapper) *Server
  • func (s *Server) CheckStatus(_ context.Context, _ *pb.CheckStatusRequest) (*pb.CheckStatusResponse, error)
  • func (s *Server) InitForcefulShutdown(_ context.Context, _ *pb.InitForcefulShutdownRequest) (*pb.InitForcefulShutdownResponse, error)
  • func (s *Server) InitGracefulShutdown(_ context.Context, req *pb.InitGracefulShutdownRequest) (*pb.InitGracefulShutdownResponse, error)
  • func (s *Server) Listen(listener net.Listener)
  • func (s *Server) Stop()

Types

type Server

type Server struct {
	pb.UnimplementedProcessWrapperServer
	// contains filtered or unexported fields
}

func New

func New(log logrus.FieldLogger, wrapper wrapper) *Server

func (*Server) CheckStatus

func (s *Server) CheckStatus(_ context.Context, _ *pb.CheckStatusRequest) (*pb.CheckStatusResponse, error)

func (*Server) InitForcefulShutdown

func (s *Server) InitForcefulShutdown(_ context.Context, _ *pb.InitForcefulShutdownRequest) (*pb.InitForcefulShutdownResponse, error)

func (*Server) InitGracefulShutdown

func (s *Server) InitGracefulShutdown(
	_ context.Context,
	req *pb.InitGracefulShutdownRequest,
) (*pb.InitGracefulShutdownResponse, error)

func (*Server) Listen

func (s *Server) Listen(listener net.Listener)

func (*Server) Stop

func (s *Server) Stop()