func parseConnection()

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)
	}
}