type Client interface {
	Close(ctx context.Context) error

	// RetryIdempotent retries the retry operation as a idempotent
	// operation (i.e. the operation can't change the state of the database)
	// while the operation returns an error
	//
	// This is an experimental API that can be changed without changing
	// the major version.
	RetryIdempotent(ctx context.Context, op RetryOperation) (err error)

	// RetryNonIdempotent retries the retry operation as a non-idempotent
	// operation (i.e. the operation can change the state of the database)
	// while the operation returns an error
	//
	// This is an experimental API that can be changed without changing
	// the major version.
	RetryNonIdempotent(ctx context.Context, op RetryOperation) (err error)
}

type DataQuery interface {
	String() string
	ID() string
	YQL() string
}

type DataQueryExplanation struct {
	AST  string
	Plan string
}

type ParameterOption func(queryParams)

type QueryParameters struct {
	// contains filtered or unexported fields
}

type RetryOperation func(context.Context, Session) (err error)

type Session interface {
	SessionInfo

	CreateTable(ctx context.Context, path string, opts ...options.CreateTableOption) (err error)
	DescribeTable(ctx context.Context, path string, opts ...options.DescribeTableOption) (desc options.Description, err error)
	DropTable(ctx context.Context, path string, opts ...options.DropTableOption) (err error)
	AlterTable(ctx context.Context, path string, opts ...options.AlterTableOption) (err error)
	CopyTable(ctx context.Context, dst, src string, opts ...options.CopyTableOption) (err error)
	Explain(ctx context.Context, query string) (exp DataQueryExplanation, err error)
	Prepare(ctx context.Context, query string) (stmt Statement, err error)
	Execute(ctx context.Context, tx *TransactionControl, query string, params *QueryParameters, opts ...options.ExecuteDataQueryOption) (txr Transaction, r resultset.Result, err error)
	ExecuteSchemeQuery(ctx context.Context, query string, opts ...options.ExecuteSchemeQueryOption) (err error)
	DescribeTableOptions(ctx context.Context) (desc options.TableOptionsDescription, err error)
	StreamReadTable(ctx context.Context, path string, opts ...options.ReadTableOption) (r resultset.Result, err error)
	StreamExecuteScanQuery(ctx context.Context, query string, params *QueryParameters, opts ...options.ExecuteScanQueryOption) (_ resultset.Result, err error)
	BulkUpsert(ctx context.Context, table string, rows types.Value) (err error)
	BeginTransaction(ctx context.Context, tx *TransactionSettings) (x Transaction, err error)
}

type SessionInfo interface {
	ID() string
	NodeID() uint32
}

type Statement interface {
	Execute(ctx context.Context, tx *TransactionControl, params *QueryParameters, opts ...options.ExecuteDataQueryOption) (txr Transaction, r resultset.Result, err error)
	NumInput() int
	Text() string
}

type Transaction interface {
	ID() string
	Execute(ctx context.Context, query string, params *QueryParameters, opts ...options.ExecuteDataQueryOption) (resultset.Result, error)
	ExecuteStatement(ctx context.Context, stmt Statement, params *QueryParameters, opts ...options.ExecuteDataQueryOption) (resultset.Result, error)
	CommitTx(ctx context.Context, opts ...options.CommitTransactionOption) (r resultset.Result, err error)
	Rollback(ctx context.Context) (err error)
}

type TransactionControl struct {
	// contains filtered or unexported fields
}

type TransactionSettings struct {
	// contains filtered or unexported fields
}

type TxControlOption func(*txControlDesc)

type TxOnlineReadOnlyOption func(*txOnlineReadOnly)

type TxOption func(*txDesc)