sql_rpc

package
v0.55.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 10, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCSqlOpsServiceID = "sql.rpc.SqlOps"
View Source 
const SRPCSqlServiceID = "sql.rpc.Sql"

Variables

This section is empty.

Functions

func DriverValueToSqlValue 

func DriverValueToSqlValue(value driver.Value) (*hydra_sql.SqlValue, error)

DriverValueToSqlValue converts a database/sql driver value to the canonical wire value.

func NamedValuesToSqlValues 

func NamedValuesToSqlValues(args []driver.NamedValue) ([]*hydra_sql.SqlValue, error)

NamedValuesToSqlValues converts positional SQL bind arguments to wire values.

func NamedValuesToValues 

func NamedValuesToValues(args []driver.NamedValue) []driver.Value

NamedValuesToValues converts positional named values to deprecated driver.Value slices.

func NewSRPCSqlHandler 

func NewSRPCSqlHandler(impl SRPCSqlServer, serviceID string) srpc.Handler

NewSRPCSqlHandler constructs a new RPC handler. serviceID: if empty, uses default: sql.rpc.Sql

func NewSRPCSqlOpsHandler 

func NewSRPCSqlOpsHandler(impl SRPCSqlOpsServer, serviceID string) srpc.Handler

NewSRPCSqlOpsHandler constructs a new RPC handler. serviceID: if empty, uses default: sql.rpc.SqlOps

func SRPCRegisterSql 

func SRPCRegisterSql(mux srpc.Mux, impl SRPCSqlServer) error

SRPCRegisterSql registers the implementation with the mux. Uses the default serviceID: sql.rpc.Sql

func SRPCRegisterSqlOps 

func SRPCRegisterSqlOps(mux srpc.Mux, impl SRPCSqlOpsServer) error

SRPCRegisterSqlOps registers the implementation with the mux. Uses the default serviceID: sql.rpc.SqlOps

func SqlValueToDriverValue 

func SqlValueToDriverValue(value *hydra_sql.SqlValue) driver.Value

SqlValueToDriverValue converts the canonical wire value to a database/sql driver value.

func SqlValuesToNamedValues 

func SqlValuesToNamedValues(values []*hydra_sql.SqlValue) []driver.NamedValue

SqlValuesToNamedValues converts wire values to positional SQL bind arguments.

func ValuesToNamedValues 

func ValuesToNamedValues(values []driver.Value) []driver.NamedValue

ValuesToNamedValues converts deprecated driver.Value slices to positional named values.

Types

type SRPCSqlClient 

type SRPCSqlClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// SqlTransaction executes a SQL transaction.
	SqlTransaction(ctx context.Context) (SRPCSql_SqlTransactionClient, error)
	// SqlTransactionRpc is a rpcstream request for an ongoing SqlTransaction.
	// Exposes service: SqlOps.
	// Component ID: transaction_id from SqlTransaction.
	SqlTransactionRpc(ctx context.Context) (SRPCSql_SqlTransactionRpcClient, error)
}

func NewSRPCSqlClient 

func NewSRPCSqlClient(cc srpc.Client) SRPCSqlClient

func NewSRPCSqlClientWithServiceID 

func NewSRPCSqlClientWithServiceID(cc srpc.Client, serviceID string) SRPCSqlClient

type SRPCSqlHandler 

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

func (SRPCSqlHandler) GetMethodIDs 

func (SRPCSqlHandler) GetMethodIDs() []string

func (*SRPCSqlHandler) GetServiceID 

func (d *SRPCSqlHandler) GetServiceID() string

func (*SRPCSqlHandler) InvokeMethod 

func (d *SRPCSqlHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCSqlHandler) InvokeMethod_SqlTransaction 

func (SRPCSqlHandler) InvokeMethod_SqlTransaction(impl SRPCSqlServer, strm srpc.Stream) error

func (SRPCSqlHandler) InvokeMethod_SqlTransactionRpc 

func (SRPCSqlHandler) InvokeMethod_SqlTransactionRpc(impl SRPCSqlServer, strm srpc.Stream) error

type SRPCSqlOpsClient 

type SRPCSqlOpsClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// Exec executes a statement.
	Exec(ctx context.Context, in *SqlExecRequest) (*SqlExecResponse, error)
	// Query executes a query with explicit row iteration control.
	Query(ctx context.Context) (SRPCSqlOps_QueryClient, error)
}

func NewSRPCSqlOpsClient 

func NewSRPCSqlOpsClient(cc srpc.Client) SRPCSqlOpsClient

func NewSRPCSqlOpsClientWithServiceID 

func NewSRPCSqlOpsClientWithServiceID(cc srpc.Client, serviceID string) SRPCSqlOpsClient

type SRPCSqlOpsHandler 

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

func (SRPCSqlOpsHandler) GetMethodIDs 

func (SRPCSqlOpsHandler) GetMethodIDs() []string

func (*SRPCSqlOpsHandler) GetServiceID 

func (d *SRPCSqlOpsHandler) GetServiceID() string

func (*SRPCSqlOpsHandler) InvokeMethod 

func (d *SRPCSqlOpsHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCSqlOpsHandler) InvokeMethod_Exec 

func (SRPCSqlOpsHandler) InvokeMethod_Exec(impl SRPCSqlOpsServer, strm srpc.Stream) error

func (SRPCSqlOpsHandler) InvokeMethod_Query 

func (SRPCSqlOpsHandler) InvokeMethod_Query(impl SRPCSqlOpsServer, strm srpc.Stream) error

type SRPCSqlOpsServer 

type SRPCSqlOpsServer interface {
	// Exec executes a statement.
	Exec(context.Context, *SqlExecRequest) (*SqlExecResponse, error)
	// Query executes a query with explicit row iteration control.
	Query(SRPCSqlOps_QueryStream) error
}

type SRPCSqlOps_ExecStream 

type SRPCSqlOps_ExecStream interface {
	srpc.Stream
}

type SRPCSqlOps_QueryClient 

type SRPCSqlOps_QueryClient interface {
	srpc.Stream
	Send(*SqlQueryRequest) error
	Recv() (*SqlQueryResponse, error)
	RecvTo(*SqlQueryResponse) error
}

