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) QueryMeter(ctx context.Context, namespace string, meter *models.Meter, ...) ([]*models.MeterValue, error)
• type ClickhouseConnectorConfig
• type SinkConfig

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

func (c *ClickhouseConnector) QueryMeter(ctx context.Context, namespace string, meter *models.Meter, params *streaming.GetValuesParams) ([]*models.MeterValue, error)

type ClickhouseConnectorConfig

type ClickhouseConnectorConfig struct {
	Logger       *slog.Logger
	KafkaConnect sink.KafkaConnect
	ClickHouse   clickhouse.Conn
	Database     string
	SinkConfig   SinkConfig
}

type SinkConfig

type SinkConfig struct {
	Database string
	Hostname string
	Port     int
	SSL      bool
	Username string
	Password string
}