registry

Types

FormatHandler

Format handler for a specific ClickHouse format

pub type FormatHandler {
  FormatHandler(
    name: String,
    encode: fn(List(dict.Dict(String, json.Json))) -> Result(
      String,
      String,
    ),
    decode: fn(String) -> Result(
      List(dict.Dict(String, json.Json)),
      String,
    ),
  )
}

Constructors

FormatHandler(
  name: String,
  encode: fn(List(dict.Dict(String, json.Json))) -> Result(
    String,
    String,
  ),
  decode: fn(String) -> Result(
    List(dict.Dict(String, json.Json)),
    String,
  ),
)

FormatRegistry

opaque </>

Global registry of format handlers

pub opaque type FormatRegistry

Values

decode

</>

pub fn decode(
  registry: FormatRegistry,
  format_name: String,
  data: String,
) -> Result(List(dict.Dict(String, json.Json)), String)

Decode data using the specified format

default_registry

</>

pub fn default_registry() -> FormatRegistry

Create default registry with all available format handlers Includes: JSONEachRow, TabSeparated, CSV

encode

</>

pub fn encode(
  registry: FormatRegistry,
  format_name: String,
  data: List(dict.Dict(String, json.Json)),
) -> Result(String, String)

Encode data using the specified format

get_handler

</>

pub fn get_handler(
  registry: FormatRegistry,
  format_name: String,
) -> option.Option(FormatHandler)

Get a format handler by name

list_formats

</>

pub fn list_formats(registry: FormatRegistry) -> List(String)

List all registered format names

new

</>

pub fn new() -> FormatRegistry

Create a new empty format registry

register

</>

pub fn register(
  registry: FormatRegistry,
  handler: FormatHandler,
) -> FormatRegistry