type SRPCSqlOps_QueryStream 

type SRPCSqlOps_QueryStream interface {
	srpc.Stream
	Send(*SqlQueryResponse) error
	SendAndClose(*SqlQueryResponse) error
	Recv() (*SqlQueryRequest, error)
	RecvTo(*SqlQueryRequest) error
}

type SRPCSqlServer 

type SRPCSqlServer interface {
	// SqlTransaction executes a SQL transaction.
	SqlTransaction(SRPCSql_SqlTransactionStream) error
	// SqlTransactionRpc is a rpcstream request for an ongoing SqlTransaction.
	// Exposes service: SqlOps.
	// Component ID: transaction_id from SqlTransaction.
	SqlTransactionRpc(SRPCSql_SqlTransactionRpcStream) error
}

type SRPCSql_SqlTransactionClient 

type SRPCSql_SqlTransactionClient interface {
	srpc.Stream
	Send(*SqlTransactionRequest) error
	Recv() (*SqlTransactionResponse, error)
	RecvTo(*SqlTransactionResponse) error
}

type SRPCSql_SqlTransactionRpcClient 

type SRPCSql_SqlTransactionRpcClient interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

type SRPCSql_SqlTransactionRpcStream 

type SRPCSql_SqlTransactionRpcStream interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	SendAndClose(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

type SRPCSql_SqlTransactionStream 

type SRPCSql_SqlTransactionStream interface {
	srpc.Stream
	Send(*SqlTransactionResponse) error
	SendAndClose(*SqlTransactionResponse) error
	Recv() (*SqlTransactionRequest, error)
	RecvTo(*SqlTransactionRequest) error
}

type SqlExecRequest 

type SqlExecRequest struct {

	// Query is the SQL statement.
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// Args are positional bind arguments.
	Args []*sql.SqlValue `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

SqlExecRequest is a SQL exec request.

func (*SqlExecRequest) CloneMessageVT 

func (m *SqlExecRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlExecRequest) CloneVT 

func (m *SqlExecRequest) CloneVT() *SqlExecRequest

func (*SqlExecRequest) EqualMessageVT 

func (this *SqlExecRequest) EqualMessageVT(thatMsg any) bool

func (*SqlExecRequest) EqualVT 

func (this *SqlExecRequest) EqualVT(that *SqlExecRequest) bool

func (*SqlExecRequest) GetArgs 

func (x *SqlExecRequest) GetArgs() []*sql.SqlValue

func (*SqlExecRequest) GetQuery 

func (x *SqlExecRequest) GetQuery() string

func (*SqlExecRequest) MarshalJSON 

func (x *SqlExecRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlExecRequest to JSON.

func (*SqlExecRequest) MarshalProtoJSON 

func (x *SqlExecRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlExecRequest message to JSON.

func (*SqlExecRequest) MarshalProtoText 

func (x *SqlExecRequest) MarshalProtoText() string

func (*SqlExecRequest) MarshalToSizedBufferVT 

func (m *SqlExecRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlExecRequest) MarshalToVT 

func (m *SqlExecRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SqlExecRequest) MarshalVT 

func (m *SqlExecRequest) MarshalVT() (dAtA []byte, err error)

func (*SqlExecRequest) ProtoMessage 

func (*SqlExecRequest) ProtoMessage()

func (*SqlExecRequest) Reset 

func (x *SqlExecRequest) Reset()

func (*SqlExecRequest) SizeVT 

func (m *SqlExecRequest) SizeVT() (n int)

func (*SqlExecRequest) String 

func (x *SqlExecRequest) String() string

func (*SqlExecRequest) UnmarshalJSON 

func (x *SqlExecRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlExecRequest from JSON.

func (*SqlExecRequest) UnmarshalProtoJSON 

func (x *SqlExecRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlExecRequest message from JSON.

func (*SqlExecRequest) UnmarshalVT 

func (m *SqlExecRequest) UnmarshalVT(dAtA []byte) error

type SqlExecResponse 

type SqlExecResponse struct {

	// Error is any execution error.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// LastInsertId is the last insert id if known.
	LastInsertId int64 `protobuf:"varint,2,opt,name=last_insert_id,json=lastInsertId,proto3" json:"lastInsertId,omitempty"`
	// RowsAffected is the row count if known.
	RowsAffected int64 `protobuf:"varint,3,opt,name=rows_affected,json=rowsAffected,proto3" json:"rowsAffected,omitempty"`
	// contains filtered or unexported fields
}

SqlExecResponse is a SQL exec response.

func (*SqlExecResponse) CloneMessageVT 

func (m *SqlExecResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlExecResponse) CloneVT 

func (m *SqlExecResponse) CloneVT() *SqlExecResponse

func (*SqlExecResponse) EqualMessageVT 

func (this *SqlExecResponse) EqualMessageVT(thatMsg any) bool

func (*SqlExecResponse) EqualVT 

func (this *SqlExecResponse) EqualVT(that *SqlExecResponse) bool

func (*SqlExecResponse) GetError 

func (x *SqlExecResponse) GetError() string

func (*SqlExecResponse) GetLastInsertId 

func (x *SqlExecResponse) GetLastInsertId() int64

func (*SqlExecResponse) GetRowsAffected 

func (x *SqlExecResponse) GetRowsAffected() int64

func (*SqlExecResponse) MarshalJSON 

func (x *SqlExecResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlExecResponse to JSON.

func (*SqlExecResponse) MarshalProtoJSON 

func (x *SqlExecResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlExecResponse message to JSON.

func (*SqlExecResponse) MarshalProtoText 

func (x *SqlExecResponse) MarshalProtoText() string

func (*SqlExecResponse) MarshalToSizedBufferVT 

func (m *SqlExecResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlExecResponse) MarshalToVT 

func (m *SqlExecResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SqlExecResponse) MarshalVT 

func (m *SqlExecResponse) MarshalVT() (dAtA []byte, err error)

func (*SqlExecResponse) ProtoMessage 

func (*SqlExecResponse) ProtoMessage()

func (*SqlExecResponse) Reset 

func (x *SqlExecResponse) Reset()

func (*SqlExecResponse) SizeVT 

func (m *SqlExecResponse) SizeVT() (n int)

func (*SqlExecResponse) String 

func (x *SqlExecResponse) String() string

func (*SqlExecResponse) UnmarshalJSON 

func (x *SqlExecResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlExecResponse from JSON.

func (*SqlExecResponse) UnmarshalProtoJSON 

func (x *SqlExecResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlExecResponse message from JSON.

func (*SqlExecResponse) UnmarshalVT 

func (m *SqlExecResponse) UnmarshalVT(dAtA []byte) error

type SqlQueryAck 

type SqlQueryAck struct {

	// Columns describes result columns.
	Columns []*sql.ColumnSchema `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

SqlQueryAck contains query metadata.

func (*SqlQueryAck) CloneMessageVT 

func (m *SqlQueryAck) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlQueryAck) CloneVT 

func (m *SqlQueryAck) CloneVT() *SqlQueryAck

func (*SqlQueryAck) EqualMessageVT 

func (this *SqlQueryAck) EqualMessageVT(thatMsg any) bool

func (*SqlQueryAck) EqualVT 

func (this *SqlQueryAck) EqualVT(that *SqlQueryAck) bool

func (*SqlQueryAck) GetColumns 

func (x *SqlQueryAck) GetColumns() []*sql.ColumnSchema

func (*SqlQueryAck) MarshalJSON 

func (x *SqlQueryAck) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlQueryAck to JSON.

func (*SqlQueryAck) MarshalProtoJSON 

func (x *SqlQueryAck) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlQueryAck message to JSON.

func (*SqlQueryAck) MarshalProtoText 

func (x *SqlQueryAck) MarshalProtoText() string

func (*SqlQueryAck) MarshalToSizedBufferVT 

func (m *SqlQueryAck) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryAck) MarshalToVT 

