clickhouse

package
v0.1.4 Latest Latest
Warning

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

Go to latest
Published: Sep 2, 2025 License: Apache-2.0 Imports: 5 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 AddNonColumnFieldsToExtras added in v0.1.0

func AddNonColumnFieldsToExtras(event *cloudevent.CloudEventHeader) map[string]any

AddNonColumnFieldsToExtras adds fields without dedicated columns to Extras

func CloudEventToObjectKey added in v0.0.3

func CloudEventToObjectKey(event *cloudevent.CloudEventHeader) string

CloudEventToObjectKey generates a unique key for storing cloud events. The key is composed of the event's key with a hex prefix derived from the hash of the key.

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 RestoreNonColumnFields added in v0.1.0

func RestoreNonColumnFields(event *cloudevent.CloudEventHeader)

RestoreNonColumnFields restores non-column fields from Extras

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

Jump to

Keyboard shortcuts

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