storage

type Client interface {
	WriteHistory(ctx context.Context, req *History) error
	ReadHistories(ctx context.Context, req *HistoryFilter) ([]History, error)
}

type ErrorDetail struct {
	Err          string              `db:"err"           json:"err"`
	Code         errorx.Code         `db:"code"          json:"code"`
	Fields       errorx.Fields       `db:"fields"        json:"fields"`
	OpTraces     []errorx.Op         `db:"op_traces"     json:"op_traces"`
	Message      errorx.Message      `db:"message"       json:"message"`
	Line         errorx.Line         `db:"line"          json:"line"`
	MetricStatus errorx.MetricStatus `db:"metric_status" json:"metric_status"`
}

type History struct {
	ID          string          `db:"id"           json:"id"`
	CreatedAt   time.Time       `db:"created_at"   json:"created_at"`
	Name        string          `db:"name"         json:"name"`
	Status      string          `db:"status"       json:"status"`
	StatusCode  int64           `db:"status_code"  json:"status_code"`
	StartedAt   time.Time       `db:"started_at"   json:"started_at"`
	FinishedAt  time.Time       `db:"finished_at"  json:"finished_at"`
	Latency     int64           `db:"latency"      json:"latency"`
	LatencyText string          `db:"latency_text" json:"latency_text"`
	Error       ErrorDetail     `db:"error"        json:"error"`
	Metadata    HistoryMetadata `db:"metadata"     json:"metadata"`
}

type HistoryFilter struct {
	Order         string  `db:"order"          json:"order"`
	Limit         int     `db:"limit"          json:"limit"`
	StartingAfter *string `db:"starting_after" json:"starting_after"`
	EndingBefore  *string `db:"ending_before"  json:"ending_before"`
}

type HistoryMetadata struct {
	MachineID  string `db:"machine_id"   json:"machine_id"`
	EntryID    int64  `db:"entry_id"     json:"entry_id"`
	Wave       int64  `db:"wave"         json:"wave"`
	TotalWave  int64  `db:"total_wave"   json:"total_wave"`
	IsLastWave bool   `db:"is_last_wave" json:"is_last_wave"`
}

type NoopClient struct{}

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