Documentation
¶
Index ¶
- Constants
- func AddNonColumnFieldsToExtras(event *cloudevent.CloudEventHeader) map[string]any
- func CloudEventToObjectKey(event *cloudevent.CloudEventHeader) string
- func CloudEventToSlice(event *cloudevent.CloudEventHeader) []any
- func CloudEventToSliceWithKey(event *cloudevent.CloudEventHeader, key string) []any
- func RestoreNonColumnFields(event *cloudevent.CloudEventHeader)
- func UnmarshalCloudEventSlice(jsonArray []byte) ([]any, error)
Constants ¶
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 ¶
UnmarshalCloudEventSlice unmarshals a byte slice into an array of any for Clickhouse insertion.
Types ¶
This section is empty.