health

Documentation

Index

• type Service
  • func NewService() *Service
  • func (s *Service) GetHealth(ctx context.Context, req *pbs.GetHealthRequest) (*pbs.GetHealthResponse, error)
  • func (s *Service) SetWorkerProcessInformationFunc(fn func() *pbhealth.HealthInfo) error
  • func (s *Service) StartServiceUnavailableReplies()

Types

type Service

type Service struct {
	pbs.UnsafeHealthServiceServer
	// contains filtered or unexported fields
}

func NewService

func NewService() *Service

func (*Service) GetHealth

func (s *Service) GetHealth(ctx context.Context, req *pbs.GetHealthRequest) (*pbs.GetHealthResponse, error)

func (*Service) SetWorkerProcessInformationFunc

func (s *Service) SetWorkerProcessInformationFunc(fn func() *pbhealth.HealthInfo) error

SetWorkerProcessInformationFunc sets the function that can be used to get the current worker related process information.

func (*Service) StartServiceUnavailableReplies

func (s *Service) StartServiceUnavailableReplies()

StartServiceUnavailableReplies gets returned to the caller of NewService. When invoked, we start responding to any health queries with a 503.