sql_rpc_server

package

v0.56.0 Latest Latest Go to latest Published: Jul 11, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Ops implements SQL transaction operations.

func NewOps(ops hydra_sql.SqlOps) *Ops

NewOps constructs a new SqlOps service.

func (o *Ops) Exec(ctx context.Context, req *sql_rpc.SqlExecRequest) (*sql_rpc.SqlExecResponse, error)

Exec executes a SQL statement.

func (o *Ops) Query(strm sql_rpc.SRPCSqlOps_QueryStream) error

Query executes a SQL query with explicit row iteration control.

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

Store wraps a SQL store in a RPC service.

func NewStore(store hydra_sql.SqlStore) *Store

NewStore constructs a new Store.

func (s *Store) GetSqlOpsMux(ctx context.Context, txID string, released func()) (srpc.Invoker, func(), error)

GetSqlOpsMux returns the SqlOpsServer mux for the given transaction id.

func (s *Store) SqlTransaction(strm sql_rpc.SRPCSql_SqlTransactionStream) error

SqlTransaction starts and manages a SQL transaction.

func (s *Store) SqlTransactionRpc(strm sql_rpc.SRPCSql_SqlTransactionRpcStream) error

SqlTransactionRpc proxies a RPC to the SqlOps service for the transaction.