sql_sqlite_wasm_rpc

package
v0.51.0 Latest Latest
Warning

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

 Go to latest Published: May 1, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCSqliteBridgeServiceID = "sql.sqlite_wasm.rpc.SqliteBridge"

Variables

This section is empty.

Functions

func NewSRPCSqliteBridgeHandler 

func NewSRPCSqliteBridgeHandler(impl SRPCSqliteBridgeServer, serviceID string) srpc.Handler

NewSRPCSqliteBridgeHandler constructs a new RPC handler. serviceID: if empty, uses default: sql.sqlite_wasm.rpc.SqliteBridge

func SRPCRegisterSqliteBridge 

func SRPCRegisterSqliteBridge(mux srpc.Mux, impl SRPCSqliteBridgeServer) error

SRPCRegisterSqliteBridge registers the implementation with the mux. Uses the default serviceID: sql.sqlite_wasm.rpc.SqliteBridge

Types

type CloseDbRequest 

type CloseDbRequest struct {

	// db_id is the handle of the database to close.
	DbId uint32 `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"dbId,omitempty"`
	// contains filtered or unexported fields
}

CloseDbRequest is the request to close a database.

func (*CloseDbRequest) CloneMessageVT 

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

func (*CloseDbRequest) CloneVT 

func (m *CloseDbRequest) CloneVT() *CloseDbRequest

func (*CloseDbRequest) EqualMessageVT 

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

func (*CloseDbRequest) EqualVT 

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

func (*CloseDbRequest) GetDbId 

func (x *CloseDbRequest) GetDbId() uint32

func (*CloseDbRequest) MarshalJSON 

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

MarshalJSON marshals the CloseDbRequest to JSON.

