package consul import ( "fmt" "github.com/armon/go-metrics" "github.com/hashicorp/consul/consul/structs" ) // Health endpoint is used to query the health information type Health struct { srv *Server } // ChecksInState is used to get all the checks in a given state func (h *Health) ChecksInState(args *structs.ChecksInStateRequest, reply *structs.IndexedHealthChecks) error { if done, err := h.srv.forward("Health.ChecksInState", args, args, reply); done { return err } // Get the state specific checks state := h.srv.fsm.State() return h.srv.blockingRPC( &args.QueryOptions, &reply.QueryMeta, state.GetQueryWatch("ChecksInState"), func() error { index, checks, err := state.ChecksInState(args.State) if err != nil { return err } reply.Index, reply.HealthChecks = index, checks if err := h.srv.filterACL(args.Token, reply); err != nil { return err } return h.srv.sortNodesByDistanceFrom(args.Source, reply.HealthChecks) }) } // NodeChecks is used to get all the checks for a node func (h *Health) NodeChecks(args *structs.NodeSpecificRequest, reply *structs.IndexedHealthChecks) error { if done, err := h.srv.forward("Health.NodeChecks", args, args, reply); done { return err } // Get the node checks state := h.srv.fsm.State() return h.srv.blockingRPC( &args.QueryOptions, &reply.QueryMeta, state.GetQueryWatch("NodeChecks"), func() error { index, checks, err := state.NodeChecks(args.Node) if err != nil { return err } reply.Index, reply.HealthChecks = index, checks return h.srv.filterACL(args.Token, reply) }) } // ServiceChecks is used to get all the checks for a service func (h *Health) ServiceChecks(args *structs.ServiceSpecificRequest, reply *structs.IndexedHealthChecks) error { // Reject if tag filtering is on if args.TagFilter { return fmt.Errorf("Tag filtering is not supported") } // Potentially forward if done, err := h.srv.forward("Health.ServiceChecks", args, args, reply); done { return err } // Get the service checks state := h.srv.fsm.State() return h.srv.blockingRPC( &args.QueryOptions, &reply.QueryMeta, state.GetQueryWatch("ServiceChecks"), func() error { index, checks, err := state.ServiceChecks(args.ServiceName) if err != nil { return err } reply.Index, reply.HealthChecks = index, checks if err := h.srv.filterACL(args.Token, reply); err != nil { return err } return h.srv.sortNodesByDistanceFrom(args.Source, reply.HealthChecks) }) } // ServiceNodes returns all the nodes registered as part of a service including health info func (h *Health) ServiceNodes(args *structs.ServiceSpecificRequest, reply *structs.IndexedCheckServiceNodes) error { if done, err := h.srv.forward("Health.ServiceNodes", args, args, reply); done { return err } // Verify the arguments if args.ServiceName == "" { return fmt.Errorf("Must provide service name") } // Get the nodes state := h.srv.fsm.State() err := h.srv.blockingRPC( &args.QueryOptions, &reply.QueryMeta, state.GetQueryWatch("CheckServiceNodes"), func() error { var index uint64 var nodes structs.CheckServiceNodes var err error if args.TagFilter { index, nodes, err = state.CheckServiceTagNodes(args.ServiceName, args.ServiceTag) } else { index, nodes, err = state.CheckServiceNodes(args.ServiceName) } if err != nil { return err } reply.Index, reply.Nodes = index, nodes if err := h.srv.filterACL(args.Token, reply); err != nil { return err } return h.srv.sortNodesByDistanceFrom(args.Source, reply.Nodes) }) // Provide some metrics if err == nil { metrics.IncrCounter([]string{"consul", "health", "service", "query", args.ServiceName}, 1) if args.ServiceTag != "" { metrics.IncrCounter([]string{"consul", "health", "service", "query-tag", args.ServiceName, args.ServiceTag}, 1) } if len(reply.Nodes) == 0 { metrics.IncrCounter([]string{"consul", "health", "service", "not-found", args.ServiceName}, 1) } } return err }