materialized_view

Documentation

Index

• func GetMeterViewName(database string, namespace string, meterSlug string) string
• type Connector
  • func NewConnector(ctx context.Context, config ConnectorConfig) (*Connector, error)
  • func (c *Connector) BatchInsert(ctx context.Context, rawEvents []streaming.RawEvent) error
  • func (c *Connector) CountEvents(ctx context.Context, namespace string, params streaming.CountEventsParams) ([]streaming.CountEventRow, error)
  • func (c *Connector) CreateMeter(ctx context.Context, namespace string, meter models.Meter) error
  • func (c *Connector) CreateNamespace(ctx context.Context, namespace string) error
  • func (c *Connector) DeleteMeter(ctx context.Context, namespace string, meter models.Meter) error
  • func (c *Connector) DeleteNamespace(ctx context.Context, namespace string) error
  • func (c *Connector) ListEvents(ctx context.Context, namespace string, params streaming.ListEventsParams) ([]api.IngestedEvent, error)
  • func (c *Connector) ListMeterSubjects(ctx context.Context, namespace string, meter models.Meter, ...) ([]string, error)
  • func (c *Connector) QueryMeter(ctx context.Context, namespace string, meter models.Meter, ...) ([]models.MeterQueryRow, error)
• type ConnectorConfig
  • func (c ConnectorConfig) Validate() error

Functions

func GetMeterViewName

func GetMeterViewName(database string, namespace string, meterSlug string) string

Types

type Connector

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

Connector implements `ingest.Connector“ and `namespace.Handler interfaces.

func NewConnector

func NewConnector(ctx context.Context, config ConnectorConfig) (*Connector, error)

func (*Connector) BatchInsert

func (c *Connector) BatchInsert(ctx context.Context, rawEvents []streaming.RawEvent) error

func (*Connector) CountEvents

func (c *Connector) CountEvents(ctx context.Context, namespace string, params streaming.CountEventsParams) ([]streaming.CountEventRow, error)

func (*Connector) CreateMeter

func (c *Connector) CreateMeter(ctx context.Context, namespace string, meter models.Meter) error

func (*Connector) CreateNamespace

func (c *Connector) CreateNamespace(ctx context.Context, namespace string) error

func (*Connector) DeleteMeter

func (c *Connector) DeleteMeter(ctx context.Context, namespace string, meter models.Meter) error

func (*Connector) DeleteNamespace

func (c *Connector) DeleteNamespace(ctx context.Context, namespace string) error

func (*Connector) ListEvents

func (c *Connector) ListEvents(ctx context.Context, namespace string, params streaming.ListEventsParams) ([]api.IngestedEvent, error)

func (*Connector) ListMeterSubjects

func (c *Connector) ListMeterSubjects(ctx context.Context, namespace string, meter models.Meter, params streaming.ListMeterSubjectsParams) ([]string, error)

func (*Connector) QueryMeter

func (c *Connector) QueryMeter(ctx context.Context, namespace string, meter models.Meter, params streaming.QueryParams) ([]models.MeterQueryRow, error)

type ConnectorConfig

type ConnectorConfig struct {
	Logger               *slog.Logger
	ClickHouse           clickhouse.Conn
	Database             string
	EventsTableName      string
	Meters               meter.Repository
	CreateOrReplaceMeter bool
	PopulateMeter        bool
	AsyncInsert          bool
	AsyncInsertWait      bool
	InsertQuerySettings  map[string]string
	QueryRawEvents       bool
}

func (ConnectorConfig) Validate

func (c ConnectorConfig) Validate() error