api

func Append(ctx context.Context, dsn string, database string, schema string, table string, input io.Reader) (rowsAppended int64, bytesRead uint64, err error)

func Execute(ctx context.Context, dsn string, request ducktape.ExecuteRequest) (sql.Result, error)

func Query(ctx context.Context, dsn string, request ducktape.QueryRequest) ([]map[string]any, error)

func RegisterApiRoutes(mux *http.ServeMux)

func RegisterHealthCheckRoutes(mux *http.ServeMux)