func (*CloseDbRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the CloseDbRequest message to JSON.

func (*CloseDbRequest) MarshalProtoText 

func (x *CloseDbRequest) MarshalProtoText() string

func (*CloseDbRequest) MarshalToSizedBufferVT 

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

func (*CloseDbRequest) MarshalToVT 

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

func (*CloseDbRequest) MarshalVT 

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

func (*CloseDbRequest) ProtoMessage 

func (*CloseDbRequest) ProtoMessage()

func (*CloseDbRequest) Reset 

func (x *CloseDbRequest) Reset()

func (*CloseDbRequest) SizeVT 

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

func (*CloseDbRequest) String 

func (x *CloseDbRequest) String() string

func (*CloseDbRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the CloseDbRequest from JSON.

func (*CloseDbRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the CloseDbRequest message from JSON.

func (*CloseDbRequest) UnmarshalVT 

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

type CloseDbResponse 

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

CloseDbResponse is the response after closing a database.

func (*CloseDbResponse) CloneMessageVT 

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

func (*CloseDbResponse) CloneVT 

func (m *CloseDbResponse) CloneVT() *CloseDbResponse

func (*CloseDbResponse) EqualMessageVT 

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

func (*CloseDbResponse) EqualVT 

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

func (*CloseDbResponse) MarshalJSON 

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

MarshalJSON marshals the CloseDbResponse to JSON.

func (*CloseDbResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the CloseDbResponse message to JSON.

func (*CloseDbResponse) MarshalProtoText 

func (x *CloseDbResponse) MarshalProtoText() string

func (*CloseDbResponse) MarshalToSizedBufferVT 

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

func (*CloseDbResponse) MarshalToVT 

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

func (*CloseDbResponse) MarshalVT 

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

func (*CloseDbResponse) ProtoMessage 

func (*CloseDbResponse) ProtoMessage()

func (*CloseDbResponse) Reset 

func (x *CloseDbResponse) Reset()

func (*CloseDbResponse) SizeVT 

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

func (*CloseDbResponse) String 

func (x *CloseDbResponse) String() string

func (*CloseDbResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the CloseDbResponse from JSON.

func (*CloseDbResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the CloseDbResponse message from JSON.

func (*CloseDbResponse) UnmarshalVT 

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

type DeleteDbRequest 

type DeleteDbRequest struct {

	// path is the database path to delete.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

DeleteDbRequest is the request to delete a database.

func (*DeleteDbRequest) CloneMessageVT 

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

func (*DeleteDbRequest) CloneVT 

func (m *DeleteDbRequest) CloneVT() *DeleteDbRequest

func (*DeleteDbRequest) EqualMessageVT 

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

func (*DeleteDbRequest) EqualVT 

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

func (*DeleteDbRequest) GetPath 

func (x *DeleteDbRequest) GetPath() string

func (*DeleteDbRequest) MarshalJSON 

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

MarshalJSON marshals the DeleteDbRequest to JSON.

func (*DeleteDbRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the DeleteDbRequest message to JSON.

func (*DeleteDbRequest) MarshalProtoText 

func (x *DeleteDbRequest) MarshalProtoText() string

func (*DeleteDbRequest) MarshalToSizedBufferVT 

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

func (*DeleteDbRequest) MarshalToVT 

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

func (*DeleteDbRequest) MarshalVT 

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

func (*DeleteDbRequest) ProtoMessage 

func (*DeleteDbRequest) ProtoMessage()

func (*DeleteDbRequest) Reset 

func (x *DeleteDbRequest) Reset()

func (*DeleteDbRequest) SizeVT 

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

func (*DeleteDbRequest) String 

func (x *DeleteDbRequest) String() string

func (*DeleteDbRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the DeleteDbRequest from JSON.

func (*DeleteDbRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the DeleteDbRequest message from JSON.

func (*DeleteDbRequest) UnmarshalVT 

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

type DeleteDbResponse 

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

DeleteDbResponse is the response after deleting a database.

func (*DeleteDbResponse) CloneMessageVT 

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

func (*DeleteDbResponse) CloneVT 

func (m *DeleteDbResponse) CloneVT() *DeleteDbResponse

func (*DeleteDbResponse) EqualMessageVT 

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

func (*DeleteDbResponse) EqualVT 

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

func (*DeleteDbResponse) MarshalJSON 

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

MarshalJSON marshals the DeleteDbResponse to JSON.

func (*DeleteDbResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the DeleteDbResponse message to JSON.

func (*DeleteDbResponse) MarshalProtoText 

func (x *DeleteDbResponse) MarshalProtoText() string

func (*DeleteDbResponse) MarshalToSizedBufferVT 

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

func (*DeleteDbResponse) MarshalToVT 

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

func (*DeleteDbResponse) MarshalVT 

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

func (*DeleteDbResponse) ProtoMessage 

func (*DeleteDbResponse) ProtoMessage()

func (*DeleteDbResponse) Reset 

func (x *DeleteDbResponse) Reset()

func (*DeleteDbResponse) SizeVT 

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

func (*DeleteDbResponse) String 

func (x *DeleteDbResponse) String() string

func (*DeleteDbResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the DeleteDbResponse from JSON.

func (*DeleteDbResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the DeleteDbResponse message from JSON.

func (*DeleteDbResponse) UnmarshalVT 

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

type ExecRequest 

type ExecRequest struct {

	// db_id is the handle of the database.
	DbId uint32 `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"dbId,omitempty"`
	// sql is the SQL statement to execute.
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// params are the bind parameters.
	Params []*SqlValue `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

ExecRequest is the request to execute a DDL/DML statement.

func (*ExecRequest) CloneMessageVT 

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

func (*ExecRequest) CloneVT 

func (m *ExecRequest) CloneVT() *ExecRequest

func (*ExecRequest) EqualMessageVT 

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

func (*ExecRequest) EqualVT 

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

func (*ExecRequest) GetDbId 

func (x *ExecRequest) GetDbId() uint32

func (*ExecRequest) GetParams 

func (x *ExecRequest) GetParams() []*SqlValue

func (*ExecRequest) GetSql 

func (x *ExecRequest) GetSql() string

func (*ExecRequest) MarshalJSON 

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

MarshalJSON marshals the ExecRequest to JSON.

func (*ExecRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ExecRequest message to JSON.

func (*ExecRequest) MarshalProtoText 

func (x *ExecRequest) MarshalProtoText() string

func (*ExecRequest) MarshalToSizedBufferVT 

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

func (*ExecRequest) MarshalToVT 

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

func (*ExecRequest) MarshalVT 

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

func (*ExecRequest) ProtoMessage 

func (*ExecRequest) ProtoMessage()

func (*ExecRequest) Reset 

func (x *ExecRequest) Reset()

func (*ExecRequest) SizeVT 

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

func (*ExecRequest) String 

func (x *ExecRequest) String() string

func (*ExecRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ExecRequest from JSON.

func (*ExecRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ExecRequest message from JSON.

func (*ExecRequest) UnmarshalVT 

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

type ExecResponse 

type ExecResponse struct {

	// changes is the number of rows changed by the statement.
	Changes int64 `protobuf:"varint,1,opt,name=changes,proto3" json:"changes,omitempty"`
	// last_insert_row_id is the rowid of the last inserted row.
	LastInsertRowId int64 `protobuf:"varint,2,opt,name=last_insert_row_id,json=lastInsertRowId,proto3" json:"lastInsertRowId,omitempty"`
	// contains filtered or unexported fields
}

ExecResponse is the response after executing a statement.

func (*ExecResponse) CloneMessageVT 

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

func (*ExecResponse) CloneVT 

func (m *ExecResponse) CloneVT() *ExecResponse

func (*ExecResponse) EqualMessageVT 

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

func (*ExecResponse) EqualVT 

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

func (*ExecResponse) GetChanges 

func (x *ExecResponse) GetChanges() int64

func (*ExecResponse) GetLastInsertRowId 

func (x *ExecResponse) GetLastInsertRowId() int64

func (*ExecResponse) MarshalJSON 

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

MarshalJSON marshals the ExecResponse to JSON.

func (*ExecResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the ExecResponse message to JSON.

func (*ExecResponse) MarshalProtoText 

func (x *ExecResponse) MarshalProtoText() string

func (*ExecResponse) MarshalToSizedBufferVT 

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

func (*ExecResponse) MarshalToVT 

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

func (*ExecResponse) MarshalVT 

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

func (*ExecResponse) ProtoMessage 

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) Reset 

func (x *ExecResponse) Reset()

func (*ExecResponse) SizeVT 

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

func (*ExecResponse) String 

func (x *ExecResponse) String() string

func (*ExecResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the ExecResponse from JSON.

func (*ExecResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the ExecResponse message from JSON.

func (*ExecResponse) UnmarshalVT 

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

type OpenDbRequest 

type OpenDbRequest struct {

	// path is the database path (e.g. "/vol-123.db").
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

OpenDbRequest is the request to open a database.

func (*OpenDbRequest) CloneMessageVT 

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

func (*OpenDbRequest) CloneVT 

func (m *OpenDbRequest) CloneVT() *OpenDbRequest

func (*OpenDbRequest) EqualMessageVT 

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

func (*OpenDbRequest) EqualVT 

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

func (*OpenDbRequest) GetPath 

func (x *OpenDbRequest) GetPath() string

func (*OpenDbRequest) MarshalJSON 

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

MarshalJSON marshals the OpenDbRequest to JSON.

func (*OpenDbRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the OpenDbRequest message to JSON.

func (*OpenDbRequest) MarshalProtoText 

func (x *OpenDbRequest) MarshalProtoText() string

func (*OpenDbRequest) MarshalToSizedBufferVT 

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

func (*OpenDbRequest) MarshalToVT 

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

func (*OpenDbRequest) MarshalVT 

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

func (*OpenDbRequest) ProtoMessage 

func (*OpenDbRequest) ProtoMessage()

func (*OpenDbRequest) Reset 

func (x *OpenDbRequest) Reset()

func (*OpenDbRequest) SizeVT 

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

func (*OpenDbRequest) String 

func (x *OpenDbRequest) String() string

func (*OpenDbRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the OpenDbRequest from JSON.

func (*OpenDbRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the OpenDbRequest message from JSON.

func (*OpenDbRequest) UnmarshalVT 

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

type OpenDbResponse 

type OpenDbResponse struct {

	// db_id is the handle for the opened database.
	DbId uint32 `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"dbId,omitempty"`
	// contains filtered or unexported fields
}

OpenDbResponse is the response after opening a database.

func (*OpenDbResponse) CloneMessageVT 

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

func (*OpenDbResponse) CloneVT 

func (m *OpenDbResponse) CloneVT() *OpenDbResponse

func (*OpenDbResponse) EqualMessageVT 

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

func (*OpenDbResponse) EqualVT 

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

func (*OpenDbResponse) GetDbId 

func (x *OpenDbResponse) GetDbId() uint32

func (*OpenDbResponse) MarshalJSON 

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

MarshalJSON marshals the OpenDbResponse to JSON.

func (*OpenDbResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the OpenDbResponse message to JSON.

func (*OpenDbResponse) MarshalProtoText 

func (x *OpenDbResponse) MarshalProtoText() string

func (*OpenDbResponse) MarshalToSizedBufferVT 

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

func (*OpenDbResponse) MarshalToVT 

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

func (*OpenDbResponse) MarshalVT 

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

func (*OpenDbResponse) ProtoMessage 

func (*OpenDbResponse) ProtoMessage()

func (*OpenDbResponse) Reset 

func (x *OpenDbResponse) Reset()

func (*OpenDbResponse) SizeVT 

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

func (*OpenDbResponse) String 

func (x *OpenDbResponse) String() string

func (*OpenDbResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the OpenDbResponse from JSON.

func (*OpenDbResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the OpenDbResponse message from JSON.

func (*OpenDbResponse) UnmarshalVT 

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

type QueryRequest 

type QueryRequest struct {

	// db_id is the handle of the database.
	DbId uint32 `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"dbId,omitempty"`
	// sql is the SQL query to execute.
	Sql string `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	// params are the bind parameters.
	Params []*SqlValue `protobuf:"bytes,3,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

QueryRequest is the request to execute a SELECT query.

func (*QueryRequest) CloneMessageVT 

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

func (*QueryRequest) CloneVT 

func (m *QueryRequest) CloneVT() *QueryRequest

func (*QueryRequest) EqualMessageVT 

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

func (*QueryRequest) EqualVT 

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

func (*QueryRequest) GetDbId 

func (x *QueryRequest) GetDbId() uint32

func (*QueryRequest) GetParams 

func (x *QueryRequest) GetParams() []*SqlValue

func (*QueryRequest) GetSql 

func (x *QueryRequest) GetSql() string

func (*QueryRequest) MarshalJSON 

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

MarshalJSON marshals the QueryRequest to JSON.

func (*QueryRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the QueryRequest message to JSON.

func (*QueryRequest) MarshalProtoText 

func (x *QueryRequest) MarshalProtoText() string

func (*QueryRequest) MarshalToSizedBufferVT 

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

func (*QueryRequest) MarshalToVT 

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

func (*QueryRequest) MarshalVT 

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

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) SizeVT 

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

func (*QueryRequest) String 

func (x *QueryRequest) String() string

func (*QueryRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the QueryRequest from JSON.

func (*QueryRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the QueryRequest message from JSON.

func (*QueryRequest) UnmarshalVT 

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

type QueryResponse 

type QueryResponse struct {

	// column_names is set in the first response message only.
	ColumnNames []string `protobuf:"bytes,1,rep,name=column_names,json=columnNames,proto3" json:"columnNames,omitempty"`
	// row contains one row of values, set in subsequent messages.
	Row []*SqlValue `protobuf:"bytes,2,rep,name=row,proto3" json:"row,omitempty"`
	// contains filtered or unexported fields
}

QueryResponse is a streaming response for a SELECT query. The first message contains column_names. Subsequent messages each contain one row.

func (*QueryResponse) CloneMessageVT 

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

func (*QueryResponse) CloneVT 

func (m *QueryResponse) CloneVT() *QueryResponse

func (*QueryResponse) EqualMessageVT 

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

func (*QueryResponse) EqualVT 

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

func (*QueryResponse) GetColumnNames 

func (x *QueryResponse) GetColumnNames() []string

func (*QueryResponse) GetRow 

func (x *QueryResponse) GetRow() []*SqlValue

func (*QueryResponse) MarshalJSON 

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

MarshalJSON marshals the QueryResponse to JSON.

func (*QueryResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the QueryResponse message to JSON.

func (*QueryResponse) MarshalProtoText 

func (x *QueryResponse) MarshalProtoText() string

func (*QueryResponse) MarshalToSizedBufferVT 

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

func (*QueryResponse) MarshalToVT 

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

func (*QueryResponse) MarshalVT 

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

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) SizeVT 

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

func (*QueryResponse) String 

func (x *QueryResponse) String() string

func (*QueryResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the QueryResponse from JSON.

func (*QueryResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the QueryResponse message from JSON.

func (*QueryResponse) UnmarshalVT 

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

type SRPCSqliteBridgeClient 

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

	// OpenDb opens or creates a SQLite database by path.
	OpenDb(ctx context.Context, in *OpenDbRequest) (*OpenDbResponse, error)
	// CloseDb closes an open database by handle.
	CloseDb(ctx context.Context, in *CloseDbRequest) (*CloseDbResponse, error)
	// Exec executes a DDL/DML statement (CREATE, INSERT, UPDATE, DELETE, BEGIN, COMMIT, ROLLBACK).
	Exec(ctx context.Context, in *ExecRequest) (*ExecResponse, error)
	// Query executes a SELECT and streams rows back one at a time.
	// First response contains column names. Subsequent responses each contain one row.
	Query(ctx context.Context, in *QueryRequest) (SRPCSqliteBridge_QueryClient, error)
	// DeleteDb deletes a database by path.
	DeleteDb(ctx context.Context, in *DeleteDbRequest) (*DeleteDbResponse, error)
}

func NewSRPCSqliteBridgeClient 

func NewSRPCSqliteBridgeClient(cc srpc.Client) SRPCSqliteBridgeClient

func NewSRPCSqliteBridgeClientWithServiceID 

func NewSRPCSqliteBridgeClientWithServiceID(cc srpc.Client, serviceID string) SRPCSqliteBridgeClient

type SRPCSqliteBridgeHandler 

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

func (SRPCSqliteBridgeHandler) GetMethodIDs 

func (SRPCSqliteBridgeHandler) GetMethodIDs() []string

func (*SRPCSqliteBridgeHandler) GetServiceID 

func (d *SRPCSqliteBridgeHandler) GetServiceID() string

func (*SRPCSqliteBridgeHandler) InvokeMethod 

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

func (SRPCSqliteBridgeHandler) InvokeMethod_CloseDb 

func (SRPCSqliteBridgeHandler) InvokeMethod_CloseDb(impl SRPCSqliteBridgeServer, strm srpc.Stream) error

func (SRPCSqliteBridgeHandler) InvokeMethod_DeleteDb 

func (SRPCSqliteBridgeHandler) InvokeMethod_DeleteDb(impl SRPCSqliteBridgeServer, strm srpc.Stream) error

func (SRPCSqliteBridgeHandler) InvokeMethod_Exec 

func (SRPCSqliteBridgeHandler) InvokeMethod_Exec(impl SRPCSqliteBridgeServer, strm srpc.Stream) error

func (SRPCSqliteBridgeHandler) InvokeMethod_OpenDb 

func (SRPCSqliteBridgeHandler) InvokeMethod_OpenDb(impl SRPCSqliteBridgeServer, strm srpc.Stream) error

func (SRPCSqliteBridgeHandler) InvokeMethod_Query 

func (SRPCSqliteBridgeHandler) InvokeMethod_Query(impl SRPCSqliteBridgeServer, strm srpc.Stream) error

type SRPCSqliteBridgeServer 

type SRPCSqliteBridgeServer interface {
	// OpenDb opens or creates a SQLite database by path.
	OpenDb(context.Context, *OpenDbRequest) (*OpenDbResponse, error)
	// CloseDb closes an open database by handle.
	CloseDb(context.Context, *CloseDbRequest) (*CloseDbResponse, error)
	// Exec executes a DDL/DML statement (CREATE, INSERT, UPDATE, DELETE, BEGIN, COMMIT, ROLLBACK).
	Exec(context.Context, *ExecRequest) (*ExecResponse, error)
	// Query executes a SELECT and streams rows back one at a time.
	// First response contains column names. Subsequent responses each contain one row.
	Query(*QueryRequest, SRPCSqliteBridge_QueryStream) error
	// DeleteDb deletes a database by path.
	DeleteDb(context.Context, *DeleteDbRequest) (*DeleteDbResponse, error)
}

type SRPCSqliteBridge_CloseDbStream 

type SRPCSqliteBridge_CloseDbStream interface {
	srpc.Stream
}

type SRPCSqliteBridge_DeleteDbStream 

type SRPCSqliteBridge_DeleteDbStream interface {
	srpc.Stream
}

type SRPCSqliteBridge_ExecStream 

type SRPCSqliteBridge_ExecStream interface {
	srpc.Stream
}

type SRPCSqliteBridge_OpenDbStream 

type SRPCSqliteBridge_OpenDbStream interface {
	srpc.Stream
}

type SRPCSqliteBridge_QueryClient 

type SRPCSqliteBridge_QueryClient interface {
	srpc.Stream
	Recv() (*QueryResponse, error)
	RecvTo(*QueryResponse) error
}

type SRPCSqliteBridge_QueryStream 

type SRPCSqliteBridge_QueryStream interface {
	srpc.Stream
	Send(*QueryResponse) error
	SendAndClose(*QueryResponse) error
}

type SqlValue 

type SqlValue struct {

	// Types that are assignable to Value:
	//
	//	*SqlValue_IntValue
	//	*SqlValue_FloatValue
	//	*SqlValue_StrValue
	//	*SqlValue_BlobValue
	Value isSqlValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

SqlValue represents a SQLite value (int64, double, string, bytes, or null).

func (*SqlValue) CloneMessageVT 

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

func (*SqlValue) CloneVT 

func (m *SqlValue) CloneVT() *SqlValue

func (*SqlValue) EqualMessageVT 

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

func (*SqlValue) EqualVT 

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

func (*SqlValue) GetBlobValue 

func (x *SqlValue) GetBlobValue() []byte

func (*SqlValue) GetFloatValue 

func (x *SqlValue) GetFloatValue() float64

func (*SqlValue) GetIntValue 

func (x *SqlValue) GetIntValue() int64

func (*SqlValue) GetStrValue 

func (x *SqlValue) GetStrValue() string

func (*SqlValue) GetValue 

func (m *SqlValue) GetValue() isSqlValue_Value

func (*SqlValue) MarshalJSON 

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

MarshalJSON marshals the SqlValue to JSON.

func (*SqlValue) MarshalProtoJSON 

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

MarshalProtoJSON marshals the SqlValue message to JSON.

func (*SqlValue) MarshalProtoText 

func (x *SqlValue) MarshalProtoText() string

func (*SqlValue) MarshalToSizedBufferVT 

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

func (*SqlValue) MarshalToVT 

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

func (*SqlValue) MarshalVT 

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

func (*SqlValue) ProtoMessage 

func (*SqlValue) ProtoMessage()

func (*SqlValue) Reset 

func (x *SqlValue) Reset()

func (*SqlValue) SizeVT 

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

func (*SqlValue) String 

func (x *SqlValue) String() string

func (*SqlValue) UnmarshalJSON 

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

UnmarshalJSON unmarshals the SqlValue from JSON.

func (*SqlValue) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the SqlValue message from JSON.

func (*SqlValue) UnmarshalVT 

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

type SqlValue_BlobValue 

type SqlValue_BlobValue struct {
	// blob_value is a BLOB value.
	BlobValue []byte `protobuf:"bytes,4,opt,name=blob_value,json=blobValue,proto3,oneof"`
}

func (*SqlValue_BlobValue) CloneOneofVT 

func (m *SqlValue_BlobValue) CloneOneofVT() isSqlValue_Value

func (*SqlValue_BlobValue) CloneVT 

func (m *SqlValue_BlobValue) CloneVT() *SqlValue_BlobValue

func (*SqlValue_BlobValue) EqualVT 

func (this *SqlValue_BlobValue) EqualVT(thatIface isSqlValue_Value) bool

func (*SqlValue_BlobValue) MarshalToSizedBufferVT 

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

func (*SqlValue_BlobValue) MarshalToVT 

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

func (*SqlValue_BlobValue) SizeVT 

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

type SqlValue_FloatValue 

type SqlValue_FloatValue struct {
	// float_value is a REAL value.
	FloatValue float64 `protobuf:"fixed64,2,opt,name=float_value,json=floatValue,proto3,oneof"`
}

func (*SqlValue_FloatValue) CloneOneofVT 

func (m *SqlValue_FloatValue) CloneOneofVT() isSqlValue_Value

func (*SqlValue_FloatValue) CloneVT 

func (m *SqlValue_FloatValue) CloneVT() *SqlValue_FloatValue

func (*SqlValue_FloatValue) EqualVT 

func (this *SqlValue_FloatValue) EqualVT(thatIface isSqlValue_Value) bool

func (*SqlValue_FloatValue) MarshalToSizedBufferVT 

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

func (*SqlValue_FloatValue) MarshalToVT 

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

func (*SqlValue_FloatValue) SizeVT 

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

type SqlValue_IntValue 

type SqlValue_IntValue struct {
	// int_value is an INTEGER value.
	IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,proto3,oneof"`
}

func (*SqlValue_IntValue) CloneOneofVT 

func (m *SqlValue_IntValue) CloneOneofVT() isSqlValue_Value

func (*SqlValue_IntValue) CloneVT 

func (m *SqlValue_IntValue) CloneVT() *SqlValue_IntValue

func (*SqlValue_IntValue) EqualVT 

func (this *SqlValue_IntValue) EqualVT(thatIface isSqlValue_Value) bool

func (*SqlValue_IntValue) MarshalToSizedBufferVT 

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

func (*SqlValue_IntValue) MarshalToVT 

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

func (*SqlValue_IntValue) SizeVT 

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

type SqlValue_StrValue 

type SqlValue_StrValue struct {
	// str_value is a TEXT value.
	StrValue string `protobuf:"bytes,3,opt,name=str_value,json=strValue,proto3,oneof"`
}

func (*SqlValue_StrValue) CloneOneofVT 

func (m *SqlValue_StrValue) CloneOneofVT() isSqlValue_Value

func (*SqlValue_StrValue) CloneVT 

func (m *SqlValue_StrValue) CloneVT() *SqlValue_StrValue

func (*SqlValue_StrValue) EqualVT 

func (this *SqlValue_StrValue) EqualVT(thatIface isSqlValue_Value) bool

func (*SqlValue_StrValue) MarshalToSizedBufferVT 

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

func (*SqlValue_StrValue) MarshalToVT 

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

func (*SqlValue_StrValue) SizeVT 

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

Source Files

View all Source files

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.