in internal/mode/chunk/chunk.go [101:127]
func parseConnection(adapterType AdapterType, connectionJSON string) (Connection, error) {
switch adapterType {
case PostgreSQLAdapter:
result, err := decodeConnection[PostgreSQLConnection](connectionJSON, adapterType)
if err != nil {
return nil, err
}
return result, nil
case OpenSearchAdapter:
result, err := decodeConnection[OpenSearchConnection](connectionJSON, adapterType)
if err != nil {
return nil, err
}
return result, nil
case ElasticsearchAdapter:
result, err := decodeConnection[ElasticsearchConnection](connectionJSON, adapterType)
if err != nil {
return nil, err
}
return result, nil
default:
return nil, fmt.Errorf("unknown adapter: %s", adapterType)
}
}