func (m *SqlQueryAck) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryAck) MarshalVT 

func (m *SqlQueryAck) MarshalVT() (dAtA []byte, err error)

func (*SqlQueryAck) ProtoMessage 

func (*SqlQueryAck) ProtoMessage()

func (*SqlQueryAck) Reset 

func (x *SqlQueryAck) Reset()

func (*SqlQueryAck) SizeVT 

func (m *SqlQueryAck) SizeVT() (n int)

func (*SqlQueryAck) String 

func (x *SqlQueryAck) String() string

func (*SqlQueryAck) UnmarshalJSON 

func (x *SqlQueryAck) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlQueryAck from JSON.

func (*SqlQueryAck) UnmarshalProtoJSON 

func (x *SqlQueryAck) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlQueryAck message from JSON.

func (*SqlQueryAck) UnmarshalVT 

func (m *SqlQueryAck) UnmarshalVT(dAtA []byte) error

type SqlQueryInit 

type SqlQueryInit struct {

	// Query is the SQL query.
	Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	// Args are positional bind arguments.
	Args []*sql.SqlValue `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

SqlQueryInit opens a query stream.

func (*SqlQueryInit) CloneMessageVT 

func (m *SqlQueryInit) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlQueryInit) CloneVT 

func (m *SqlQueryInit) CloneVT() *SqlQueryInit

func (*SqlQueryInit) EqualMessageVT 

func (this *SqlQueryInit) EqualMessageVT(thatMsg any) bool

func (*SqlQueryInit) EqualVT 

func (this *SqlQueryInit) EqualVT(that *SqlQueryInit) bool

func (*SqlQueryInit) GetArgs 

func (x *SqlQueryInit) GetArgs() []*sql.SqlValue

func (*SqlQueryInit) GetQuery 

func (x *SqlQueryInit) GetQuery() string

func (*SqlQueryInit) MarshalJSON 

func (x *SqlQueryInit) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlQueryInit to JSON.

func (*SqlQueryInit) MarshalProtoJSON 

func (x *SqlQueryInit) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlQueryInit message to JSON.

func (*SqlQueryInit) MarshalProtoText 

func (x *SqlQueryInit) MarshalProtoText() string

func (*SqlQueryInit) MarshalToSizedBufferVT 

func (m *SqlQueryInit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryInit) MarshalToVT 

func (m *SqlQueryInit) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryInit) MarshalVT 

func (m *SqlQueryInit) MarshalVT() (dAtA []byte, err error)

func (*SqlQueryInit) ProtoMessage 

func (*SqlQueryInit) ProtoMessage()

func (*SqlQueryInit) Reset 

func (x *SqlQueryInit) Reset()

func (*SqlQueryInit) SizeVT 

func (m *SqlQueryInit) SizeVT() (n int)

func (*SqlQueryInit) String 

func (x *SqlQueryInit) String() string

func (*SqlQueryInit) UnmarshalJSON 

func (x *SqlQueryInit) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlQueryInit from JSON.

func (*SqlQueryInit) UnmarshalProtoJSON 

func (x *SqlQueryInit) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlQueryInit message from JSON.

func (*SqlQueryInit) UnmarshalVT 

func (m *SqlQueryInit) UnmarshalVT(dAtA []byte) error

type SqlQueryRequest 

type SqlQueryRequest struct {

	// Body contains the query stream request.
	//
	// Types that are assignable to Body:
	//
	//	*SqlQueryRequest_Init
	//	*SqlQueryRequest_Next
	//	*SqlQueryRequest_Close
	Body isSqlQueryRequest_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

SqlQueryRequest controls a query stream.

func (*SqlQueryRequest) CloneMessageVT 

func (m *SqlQueryRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlQueryRequest) CloneVT 

func (m *SqlQueryRequest) CloneVT() *SqlQueryRequest

func (*SqlQueryRequest) EqualMessageVT 

func (this *SqlQueryRequest) EqualMessageVT(thatMsg any) bool

func (*SqlQueryRequest) EqualVT 

func (this *SqlQueryRequest) EqualVT(that *SqlQueryRequest) bool

func (*SqlQueryRequest) GetBody 

func (m *SqlQueryRequest) GetBody() isSqlQueryRequest_Body

func (*SqlQueryRequest) GetClose 

func (x *SqlQueryRequest) GetClose() bool

func (*SqlQueryRequest) GetInit 

func (x *SqlQueryRequest) GetInit() *SqlQueryInit

func (*SqlQueryRequest) GetNext 

func (x *SqlQueryRequest) GetNext() uint32

func (*SqlQueryRequest) MarshalJSON 

func (x *SqlQueryRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlQueryRequest to JSON.

func (*SqlQueryRequest) MarshalProtoJSON 

func (x *SqlQueryRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlQueryRequest message to JSON.

func (*SqlQueryRequest) MarshalProtoText 

func (x *SqlQueryRequest) MarshalProtoText() string

func (*SqlQueryRequest) MarshalToSizedBufferVT 

func (m *SqlQueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryRequest) MarshalToVT 

func (m *SqlQueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryRequest) MarshalVT 

func (m *SqlQueryRequest) MarshalVT() (dAtA []byte, err error)

func (*SqlQueryRequest) ProtoMessage 

func (*SqlQueryRequest) ProtoMessage()

func (*SqlQueryRequest) Reset 

func (x *SqlQueryRequest) Reset()

func (*SqlQueryRequest) SizeVT 

func (m *SqlQueryRequest) SizeVT() (n int)

func (*SqlQueryRequest) String 

func (x *SqlQueryRequest) String() string

func (*SqlQueryRequest) UnmarshalJSON 

func (x *SqlQueryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlQueryRequest from JSON.

func (*SqlQueryRequest) UnmarshalProtoJSON 

func (x *SqlQueryRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlQueryRequest message from JSON.

func (*SqlQueryRequest) UnmarshalVT 

func (m *SqlQueryRequest) UnmarshalVT(dAtA []byte) error

type SqlQueryRequest_Close 

type SqlQueryRequest_Close struct {
	// Close closes the query.
	Close bool `protobuf:"varint,3,opt,name=close,proto3,oneof"`
}

func (*SqlQueryRequest_Close) CloneOneofVT 

func (m *SqlQueryRequest_Close) CloneOneofVT() isSqlQueryRequest_Body

func (*SqlQueryRequest_Close) CloneVT 

func (m *SqlQueryRequest_Close) CloneVT() *SqlQueryRequest_Close

func (*SqlQueryRequest_Close) EqualVT 

func (this *SqlQueryRequest_Close) EqualVT(thatIface isSqlQueryRequest_Body) bool

func (*SqlQueryRequest_Close) MarshalToSizedBufferVT 

func (m *SqlQueryRequest_Close) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryRequest_Close) MarshalToVT 

func (m *SqlQueryRequest_Close) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryRequest_Close) SizeVT 

func (m *SqlQueryRequest_Close) SizeVT() (n int)

type SqlQueryRequest_Init 

type SqlQueryRequest_Init struct {
	// Init opens the query.
	Init *SqlQueryInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

func (*SqlQueryRequest_Init) CloneOneofVT 

func (m *SqlQueryRequest_Init) CloneOneofVT() isSqlQueryRequest_Body

func (*SqlQueryRequest_Init) CloneVT 

func (m *SqlQueryRequest_Init) CloneVT() *SqlQueryRequest_Init

func (*SqlQueryRequest_Init) EqualVT 

func (this *SqlQueryRequest_Init) EqualVT(thatIface isSqlQueryRequest_Body) bool

func (*SqlQueryRequest_Init) MarshalToSizedBufferVT 

func (m *SqlQueryRequest_Init) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryRequest_Init) MarshalToVT 

func (m *SqlQueryRequest_Init) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryRequest_Init) SizeVT 

func (m *SqlQueryRequest_Init) SizeVT() (n int)

type SqlQueryRequest_Next 

type SqlQueryRequest_Next struct {
	// Next requests up to this many rows. Zero means one row.
	Next uint32 `protobuf:"varint,2,opt,name=next,proto3,oneof"`
}

func (*SqlQueryRequest_Next) CloneOneofVT 

func (m *SqlQueryRequest_Next) CloneOneofVT() isSqlQueryRequest_Body

func (*SqlQueryRequest_Next) CloneVT 

func (m *SqlQueryRequest_Next) CloneVT() *SqlQueryRequest_Next

func (*SqlQueryRequest_Next) EqualVT 

func (this *SqlQueryRequest_Next) EqualVT(thatIface isSqlQueryRequest_Body) bool

func (*SqlQueryRequest_Next) MarshalToSizedBufferVT 

func (m *SqlQueryRequest_Next) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryRequest_Next) MarshalToVT 

func (m *SqlQueryRequest_Next) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryRequest_Next) SizeVT 

func (m *SqlQueryRequest_Next) SizeVT() (n int)

type SqlQueryResponse 

type SqlQueryResponse struct {

	// Body contains the response body.
	//
	// Types that are assignable to Body:
	//
	//	*SqlQueryResponse_Ack
	//	*SqlQueryResponse_Batch
	//	*SqlQueryResponse_ReqError
	//	*SqlQueryResponse_Closed
	Body isSqlQueryResponse_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

SqlQueryResponse is a query stream response.

func (*SqlQueryResponse) CloneMessageVT 

func (m *SqlQueryResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlQueryResponse) CloneVT 

func (m *SqlQueryResponse) CloneVT() *SqlQueryResponse

func (*SqlQueryResponse) EqualMessageVT 

func (this *SqlQueryResponse) EqualMessageVT(thatMsg any) bool

func (*SqlQueryResponse) EqualVT 

func (this *SqlQueryResponse) EqualVT(that *SqlQueryResponse) bool

func (*SqlQueryResponse) GetAck 

func (x *SqlQueryResponse) GetAck() *SqlQueryAck

func (*SqlQueryResponse) GetBatch 

func (x *SqlQueryResponse) GetBatch() *sql.RowBatch

func (*SqlQueryResponse) GetBody 

func (m *SqlQueryResponse) GetBody() isSqlQueryResponse_Body

func (*SqlQueryResponse) GetClosed 

func (x *SqlQueryResponse) GetClosed() bool

func (*SqlQueryResponse) GetReqError 

func (x *SqlQueryResponse) GetReqError() string

func (*SqlQueryResponse) MarshalJSON 

func (x *SqlQueryResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlQueryResponse to JSON.

func (*SqlQueryResponse) MarshalProtoJSON 

func (x *SqlQueryResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlQueryResponse message to JSON.

func (*SqlQueryResponse) MarshalProtoText 

func (x *SqlQueryResponse) MarshalProtoText() string

func (*SqlQueryResponse) MarshalToSizedBufferVT 

func (m *SqlQueryResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryResponse) MarshalToVT 

func (m *SqlQueryResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryResponse) MarshalVT 

func (m *SqlQueryResponse) MarshalVT() (dAtA []byte, err error)

func (*SqlQueryResponse) ProtoMessage 

func (*SqlQueryResponse) ProtoMessage()

func (*SqlQueryResponse) Reset 

func (x *SqlQueryResponse) Reset()

func (*SqlQueryResponse) SizeVT 

func (m *SqlQueryResponse) SizeVT() (n int)

func (*SqlQueryResponse) String 

func (x *SqlQueryResponse) String() string

func (*SqlQueryResponse) UnmarshalJSON 

func (x *SqlQueryResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlQueryResponse from JSON.

func (*SqlQueryResponse) UnmarshalProtoJSON 

func (x *SqlQueryResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlQueryResponse message from JSON.

func (*SqlQueryResponse) UnmarshalVT 

func (m *SqlQueryResponse) UnmarshalVT(dAtA []byte) error

type SqlQueryResponse_Ack 

type SqlQueryResponse_Ack struct {
	// Ack returns result columns.
	Ack *SqlQueryAck `protobuf:"bytes,1,opt,name=ack,proto3,oneof"`
}

func (*SqlQueryResponse_Ack) CloneOneofVT 

func (m *SqlQueryResponse_Ack) CloneOneofVT() isSqlQueryResponse_Body

func (*SqlQueryResponse_Ack) CloneVT 

func (m *SqlQueryResponse_Ack) CloneVT() *SqlQueryResponse_Ack

func (*SqlQueryResponse_Ack) EqualVT 

func (this *SqlQueryResponse_Ack) EqualVT(thatIface isSqlQueryResponse_Body) bool

func (*SqlQueryResponse_Ack) MarshalToSizedBufferVT 

func (m *SqlQueryResponse_Ack) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_Ack) MarshalToVT 

func (m *SqlQueryResponse_Ack) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_Ack) SizeVT 

func (m *SqlQueryResponse_Ack) SizeVT() (n int)

type SqlQueryResponse_Batch 

type SqlQueryResponse_Batch struct {
	// Batch returns query rows.
	Batch *sql.RowBatch `protobuf:"bytes,2,opt,name=batch,proto3,oneof"`
}

func (*SqlQueryResponse_Batch) CloneOneofVT 

func (m *SqlQueryResponse_Batch) CloneOneofVT() isSqlQueryResponse_Body

func (*SqlQueryResponse_Batch) CloneVT 

func (m *SqlQueryResponse_Batch) CloneVT() *SqlQueryResponse_Batch

func (*SqlQueryResponse_Batch) EqualVT 

func (this *SqlQueryResponse_Batch) EqualVT(thatIface isSqlQueryResponse_Body) bool

func (*SqlQueryResponse_Batch) MarshalToSizedBufferVT 

func (m *SqlQueryResponse_Batch) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_Batch) MarshalToVT 

func (m *SqlQueryResponse_Batch) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_Batch) SizeVT 

func (m *SqlQueryResponse_Batch) SizeVT() (n int)

type SqlQueryResponse_Closed 

type SqlQueryResponse_Closed struct {
	// Closed acknowledges stream close or EOF.
	Closed bool `protobuf:"varint,4,opt,name=closed,proto3,oneof"`
}

func (*SqlQueryResponse_Closed) CloneOneofVT 

func (m *SqlQueryResponse_Closed) CloneOneofVT() isSqlQueryResponse_Body

func (*SqlQueryResponse_Closed) CloneVT 

func (m *SqlQueryResponse_Closed) CloneVT() *SqlQueryResponse_Closed

func (*SqlQueryResponse_Closed) EqualVT 

func (this *SqlQueryResponse_Closed) EqualVT(thatIface isSqlQueryResponse_Body) bool

func (*SqlQueryResponse_Closed) MarshalToSizedBufferVT 

func (m *SqlQueryResponse_Closed) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_Closed) MarshalToVT 

func (m *SqlQueryResponse_Closed) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_Closed) SizeVT 

func (m *SqlQueryResponse_Closed) SizeVT() (n int)

type SqlQueryResponse_ReqError 

type SqlQueryResponse_ReqError struct {
	// ReqError reports a request error.
	ReqError string `protobuf:"bytes,3,opt,name=req_error,json=reqError,proto3,oneof"`
}

func (*SqlQueryResponse_ReqError) CloneOneofVT 

func (m *SqlQueryResponse_ReqError) CloneOneofVT() isSqlQueryResponse_Body

func (*SqlQueryResponse_ReqError) CloneVT 

func (m *SqlQueryResponse_ReqError) CloneVT() *SqlQueryResponse_ReqError

func (*SqlQueryResponse_ReqError) EqualVT 

func (this *SqlQueryResponse_ReqError) EqualVT(thatIface isSqlQueryResponse_Body) bool

func (*SqlQueryResponse_ReqError) MarshalToSizedBufferVT 

func (m *SqlQueryResponse_ReqError) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_ReqError) MarshalToVT 

func (m *SqlQueryResponse_ReqError) MarshalToVT(dAtA []byte) (int, error)

func (*SqlQueryResponse_ReqError) SizeVT 

func (m *SqlQueryResponse_ReqError) SizeVT() (n int)

type SqlTransactionAck 

type SqlTransactionAck struct {

	// Error is any error opening the transaction.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// TransactionId is the identifier to use for the RpcStream.
	TransactionId string `protobuf:"bytes,2,opt,name=transaction_id,json=transactionId,proto3" json:"transactionId,omitempty"`
	// contains filtered or unexported fields
}

SqlTransactionAck contains transaction open status.

func (*SqlTransactionAck) CloneMessageVT 

func (m *SqlTransactionAck) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlTransactionAck) CloneVT 

func (m *SqlTransactionAck) CloneVT() *SqlTransactionAck

func (*SqlTransactionAck) EqualMessageVT 

func (this *SqlTransactionAck) EqualMessageVT(thatMsg any) bool

func (*SqlTransactionAck) EqualVT 

func (this *SqlTransactionAck) EqualVT(that *SqlTransactionAck) bool

func (*SqlTransactionAck) GetError 

func (x *SqlTransactionAck) GetError() string

func (*SqlTransactionAck) GetTransactionId 

func (x *SqlTransactionAck) GetTransactionId() string

func (*SqlTransactionAck) MarshalJSON 

func (x *SqlTransactionAck) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlTransactionAck to JSON.

func (*SqlTransactionAck) MarshalProtoJSON 

func (x *SqlTransactionAck) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlTransactionAck message to JSON.

func (*SqlTransactionAck) MarshalProtoText 

func (x *SqlTransactionAck) MarshalProtoText() string

func (*SqlTransactionAck) MarshalToSizedBufferVT 

func (m *SqlTransactionAck) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionAck) MarshalToVT 

func (m *SqlTransactionAck) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionAck) MarshalVT 

func (m *SqlTransactionAck) MarshalVT() (dAtA []byte, err error)

func (*SqlTransactionAck) ProtoMessage 

func (*SqlTransactionAck) ProtoMessage()

func (*SqlTransactionAck) Reset 

func (x *SqlTransactionAck) Reset()

func (*SqlTransactionAck) SizeVT 

func (m *SqlTransactionAck) SizeVT() (n int)

func (*SqlTransactionAck) String 

func (x *SqlTransactionAck) String() string

func (*SqlTransactionAck) UnmarshalJSON 

func (x *SqlTransactionAck) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlTransactionAck from JSON.

func (*SqlTransactionAck) UnmarshalProtoJSON 

func (x *SqlTransactionAck) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlTransactionAck message from JSON.

func (*SqlTransactionAck) UnmarshalVT 

func (m *SqlTransactionAck) UnmarshalVT(dAtA []byte) error

type SqlTransactionComplete 

type SqlTransactionComplete struct {

	// Error is any error completing the transaction.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// Committed indicates the transaction committed.
	Committed bool `protobuf:"varint,2,opt,name=committed,proto3" json:"committed,omitempty"`
	// Discarded indicates the transaction was discarded.
	Discarded bool `protobuf:"varint,3,opt,name=discarded,proto3" json:"discarded,omitempty"`
	// contains filtered or unexported fields
}

SqlTransactionComplete contains transaction completion status.

func (*SqlTransactionComplete) CloneMessageVT 

func (m *SqlTransactionComplete) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlTransactionComplete) CloneVT 

func (m *SqlTransactionComplete) CloneVT() *SqlTransactionComplete

func (*SqlTransactionComplete) EqualMessageVT 

func (this *SqlTransactionComplete) EqualMessageVT(thatMsg any) bool

func (*SqlTransactionComplete) EqualVT 

func (this *SqlTransactionComplete) EqualVT(that *SqlTransactionComplete) bool

func (*SqlTransactionComplete) GetCommitted 

func (x *SqlTransactionComplete) GetCommitted() bool

func (*SqlTransactionComplete) GetDiscarded 

func (x *SqlTransactionComplete) GetDiscarded() bool

func (*SqlTransactionComplete) GetError 

func (x *SqlTransactionComplete) GetError() string

func (*SqlTransactionComplete) MarshalJSON 

func (x *SqlTransactionComplete) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlTransactionComplete to JSON.

func (*SqlTransactionComplete) MarshalProtoJSON 

func (x *SqlTransactionComplete) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlTransactionComplete message to JSON.

func (*SqlTransactionComplete) MarshalProtoText 

func (x *SqlTransactionComplete) MarshalProtoText() string

func (*SqlTransactionComplete) MarshalToSizedBufferVT 

func (m *SqlTransactionComplete) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionComplete) MarshalToVT 

func (m *SqlTransactionComplete) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionComplete) MarshalVT 

func (m *SqlTransactionComplete) MarshalVT() (dAtA []byte, err error)

func (*SqlTransactionComplete) ProtoMessage 

func (*SqlTransactionComplete) ProtoMessage()

func (*SqlTransactionComplete) Reset 

func (x *SqlTransactionComplete) Reset()

func (*SqlTransactionComplete) SizeVT 

func (m *SqlTransactionComplete) SizeVT() (n int)

func (*SqlTransactionComplete) String 

func (x *SqlTransactionComplete) String() string

func (*SqlTransactionComplete) UnmarshalJSON 

func (x *SqlTransactionComplete) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlTransactionComplete from JSON.

func (*SqlTransactionComplete) UnmarshalProtoJSON 

func (x *SqlTransactionComplete) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlTransactionComplete message from JSON.

func (*SqlTransactionComplete) UnmarshalVT 

func (m *SqlTransactionComplete) UnmarshalVT(dAtA []byte) error

type SqlTransactionInit 

type SqlTransactionInit struct {

	// Write indicates if this should be a write transaction.
	Write bool `protobuf:"varint,1,opt,name=write,proto3" json:"write,omitempty"`
	// Dsn is the SQL database path/name.
	Dsn string `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

SqlTransactionInit initializes a SQL transaction.

func (*SqlTransactionInit) CloneMessageVT 

func (m *SqlTransactionInit) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlTransactionInit) CloneVT 

