grpc

Documentation

Index

• func GRPCLiveCheck() int
• func LivePath(path string) func(*Server)
• type Server
  • func NewCheckGRPC(options ...func(*Server)) (*Server, error)
  • func Port(s *Server) *Server
  • func ReadyPath(s *Server) *Server
  • func (h *Server) NotReady()
  • func (h *Server) Ready()
  • func (h *Server) Start() error
  • func (h *Server) Terminating() bool

Functions

func GRPCLiveCheck

func GRPCLiveCheck() int

func LivePath

func LivePath(path string) func(*Server)

Types

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewCheckGRPC

func NewCheckGRPC(options ...func(*Server)) (*Server, error)

func Port

func Port(s *Server) *Server

func ReadyPath

func ReadyPath(s *Server) *Server

func (*Server) NotReady

func (h *Server) NotReady()

NotReady sets the state to notready.

func (*Server) Ready

func (h *Server) Ready()

Ready sets the state of service to ready. State's default value is false. You have to manually enabled whenever app is ready to service requests.

func (*Server) Start

func (h *Server) Start() error

func (*Server) Terminating

func (h *Server) Terminating() bool

Terminating starts a go routine waiting for SIGINT & SIGTERM signals. Returns true when Kubernetes sends a termination signal to the pod. It is a blocking function.