streaming

type Connector interface {
	namespace.Handler

	CountEvents(ctx context.Context, namespace string, params CountEventsParams) ([]CountEventRow, error)
	ListEvents(ctx context.Context, namespace string, params meterevent.ListEventsParams) ([]RawEvent, error)
	ListEventsV2(ctx context.Context, params meterevent.ListEventsV2Params) ([]RawEvent, error)
	CreateMeter(ctx context.Context, namespace string, meter meter.Meter) error
	UpdateMeter(ctx context.Context, namespace string, meter meter.Meter) error
	DeleteMeter(ctx context.Context, namespace string, meter meter.Meter) error
	QueryMeter(ctx context.Context, namespace string, meter meter.Meter, params QueryParams) ([]meter.MeterQueryRow, error)
	ListMeterSubjects(ctx context.Context, namespace string, meter meter.Meter, params ListMeterSubjectsParams) ([]string, error)
	BatchInsert(ctx context.Context, events []RawEvent) error
	ValidateJSONPath(ctx context.Context, jsonPath string) (bool, error)
}

type CountEventRow struct {
	Count   uint64
	Subject string
}

type CountEventsParams struct {
	From time.Time
}

type ListMeterSubjectsParams struct {
	From *time.Time
	To   *time.Time
}

type QueryParams struct {
	ClientID       *string
	From           *time.Time
	To             *time.Time
	FilterSubject  []string
	FilterGroupBy  map[string][]string
	GroupBy        []string
	WindowSize     *meter.WindowSize
	WindowTimeZone *time.Location
}

type RawEvent struct {
	Namespace  string    `ch:"namespace"`
	ID         string    `ch:"id"`
	Type       string    `ch:"type"`
	Source     string    `ch:"source"`
	Subject    string    `ch:"subject"`
	Time       time.Time `ch:"time"`
	Data       string    `ch:"data"`
	IngestedAt time.Time `ch:"ingested_at"`
	StoredAt   time.Time `ch:"stored_at"`
}