func (m *SqlTransactionInit) CloneVT() *SqlTransactionInit

func (*SqlTransactionInit) EqualMessageVT 

func (this *SqlTransactionInit) EqualMessageVT(thatMsg any) bool

func (*SqlTransactionInit) EqualVT 

func (this *SqlTransactionInit) EqualVT(that *SqlTransactionInit) bool

func (*SqlTransactionInit) GetDsn 

func (x *SqlTransactionInit) GetDsn() string

func (*SqlTransactionInit) GetWrite 

func (x *SqlTransactionInit) GetWrite() bool

func (*SqlTransactionInit) MarshalJSON 

func (x *SqlTransactionInit) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlTransactionInit to JSON.

func (*SqlTransactionInit) MarshalProtoJSON 

func (x *SqlTransactionInit) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlTransactionInit message to JSON.

func (*SqlTransactionInit) MarshalProtoText 

func (x *SqlTransactionInit) MarshalProtoText() string

func (*SqlTransactionInit) MarshalToSizedBufferVT 

func (m *SqlTransactionInit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionInit) MarshalToVT 

func (m *SqlTransactionInit) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionInit) MarshalVT 

func (m *SqlTransactionInit) MarshalVT() (dAtA []byte, err error)

func (*SqlTransactionInit) ProtoMessage 

