This is an automated email from the ASF dual-hosted git repository.
lidavidm pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-adbc.git
The following commit(s) were added to refs/heads/main by this push:
new 85644ec feat(go/adbc/driver/flightsql): add transaction and substrait
support (#467)
85644ec is described below
commit 85644ec8951420c14a11dddbe94002844222668a
Author: Matt Topol <[email protected]>
AuthorDate: Fri Feb 17 16:13:32 2023 -0500
feat(go/adbc/driver/flightsql): add transaction and substrait support (#467)
Relies on https://github.com/apache/arrow/pull/34220 for the tests to
work (that PR adds Transaction Support to the example SQLite flight sql
server)
---
go/adbc/driver/flightsql/flightsql_adbc.go | 208 ++++++++++++++++++++++--
go/adbc/driver/flightsql/flightsql_adbc_test.go | 21 ++-
go/adbc/driver/flightsql/flightsql_statement.go | 62 ++++---
go/adbc/driver/flightsql/record_reader_test.go | 3 +-
go/adbc/go.mod | 3 +-
go/adbc/go.sum | 146 +----------------
6 files changed, 248 insertions(+), 195 deletions(-)
diff --git a/go/adbc/driver/flightsql/flightsql_adbc.go
b/go/adbc/driver/flightsql/flightsql_adbc.go
index d338c5e..19ab05f 100644
--- a/go/adbc/driver/flightsql/flightsql_adbc.go
+++ b/go/adbc/driver/flightsql/flightsql_adbc.go
@@ -85,6 +85,11 @@ var (
infoDriverArrowVersion string
)
+var errNoTransactionSupport = adbc.Error{
+ Msg: "[Flight SQL] server does not report transaction support",
+ Code: adbc.StatusNotImplemented,
+}
+
func init() {
if info, ok := debug.ReadBuildInfo(); ok {
for _, dep := range info.Deps {
@@ -439,6 +444,10 @@ func getFlightClient(ctx context.Context, loc string, d
*database) (*flightsql.C
return cl, nil
}
+type support struct {
+ transactions bool
+}
+
func (d *database) Open(ctx context.Context) (adbc.Connection, error) {
cl, err := getFlightClient(ctx, d.uri.String(), d)
if err != nil {
@@ -465,8 +474,52 @@ func (d *database) Open(ctx context.Context)
(adbc.Connection, error) {
conn := client.(*flightsql.Client)
conn.Close()
}).Build()
+
+ var cnxnSupport support
+
+ info, err := cl.GetSqlInfo(ctx,
[]flightsql.SqlInfo{flightsql.SqlInfoFlightSqlServerTransaction}, d.timeout)
+ // ignore this if it fails
+ if err == nil {
+ const int32code = 3
+
+ for _, endpoint := range info.Endpoint {
+ rdr, err := doGet(ctx, cl, endpoint, cache, d.timeout)
+ if err != nil {
+ continue
+ }
+ defer rdr.Release()
+
+ for rdr.Next() {
+ rec := rdr.Record()
+ codes := rec.Column(0).(*array.Uint32)
+ values := rec.Column(1).(*array.DenseUnion)
+ int32Value :=
values.Field(int32code).(*array.Int32)
+
+ for i := 0; i < int(rec.NumRows()); i++ {
+ switch codes.Value(i) {
+ case
uint32(flightsql.SqlInfoFlightSqlServerTransaction):
+ if values.TypeCode(i) !=
int32code {
+ continue
+ }
+
+ idx := values.ValueOffset(i)
+ if
!int32Value.IsValid(int(idx)) {
+ continue
+ }
+
+ value :=
int32Value.Value(int(idx))
+ cnxnSupport.transactions =
+ value ==
int32(flightsql.SqlTransactionTransaction) ||
+ value ==
int32(flightsql.SqlTransactionSavepoint)
+ }
+ }
+ }
+ }
+ }
+
return &cnxn{cl: cl, db: d, clientCache: cache,
- hdrs: make(metadata.MD), timeouts: d.timeout}, nil
+ hdrs: make(metadata.MD), timeouts: d.timeout,
+ supportInfo: cnxnSupport}, nil
}
type cnxn struct {
@@ -476,6 +529,8 @@ type cnxn struct {
clientCache gcache.Cache
hdrs metadata.MD
timeouts timeoutOption
+ txn *flightsql.Txn
+ supportInfo support
}
var adbcToFlightSQLInfo = map[adbc.InfoCode]flightsql.SqlInfo{
@@ -554,10 +609,51 @@ func (c *cnxn) SetOption(key, value string) error {
}
c.timeouts.updateTimeout = timeout
case adbc.OptionKeyAutoCommit:
- return adbc.Error{
- Msg: "[Flight SQL] transactions not yet supported",
- Code: adbc.StatusNotImplemented,
+ autocommit := true
+ switch value {
+ case adbc.OptionValueEnabled:
+ case adbc.OptionValueDisabled:
+ autocommit = false
+ default:
+ return adbc.Error{
+ Msg: "[Flight SQL] invalid value for option "
+ key + ": " + value,
+ Code: adbc.StatusInvalidArgument,
+ }
+ }
+
+ if autocommit && c.txn == nil {
+ // no-op don't even error if the server didn't support
transactions
+ return nil
}
+
+ if !c.supportInfo.transactions {
+ return errNoTransactionSupport
+ }
+
+ ctx := metadata.NewOutgoingContext(context.Background(), c.hdrs)
+ var err error
+ if c.txn != nil {
+ if err = c.txn.Commit(ctx, c.timeouts); err != nil {
+ return adbc.Error{
+ Msg: "[Flight SQL] failed to update
autocommit: " + err.Error(),
+ Code: adbc.StatusIO,
+ }
+ }
+ }
+
+ if autocommit {
+ c.txn = nil
+ return nil
+ }
+
+ if c.txn, err = c.cl.BeginTransaction(ctx, c.timeouts); err !=
nil {
+ return adbc.Error{
+ Msg: "[Flight SQL] failed to update
autocommit: " + err.Error(),
+ Code: adbc.StatusIO,
+ }
+ }
+ return nil
+
default:
return adbc.Error{
Msg: "[Flight SQL] unknown connection option",
@@ -1263,10 +1359,29 @@ func (c *cnxn) GetTableTypes(ctx context.Context)
(array.RecordReader, error) {
// Behavior is undefined if this is mixed with SQL transaction statements.
// When not supported, the convention is that it should act as if autocommit
// is enabled and return INVALID_STATE errors.
-func (c *cnxn) Commit(_ context.Context) error {
- return adbc.Error{
- Msg: "[Flight SQL] Transaction methods are not implemented
yet",
- Code: adbc.StatusInvalidState}
+func (c *cnxn) Commit(ctx context.Context) error {
+ if c.txn == nil {
+ return adbc.Error{
+ Msg: "[Flight SQL] Cannot commit when autocommit is
enabled",
+ Code: adbc.StatusInvalidState,
+ }
+ }
+
+ if !c.supportInfo.transactions {
+ return errNoTransactionSupport
+ }
+
+ ctx = metadata.NewOutgoingContext(ctx, c.hdrs)
+ err := c.txn.Commit(ctx, c.timeouts)
+ if err != nil {
+ return adbcFromFlightStatus(err)
+ }
+
+ c.txn, err = c.cl.BeginTransaction(ctx, c.timeouts)
+ if err != nil {
+ return adbcFromFlightStatus(err)
+ }
+ return nil
}
// Rollback rolls back any pending transactions. Only used if autocommit
@@ -1275,24 +1390,91 @@ func (c *cnxn) Commit(_ context.Context) error {
// Behavior is undefined if this is mixed with SQL transaction statements.
// When not supported, the convention is that it should act as if autocommit
// is enabled and return INVALID_STATE errors.
-func (c *cnxn) Rollback(_ context.Context) error {
- return adbc.Error{
- Msg: "[Flight SQL] Transaction methods are not implemented
yet",
- Code: adbc.StatusInvalidState}
+func (c *cnxn) Rollback(ctx context.Context) error {
+ if c.txn == nil {
+ return adbc.Error{
+ Msg: "[Flight SQL] Cannot rollback when autocommit is
enabled",
+ Code: adbc.StatusInvalidState,
+ }
+ }
+
+ if !c.supportInfo.transactions {
+ return errNoTransactionSupport
+ }
+
+ ctx = metadata.NewOutgoingContext(ctx, c.hdrs)
+ err := c.txn.Rollback(ctx, c.timeouts)
+ if err != nil {
+ return adbcFromFlightStatus(err)
+ }
+
+ c.txn, err = c.cl.BeginTransaction(ctx, c.timeouts)
+ if err != nil {
+ return adbcFromFlightStatus(err)
+ }
+ return nil
}
// NewStatement initializes a new statement object tied to this connection
func (c *cnxn) NewStatement() (adbc.Statement, error) {
return &statement{
alloc: c.db.alloc,
- cl: c.cl,
clientCache: c.clientCache,
hdrs: c.hdrs.Copy(),
queueSize: 5,
timeouts: c.timeouts,
+ cnxn: c,
}, nil
}
+func (c *cnxn) execute(ctx context.Context, query string, opts
...grpc.CallOption) (*flight.FlightInfo, error) {
+ if c.txn != nil {
+ return c.txn.Execute(ctx, query, opts...)
+ }
+
+ return c.cl.Execute(ctx, query, opts...)
+}
+
+func (c *cnxn) executeSubstrait(ctx context.Context, plan
flightsql.SubstraitPlan, opts ...grpc.CallOption) (*flight.FlightInfo, error) {
+ if c.txn != nil {
+ return c.txn.ExecuteSubstrait(ctx, plan, opts...)
+ }
+
+ return c.cl.ExecuteSubstrait(ctx, plan, opts...)
+}
+
+func (c *cnxn) executeUpdate(ctx context.Context, query string, opts
...grpc.CallOption) (n int64, err error) {
+ if c.txn != nil {
+ return c.txn.ExecuteUpdate(ctx, query, opts...)
+ }
+
+ return c.cl.ExecuteUpdate(ctx, query, opts...)
+}
+
+func (c *cnxn) executeSubstraitUpdate(ctx context.Context, plan
flightsql.SubstraitPlan, opts ...grpc.CallOption) (n int64, err error) {
+ if c.txn != nil {
+ return c.txn.ExecuteSubstraitUpdate(ctx, plan, opts...)
+ }
+
+ return c.cl.ExecuteSubstraitUpdate(ctx, plan, opts...)
+}
+
+func (c *cnxn) prepare(ctx context.Context, query string, opts
...grpc.CallOption) (*flightsql.PreparedStatement, error) {
+ if c.txn != nil {
+ return c.txn.Prepare(ctx, query, opts...)
+ }
+
+ return c.cl.Prepare(ctx, query, opts...)
+}
+
+func (c *cnxn) prepareSubstrait(ctx context.Context, plan
flightsql.SubstraitPlan, opts ...grpc.CallOption)
(*flightsql.PreparedStatement, error) {
+ if c.txn != nil {
+ return c.txn.PrepareSubstrait(ctx, plan, opts...)
+ }
+
+ return c.cl.PrepareSubstrait(ctx, plan, opts...)
+}
+
// Close closes this connection and releases any associated resources.
func (c *cnxn) Close() error {
if c.cl == nil {
diff --git a/go/adbc/driver/flightsql/flightsql_adbc_test.go
b/go/adbc/driver/flightsql/flightsql_adbc_test.go
index 441de66..cdd1386 100644
--- a/go/adbc/driver/flightsql/flightsql_adbc_test.go
+++ b/go/adbc/driver/flightsql/flightsql_adbc_test.go
@@ -81,10 +81,8 @@ func (s *FlightSQLQuirks) SetupDriver(t *testing.T)
adbc.Driver {
s.middle.recordedHeaders = make(metadata.MD)
var err error
- s.done = make(chan bool)
s.mem = memory.NewCheckedAllocator(memory.DefaultAllocator)
s.s =
flight.NewServerWithMiddleware([]flight.ServerMiddleware{flight.CreateServerMiddleware(&s.middle)},
s.opts...)
- s.db, err = example.CreateDB()
require.NoError(t, err)
s.srv, err = example.NewSQLiteFlightSQLServer(s.db)
require.NoError(t, err)
@@ -93,6 +91,7 @@ func (s *FlightSQLQuirks) SetupDriver(t *testing.T)
adbc.Driver {
s.s.RegisterFlightService(flightsql.NewFlightServer(s.srv))
require.NoError(t, s.s.Init("localhost:0"))
s.s.SetShutdownOnSignals(os.Interrupt, os.Kill)
+ s.done = make(chan bool)
go func() {
defer close(s.done)
_ = s.s.Serve()
@@ -102,11 +101,15 @@ func (s *FlightSQLQuirks) SetupDriver(t *testing.T)
adbc.Driver {
}
func (s *FlightSQLQuirks) TearDownDriver(t *testing.T, _ adbc.Driver) {
+ if s.done == nil {
+ return
+ }
+
s.s.Shutdown()
<-s.done
- s.db.Close()
s.srv = nil
s.mem.AssertSize(t, 0)
+ s.done = nil
}
func (s *FlightSQLQuirks) DatabaseOptions() map[string]string {
@@ -212,7 +215,7 @@ func (s *FlightSQLQuirks) Alloc() memory.Allocator
{ return s.mem
func (s *FlightSQLQuirks) BindParameter(_ int) string { return "?" }
func (s *FlightSQLQuirks) SupportsConcurrentStatements() bool { return true
}
func (s *FlightSQLQuirks) SupportsPartitionedData() bool { return true
}
-func (s *FlightSQLQuirks) SupportsTransactions() bool { return
false }
+func (s *FlightSQLQuirks) SupportsTransactions() bool { return true
}
func (s *FlightSQLQuirks) SupportsGetParameterSchema() bool { return
false }
func (s *FlightSQLQuirks) SupportsDynamicParameterBinding() bool { return true
}
func (s *FlightSQLQuirks) GetMetadata(code adbc.InfoCode) interface{} {
@@ -237,7 +240,11 @@ func (s *FlightSQLQuirks) GetMetadata(code adbc.InfoCode)
interface{} {
}
func TestADBCFlightSQL(t *testing.T) {
- q := &FlightSQLQuirks{}
+ db, err := example.CreateDB()
+ require.NoError(t, err)
+ defer db.Close()
+
+ q := &FlightSQLQuirks{db: db}
suite.Run(t, &validation.DatabaseTests{Quirks: q})
suite.Run(t, &validation.ConnectionTests{Quirks: q})
suite.Run(t, &validation.StatementTests{Quirks: q})
@@ -248,7 +255,7 @@ func TestADBCFlightSQL(t *testing.T) {
suite.Run(t, &PartitionTests{Quirks: q})
suite.Run(t, &StatementTests{Quirks: q})
suite.Run(t, &TimeoutTestSuite{})
- suite.Run(t, &TLSTests{Quirks: &FlightSQLQuirks{}})
+ suite.Run(t, &TLSTests{Quirks: &FlightSQLQuirks{db: db}})
}
// Driver-specific tests
@@ -523,7 +530,7 @@ func (suite *StatementTests) TestSubstrait() {
suite.Require().NoError(err)
_, _, err = suite.Stmt.ExecuteQuery(context.Background())
- suite.Require().ErrorContains(err, "Substrait is not yet implemented")
+ suite.Require().ErrorContains(err, "not implemented")
var adbcError adbc.Error
suite.ErrorAs(err, &adbcError)
suite.Equal(adbc.StatusNotImplemented, adbcError.Code)
diff --git a/go/adbc/driver/flightsql/flightsql_statement.go
b/go/adbc/driver/flightsql/flightsql_statement.go
index 79f2a09..980ade5 100644
--- a/go/adbc/driver/flightsql/flightsql_statement.go
+++ b/go/adbc/driver/flightsql/flightsql_statement.go
@@ -37,11 +37,17 @@ import (
const (
OptionStatementQueueSize = "adbc.flight.sql.rpc.queue_size"
+ // Explicitly set substrait version for Flight SQL
+ // substrait *does* include the version in the serialized plan
+ // so this is not entirely necessary depending on the version
+ // of substrait and the capabilities of the server.
+ OptionStatementSubstraitVersion = "adbc.flight.sql.substrait.version"
)
type sqlOrSubstrait struct {
- sqlQuery string
- substraitPlan []byte
+ sqlQuery string
+ substraitPlan []byte
+ substraitVersion string
}
func (s *sqlOrSubstrait) setSqlQuery(query string) {
@@ -54,48 +60,39 @@ func (s *sqlOrSubstrait) setSubstraitPlan(plan []byte) {
s.substraitPlan = plan
}
-func (s *sqlOrSubstrait) execute(ctx context.Context, cl *flightsql.Client,
opts ...grpc.CallOption) (*flight.FlightInfo, error) {
+func (s *sqlOrSubstrait) execute(ctx context.Context, cnxn *cnxn, opts
...grpc.CallOption) (*flight.FlightInfo, error) {
if s.sqlQuery != "" {
- return cl.Execute(ctx, s.sqlQuery, opts...)
+ return cnxn.execute(ctx, s.sqlQuery, opts...)
} else if s.substraitPlan != nil {
- // TODO(apache/arrow#33935): Substrait not supported upstream
- return nil, adbc.Error{
- Code: adbc.StatusNotImplemented,
- Msg: "Substrait is not yet implemented",
- }
+ return cnxn.executeSubstrait(ctx, flightsql.SubstraitPlan{Plan:
s.substraitPlan, Version: s.substraitVersion}, opts...)
}
+
return nil, adbc.Error{
Code: adbc.StatusInvalidState,
Msg: "[Flight SQL Statement] cannot call ExecuteQuery without
a query or prepared statement",
}
}
-func (s *sqlOrSubstrait) executeUpdate(ctx context.Context, cl
*flightsql.Client, opts ...grpc.CallOption) (int64, error) {
+func (s *sqlOrSubstrait) executeUpdate(ctx context.Context, cnxn *cnxn, opts
...grpc.CallOption) (int64, error) {
if s.sqlQuery != "" {
- return cl.ExecuteUpdate(ctx, s.sqlQuery, opts...)
+ return cnxn.executeUpdate(ctx, s.sqlQuery, opts...)
} else if s.substraitPlan != nil {
- // TODO: Substrait not supported upstream
- return -1, adbc.Error{
- Code: adbc.StatusNotImplemented,
- Msg: "Substrait is not yet implemented",
- }
+ return cnxn.executeSubstraitUpdate(ctx,
flightsql.SubstraitPlan{Plan: s.substraitPlan, Version: s.substraitVersion},
opts...)
}
+
return -1, adbc.Error{
Code: adbc.StatusInvalidState,
Msg: "[Flight SQL Statement] cannot call ExecuteUpdate without
a query or prepared statement",
}
}
-func (s *sqlOrSubstrait) prepare(ctx context.Context, cl *flightsql.Client,
alloc memory.Allocator, opts ...grpc.CallOption) (*flightsql.PreparedStatement,
error) {
+func (s *sqlOrSubstrait) prepare(ctx context.Context, cnxn *cnxn, opts
...grpc.CallOption) (*flightsql.PreparedStatement, error) {
if s.sqlQuery != "" {
- return cl.Prepare(ctx, s.sqlQuery, opts...)
+ return cnxn.prepare(ctx, s.sqlQuery, opts...)
} else if s.substraitPlan != nil {
- // TODO: Substrait not supported upstream
- return nil, adbc.Error{
- Code: adbc.StatusNotImplemented,
- Msg: "Substrait is not yet implemented",
- }
+ return cnxn.prepareSubstrait(ctx, flightsql.SubstraitPlan{Plan:
s.substraitPlan, Version: s.substraitVersion}, opts...)
}
+
return nil, adbc.Error{
Code: adbc.StatusInvalidState,
Msg: "[FlightSQL Statement] must call SetSqlQuery before
Prepare",
@@ -104,7 +101,7 @@ func (s *sqlOrSubstrait) prepare(ctx context.Context, cl
*flightsql.Client, allo
type statement struct {
alloc memory.Allocator
- cl *flightsql.Client
+ cnxn *cnxn
clientCache gcache.Cache
hdrs metadata.MD
@@ -128,15 +125,15 @@ func (s *statement) Close() (err error) {
s.prepared = nil
}
- if s.cl == nil {
+ if s.cnxn == nil {
return adbc.Error{
Msg: "[Flight SQL Statement] cannot close already
closed statement",
Code: adbc.StatusInvalidState,
}
}
- s.cl = nil
s.clientCache = nil
+ s.cnxn = nil
return err
}
@@ -199,7 +196,8 @@ func (s *statement) SetOption(key string, val string) error
{
}
}
s.queueSize = size
- return nil
+ case OptionStatementSubstraitVersion:
+ s.query.substraitVersion = val
default:
return adbc.Error{
Msg: "[Flight SQL] Unknown statement option '" + key +
"'",
@@ -237,7 +235,7 @@ func (s *statement) ExecuteQuery(ctx context.Context) (rdr
array.RecordReader, n
if s.prepared != nil {
info, err = s.prepared.Execute(ctx, s.timeouts)
} else {
- info, err = s.query.execute(ctx, s.cl, s.timeouts)
+ info, err = s.query.execute(ctx, s.cnxn, s.timeouts)
}
if err != nil {
@@ -245,7 +243,7 @@ func (s *statement) ExecuteQuery(ctx context.Context) (rdr
array.RecordReader, n
}
nrec = info.TotalRecords
- rdr, err = newRecordReader(ctx, s.alloc, s.cl, info, s.clientCache,
s.queueSize, s.timeouts)
+ rdr, err = newRecordReader(ctx, s.alloc, s.cnxn.cl, info,
s.clientCache, s.queueSize, s.timeouts)
return
}
@@ -257,14 +255,14 @@ func (s *statement) ExecuteUpdate(ctx context.Context)
(int64, error) {
return s.prepared.ExecuteUpdate(ctx, s.timeouts)
}
- return s.query.executeUpdate(ctx, s.cl, s.timeouts)
+ return s.query.executeUpdate(ctx, s.cnxn, s.timeouts)
}
// Prepare turns this statement into a prepared statement to be executed
// multiple times. This invalidates any prior result sets.
func (s *statement) Prepare(ctx context.Context) error {
ctx = metadata.NewOutgoingContext(ctx, s.hdrs)
- prep, err := s.query.prepare(ctx, s.cl, s.alloc, s.timeouts)
+ prep, err := s.query.prepare(ctx, s.cnxn, s.timeouts)
if err != nil {
return adbcFromFlightStatus(err)
}
@@ -383,7 +381,7 @@ func (s *statement) ExecutePartitions(ctx context.Context)
(*arrow.Schema, adbc.
if s.prepared != nil {
info, err = s.prepared.Execute(ctx, s.timeouts)
} else {
- info, err = s.query.execute(ctx, s.cl, s.timeouts)
+ info, err = s.query.execute(ctx, s.cnxn, s.timeouts)
}
if err != nil {
diff --git a/go/adbc/driver/flightsql/record_reader_test.go
b/go/adbc/driver/flightsql/record_reader_test.go
index c210122..0c0cec5 100644
--- a/go/adbc/driver/flightsql/record_reader_test.go
+++ b/go/adbc/driver/flightsql/record_reader_test.go
@@ -344,7 +344,8 @@ func (suite *RecordReaderTests) TestOrdering() {
for batchIdx := int8(0); batchIdx < 4; batchIdx++ {
suite.True(reader.Next())
rec := reader.Record()
- defer rec.Release()
+ // don't need to manually release this record because
we never
+ // call retain. Each call to Next releases the previous
record
suite.True(rec.Schema().Equal(orderingSchema()))
suite.Equal(int64(1), rec.NumRows())
diff --git a/go/adbc/go.mod b/go/adbc/go.mod
index 3218d67..7151e63 100644
--- a/go/adbc/go.mod
+++ b/go/adbc/go.mod
@@ -20,7 +20,7 @@ module github.com/apache/arrow-adbc/go/adbc
go 1.18
require (
- github.com/apache/arrow/go/v12 v12.0.0-20230210052322-717d4fb7701f
+ github.com/apache/arrow/go/v12 v12.0.0-20230217202445-03463dec5f92
github.com/bluele/gcache v0.0.2
github.com/stretchr/testify v1.8.1
golang.org/x/exp v0.0.0-20230206171751-46f607a40771
@@ -51,7 +51,6 @@ require (
github.com/pierrec/lz4/v4 v4.1.17 // indirect
github.com/pmezard/go-difflib v1.0.0 // indirect
github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec //
indirect
- github.com/stretchr/objx v0.5.0 // indirect
github.com/zeebo/xxh3 v1.0.2 // indirect
golang.org/x/mod v0.8.0 // indirect
golang.org/x/net v0.6.0 // indirect
diff --git a/go/adbc/go.sum b/go/adbc/go.sum
index 3e8655b..14dc7f0 100644
--- a/go/adbc/go.sum
+++ b/go/adbc/go.sum
@@ -1,43 +1,22 @@
-cloud.google.com/go v0.26.0/go.mod
h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw=
-github.com/BurntSushi/toml v0.3.1/go.mod
h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=
github.com/JohnCGriffin/overflow v0.0.0-20211019200055-46fa312c352c
h1:RGWPOewvKIROun94nF7v2cua9qP+thov/7M50KEoeSU=
github.com/andybalholm/brotli v1.0.4
h1:V7DdXeJtZscaqfNuAdSRuRFzuiKlHSC/Zh3zl9qY3JY=
github.com/andybalholm/brotli v1.0.4/go.mod
h1:fO7iG3H7G2nSZ7m0zPUDn85XEX2GTukHGRSepvi9Eig=
-github.com/apache/arrow/go/v12 v12.0.0-20230131200310-5765aa29b5ca
h1:rLD16hTZFW/66Y6PJfUO7vmn8x1b7Lf1MBKIV6k0WTo=
-github.com/apache/arrow/go/v12 v12.0.0-20230131200310-5765aa29b5ca/go.mod
h1:qwJWRMGOu/SUTlFiQBgCjtOoxYqdG2KqXiDB3+e7BNA=
-github.com/apache/arrow/go/v12 v12.0.0-20230210052322-717d4fb7701f
h1:PiJJEcWLjapfXjCdp8G2QDKANnU/pOYYrxomEfUpWYQ=
-github.com/apache/arrow/go/v12 v12.0.0-20230210052322-717d4fb7701f/go.mod
h1:qwJWRMGOu/SUTlFiQBgCjtOoxYqdG2KqXiDB3+e7BNA=
-github.com/apache/thrift v0.16.0
h1:qEy6UW60iVOlUy+b9ZR0d5WzUWYGOo4HfopoyBaNmoY=
-github.com/apache/thrift v0.16.0/go.mod
h1:PHK3hniurgQaNMZYaCLEqXKsYK8upmhPbmdP2FXSqgU=
+github.com/apache/arrow/go/v12 v12.0.0-20230217185730-ae1f98f57f4b
h1:hH2AUVUNqmQbRlbFOyolqFVhpnl3iZ9xie9OAhQYnyE=
+github.com/apache/arrow/go/v12 v12.0.0-20230217185730-ae1f98f57f4b/go.mod
h1:qwJWRMGOu/SUTlFiQBgCjtOoxYqdG2KqXiDB3+e7BNA=
+github.com/apache/arrow/go/v12 v12.0.0-20230217202445-03463dec5f92
h1:KIxA6iY3SPKpNxJMO/a8gTcvEvoNyxAtYBLGYZzloSU=
+github.com/apache/arrow/go/v12 v12.0.0-20230217202445-03463dec5f92/go.mod
h1:qwJWRMGOu/SUTlFiQBgCjtOoxYqdG2KqXiDB3+e7BNA=
github.com/apache/thrift v0.17.0
h1:cMd2aj52n+8VoAtvSvLn4kDC3aZ6IAkBuqWQ2IDu7wo=
github.com/apache/thrift v0.17.0/go.mod
h1:OLxhMRJxomX+1I/KUw03qoV3mMz16BwaKI+d4fPBx7Q=
github.com/bluele/gcache v0.0.2 h1:WcbfdXICg7G/DGBh1PFfcirkWOQV+v077yF1pSy3DGw=
github.com/bluele/gcache v0.0.2/go.mod
h1:m15KV+ECjptwSPxKhOhQoAFQVtUFjTVkc3H8o0t/fp0=
-github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod
h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU=
-github.com/client9/misspell v0.3.4/go.mod
h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/creack/pty v1.1.9/go.mod
h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
github.com/davecgh/go-spew v1.1.0/go.mod
h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/davecgh/go-spew v1.1.1
h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod
h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/dustin/go-humanize v1.0.0
h1:VSnTsYCnlFHaM2/igO1h6X3HA71jcobQuxemgkq4zYo=
github.com/dustin/go-humanize v1.0.0/go.mod
h1:HtrtbFcZ19U5GC7JDqmcUSB87Iq5E25KnS6fMYU6eOk=
-github.com/envoyproxy/go-control-plane
v0.9.1-0.20191026205805-5f8ba28d4473/go.mod
h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4=
-github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod
h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
-github.com/goccy/go-json v0.9.11
h1:/pAaQDLHEoCq/5FFmSKBswWmK6H0e8g4159Kc/X/nqk=
-github.com/goccy/go-json v0.9.11/go.mod
h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
github.com/goccy/go-json v0.10.0
h1:mXKd9Qw4NuzShiRlOXKews24ufknHO7gx30lsDyokKA=
github.com/goccy/go-json v0.10.0/go.mod
h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I=
-github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod
h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q=
-github.com/golang/mock v1.1.1/go.mod
h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A=
-github.com/golang/mock v1.5.0/go.mod
h1:CWnOUgYIOo4TcNZ0wHX3YZCqsaM1I1Jvs6v3mP3KVu8=
-github.com/golang/protobuf v1.2.0/go.mod
h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
-github.com/golang/protobuf v1.3.2/go.mod
h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
-github.com/golang/protobuf v1.4.0-rc.1/go.mod
h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8=
-github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod
h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA=
-github.com/golang/protobuf v1.4.0-rc.2/go.mod
h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs=
-github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod
h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w=
-github.com/golang/protobuf v1.4.0/go.mod
h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0=
-github.com/golang/protobuf v1.4.1/go.mod
h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8=
github.com/golang/protobuf v1.5.0/go.mod
h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
github.com/golang/protobuf v1.5.2
h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw=
github.com/golang/protobuf v1.5.2/go.mod
h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
@@ -45,159 +24,72 @@ github.com/golang/snappy v0.0.4
h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
github.com/golang/snappy v0.0.4/go.mod
h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
github.com/google/flatbuffers v23.1.21+incompatible
h1:bUqzx/MXCDxuS0hRJL2EfjyZL3uQrPbMocUa8zGqsTA=
github.com/google/flatbuffers v23.1.21+incompatible/go.mod
h1:1AeVuKshWv4vARoZatz6mlQ0JxURH0Kv5+zNeJKJCa8=
-github.com/google/go-cmp v0.2.0/go.mod
h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M=
-github.com/google/go-cmp v0.3.0/go.mod
h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
-github.com/google/go-cmp v0.3.1/go.mod
h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU=
-github.com/google/go-cmp v0.4.0/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
-github.com/google/go-cmp v0.5.3/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-cmp v0.5.5/go.mod
h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
-github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26
h1:Xim43kblpZXfIBQsbuBVKCudVG457BR2GZFIz3uw3hQ=
github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
github.com/google/uuid v1.3.0/go.mod
h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51
h1:Z9n2FFNUXsshfwJMBgNA0RU6/i7WVaAegv3PtuIHPMs=
github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51/go.mod
h1:CzGEWj7cYgsdH8dAjBGEr58BoE7ScuLd+fwFZ44+/x8=
github.com/klauspost/asmfmt v1.3.2
h1:4Ri7ox3EwapiOjCki+hw14RyKk201CN4rzyCJRFLpK4=
github.com/klauspost/asmfmt v1.3.2/go.mod
h1:AG8TuvYojzulgDAMCnYn50l/5QV3Bs/tp6j0HLHbNSE=
-github.com/klauspost/compress v1.15.9
h1:wKRjX6JRtDdrE9qwa4b/Cip7ACOshUI4smpCQanqjSY=
-github.com/klauspost/compress v1.15.9/go.mod
h1:PhcZ0MbTNciWF3rruxRgKxI5NkcHHrHUDtV4Yw2GlzU=
github.com/klauspost/compress v1.15.15
h1:EF27CXIuDsYJ6mmvtBRlEuB2UVOqHG1tAXgZ7yIO+lw=
github.com/klauspost/compress v1.15.15/go.mod
h1:ZcK2JAFqKOpnBlxcLsJzYfrS9X1akm9fHZNnD9+Vo/4=
-github.com/klauspost/cpuid/v2 v2.0.9
h1:lgaqFMSdTdQYdZ04uHyN2d/eKdOMyi2YLSvlQIBFYa4=
-github.com/klauspost/cpuid/v2 v2.0.9/go.mod
h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg=
github.com/klauspost/cpuid/v2 v2.2.3
h1:sxCkb+qR91z4vsqw4vGGZlDgPz3G7gjaLyK3V8y70BU=
github.com/klauspost/cpuid/v2 v2.2.3/go.mod
h1:RVVoqg1df56z8g3pUjL/3lE5UfnlrJX8tyFgg4nqhuY=
github.com/kr/pretty v0.3.0 h1:WgNl7dwNpEZ6jJ9k1snq4pZsg7DOEN8hP9Xw0Tsjwk0=
github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
github.com/kr/text v0.2.0/go.mod
h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
-github.com/mattn/go-isatty v0.0.12/go.mod
h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
-github.com/mattn/go-isatty v0.0.16
h1:bq3VjFmv/sOjHtdEhmkEV4x1AJtvUvOJ2PFAZ5+peKQ=
-github.com/mattn/go-isatty v0.0.16/go.mod
h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
github.com/mattn/go-isatty v0.0.17
h1:BTarxUcIeDqL27Mc+vyvdWYSL28zpIhv3RoTdsLMPng=
github.com/mattn/go-isatty v0.0.17/go.mod
h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
-github.com/mattn/go-sqlite3 v1.14.14
h1:qZgc/Rwetq+MtyE18WhzjokPD93dNqLGNT3QJuLvBGw=
github.com/mattn/go-sqlite3 v1.14.15
h1:vfoHhTN1af61xCRSWzFIWzx2YskyMTwHLrExkBOjvxI=
github.com/minio/asm2plan9s v0.0.0-20200509001527-cdd76441f9d8
h1:AMFGa4R4MiIpspGNG7Z948v4n35fFGB3RR3G/ry4FWs=
github.com/minio/asm2plan9s v0.0.0-20200509001527-cdd76441f9d8/go.mod
h1:mC1jAcsrzbxHt8iiaC+zU4b1ylILSosueou12R++wfY=
github.com/minio/c2goasm v0.0.0-20190812172519-36a3d3bbc4f3
h1:+n/aFZefKZp7spd8DFdX7uMikMLXX4oubIzJF4kv/wI=
github.com/minio/c2goasm v0.0.0-20190812172519-36a3d3bbc4f3/go.mod
h1:RagcQ7I8IeTMnF8JTXieKnO4Z6JCsikNEzj0DwauVzE=
-github.com/pierrec/lz4/v4 v4.1.15
h1:MO0/ucJhngq7299dKLwIMtgTfbkoSPF6AoMYDd8Q4q0=
-github.com/pierrec/lz4/v4 v4.1.15/go.mod
h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4=
github.com/pierrec/lz4/v4 v4.1.17
h1:kV4Ip+/hUBC+8T6+2EgburRtkE9ef4nbY3f4dFhGjMc=
github.com/pierrec/lz4/v4 v4.1.17/go.mod
h1:gZWDp/Ze/IJXGXf23ltt2EXimqmTUXEy0GFuRQyBid4=
github.com/pmezard/go-difflib v1.0.0
h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod
h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod
h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
-github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0
h1:OdAsTTz6OkFY5QxjkYwrChwuRruF69c169dPK26NUlk=
github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod
h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec
h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod
h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
github.com/rogpeppe/go-internal v1.9.0
h1:73kH8U+JUqXU8lRuOHeVHaa/SZPifC7BkcraZVejAe8=
github.com/stretchr/objx v0.1.0/go.mod
h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-github.com/stretchr/objx v0.4.0 h1:M2gUjqZET1qApGOWNSnZ49BAIMX4F/1plDv3+l31EJ4=
github.com/stretchr/objx v0.4.0/go.mod
h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
github.com/stretchr/objx v0.5.0 h1:1zr/of2m5FGMsad5YfcqgdqdWrIhu+EBEJRhR1U7z/c=
github.com/stretchr/objx v0.5.0/go.mod
h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
github.com/stretchr/testify v1.7.1/go.mod
h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.8.0
h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
github.com/stretchr/testify v1.8.0/go.mod
h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
github.com/stretchr/testify v1.8.1
h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk=
github.com/stretchr/testify v1.8.1/go.mod
h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
-github.com/yuin/goldmark v1.2.1/go.mod
h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
github.com/zeebo/assert v1.3.0 h1:g7C04CbJuIDKNPFHmsk4hwZDO5O+kntRxzaUoNXj+IQ=
github.com/zeebo/xxh3 v1.0.2 h1:xZmwmqxHZA8AI603jOQ0tMqmBr9lPeFwGg6d+xy9DC0=
github.com/zeebo/xxh3 v1.0.2/go.mod
h1:5NWz9Sef7zIDm2JHfFlcQvNekmcEl9ekUZQQKCYaDcA=
-golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod
h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
-golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod
h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
-golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod
h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
-golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod
h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
-golang.org/x/exp v0.0.0-20220827204233-334a2380cb91
h1:tnebWN09GYg9OLPss1KXj8txwZc6X6uMr6VFdcGNbHw=
-golang.org/x/exp v0.0.0-20220827204233-334a2380cb91/go.mod
h1:cyybsKvd6eL0RnXn6p/Grxp8F5bW7iYuBgsNCOHpMYE=
golang.org/x/exp v0.0.0-20230206171751-46f607a40771
h1:xP7rWLUr1e1n2xkK5YB4LI0hPEy3LJC6Wk+D4pGlOJg=
golang.org/x/exp v0.0.0-20230206171751-46f607a40771/go.mod
h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc=
-golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod
h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
-golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod
h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
-golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod
h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=
-golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
-golang.org/x/mod v0.7.0 h1:LapD9S96VoQRhi/GrNTqeBJFrUjs5UHCAtTlgwA5oZA=
-golang.org/x/mod v0.7.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
golang.org/x/mod v0.8.0 h1:LUYupSeNrTNCGzR/hVBk2NHZO4hXcVaW1k4Qx7rjPx8=
golang.org/x/mod v0.8.0/go.mod h1:iBbtSCu2XBx23ZKBPSOrRkjjQPZFPuis4dIYUhu/chs=
-golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod
h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
-golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod
h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
-golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod
h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
-golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod
h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
-golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod
h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
-golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod
h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod
h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
-golang.org/x/net v0.5.0 h1:GyT4nK/YDHSqa1c4753ouYCDajOYKTja9Xb/OHtgvSw=
-golang.org/x/net v0.5.0/go.mod h1:DivGGAXEgPSlEBzxGzZI+ZLohi+xUj054jfeKui00ws=
golang.org/x/net v0.6.0 h1:L4ZwwTvKW9gr0ZMS1yrHD9GZhIuVjOBBnaKH+SPQK0Q=
golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
-golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod
h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
-golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod
h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod
h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod
h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod
h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.1.0 h1:wsuoTGHzEhffawBOhz5CYhcrV4IdKZbEyZjBMuTp12o=
golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod
h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
-golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod
h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220704084225-05e143d24a9e/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod
h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.4.0 h1:Zr2JFtRQNX3BCZ8YtxRE9hNJYC8J6I1MVbMg6owUp18=
-golang.org/x/sys v0.4.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.5.0 h1:MUK/U/4lj1t1oPg0HfuXDN/Z1wv31ZJ/YcPiGccS4DU=
golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
-golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
-golang.org/x/text v0.6.0 h1:3XmdazWV+ubf7QgHSTWeykHOci5oeekaGJBLkrkaw4k=
-golang.org/x/text v0.6.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
golang.org/x/text v0.7.0 h1:4BRB4x83lYWy72KwLD/qYDuTu7q9PjSagHvijDw7cLo=
golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
-golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod
h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod
h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
-golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod
h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
-golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod
h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=
-golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod
h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q=
-golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod
h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
-golang.org/x/tools v0.0.0-20201124115921-2c860bdd6e78/go.mod
h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
-golang.org/x/tools v0.5.0 h1:+bSpV5HIeWkuvgaMfI3UmKRThoTA5ODJTUd8T17NO+4=
-golang.org/x/tools v0.5.0/go.mod
h1:N+Kgy78s5I24c24dU8OfWNEotWjutIs8SnJvn5IDq+k=
golang.org/x/tools v0.6.0 h1:BOw41kyTf3PuCW1pVQf8+Cyg8pMlkYB1oo9iJ6D/lKM=
golang.org/x/tools v0.6.0/go.mod
h1:Xwgl3UAJ/d3gWutnCtw505GrjyAbvKui8lOU390QaIU=
-golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod
h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod
h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod
h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod
h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
golang.org/x/xerrors v0.0.0-20220907171357-04be3eba64a2
h1:H2TDz8ibqkAF6YGhCdN3jS9O0/s90v0rJh3X/OLHEUk=
golang.org/x/xerrors v0.0.0-20220907171357-04be3eba64a2/go.mod
h1:K8+ghG5WaK9qNqU5K3HdILfMLy1f3aNYFI/wnl100a8=
gonum.org/v1/gonum v0.11.0 h1:f1IJhK4Km5tBJmaiJXtk/PkL4cdVX6J+tGiM187uT5E=
-google.golang.org/appengine v1.1.0/go.mod
h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM=
-google.golang.org/appengine v1.4.0/go.mod
h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
-google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod
h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
-google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod
h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc=
-google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013
h1:+kGHl1aib/qcwaRi1CbqBZ1rk19r85MNUf8HaBghugY=
-google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod
h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo=
google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc
h1:ijGwO+0vL2hJt5gaygqP2j6PfflOBrRot0IczKbmtio=
google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc/go.mod
h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM=
-google.golang.org/grpc v1.19.0/go.mod
h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
-google.golang.org/grpc v1.23.0/go.mod
h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg=
-google.golang.org/grpc v1.27.0/go.mod
h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk=
-google.golang.org/grpc v1.49.0 h1:WTLtQzmQori5FUH25Pq4WT22oCsv8USpQ+F6rqtsmxw=
-google.golang.org/grpc v1.49.0/go.mod
h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCDK+GI=
google.golang.org/grpc v1.53.0 h1:LAv2ds7cmFV/XTS3XG1NneeENYrXGmorPxsBbptIjNc=
google.golang.org/grpc v1.53.0/go.mod
h1:OnIrk0ipVdj4N5d9IUoFUx72/VlD7+jUsHwZgwSMQpw=
-google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod
h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8=
-google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod
h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0=
-google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod
h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM=
-google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod
h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE=
-google.golang.org/protobuf v1.21.0/go.mod
h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo=
-google.golang.org/protobuf v1.22.0/go.mod
h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
-google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod
h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
google.golang.org/protobuf v1.26.0-rc.1/go.mod
h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
google.golang.org/protobuf v1.26.0/go.mod
h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
google.golang.org/protobuf v1.28.1
h1:d0NfwRgPtno5B1Wa6L2DAG+KivqkdutMf1UhdNx175w=
@@ -207,53 +99,27 @@ gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c
h1:Hei/4ADfdWqJk1ZMxUNpqntN
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod
h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod
h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
-honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod
h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
-lukechampine.com/uint128 v1.1.1/go.mod
h1:c4eWIwlEGaxC/+H1VguhU4PHXNWDCDMUlWdIWl2j1gk=
lukechampine.com/uint128 v1.2.0 h1:mBi/5l91vocEN8otkC5bDLhi2KdCticRiwbdB0O+rjI=
lukechampine.com/uint128 v1.2.0/go.mod
h1:c4eWIwlEGaxC/+H1VguhU4PHXNWDCDMUlWdIWl2j1gk=
-modernc.org/cc/v3 v3.36.2/go.mod
h1:NFUHyPn4ekoC/JHeZFfZurN6ixxawE1BnVonP/oahEI=
-modernc.org/cc/v3 v3.36.3 h1:uISP3F66UlixxWEcKuIWERa4TwrZENHSL8tWxZz8bHg=
-modernc.org/cc/v3 v3.36.3/go.mod
h1:NFUHyPn4ekoC/JHeZFfZurN6ixxawE1BnVonP/oahEI=
modernc.org/cc/v3 v3.40.0 h1:P3g79IUS/93SYhtoeaHW+kRCIrYaxJ27MFPv+7kaTOw=
modernc.org/cc/v3 v3.40.0/go.mod
h1:/bTg4dnWkSXowUO6ssQKnOV0yMVxDYNIsIrzqTFDGH0=
-modernc.org/ccgo/v3 v3.16.9 h1:AXquSwg7GuMk11pIdw7fmO1Y/ybgazVkMhsZWCV0mHM=
-modernc.org/ccgo/v3 v3.16.9/go.mod
h1:zNMzC9A9xeNUepy6KuZBbugn3c0Mc9TeiJO4lgvkJDo=
modernc.org/ccgo/v3 v3.16.13 h1:Mkgdzl46i5F/CNR/Kj80Ri59hC8TKAhZrYSaqvkwzUw=
modernc.org/ccgo/v3 v3.16.13/go.mod
h1:2Quk+5YgpImhPjv2Qsob1DnZ/4som1lJTodubIcoUkY=
modernc.org/ccorpus v1.11.6 h1:J16RXiiqiCgua6+ZvQot4yUuUy8zxgqbqEEUuGPlISk=
-modernc.org/ccorpus v1.11.6/go.mod
h1:2gEUTrWqdpH2pXsmTM1ZkjeSrUWDpjMu2T6m29L/ErQ=
modernc.org/httpfs v1.0.6 h1:AAgIpFZRXuYnkjftxTAZwMIiwEqAfk8aVB2/oA6nAeM=
-modernc.org/httpfs v1.0.6/go.mod
h1:7dosgurJGp0sPaRanU53W4xZYKh14wfzX420oZADeHM=
-modernc.org/libc v1.17.0/go.mod h1:XsgLldpP4aWlPlsjqKRdHPqCxCjISdHfM/yeWC5GyW0=
-modernc.org/libc v1.17.1 h1:Q8/Cpi36V/QBfuQaFVeisEBs3WqoGAJprZzmf7TfEYI=
-modernc.org/libc v1.17.1/go.mod h1:FZ23b+8LjxZs7XtFMbSzL/EhPxNbfZbErxEHc7cbD9s=
modernc.org/libc v1.22.2 h1:4U7v51GyhlWqQmwCHj28Rdq2Yzwk55ovjFrdPjs8Hb0=
modernc.org/libc v1.22.2/go.mod h1:uvQavJ1pZ0hIoC/jfqNoMLURIMhKzINIWypNM17puug=
-modernc.org/mathutil v1.2.2/go.mod
h1:mZW8CKdRPY1v87qxC/wUdX5O1qDzXMP5TH3wjfpga6E=
-modernc.org/mathutil v1.4.1/go.mod
h1:mZW8CKdRPY1v87qxC/wUdX5O1qDzXMP5TH3wjfpga6E=
modernc.org/mathutil v1.5.0 h1:rV0Ko/6SfM+8G+yKiyI830l3Wuz1zRutdslNoQ0kfiQ=
modernc.org/mathutil v1.5.0/go.mod
h1:mZW8CKdRPY1v87qxC/wUdX5O1qDzXMP5TH3wjfpga6E=
-modernc.org/memory v1.2.0/go.mod
h1:/0wo5ibyrQiaoUoH7f9D8dnglAmILJ5/cxZlRECf+Nw=
-modernc.org/memory v1.2.1 h1:dkRh86wgmq/bJu2cAS2oqBCz/KsMZU7TUM4CibQ7eBs=
-modernc.org/memory v1.2.1/go.mod
h1:PkUhL0Mugw21sHPeskwZW4D6VscE/GQJOnIpCnW6pSU=
modernc.org/memory v1.5.0 h1:N+/8c5rE6EqugZwHii4IFsaJ7MUhoWX07J5tC/iI5Ds=
modernc.org/memory v1.5.0/go.mod
h1:PkUhL0Mugw21sHPeskwZW4D6VscE/GQJOnIpCnW6pSU=
-modernc.org/opt v0.1.1/go.mod h1:WdSiB5evDcignE70guQKxYUl14mgWtbClRi5wmkkTX0=
modernc.org/opt v0.1.3 h1:3XOZf2yznlhC+ibLltsDGzABUGVx8J6pnFMS3E4dcq4=
modernc.org/opt v0.1.3/go.mod h1:WdSiB5evDcignE70guQKxYUl14mgWtbClRi5wmkkTX0=
-modernc.org/sqlite v1.18.1 h1:ko32eKt3jf7eqIkCgPAeHMBXw3riNSLhl2f3loEF7o8=
-modernc.org/sqlite v1.18.1/go.mod
h1:6ho+Gow7oX5V+OiOQ6Tr4xeqbx13UZ6t+Fw9IRUG4d4=
modernc.org/sqlite v1.20.4 h1:J8+m2trkN+KKoE7jglyHYYYiaq5xmz2HoHJIiBlRzbE=
modernc.org/sqlite v1.20.4/go.mod
h1:zKcGyrICaxNTMEHSr1HQ2GUraP0j+845GYw37+EyT6A=
-modernc.org/strutil v1.1.1/go.mod
h1:DE+MQQ/hjKBZS2zNInV5hhcipt5rLPWkmpbGeW5mmdw=
modernc.org/strutil v1.1.3 h1:fNMm+oJklMGYfU9Ylcywl0CO5O6nTfaowNsh2wpPjzY=
modernc.org/strutil v1.1.3/go.mod
h1:MEHNA7PdEnEwLvspRMtWTNnp2nnyvMfkimT1NKNAGbw=
-modernc.org/tcl v1.13.1 h1:npxzTwFTZYM8ghWicVIX1cRWzj7Nd8i6AqqX2p+IYao=
modernc.org/tcl v1.15.0 h1:oY+JeD11qVVSgVvodMJsu7Edf8tr5E/7tuhF5cNYz34=
-modernc.org/token v1.0.0 h1:a0jaWiNMDhDUtqOj09wvjWWAqd3q7WpBulmL9H2egsk=
-modernc.org/token v1.0.0/go.mod h1:UGzOrNV1mAFSEB63lOFHIpNRUVMvYTc6yu1SMY/XTDM=
modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y=
modernc.org/token v1.1.0/go.mod h1:UGzOrNV1mAFSEB63lOFHIpNRUVMvYTc6yu1SMY/XTDM=
-modernc.org/z v1.5.1 h1:RTNHdsrOpeoSeOF4FbzTo8gBYByaJ5xT7NgZ9ZqRiJM=
modernc.org/z v1.7.0 h1:xkDw/KepgEjeizO2sNco+hqYkU12taxQFqPEmgm1GWE=
