clickhouse_multi

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

type FindEndsByMSISDNRow struct {
	EndedAt *time.Time          `ch:"ended_at" json:"ended_at"`
	TagSets []map[string]string `ch:"tag_sets" json:"tag_sets"`
}

type Querier interface {
	// Sums usage per subscriber for one provider.
	SumByProvider(ctx context.Context, provider string) ([]UsageRow, error)

	// The same shape over a different filter, so the two share one Go struct.
	SumBusySubscribers(ctx context.Context, minUnits int64) ([]UsageRow, error)

	// Sums usage for one subscriber, sharing UsageRow across files.
	SumByMSISDN(ctx context.Context, msisdnA string) ([]UsageRow, error)

	// Returns the two columns whose Go types are built out of wrappers. A pointer
	// reports no import of its own and a map reports none either — its key and
	// value can come from different packages — so this file needs "time" from
	// inside a *time.Time and nothing else brings it in.
	FindEndsByMSISDN(ctx context.Context, msisdnA string) ([]FindEndsByMSISDNRow, error)
}

type RecordType struct {
	Label string
}

type UsageRow struct {
	MSISDNA    string     `ch:"msisdn_a"    json:"msisdn_a"`
	RecordType RecordType `ch:"record_type" json:"record_type"`
	Units      int64      `ch:"units"       json:"units"`
}