clickhouse_connector

Documentation

Index

• Variables
• func GetEventsTableName(database string) string
• func GetMeterViewName(database string, namespace string, meterSlug string) string
• type ClickhouseConnector
  • func NewClickhouseConnector(config ClickhouseConnectorConfig) (*ClickhouseConnector, error)
  • func (c *ClickhouseConnector) CountEvents(ctx context.Context, namespace string, params streaming.CountEventsParams) ([]streaming.CountEventRow, 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) DeleteNamespace(ctx context.Context, namespace string) error
  • func (c *ClickhouseConnector) ListEvents(ctx context.Context, namespace string, params streaming.ListEventsParams) ([]api.IngestedEvent, error)
  • func (c *ClickhouseConnector) ListMeterSubjects(ctx context.Context, namespace string, meterSlug string, from *time.Time, ...) ([]string, error)
  • func (c *ClickhouseConnector) QueryMeter(ctx context.Context, namespace string, meterSlug string, ...) ([]models.MeterQueryRow, error)
• type ClickhouseConnectorConfig
• type MeterView

Variables

var (
	EventsTableName = "events"
)

Functions

func GetEventsTableName

func GetEventsTableName(database string) string

func GetMeterViewName

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

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) CountEvents

func (c *ClickhouseConnector) CountEvents(ctx context.Context, namespace string, params streaming.CountEventsParams) ([]streaming.CountEventRow, 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) DeleteNamespace

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

func (*ClickhouseConnector) ListEvents

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

func (*ClickhouseConnector) ListMeterSubjects

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

func (*ClickhouseConnector) QueryMeter

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

type ClickhouseConnectorConfig

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

type MeterView

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