distributed

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

type Querier interface {
	// Query runs the distributed query on the provided hosts and returns a channel from
	// which the results can be read. In addition, keepalives are sent via a second channel.
	// It is the responsibility of the implementing type to close the channels.
	// This may become a requirement through the interface definitions in future versions.
	Query(ctx context.Context, queryHosts hosts.Hosts, args *query.Args) (<-chan *results.Result, <-chan struct{})
}

type QuerierAnyable interface {
	// AllHosts returns a list of all hosts / targets available to the Querier
	AllHosts() (hosts.Hosts, error)
}