func (*SqlTransactionInit) ProtoMessage()

func (*SqlTransactionInit) Reset 

func (x *SqlTransactionInit) Reset()

func (*SqlTransactionInit) SizeVT 

func (m *SqlTransactionInit) SizeVT() (n int)

func (*SqlTransactionInit) String 

func (x *SqlTransactionInit) String() string

func (*SqlTransactionInit) UnmarshalJSON 

func (x *SqlTransactionInit) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlTransactionInit from JSON.

func (*SqlTransactionInit) UnmarshalProtoJSON 

func (x *SqlTransactionInit) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlTransactionInit message from JSON.

func (*SqlTransactionInit) UnmarshalVT 

func (m *SqlTransactionInit) UnmarshalVT(dAtA []byte) error

type SqlTransactionRequest 

type SqlTransactionRequest struct {

	// Body contains the message body.
	//
	// Types that are assignable to Body:
	//
	//	*SqlTransactionRequest_Init
	//	*SqlTransactionRequest_Commit
	//	*SqlTransactionRequest_Discard
	Body isSqlTransactionRequest_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

SqlTransactionRequest is a request in a SqlTransaction rpc.

func (*SqlTransactionRequest) CloneMessageVT 

func (m *SqlTransactionRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlTransactionRequest) CloneVT 

func (m *SqlTransactionRequest) CloneVT() *SqlTransactionRequest

func (*SqlTransactionRequest) EqualMessageVT 

func (this *SqlTransactionRequest) EqualMessageVT(thatMsg any) bool

func (*SqlTransactionRequest) EqualVT 

func (this *SqlTransactionRequest) EqualVT(that *SqlTransactionRequest) bool

func (*SqlTransactionRequest) GetBody 

func (m *SqlTransactionRequest) GetBody() isSqlTransactionRequest_Body

func (*SqlTransactionRequest) GetCommit 

func (x *SqlTransactionRequest) GetCommit() bool

func (*SqlTransactionRequest) GetDiscard 

func (x *SqlTransactionRequest) GetDiscard() bool

func (*SqlTransactionRequest) GetInit 

func (x *SqlTransactionRequest) GetInit() *SqlTransactionInit

func (*SqlTransactionRequest) MarshalJSON 

func (x *SqlTransactionRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlTransactionRequest to JSON.

func (*SqlTransactionRequest) MarshalProtoJSON 

func (x *SqlTransactionRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlTransactionRequest message to JSON.

func (*SqlTransactionRequest) MarshalProtoText 

func (x *SqlTransactionRequest) MarshalProtoText() string

func (*SqlTransactionRequest) MarshalToSizedBufferVT 

func (m *SqlTransactionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest) MarshalToVT 

func (m *SqlTransactionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest) MarshalVT 

func (m *SqlTransactionRequest) MarshalVT() (dAtA []byte, err error)

func (*SqlTransactionRequest) ProtoMessage 

func (*SqlTransactionRequest) ProtoMessage()

func (*SqlTransactionRequest) Reset 

func (x *SqlTransactionRequest) Reset()

func (*SqlTransactionRequest) SizeVT 

func (m *SqlTransactionRequest) SizeVT() (n int)

func (*SqlTransactionRequest) String 

func (x *SqlTransactionRequest) String() string

func (*SqlTransactionRequest) UnmarshalJSON 

func (x *SqlTransactionRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlTransactionRequest from JSON.

func (*SqlTransactionRequest) UnmarshalProtoJSON 

func (x *SqlTransactionRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlTransactionRequest message from JSON.

func (*SqlTransactionRequest) UnmarshalVT 

func (m *SqlTransactionRequest) UnmarshalVT(dAtA []byte) error

type SqlTransactionRequest_Commit 

type SqlTransactionRequest_Commit struct {
	// Commit commits the transaction.
	Commit bool `protobuf:"varint,2,opt,name=commit,proto3,oneof"`
}

func (*SqlTransactionRequest_Commit) CloneOneofVT 

func (m *SqlTransactionRequest_Commit) CloneOneofVT() isSqlTransactionRequest_Body

func (*SqlTransactionRequest_Commit) CloneVT 

func (m *SqlTransactionRequest_Commit) CloneVT() *SqlTransactionRequest_Commit

func (*SqlTransactionRequest_Commit) EqualVT 

func (this *SqlTransactionRequest_Commit) EqualVT(thatIface isSqlTransactionRequest_Body) bool

func (*SqlTransactionRequest_Commit) MarshalToSizedBufferVT 

func (m *SqlTransactionRequest_Commit) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest_Commit) MarshalToVT 

func (m *SqlTransactionRequest_Commit) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest_Commit) SizeVT 

func (m *SqlTransactionRequest_Commit) SizeVT() (n int)

type SqlTransactionRequest_Discard 

type SqlTransactionRequest_Discard struct {
	// Discard discards the transaction.
	Discard bool `protobuf:"varint,3,opt,name=discard,proto3,oneof"`
}

func (*SqlTransactionRequest_Discard) CloneOneofVT 

func (m *SqlTransactionRequest_Discard) CloneOneofVT() isSqlTransactionRequest_Body

func (*SqlTransactionRequest_Discard) CloneVT 

func (m *SqlTransactionRequest_Discard) CloneVT() *SqlTransactionRequest_Discard

func (*SqlTransactionRequest_Discard) EqualVT 

func (this *SqlTransactionRequest_Discard) EqualVT(thatIface isSqlTransactionRequest_Body) bool

func (*SqlTransactionRequest_Discard) MarshalToSizedBufferVT 

func (m *SqlTransactionRequest_Discard) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest_Discard) MarshalToVT 

func (m *SqlTransactionRequest_Discard) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest_Discard) SizeVT 

func (m *SqlTransactionRequest_Discard) SizeVT() (n int)

type SqlTransactionRequest_Init 

type SqlTransactionRequest_Init struct {
	// Init initializes the transaction.
	Init *SqlTransactionInit `protobuf:"bytes,1,opt,name=init,proto3,oneof"`
}

func (*SqlTransactionRequest_Init) CloneOneofVT 

func (m *SqlTransactionRequest_Init) CloneOneofVT() isSqlTransactionRequest_Body

func (*SqlTransactionRequest_Init) CloneVT 

func (m *SqlTransactionRequest_Init) CloneVT() *SqlTransactionRequest_Init

func (*SqlTransactionRequest_Init) EqualVT 

func (this *SqlTransactionRequest_Init) EqualVT(thatIface isSqlTransactionRequest_Body) bool

func (*SqlTransactionRequest_Init) MarshalToSizedBufferVT 

func (m *SqlTransactionRequest_Init) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest_Init) MarshalToVT 

