materialized_view

package

v1.0.0-beta.199 Latest Latest Go to latest Published: Mar 7, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation ¶

Index ¶

func GetMeterViewName(database string, namespace string, meterSlug string) string
type Connector
- func NewConnector(ctx context.Context, config ConnectorConfig) (*Connector, error)
type ConnectorConfig
- func (c ConnectorConfig) Validate() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 meterpkg.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 meterpkg.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 meterpkg.Meter, params streaming.ListMeterSubjectsParams) ([]string, error)

func (*Connector) QueryMeter ¶

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

func (*Connector) ValidateJSONPath ¶

func (c *Connector) ValidateJSONPath(ctx context.Context, jsonPath string) (bool, error)

type ConnectorConfig ¶

type ConnectorConfig struct {
	Logger          *slog.Logger
	ClickHouse      clickhouse.Conn
	Database        string
	EventsTableName string

	CreateOrReplaceMeter bool
	PopulateMeter        bool
	AsyncInsert          bool
	AsyncInsertWait      bool
	InsertQuerySettings  map[string]string
	QueryRawEvents       bool
	ProgressManager      progressmanager.Service
}

func (ConnectorConfig) Validate ¶

func (c ConnectorConfig) Validate() error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL