package test import ( "net/http" "strings" "github.com/pilosa/pilosa" "github.com/pilosa/pilosa/pql" ) // Executor represents a test wrapper for pilosa.Executor. type Executor struct { *pilosa.Executor } var remoteClient *http.Client func init() { remoteClient = pilosa.GetHTTPClient(nil) } // NewExecutor returns a new instance of Executor. // The executor always matches the hostname of the first cluster node. func NewExecutor(holder *pilosa.Holder, cluster *pilosa.Cluster) *Executor { executor := pilosa.NewExecutor(remoteClient) e := &Executor{Executor: executor} e.Holder = holder e.Cluster = cluster e.Scheme = cluster.Nodes[0].Scheme e.Host = cluster.Nodes[0].Host return e } // MustParse parses s into a PQL query. Panic on error. func MustParse(s string) *pql.Query { q, err := pql.NewParser(strings.NewReader(s)).Parse() if err != nil { panic(err) } return q }