cli

type CloudAuthConfig struct {
	ClientID string `json:"client-id"`
	Region   string `json:"region"`
	Email    string `json:"email"`
	Password string `json:"password"`
}

type Command struct {
	Queryer Queryer `json:"-"`

	Config *Config `json:"config"`

	// Commands contains optional commands provided via one or more `-c` (or
	// `--command`) flags. If this is non-empty, the cli will run in
	// non-interactive mode; i.e. it will quit after the command is complete.
	Commands []string `json:"commands"`

	// Files contains optional files provided via one or more `-f` (or `--file`)
	// flags. If this is non-empty, the cli will run in non-interactive mode;
	// i.e. it will quit after the command is complete.
	Files []string `json:"files"`
	// contains filtered or unexported fields
}

type Config struct {
	Host string `json:"host"`
	Port string `json:"port"`

	OrganizationID string `json:"org-id"`
	Database       string `json:"db"`

	// CloudAuth
	CloudAuth CloudAuthConfig `json:"cloud-auth"`

	// Kafka
	KafkaConfig string `json:"kafka-config"`

	HistoryPath string `json:"history-path"`

	// CSV (Comma-Separated Values) table output mode.
	CSV bool `json:"csv"`

	// PSet takes one or more pset arguments of the form: `--pset=VAR[=ARG]`.
	PSets []string `json:"pset"`
}

type Queryer interface {
	Query(org string, db string, sql io.Reader) (*featurebase.WireQueryResponse, error)
}