clickhouse_connector

Documentation

Index

• type ClickhouseConnector
  • func NewClickhouseConnector(config ClickhouseConnectorConfig) (*ClickhouseConnector, error)
  • func (c *ClickhouseConnector) CreateMeter(ctx context.Context, namespace string, meter *models.Meter) error
  • func (c *ClickhouseConnector) CreateNamespace(ctx context.Context, namespace string) error
  • func (c *ClickhouseConnector) DeleteMeter(ctx context.Context, namespace string, meterSlug string) error
  • func (c *ClickhouseConnector) ListMeterSubjects(ctx context.Context, namespace string, meterSlug string) ([]string, error)
  • func (c *ClickhouseConnector) QueryMeter(ctx context.Context, namespace string, meterSlug string, ...) (*streaming.QueryResult, error)
• type ClickhouseConnectorConfig
• type MeterView

Types

type ClickhouseConnector

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

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

func NewClickhouseConnector

func NewClickhouseConnector(config ClickhouseConnectorConfig) (*ClickhouseConnector, error)

func (*ClickhouseConnector) CreateMeter

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

func (*ClickhouseConnector) CreateNamespace

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

func (*ClickhouseConnector) DeleteMeter

func (c *ClickhouseConnector) DeleteMeter(ctx context.Context, namespace string, meterSlug string) error

func (*ClickhouseConnector) ListMeterSubjects

func (c *ClickhouseConnector) ListMeterSubjects(ctx context.Context, namespace string, meterSlug string) ([]string, error)

func (*ClickhouseConnector) QueryMeter

func (c *ClickhouseConnector) QueryMeter(ctx context.Context, namespace string, meterSlug string, params *streaming.QueryParams) (*streaming.QueryResult, error)

type ClickhouseConnectorConfig

type ClickhouseConnectorConfig struct {
	Logger     *slog.Logger
	ClickHouse clickhouse.Conn
	Database   string
	Meters     meter.Repository
}

type MeterView

type MeterView struct {
	Slug        string
	Aggregation models.MeterAggregation
	GroupBy     []string
}