func (m *SqlTransactionRequest_Init) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionRequest_Init) SizeVT 

func (m *SqlTransactionRequest_Init) SizeVT() (n int)

type SqlTransactionResponse 

type SqlTransactionResponse struct {

	// Body contains the message body.
	//
	// Types that are assignable to Body:
	//
	//	*SqlTransactionResponse_Ack
	//	*SqlTransactionResponse_Complete
	Body isSqlTransactionResponse_Body `protobuf_oneof:"body"`
	// contains filtered or unexported fields
}

SqlTransactionResponse is a response to the SqlTransaction rpc.

func (*SqlTransactionResponse) CloneMessageVT 

func (m *SqlTransactionResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*SqlTransactionResponse) CloneVT 

func (m *SqlTransactionResponse) CloneVT() *SqlTransactionResponse

func (*SqlTransactionResponse) EqualMessageVT 

func (this *SqlTransactionResponse) EqualMessageVT(thatMsg any) bool

func (*SqlTransactionResponse) EqualVT 

func (this *SqlTransactionResponse) EqualVT(that *SqlTransactionResponse) bool

func (*SqlTransactionResponse) GetAck 

func (x *SqlTransactionResponse) GetAck() *SqlTransactionAck

func (*SqlTransactionResponse) GetBody 

