clickhouse

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 25, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// TableName is the name of the table in Clickhouse.
	TableName = "cloud_event"
	// SubjectColumn is the name of the subject column in Clickhouse.
	SubjectColumn = "subject"
	// TimestampColumn is the name of the timestamp column in Clickhouse.
	TimestampColumn = "event_time"
	// TypeColumn is the name of the cloud event type column in Clickhouse.
	TypeColumn = "event_type"
	// IDColumn is the name of the ID column in Clickhouse.
	IDColumn = "id"
	// SourceColumn is the name of the source column in Clickhouse.
	SourceColumn = "source"
	// ProducerColumn is the name of the producer column in Clickhouse.
	ProducerColumn = "producer"
	// DataContentTypeColumn is the name of the data content type column in Clickhouse.
	DataContentTypeColumn = "data_content_type"
	// DataVersionColumn is the name of the data version column in Clickhouse.
	DataVersionColumn = "data_version"
	// ExtraColumn is the name of the extra column in Clickhouse.
	ExtrasColumn = "extras"
	// IndexKeyColumn is the name of the index name column in Clickhouse.
	IndexKeyColumn = "index_key"

	// InsertStmt is the SQL statement for inserting a row into Clickhouse.
	InsertStmt = "INSERT INTO " + TableName + " (" +
		SubjectColumn + ", " +
		TimestampColumn + ", " +
		TypeColumn + ", " +
		IDColumn + ", " +
		SourceColumn + ", " +
		ProducerColumn + ", " +
		DataContentTypeColumn + ", " +
		DataVersionColumn + ", " +
		ExtrasColumn + ", " +
		IndexKeyColumn +
		") VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
)

Variables

This section is empty.

Functions

func CloudEventToSlice

func CloudEventToSlice(event *cloudevent.CloudEventHeader) []any

CloudEventToSlice converts a CloudEvent to an array of any for Clickhouse insertion. The order of the elements in the array match the order of the columns in the table.

func CloudEventToSliceWithKey

func CloudEventToSliceWithKey(event *cloudevent.CloudEventHeader, key string) []any

CloudEventToSliceWithKey converts a CloudEvent to an array of any for Clickhouse insertion. The order of the elements in the array match the order of the columns in the table.

func UnmarshalCloudEventSlice

func UnmarshalCloudEventSlice(jsonArray []byte) ([]any, error)

UnmarshalCloudEventSlice unmarshals a byte slice into an array of any for Clickhouse insertion.

Types

This section is empty.

Directories

Path Synopsis
Package eventrepo contains service code for gettting and managing cloudevent objects.
Package eventrepo contains service code for gettting and managing cloudevent objects.
Code generated by "clickhouse-infra" DO NOT EDIT.
Code generated by "clickhouse-infra" DO NOT EDIT.

Jump to

Keyboard shortcuts

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