Documentation
¶
Index ¶
- func CopyService(service *discovery.Service) *discovery.Service
- func GetOutBoundIp() string
- type Client
- func (s *Client) Delete(key string) error
- func (s *Client) Deregister() error
- func (s *Client) Get(key string) ([]byte, error)
- func (s *Client) List(key string) (map[string][]byte, error)
- func (s *Client) Register() error
- func (s *Client) Set(key string, value string) error
- func (s *Client) SetTags(tags ...string)
- type Server
- func (s *Server) Check(ctx context.Context, in *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
- func (s *Server) Resume()
- func (s *Server) SetServingStatus(service string, servingStatus healthpb.HealthCheckResponse_ServingStatus)
- func (s *Server) Shutdown()
- func (s *Server) Watch(in *healthpb.HealthCheckRequest, stream healthgrpc.Health_WatchServer) error
- type Watcher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) Deregister ¶
type Server ¶
type Server struct {
Service string
healthgrpc.UnimplementedHealthServer
// contains filtered or unexported fields
}
Server implements `service Health`.
func (*Server) Check ¶
func (s *Server) Check(ctx context.Context, in *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
Check implements `service Health`.
func (*Server) Resume ¶
func (s *Server) Resume()
Resume sets all serving status to SERVING, and configures the server to accept all future status changes.
This changes serving status for all services. To set status for a particular services, call SetServingStatus().
func (*Server) SetServingStatus ¶
func (s *Server) SetServingStatus(service string, servingStatus healthpb.HealthCheckResponse_ServingStatus)
SetServingStatus is called when need to reset the serving status of a service or insert a new service entry into the statusMap.
func (*Server) Shutdown ¶
func (s *Server) Shutdown()
Shutdown sets all serving status to NOT_SERVING, and configures the server to ignore all future status changes.
This changes serving status for all services. To set status for a particular services, call SetServingStatus().
func (*Server) Watch ¶
func (s *Server) Watch(in *healthpb.HealthCheckRequest, stream healthgrpc.Health_WatchServer) error
Watch implements `service Health`.
Source Files
Click to show internal directories.
Click to hide internal directories.