streaming

type Connector interface {
	namespace.Handler

	CountEvents(ctx context.Context, namespace string, params CountEventsParams) ([]CountEventRow, error)
	ListEvents(ctx context.Context, namespace string, params ListEventsParams) ([]api.IngestedEvent, 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 ListEventsParams struct {
	ClientID       *string
	From           time.Time
	To             *time.Time
	IngestedAtFrom *time.Time
	IngestedAtTo   *time.Time
	ID             *string
	Subject        *string
	Limit          int
}

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
	ID         string
	Type       string
	Source     string
	Subject    string
	Time       time.Time
	Data       string
	IngestedAt time.Time
	StoredAt   time.Time
}