store

type CountResultsRequest struct {
	Referer  string
	Response chan CountResultsResponse
}

type CountResultsResponse struct {
	Count int
	Err   error
}

type ParsedQuery struct {
	Query          int
	MeasurementId  string
	Timestamp      time.Time
	ClientIp       net.IP
	ClientLocation string
	Substrate      string
	Parameters     map[string]sql.NullString
}

type ParsedResult struct {
	Result         int
	Timestamp      time.Time
	MeasurementId  string
	Outcome        string
	Message        string
	Origin         string
	Referer        string
	ClientIp       net.IP
	ClientLocation string
	UserAgent      string
}

type Query struct {
	Id             int
	Timestamp      time.Time
	RemoteAddr     string
	RawRequest     []byte
	Task           int
	Substrate      string
	ParametersJson []byte
	ResponseBody   []byte
}

type Result struct {
	Id         int
	Timestamp  time.Time
	RemoteAddr string
	RawRequest []byte
}

type ResultsPerCountryRequest struct {
	Referer  string
	Response chan ResultsPerCountryResponse
}

type ResultsPerCountryResponse struct {
	Results map[string]int
	Err     error
}

type ResultsPerDayRequest struct {
	Referer  string
	Response chan ResultsPerDayResponse
}

type ResultsPerDayResponse struct {
	Results map[string]int
	Err     error
}

type Store interface {
	Close()
	ScheduleTaskFunctions()
	Tasks(<-chan *TaskRequest)
	WriteTasks(tasks <-chan *Task)
	WriteQueries(queries <-chan *Query)
	Queries() <-chan *Query
	UnparsedQueries() <-chan *Query
	WriteParsedQueries(queries <-chan *ParsedQuery)
	WriteResults(results <-chan *Result)
	Results() <-chan *Result
	UnparsedResults() <-chan *Result
	WriteParsedResults(results <-chan *ParsedResult)
	CountResultsForReferrer(requests <-chan CountResultsRequest)
	ResultsPerDayForReferrer(requests <-chan ResultsPerDayRequest)
	ResultsPerCountryForReferrer(requests <-chan ResultsPerCountryRequest)
	ComputeResultsTables() error
}

type Task struct {
	Id         int
	Parameters map[string]sql.NullString
}

type TaskRequest struct {
	Hints    map[string]string
	Response chan *Task
}