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
	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
	IsError bool
}

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