func (m *SqlTransactionResponse) GetBody() isSqlTransactionResponse_Body

func (*SqlTransactionResponse) GetComplete 

func (x *SqlTransactionResponse) GetComplete() *SqlTransactionComplete

func (*SqlTransactionResponse) MarshalJSON 

func (x *SqlTransactionResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the SqlTransactionResponse to JSON.

func (*SqlTransactionResponse) MarshalProtoJSON 

func (x *SqlTransactionResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the SqlTransactionResponse message to JSON.

func (*SqlTransactionResponse) MarshalProtoText 

func (x *SqlTransactionResponse) MarshalProtoText() string

func (*SqlTransactionResponse) MarshalToSizedBufferVT 

func (m *SqlTransactionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionResponse) MarshalToVT 

func (m *SqlTransactionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionResponse) MarshalVT 

func (m *SqlTransactionResponse) MarshalVT() (dAtA []byte, err error)

func (*SqlTransactionResponse) ProtoMessage 

func (*SqlTransactionResponse) ProtoMessage()

func (*SqlTransactionResponse) Reset 

func (x *SqlTransactionResponse) Reset()

func (*SqlTransactionResponse) SizeVT 

func (m *SqlTransactionResponse) SizeVT() (n int)

func (*SqlTransactionResponse) String 

func (x *SqlTransactionResponse) String() string

func (*SqlTransactionResponse) UnmarshalJSON 

func (x *SqlTransactionResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the SqlTransactionResponse from JSON.

func (*SqlTransactionResponse) UnmarshalProtoJSON 

func (x *SqlTransactionResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the SqlTransactionResponse message from JSON.

func (*SqlTransactionResponse) UnmarshalVT 

func (m *SqlTransactionResponse) UnmarshalVT(dAtA []byte) error

type SqlTransactionResponse_Ack 

type SqlTransactionResponse_Ack struct {
	// Ack acknowledges the transaction open.
	Ack *SqlTransactionAck `protobuf:"bytes,1,opt,name=ack,proto3,oneof"`
}

func (*SqlTransactionResponse_Ack) CloneOneofVT 

func (m *SqlTransactionResponse_Ack) CloneOneofVT() isSqlTransactionResponse_Body

func (*SqlTransactionResponse_Ack) CloneVT 

func (m *SqlTransactionResponse_Ack) CloneVT() *SqlTransactionResponse_Ack

func (*SqlTransactionResponse_Ack) EqualVT 

func (this *SqlTransactionResponse_Ack) EqualVT(thatIface isSqlTransactionResponse_Body) bool

func (*SqlTransactionResponse_Ack) MarshalToSizedBufferVT 

func (m *SqlTransactionResponse_Ack) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionResponse_Ack) MarshalToVT 

func (m *SqlTransactionResponse_Ack) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionResponse_Ack) SizeVT 

func (m *SqlTransactionResponse_Ack) SizeVT() (n int)

type SqlTransactionResponse_Complete 

type SqlTransactionResponse_Complete struct {
	// Complete contains transaction completion status.
	Complete *SqlTransactionComplete `protobuf:"bytes,2,opt,name=complete,proto3,oneof"`
}

func (*SqlTransactionResponse_Complete) CloneOneofVT 

func (m *SqlTransactionResponse_Complete) CloneOneofVT() isSqlTransactionResponse_Body

func (*SqlTransactionResponse_Complete) CloneVT 

func (m *SqlTransactionResponse_Complete) CloneVT() *SqlTransactionResponse_Complete

func (*SqlTransactionResponse_Complete) EqualVT 

func (this *SqlTransactionResponse_Complete) EqualVT(thatIface isSqlTransactionResponse_Body) bool

func (*SqlTransactionResponse_Complete) MarshalToSizedBufferVT 

func (m *SqlTransactionResponse_Complete) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SqlTransactionResponse_Complete) MarshalToVT 

func (m *SqlTransactionResponse_Complete) MarshalToVT(dAtA []byte) (int, error)

func (*SqlTransactionResponse_Complete) SizeVT 

func (m *SqlTransactionResponse_Complete) SizeVT() (n int)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.