Documentation ¶
Overview ¶
Package protocol defines the wire format for SQL statements and results.
It's kept in a separate package since this code is entirely generated by the protobuf compile, and should not affect code coverage measurements.
Package protocol is a generated protocol buffer package. It is generated from these files: internal/protocol/sql.proto It has these top-level messages: Request RequestOpen RequestPrepare RequestExec RequestQuery RequestNext RequestColumnTypeScanType RequestColumnTypeDatabaseTypeName RequestRowsClose RequestStmtClose RequestBegin RequestCommit RequestRollback RequestClose RequestConnExec Response ResponseOpen ResponsePrepare ResponseExec ResponseQuery ResponseNext ResponseColumnTypeScanType ResponseColumnTypeDatabaseTypeName ResponseRowsClose ResponseStmtClose ResponseBegin ResponseCommit ResponseRollback ResponseClose ResponseSQLiteError Value ValueInt64 ValueFloat64 ValueBool ValueBytes ValueString ValueTime ValueNull
Index ¶
- Variables
- func FromValueCode(code ValueCode) reflect.Type
- func FromValueSlice(values []*Value) ([]interface{}, error)
- func RegisterSQLServer(s *grpc.Server, srv SQLServer)
- func ToDriverValues(values []*Value) ([]driver.Value, error)
- type Request
- func NewRequestBegin() *Request
- func NewRequestClose() *Request
- func NewRequestColumnTypeDatabaseTypeName(id int64, column int64) *Request
- func NewRequestColumnTypeScanType(id int64, column int64) *Request
- func NewRequestCommit(id int64) *Request
- func NewRequestConnExec(query string, args []*Value) *Request
- func NewRequestExec(id int64, args []*Value) *Request
- func NewRequestNext(id int64, n int64) *Request
- func NewRequestOpen(name string) *Request
- func NewRequestPrepare(query string) *Request
- func NewRequestQuery(id int64, args []*Value) *Request
- func NewRequestRollback(id int64) *Request
- func NewRequestRowsClose(id int64) *Request
- func NewRequestStmtClose(id int64) *Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetCode() RequestCode
- func (m *Request) GetData() []byte
- func (m *Request) Marshal() (dAtA []byte, err error)
- func (m *Request) MarshalTo(dAtA []byte) (int, error)
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) Size() (n int)
- func (m *Request) String() string
- func (m *Request) Unmarshal(dAtA []byte) error
- type RequestBegin
- func (*RequestBegin) Descriptor() ([]byte, []int)
- func (m *RequestBegin) Marshal() (dAtA []byte, err error)
- func (m *RequestBegin) MarshalTo(dAtA []byte) (int, error)
- func (*RequestBegin) ProtoMessage()
- func (m *RequestBegin) Reset()
- func (m *RequestBegin) Size() (n int)
- func (m *RequestBegin) String() string
- func (m *RequestBegin) Unmarshal(dAtA []byte) error
- type RequestClose
- func (*RequestClose) Descriptor() ([]byte, []int)
- func (m *RequestClose) Marshal() (dAtA []byte, err error)
- func (m *RequestClose) MarshalTo(dAtA []byte) (int, error)
- func (*RequestClose) ProtoMessage()
- func (m *RequestClose) Reset()
- func (m *RequestClose) Size() (n int)
- func (m *RequestClose) String() string
- func (m *RequestClose) Unmarshal(dAtA []byte) error
- type RequestCode
- type RequestColumnTypeDatabaseTypeName
- func (*RequestColumnTypeDatabaseTypeName) Descriptor() ([]byte, []int)
- func (m *RequestColumnTypeDatabaseTypeName) GetColumn() int64
- func (m *RequestColumnTypeDatabaseTypeName) GetId() int64
- func (m *RequestColumnTypeDatabaseTypeName) Marshal() (dAtA []byte, err error)
- func (m *RequestColumnTypeDatabaseTypeName) MarshalTo(dAtA []byte) (int, error)
- func (*RequestColumnTypeDatabaseTypeName) ProtoMessage()
- func (m *RequestColumnTypeDatabaseTypeName) Reset()
- func (m *RequestColumnTypeDatabaseTypeName) Size() (n int)
- func (m *RequestColumnTypeDatabaseTypeName) String() string
- func (m *RequestColumnTypeDatabaseTypeName) Unmarshal(dAtA []byte) error
- type RequestColumnTypeScanType
- func (*RequestColumnTypeScanType) Descriptor() ([]byte, []int)
- func (m *RequestColumnTypeScanType) GetColumn() int64
- func (m *RequestColumnTypeScanType) GetId() int64
- func (m *RequestColumnTypeScanType) Marshal() (dAtA []byte, err error)
- func (m *RequestColumnTypeScanType) MarshalTo(dAtA []byte) (int, error)
- func (*RequestColumnTypeScanType) ProtoMessage()
- func (m *RequestColumnTypeScanType) Reset()
- func (m *RequestColumnTypeScanType) Size() (n int)
- func (m *RequestColumnTypeScanType) String() string
- func (m *RequestColumnTypeScanType) Unmarshal(dAtA []byte) error
- type RequestCommit
- func (*RequestCommit) Descriptor() ([]byte, []int)
- func (m *RequestCommit) GetId() int64
- func (m *RequestCommit) Marshal() (dAtA []byte, err error)
- func (m *RequestCommit) MarshalTo(dAtA []byte) (int, error)
- func (*RequestCommit) ProtoMessage()
- func (m *RequestCommit) Reset()
- func (m *RequestCommit) Size() (n int)
- func (m *RequestCommit) String() string
- func (m *RequestCommit) Unmarshal(dAtA []byte) error
- type RequestConnExec
- func (*RequestConnExec) Descriptor() ([]byte, []int)
- func (m *RequestConnExec) GetArgs() []*Value
- func (m *RequestConnExec) GetQuery() string
- func (m *RequestConnExec) Marshal() (dAtA []byte, err error)
- func (m *RequestConnExec) MarshalTo(dAtA []byte) (int, error)
- func (*RequestConnExec) ProtoMessage()
- func (m *RequestConnExec) Reset()
- func (m *RequestConnExec) Size() (n int)
- func (m *RequestConnExec) String() string
- func (m *RequestConnExec) Unmarshal(dAtA []byte) error
- type RequestExec
- func (*RequestExec) Descriptor() ([]byte, []int)
- func (m *RequestExec) GetArgs() []*Value
- func (m *RequestExec) GetId() int64
- func (m *RequestExec) Marshal() (dAtA []byte, err error)
- func (m *RequestExec) MarshalTo(dAtA []byte) (int, error)
- func (*RequestExec) ProtoMessage()
- func (m *RequestExec) Reset()
- func (m *RequestExec) Size() (n int)
- func (m *RequestExec) String() string
- func (m *RequestExec) Unmarshal(dAtA []byte) error
- type RequestNext
- func (*RequestNext) Descriptor() ([]byte, []int)
- func (m *RequestNext) GetId() int64
- func (m *RequestNext) GetLen() int64
- func (m *RequestNext) Marshal() (dAtA []byte, err error)
- func (m *RequestNext) MarshalTo(dAtA []byte) (int, error)
- func (*RequestNext) ProtoMessage()
- func (m *RequestNext) Reset()
- func (m *RequestNext) Size() (n int)
- func (m *RequestNext) String() string
- func (m *RequestNext) Unmarshal(dAtA []byte) error
- type RequestOpen
- func (*RequestOpen) Descriptor() ([]byte, []int)
- func (m *RequestOpen) GetName() string
- func (m *RequestOpen) Marshal() (dAtA []byte, err error)
- func (m *RequestOpen) MarshalTo(dAtA []byte) (int, error)
- func (*RequestOpen) ProtoMessage()
- func (m *RequestOpen) Reset()
- func (m *RequestOpen) Size() (n int)
- func (m *RequestOpen) String() string
- func (m *RequestOpen) Unmarshal(dAtA []byte) error
- type RequestPrepare
- func (*RequestPrepare) Descriptor() ([]byte, []int)
- func (m *RequestPrepare) GetQuery() string
- func (m *RequestPrepare) Marshal() (dAtA []byte, err error)
- func (m *RequestPrepare) MarshalTo(dAtA []byte) (int, error)
- func (*RequestPrepare) ProtoMessage()
- func (m *RequestPrepare) Reset()
- func (m *RequestPrepare) Size() (n int)
- func (m *RequestPrepare) String() string
- func (m *RequestPrepare) Unmarshal(dAtA []byte) error
- type RequestQuery
- func (*RequestQuery) Descriptor() ([]byte, []int)
- func (m *RequestQuery) GetArgs() []*Value
- func (m *RequestQuery) GetId() int64
- func (m *RequestQuery) Marshal() (dAtA []byte, err error)
- func (m *RequestQuery) MarshalTo(dAtA []byte) (int, error)
- func (*RequestQuery) ProtoMessage()
- func (m *RequestQuery) Reset()
- func (m *RequestQuery) Size() (n int)
- func (m *RequestQuery) String() string
- func (m *RequestQuery) Unmarshal(dAtA []byte) error
- type RequestRollback
- func (*RequestRollback) Descriptor() ([]byte, []int)
- func (m *RequestRollback) GetId() int64
- func (m *RequestRollback) Marshal() (dAtA []byte, err error)
- func (m *RequestRollback) MarshalTo(dAtA []byte) (int, error)
- func (*RequestRollback) ProtoMessage()
- func (m *RequestRollback) Reset()
- func (m *RequestRollback) Size() (n int)
- func (m *RequestRollback) String() string
- func (m *RequestRollback) Unmarshal(dAtA []byte) error
- type RequestRowsClose
- func (*RequestRowsClose) Descriptor() ([]byte, []int)
- func (m *RequestRowsClose) GetId() int64
- func (m *RequestRowsClose) Marshal() (dAtA []byte, err error)
- func (m *RequestRowsClose) MarshalTo(dAtA []byte) (int, error)
- func (*RequestRowsClose) ProtoMessage()
- func (m *RequestRowsClose) Reset()
- func (m *RequestRowsClose) Size() (n int)
- func (m *RequestRowsClose) String() string
- func (m *RequestRowsClose) Unmarshal(dAtA []byte) error
- type RequestStmtClose
- func (*RequestStmtClose) Descriptor() ([]byte, []int)
- func (m *RequestStmtClose) GetId() int64
- func (m *RequestStmtClose) Marshal() (dAtA []byte, err error)
- func (m *RequestStmtClose) MarshalTo(dAtA []byte) (int, error)
- func (*RequestStmtClose) ProtoMessage()
- func (m *RequestStmtClose) Reset()
- func (m *RequestStmtClose) Size() (n int)
- func (m *RequestStmtClose) String() string
- func (m *RequestStmtClose) Unmarshal(dAtA []byte) error
- type Response
- func NewResponseBegin(id int64) *Response
- func NewResponseClose() *Response
- func NewResponseColumnTypeDatabaseTypeName(name string) *Response
- func NewResponseColumnTypeScanType(code ValueCode) *Response
- func NewResponseCommit() *Response
- func NewResponseExec(lastInsertID, rowsAffected int64) *Response
- func NewResponseNext(eof bool, values []*Value) *Response
- func NewResponseOpen() *Response
- func NewResponsePrepare(id int64, numInput int) *Response
- func NewResponseQuery(id int64, columns []string) *Response
- func NewResponseRollback() *Response
- func NewResponseRowsClose() *Response
- func NewResponseSQLiteError(code sqlite3.ErrNo, extendedCode sqlite3.ErrNoExtended, err string) *Response
- func NewResponseStmtClose() *Response
- func (r *Response) Begin() *ResponseBegin
- func (r *Response) ColumnTypeDatabaseTypeName() *ResponseColumnTypeDatabaseTypeName
- func (r *Response) ColumnTypeScanType() *ResponseColumnTypeScanType
- func (*Response) Descriptor() ([]byte, []int)
- func (r *Response) Exec() *ResponseExec
- func (m *Response) GetCode() RequestCode
- func (m *Response) GetData() []byte
- func (m *Response) Marshal() (dAtA []byte, err error)
- func (m *Response) MarshalTo(dAtA []byte) (int, error)
- func (r *Response) Next() *ResponseNext
- func (r *Response) Prepare() *ResponsePrepare
- func (*Response) ProtoMessage()
- func (r *Response) Query() *ResponseQuery
- func (m *Response) Reset()
- func (r *Response) SQLiteError() sqlite3.Error
- func (m *Response) Size() (n int)
- func (m *Response) String() string
- func (m *Response) Unmarshal(dAtA []byte) error
- type ResponseBegin
- func (*ResponseBegin) Descriptor() ([]byte, []int)
- func (m *ResponseBegin) GetId() int64
- func (m *ResponseBegin) Marshal() (dAtA []byte, err error)
- func (m *ResponseBegin) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseBegin) ProtoMessage()
- func (m *ResponseBegin) Reset()
- func (m *ResponseBegin) Size() (n int)
- func (m *ResponseBegin) String() string
- func (m *ResponseBegin) Unmarshal(dAtA []byte) error
- type ResponseClose
- func (*ResponseClose) Descriptor() ([]byte, []int)
- func (m *ResponseClose) Marshal() (dAtA []byte, err error)
- func (m *ResponseClose) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseClose) ProtoMessage()
- func (m *ResponseClose) Reset()
- func (m *ResponseClose) Size() (n int)
- func (m *ResponseClose) String() string
- func (m *ResponseClose) Unmarshal(dAtA []byte) error
- type ResponseColumnTypeDatabaseTypeName
- func (*ResponseColumnTypeDatabaseTypeName) Descriptor() ([]byte, []int)
- func (m *ResponseColumnTypeDatabaseTypeName) GetName() string
- func (m *ResponseColumnTypeDatabaseTypeName) Marshal() (dAtA []byte, err error)
- func (m *ResponseColumnTypeDatabaseTypeName) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseColumnTypeDatabaseTypeName) ProtoMessage()
- func (m *ResponseColumnTypeDatabaseTypeName) Reset()
- func (m *ResponseColumnTypeDatabaseTypeName) Size() (n int)
- func (m *ResponseColumnTypeDatabaseTypeName) String() string
- func (m *ResponseColumnTypeDatabaseTypeName) Unmarshal(dAtA []byte) error
- type ResponseColumnTypeScanType
- func (*ResponseColumnTypeScanType) Descriptor() ([]byte, []int)
- func (m *ResponseColumnTypeScanType) GetCode() ValueCode
- func (m *ResponseColumnTypeScanType) Marshal() (dAtA []byte, err error)
- func (m *ResponseColumnTypeScanType) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseColumnTypeScanType) ProtoMessage()
- func (m *ResponseColumnTypeScanType) Reset()
- func (m *ResponseColumnTypeScanType) Size() (n int)
- func (m *ResponseColumnTypeScanType) String() string
- func (m *ResponseColumnTypeScanType) Unmarshal(dAtA []byte) error
- type ResponseCommit
- func (*ResponseCommit) Descriptor() ([]byte, []int)
- func (m *ResponseCommit) Marshal() (dAtA []byte, err error)
- func (m *ResponseCommit) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseCommit) ProtoMessage()
- func (m *ResponseCommit) Reset()
- func (m *ResponseCommit) Size() (n int)
- func (m *ResponseCommit) String() string
- func (m *ResponseCommit) Unmarshal(dAtA []byte) error
- type ResponseExec
- func (*ResponseExec) Descriptor() ([]byte, []int)
- func (m *ResponseExec) GetLastInsertId() int64
- func (m *ResponseExec) GetRowsAffected() int64
- func (m *ResponseExec) Marshal() (dAtA []byte, err error)
- func (m *ResponseExec) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseExec) ProtoMessage()
- func (m *ResponseExec) Reset()
- func (m *ResponseExec) Size() (n int)
- func (m *ResponseExec) String() string
- func (m *ResponseExec) Unmarshal(dAtA []byte) error
- type ResponseNext
- func (*ResponseNext) Descriptor() ([]byte, []int)
- func (m *ResponseNext) GetEof() bool
- func (m *ResponseNext) GetValues() []*Value
- func (m *ResponseNext) Marshal() (dAtA []byte, err error)
- func (m *ResponseNext) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseNext) ProtoMessage()
- func (m *ResponseNext) Reset()
- func (m *ResponseNext) Size() (n int)
- func (m *ResponseNext) String() string
- func (m *ResponseNext) Unmarshal(dAtA []byte) error
- type ResponseOpen
- func (*ResponseOpen) Descriptor() ([]byte, []int)
- func (m *ResponseOpen) Marshal() (dAtA []byte, err error)
- func (m *ResponseOpen) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseOpen) ProtoMessage()
- func (m *ResponseOpen) Reset()
- func (m *ResponseOpen) Size() (n int)
- func (m *ResponseOpen) String() string
- func (m *ResponseOpen) Unmarshal(dAtA []byte) error
- type ResponsePrepare
- func (*ResponsePrepare) Descriptor() ([]byte, []int)
- func (m *ResponsePrepare) GetId() int64
- func (m *ResponsePrepare) GetNumInput() int64
- func (m *ResponsePrepare) Marshal() (dAtA []byte, err error)
- func (m *ResponsePrepare) MarshalTo(dAtA []byte) (int, error)
- func (*ResponsePrepare) ProtoMessage()
- func (m *ResponsePrepare) Reset()
- func (m *ResponsePrepare) Size() (n int)
- func (m *ResponsePrepare) String() string
- func (m *ResponsePrepare) Unmarshal(dAtA []byte) error
- type ResponseQuery
- func (*ResponseQuery) Descriptor() ([]byte, []int)
- func (m *ResponseQuery) GetColumns() []string
- func (m *ResponseQuery) GetId() int64
- func (m *ResponseQuery) Marshal() (dAtA []byte, err error)
- func (m *ResponseQuery) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseQuery) ProtoMessage()
- func (m *ResponseQuery) Reset()
- func (m *ResponseQuery) Size() (n int)
- func (m *ResponseQuery) String() string
- func (m *ResponseQuery) Unmarshal(dAtA []byte) error
- type ResponseRollback
- func (*ResponseRollback) Descriptor() ([]byte, []int)
- func (m *ResponseRollback) Marshal() (dAtA []byte, err error)
- func (m *ResponseRollback) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseRollback) ProtoMessage()
- func (m *ResponseRollback) Reset()
- func (m *ResponseRollback) Size() (n int)
- func (m *ResponseRollback) String() string
- func (m *ResponseRollback) Unmarshal(dAtA []byte) error
- type ResponseRowsClose
- func (*ResponseRowsClose) Descriptor() ([]byte, []int)
- func (m *ResponseRowsClose) Marshal() (dAtA []byte, err error)
- func (m *ResponseRowsClose) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseRowsClose) ProtoMessage()
- func (m *ResponseRowsClose) Reset()
- func (m *ResponseRowsClose) Size() (n int)
- func (m *ResponseRowsClose) String() string
- func (m *ResponseRowsClose) Unmarshal(dAtA []byte) error
- type ResponseSQLiteError
- func (*ResponseSQLiteError) Descriptor() ([]byte, []int)
- func (m *ResponseSQLiteError) GetCode() int32
- func (m *ResponseSQLiteError) GetErr() string
- func (m *ResponseSQLiteError) GetExtendedCode() int32
- func (m *ResponseSQLiteError) Marshal() (dAtA []byte, err error)
- func (m *ResponseSQLiteError) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseSQLiteError) ProtoMessage()
- func (m *ResponseSQLiteError) Reset()
- func (m *ResponseSQLiteError) Size() (n int)
- func (m *ResponseSQLiteError) String() string
- func (m *ResponseSQLiteError) Unmarshal(dAtA []byte) error
- type ResponseStmtClose
- func (*ResponseStmtClose) Descriptor() ([]byte, []int)
- func (m *ResponseStmtClose) Marshal() (dAtA []byte, err error)
- func (m *ResponseStmtClose) MarshalTo(dAtA []byte) (int, error)
- func (*ResponseStmtClose) ProtoMessage()
- func (m *ResponseStmtClose) Reset()
- func (m *ResponseStmtClose) Size() (n int)
- func (m *ResponseStmtClose) String() string
- func (m *ResponseStmtClose) Unmarshal(dAtA []byte) error
- type SQLClient
- type SQLServer
- type SQL_ConnClient
- type SQL_ConnServer
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetCode() ValueCode
- func (m *Value) GetData() []byte
- func (m *Value) Marshal() (dAtA []byte, err error)
- func (m *Value) MarshalTo(dAtA []byte) (int, error)
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) Size() (n int)
- func (m *Value) String() string
- func (m *Value) Unmarshal(dAtA []byte) error
- type ValueBool
- func (*ValueBool) Descriptor() ([]byte, []int)
- func (m *ValueBool) GetValue() bool
- func (v *ValueBool) Interface() interface{}
- func (m *ValueBool) Marshal() (dAtA []byte, err error)
- func (m *ValueBool) MarshalTo(dAtA []byte) (int, error)
- func (*ValueBool) ProtoMessage()
- func (m *ValueBool) Reset()
- func (m *ValueBool) Size() (n int)
- func (m *ValueBool) String() string
- func (m *ValueBool) Unmarshal(dAtA []byte) error
- type ValueBytes
- func (*ValueBytes) Descriptor() ([]byte, []int)
- func (m *ValueBytes) GetValue() []byte
- func (v *ValueBytes) Interface() interface{}
- func (m *ValueBytes) Marshal() (dAtA []byte, err error)
- func (m *ValueBytes) MarshalTo(dAtA []byte) (int, error)
- func (*ValueBytes) ProtoMessage()
- func (m *ValueBytes) Reset()
- func (m *ValueBytes) Size() (n int)
- func (m *ValueBytes) String() string
- func (m *ValueBytes) Unmarshal(dAtA []byte) error
- type ValueCode
- type ValueFloat64
- func (*ValueFloat64) Descriptor() ([]byte, []int)
- func (m *ValueFloat64) GetValue() float64
- func (v *ValueFloat64) Interface() interface{}
- func (m *ValueFloat64) Marshal() (dAtA []byte, err error)
- func (m *ValueFloat64) MarshalTo(dAtA []byte) (int, error)
- func (*ValueFloat64) ProtoMessage()
- func (m *ValueFloat64) Reset()
- func (m *ValueFloat64) Size() (n int)
- func (m *ValueFloat64) String() string
- func (m *ValueFloat64) Unmarshal(dAtA []byte) error
- type ValueInt64
- func (*ValueInt64) Descriptor() ([]byte, []int)
- func (m *ValueInt64) GetValue() int64
- func (v *ValueInt64) Interface() interface{}
- func (m *ValueInt64) Marshal() (dAtA []byte, err error)
- func (m *ValueInt64) MarshalTo(dAtA []byte) (int, error)
- func (*ValueInt64) ProtoMessage()
- func (m *ValueInt64) Reset()
- func (m *ValueInt64) Size() (n int)
- func (m *ValueInt64) String() string
- func (m *ValueInt64) Unmarshal(dAtA []byte) error
- type ValueNull
- func (*ValueNull) Descriptor() ([]byte, []int)
- func (v *ValueNull) Interface() interface{}
- func (m *ValueNull) Marshal() (dAtA []byte, err error)
- func (m *ValueNull) MarshalTo(dAtA []byte) (int, error)
- func (*ValueNull) ProtoMessage()
- func (m *ValueNull) Reset()
- func (m *ValueNull) Size() (n int)
- func (m *ValueNull) String() string
- func (m *ValueNull) Unmarshal(dAtA []byte) error
- type ValueString
- func (*ValueString) Descriptor() ([]byte, []int)
- func (m *ValueString) GetValue() string
- func (v *ValueString) Interface() interface{}
- func (m *ValueString) Marshal() (dAtA []byte, err error)
- func (m *ValueString) MarshalTo(dAtA []byte) (int, error)
- func (*ValueString) ProtoMessage()
- func (m *ValueString) Reset()
- func (m *ValueString) Size() (n int)
- func (m *ValueString) String() string
- func (m *ValueString) Unmarshal(dAtA []byte) error
- type ValueTime
- func (*ValueTime) Descriptor() ([]byte, []int)
- func (m *ValueTime) GetValue() int64
- func (v *ValueTime) Interface() interface{}
- func (m *ValueTime) Marshal() (dAtA []byte, err error)
- func (m *ValueTime) MarshalTo(dAtA []byte) (int, error)
- func (*ValueTime) ProtoMessage()
- func (m *ValueTime) Reset()
- func (m *ValueTime) Size() (n int)
- func (m *ValueTime) String() string
- func (m *ValueTime) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthSql = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowSql = fmt.Errorf("proto: integer overflow") )
var RequestCode_name = map[int32]string{
0: "OPEN",
1: "PREPARE",
2: "EXEC",
3: "QUERY",
4: "NEXT",
5: "ROWS_CLOSE",
6: "COLUMN_TYPE_SCAN_TYPE",
7: "COLUMN_TYPE_DATABASE_TYPE_NAME",
8: "STMT_CLOSE",
9: "BEGIN",
10: "COMMIT",
11: "ROLLBACK",
12: "CLOSE",
13: "CONN_EXEC",
14: "SQLITE_ERROR",
}
var RequestCode_value = map[string]int32{
"OPEN": 0,
"PREPARE": 1,
"EXEC": 2,
"QUERY": 3,
"NEXT": 4,
"ROWS_CLOSE": 5,
"COLUMN_TYPE_SCAN_TYPE": 6,
"COLUMN_TYPE_DATABASE_TYPE_NAME": 7,
"STMT_CLOSE": 8,
"BEGIN": 9,
"COMMIT": 10,
"ROLLBACK": 11,
"CLOSE": 12,
"CONN_EXEC": 13,
"SQLITE_ERROR": 14,
}
var ValueCode_name = map[int32]string{
0: "INT64",
1: "FLOAT64",
2: "BOOL",
3: "BYTES",
4: "STRING",
5: "TIME",
6: "NULL",
}
var ValueCode_value = map[string]int32{
"INT64": 0,
"FLOAT64": 1,
"BOOL": 2,
"BYTES": 3,
"STRING": 4,
"TIME": 5,
"NULL": 6,
}
Functions ¶
func FromValueCode ¶
FromValueCode converts a serialized value type code into a Go type object.
func FromValueSlice ¶
FromValueSlice converts a slice of protobuf Value objects to a slice of Go interface{} objects.
func RegisterSQLServer ¶
Types ¶
type Request ¶
type Request struct { Code RequestCode `protobuf:"varint,1,opt,name=code,proto3,enum=protocol.RequestCode" json:"code,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
A single request targeted to a certain SQL connection.
func NewRequestBegin ¶
func NewRequestBegin() *Request
NewRequestBegin creates a new Request of type RequestBegin.
func NewRequestClose ¶
func NewRequestClose() *Request
NewRequestClose creates a new Request of type RequestClose.
func NewRequestColumnTypeDatabaseTypeName ¶
NewRequestColumnTypeDatabaseTypeName creates a new Request of type ColumnTypeDatabaseTypeName.
func NewRequestColumnTypeScanType ¶
NewRequestColumnTypeScanType creates a new Request of type ColumnTypeScanType.
func NewRequestCommit ¶
NewRequestCommit creates a new Request of type RequestCommit.
func NewRequestConnExec ¶
NewRequestConnExec creates a new Request of type RequestConnExec.
func NewRequestExec ¶
NewRequestExec creates a new Request of type RequestExec.
func NewRequestNext ¶
NewRequestNext creates a new Request of type RequestNext.
func NewRequestOpen ¶
NewRequestOpen creates a new Request of type RequestOpen.
func NewRequestPrepare ¶
NewRequestPrepare creates a new Request of type RequestPrepare.
func NewRequestQuery ¶
NewRequestQuery creates a new Request of type RequestQuery.
func NewRequestRollback ¶
NewRequestRollback creates a new Request of type RequestRollback.
func NewRequestRowsClose ¶
NewRequestRowsClose creates a new Request of type RequestRowsClose.
func NewRequestStmtClose ¶
NewRequestStmtClose creates a new Request of type RequestStmtClose.
func (*Request) Descriptor ¶
func (*Request) GetCode ¶
func (m *Request) GetCode() RequestCode
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
type RequestBegin ¶
type RequestBegin struct { }
func (*RequestBegin) Descriptor ¶
func (*RequestBegin) Descriptor() ([]byte, []int)
func (*RequestBegin) Marshal ¶
func (m *RequestBegin) Marshal() (dAtA []byte, err error)
func (*RequestBegin) ProtoMessage ¶
func (*RequestBegin) ProtoMessage()
func (*RequestBegin) Reset ¶
func (m *RequestBegin) Reset()
func (*RequestBegin) Size ¶
func (m *RequestBegin) Size() (n int)
func (*RequestBegin) String ¶
func (m *RequestBegin) String() string
func (*RequestBegin) Unmarshal ¶
func (m *RequestBegin) Unmarshal(dAtA []byte) error
type RequestClose ¶
type RequestClose struct { }
func (*RequestClose) Descriptor ¶
func (*RequestClose) Descriptor() ([]byte, []int)
func (*RequestClose) Marshal ¶
func (m *RequestClose) Marshal() (dAtA []byte, err error)
func (*RequestClose) ProtoMessage ¶
func (*RequestClose) ProtoMessage()
func (*RequestClose) Reset ¶
func (m *RequestClose) Reset()
func (*RequestClose) Size ¶
func (m *RequestClose) Size() (n int)
func (*RequestClose) String ¶
func (m *RequestClose) String() string
func (*RequestClose) Unmarshal ¶
func (m *RequestClose) Unmarshal(dAtA []byte) error
type RequestCode ¶
type RequestCode int32
RequestCode is a numberic code identifying the SQL gRPC request to handle.
const ( RequestCode_OPEN RequestCode = 0 RequestCode_PREPARE RequestCode = 1 RequestCode_EXEC RequestCode = 2 RequestCode_QUERY RequestCode = 3 RequestCode_NEXT RequestCode = 4 RequestCode_ROWS_CLOSE RequestCode = 5 RequestCode_COLUMN_TYPE_SCAN_TYPE RequestCode = 6 RequestCode_COLUMN_TYPE_DATABASE_TYPE_NAME RequestCode = 7 RequestCode_STMT_CLOSE RequestCode = 8 RequestCode_BEGIN RequestCode = 9 RequestCode_COMMIT RequestCode = 10 RequestCode_ROLLBACK RequestCode = 11 RequestCode_CLOSE RequestCode = 12 RequestCode_CONN_EXEC RequestCode = 13 // XXX error codes should be part of a separate ResponseCode enum. RequestCode_SQLITE_ERROR RequestCode = 14 )
func (RequestCode) EnumDescriptor ¶
func (RequestCode) EnumDescriptor() ([]byte, []int)
func (RequestCode) String ¶
func (x RequestCode) String() string
type RequestColumnTypeDatabaseTypeName ¶
type RequestColumnTypeDatabaseTypeName struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Column int64 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"` }
func (*RequestColumnTypeDatabaseTypeName) Descriptor ¶
func (*RequestColumnTypeDatabaseTypeName) Descriptor() ([]byte, []int)
func (*RequestColumnTypeDatabaseTypeName) GetColumn ¶
func (m *RequestColumnTypeDatabaseTypeName) GetColumn() int64
func (*RequestColumnTypeDatabaseTypeName) GetId ¶
func (m *RequestColumnTypeDatabaseTypeName) GetId() int64
func (*RequestColumnTypeDatabaseTypeName) Marshal ¶
func (m *RequestColumnTypeDatabaseTypeName) Marshal() (dAtA []byte, err error)
func (*RequestColumnTypeDatabaseTypeName) MarshalTo ¶
func (m *RequestColumnTypeDatabaseTypeName) MarshalTo(dAtA []byte) (int, error)
func (*RequestColumnTypeDatabaseTypeName) ProtoMessage ¶
func (*RequestColumnTypeDatabaseTypeName) ProtoMessage()
func (*RequestColumnTypeDatabaseTypeName) Reset ¶
func (m *RequestColumnTypeDatabaseTypeName) Reset()
func (*RequestColumnTypeDatabaseTypeName) Size ¶
func (m *RequestColumnTypeDatabaseTypeName) Size() (n int)
func (*RequestColumnTypeDatabaseTypeName) String ¶
func (m *RequestColumnTypeDatabaseTypeName) String() string
func (*RequestColumnTypeDatabaseTypeName) Unmarshal ¶
func (m *RequestColumnTypeDatabaseTypeName) Unmarshal(dAtA []byte) error
type RequestColumnTypeScanType ¶
type RequestColumnTypeScanType struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Column int64 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"` }
func (*RequestColumnTypeScanType) Descriptor ¶
func (*RequestColumnTypeScanType) Descriptor() ([]byte, []int)
func (*RequestColumnTypeScanType) GetColumn ¶
func (m *RequestColumnTypeScanType) GetColumn() int64
func (*RequestColumnTypeScanType) GetId ¶
func (m *RequestColumnTypeScanType) GetId() int64
func (*RequestColumnTypeScanType) Marshal ¶
func (m *RequestColumnTypeScanType) Marshal() (dAtA []byte, err error)
func (*RequestColumnTypeScanType) MarshalTo ¶
func (m *RequestColumnTypeScanType) MarshalTo(dAtA []byte) (int, error)
func (*RequestColumnTypeScanType) ProtoMessage ¶
func (*RequestColumnTypeScanType) ProtoMessage()
func (*RequestColumnTypeScanType) Reset ¶
func (m *RequestColumnTypeScanType) Reset()
func (*RequestColumnTypeScanType) Size ¶
func (m *RequestColumnTypeScanType) Size() (n int)
func (*RequestColumnTypeScanType) String ¶
func (m *RequestColumnTypeScanType) String() string
func (*RequestColumnTypeScanType) Unmarshal ¶
func (m *RequestColumnTypeScanType) Unmarshal(dAtA []byte) error
type RequestCommit ¶
type RequestCommit struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*RequestCommit) Descriptor ¶
func (*RequestCommit) Descriptor() ([]byte, []int)
func (*RequestCommit) GetId ¶
func (m *RequestCommit) GetId() int64
func (*RequestCommit) Marshal ¶
func (m *RequestCommit) Marshal() (dAtA []byte, err error)
func (*RequestCommit) ProtoMessage ¶
func (*RequestCommit) ProtoMessage()
func (*RequestCommit) Reset ¶
func (m *RequestCommit) Reset()
func (*RequestCommit) Size ¶
func (m *RequestCommit) Size() (n int)
func (*RequestCommit) String ¶
func (m *RequestCommit) String() string
func (*RequestCommit) Unmarshal ¶
func (m *RequestCommit) Unmarshal(dAtA []byte) error
type RequestConnExec ¶
type RequestConnExec struct { Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Args []*Value `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"` }
func (*RequestConnExec) Descriptor ¶
func (*RequestConnExec) Descriptor() ([]byte, []int)
func (*RequestConnExec) GetArgs ¶
func (m *RequestConnExec) GetArgs() []*Value
func (*RequestConnExec) GetQuery ¶
func (m *RequestConnExec) GetQuery() string
func (*RequestConnExec) Marshal ¶
func (m *RequestConnExec) Marshal() (dAtA []byte, err error)
func (*RequestConnExec) ProtoMessage ¶
func (*RequestConnExec) ProtoMessage()
func (*RequestConnExec) Reset ¶
func (m *RequestConnExec) Reset()
func (*RequestConnExec) Size ¶
func (m *RequestConnExec) Size() (n int)
func (*RequestConnExec) String ¶
func (m *RequestConnExec) String() string
func (*RequestConnExec) Unmarshal ¶
func (m *RequestConnExec) Unmarshal(dAtA []byte) error
type RequestExec ¶
type RequestExec struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Args []*Value `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"` }
func (*RequestExec) Descriptor ¶
func (*RequestExec) Descriptor() ([]byte, []int)
func (*RequestExec) GetArgs ¶
func (m *RequestExec) GetArgs() []*Value
func (*RequestExec) GetId ¶
func (m *RequestExec) GetId() int64
func (*RequestExec) Marshal ¶
func (m *RequestExec) Marshal() (dAtA []byte, err error)
func (*RequestExec) ProtoMessage ¶
func (*RequestExec) ProtoMessage()
func (*RequestExec) Reset ¶
func (m *RequestExec) Reset()
func (*RequestExec) Size ¶
func (m *RequestExec) Size() (n int)
func (*RequestExec) String ¶
func (m *RequestExec) String() string
func (*RequestExec) Unmarshal ¶
func (m *RequestExec) Unmarshal(dAtA []byte) error
type RequestNext ¶
type RequestNext struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Len int64 `protobuf:"varint,2,opt,name=len,proto3" json:"len,omitempty"` }
func (*RequestNext) Descriptor ¶
func (*RequestNext) Descriptor() ([]byte, []int)
func (*RequestNext) GetId ¶
func (m *RequestNext) GetId() int64
func (*RequestNext) GetLen ¶
func (m *RequestNext) GetLen() int64
func (*RequestNext) Marshal ¶
func (m *RequestNext) Marshal() (dAtA []byte, err error)
func (*RequestNext) ProtoMessage ¶
func (*RequestNext) ProtoMessage()
func (*RequestNext) Reset ¶
func (m *RequestNext) Reset()
func (*RequestNext) Size ¶
func (m *RequestNext) Size() (n int)
func (*RequestNext) String ¶
func (m *RequestNext) String() string
func (*RequestNext) Unmarshal ¶
func (m *RequestNext) Unmarshal(dAtA []byte) error
type RequestOpen ¶
type RequestOpen struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*RequestOpen) Descriptor ¶
func (*RequestOpen) Descriptor() ([]byte, []int)
func (*RequestOpen) GetName ¶
func (m *RequestOpen) GetName() string
func (*RequestOpen) Marshal ¶
func (m *RequestOpen) Marshal() (dAtA []byte, err error)
func (*RequestOpen) ProtoMessage ¶
func (*RequestOpen) ProtoMessage()
func (*RequestOpen) Reset ¶
func (m *RequestOpen) Reset()
func (*RequestOpen) Size ¶
func (m *RequestOpen) Size() (n int)
func (*RequestOpen) String ¶
func (m *RequestOpen) String() string
func (*RequestOpen) Unmarshal ¶
func (m *RequestOpen) Unmarshal(dAtA []byte) error
type RequestPrepare ¶
type RequestPrepare struct {
Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
}
func (*RequestPrepare) Descriptor ¶
func (*RequestPrepare) Descriptor() ([]byte, []int)
func (*RequestPrepare) GetQuery ¶
func (m *RequestPrepare) GetQuery() string
func (*RequestPrepare) Marshal ¶
func (m *RequestPrepare) Marshal() (dAtA []byte, err error)
func (*RequestPrepare) ProtoMessage ¶
func (*RequestPrepare) ProtoMessage()
func (*RequestPrepare) Reset ¶
func (m *RequestPrepare) Reset()
func (*RequestPrepare) Size ¶
func (m *RequestPrepare) Size() (n int)
func (*RequestPrepare) String ¶
func (m *RequestPrepare) String() string
func (*RequestPrepare) Unmarshal ¶
func (m *RequestPrepare) Unmarshal(dAtA []byte) error
type RequestQuery ¶
type RequestQuery struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Args []*Value `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"` }
func (*RequestQuery) Descriptor ¶
func (*RequestQuery) Descriptor() ([]byte, []int)
func (*RequestQuery) GetArgs ¶
func (m *RequestQuery) GetArgs() []*Value
func (*RequestQuery) GetId ¶
func (m *RequestQuery) GetId() int64
func (*RequestQuery) Marshal ¶
func (m *RequestQuery) Marshal() (dAtA []byte, err error)
func (*RequestQuery) ProtoMessage ¶
func (*RequestQuery) ProtoMessage()
func (*RequestQuery) Reset ¶
func (m *RequestQuery) Reset()
func (*RequestQuery) Size ¶
func (m *RequestQuery) Size() (n int)
func (*RequestQuery) String ¶
func (m *RequestQuery) String() string
func (*RequestQuery) Unmarshal ¶
func (m *RequestQuery) Unmarshal(dAtA []byte) error
type RequestRollback ¶
type RequestRollback struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*RequestRollback) Descriptor ¶
func (*RequestRollback) Descriptor() ([]byte, []int)
func (*RequestRollback) GetId ¶
func (m *RequestRollback) GetId() int64
func (*RequestRollback) Marshal ¶
func (m *RequestRollback) Marshal() (dAtA []byte, err error)
func (*RequestRollback) ProtoMessage ¶
func (*RequestRollback) ProtoMessage()
func (*RequestRollback) Reset ¶
func (m *RequestRollback) Reset()
func (*RequestRollback) Size ¶
func (m *RequestRollback) Size() (n int)
func (*RequestRollback) String ¶
func (m *RequestRollback) String() string
func (*RequestRollback) Unmarshal ¶
func (m *RequestRollback) Unmarshal(dAtA []byte) error
type RequestRowsClose ¶
type RequestRowsClose struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*RequestRowsClose) Descriptor ¶
func (*RequestRowsClose) Descriptor() ([]byte, []int)
func (*RequestRowsClose) GetId ¶
func (m *RequestRowsClose) GetId() int64
func (*RequestRowsClose) Marshal ¶
func (m *RequestRowsClose) Marshal() (dAtA []byte, err error)
func (*RequestRowsClose) ProtoMessage ¶
func (*RequestRowsClose) ProtoMessage()
func (*RequestRowsClose) Reset ¶
func (m *RequestRowsClose) Reset()
func (*RequestRowsClose) Size ¶
func (m *RequestRowsClose) Size() (n int)
func (*RequestRowsClose) String ¶
func (m *RequestRowsClose) String() string
func (*RequestRowsClose) Unmarshal ¶
func (m *RequestRowsClose) Unmarshal(dAtA []byte) error
type RequestStmtClose ¶
type RequestStmtClose struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*RequestStmtClose) Descriptor ¶
func (*RequestStmtClose) Descriptor() ([]byte, []int)
func (*RequestStmtClose) GetId ¶
func (m *RequestStmtClose) GetId() int64
func (*RequestStmtClose) Marshal ¶
func (m *RequestStmtClose) Marshal() (dAtA []byte, err error)
func (*RequestStmtClose) ProtoMessage ¶
func (*RequestStmtClose) ProtoMessage()
func (*RequestStmtClose) Reset ¶
func (m *RequestStmtClose) Reset()
func (*RequestStmtClose) Size ¶
func (m *RequestStmtClose) Size() (n int)
func (*RequestStmtClose) String ¶
func (m *RequestStmtClose) String() string
func (*RequestStmtClose) Unmarshal ¶
func (m *RequestStmtClose) Unmarshal(dAtA []byte) error
type Response ¶
type Response struct { Code RequestCode `protobuf:"varint,1,opt,name=code,proto3,enum=protocol.RequestCode" json:"code,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
A single response to a request.
func NewResponseBegin ¶
NewResponseBegin creates a new Response of type ResponseBegin.
func NewResponseClose ¶
func NewResponseClose() *Response
NewResponseClose creates a new Response of type ResponseClose.
func NewResponseColumnTypeDatabaseTypeName ¶
NewResponseColumnTypeDatabaseTypeName creates a new Response of type ResponseColumnTypeDatabaseTypeName.
func NewResponseColumnTypeScanType ¶
NewResponseColumnTypeScanType creates a new Response of type ResponseColumnTypeScanType.
func NewResponseCommit ¶
func NewResponseCommit() *Response
NewResponseCommit creates a new Response of type ResponseCommit.
func NewResponseExec ¶
NewResponseExec creates a new Response of type ResponseExec.
func NewResponseNext ¶
NewResponseNext creates a new Response of type ResponseNext.
func NewResponseOpen ¶
func NewResponseOpen() *Response
NewResponseOpen creates a new Response of type ResponseOpen.
func NewResponsePrepare ¶
NewResponsePrepare creates a new Response of type ResponsePrepare.
func NewResponseQuery ¶
NewResponseQuery creates a new Response of type ResponseQuery.
func NewResponseRollback ¶
func NewResponseRollback() *Response
NewResponseRollback creates a new Response of type ResponseRollback.
func NewResponseRowsClose ¶
func NewResponseRowsClose() *Response
NewResponseRowsClose creates a new Response of type ResponseRowsClose.
func NewResponseSQLiteError ¶
func NewResponseSQLiteError(code sqlite3.ErrNo, extendedCode sqlite3.ErrNoExtended, err string) *Response
NewResponseSQLiteError creates a new Response of type ResponseSQLiteError.
func NewResponseStmtClose ¶
func NewResponseStmtClose() *Response
NewResponseStmtClose creates a new Response of type ResponseStmtClose.
func (*Response) Begin ¶
func (r *Response) Begin() *ResponseBegin
Begin returns a ResponseBegin payload.
func (*Response) ColumnTypeDatabaseTypeName ¶
func (r *Response) ColumnTypeDatabaseTypeName() *ResponseColumnTypeDatabaseTypeName
ColumnTypeDatabaseTypeName returns a ResponseColumnTypeDatabaseTypeName payload.
func (*Response) ColumnTypeScanType ¶
func (r *Response) ColumnTypeScanType() *ResponseColumnTypeScanType
ColumnTypeScanType returns a ResponseColumnTypeScanType payload.
func (*Response) Descriptor ¶
func (*Response) Exec ¶
func (r *Response) Exec() *ResponseExec
Exec returns a ResponseExec payload.
func (*Response) GetCode ¶
func (m *Response) GetCode() RequestCode
func (*Response) Next ¶
func (r *Response) Next() *ResponseNext
Next returns a ResponseNext payload.
func (*Response) Prepare ¶
func (r *Response) Prepare() *ResponsePrepare
Prepare returns a ResponsePrepare payload.
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) Query ¶
func (r *Response) Query() *ResponseQuery
Query returns a ResponseQuery payload.
func (*Response) SQLiteError ¶
func (r *Response) SQLiteError() sqlite3.Error
SQLiteError returns a ResponseSQLiteError payload.
type ResponseBegin ¶
type ResponseBegin struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*ResponseBegin) Descriptor ¶
func (*ResponseBegin) Descriptor() ([]byte, []int)
func (*ResponseBegin) GetId ¶
func (m *ResponseBegin) GetId() int64
func (*ResponseBegin) Marshal ¶
func (m *ResponseBegin) Marshal() (dAtA []byte, err error)
func (*ResponseBegin) ProtoMessage ¶
func (*ResponseBegin) ProtoMessage()
func (*ResponseBegin) Reset ¶
func (m *ResponseBegin) Reset()
func (*ResponseBegin) Size ¶
func (m *ResponseBegin) Size() (n int)
func (*ResponseBegin) String ¶
func (m *ResponseBegin) String() string
func (*ResponseBegin) Unmarshal ¶
func (m *ResponseBegin) Unmarshal(dAtA []byte) error
type ResponseClose ¶
type ResponseClose struct { }
func (*ResponseClose) Descriptor ¶
func (*ResponseClose) Descriptor() ([]byte, []int)
func (*ResponseClose) Marshal ¶
func (m *ResponseClose) Marshal() (dAtA []byte, err error)
func (*ResponseClose) ProtoMessage ¶
func (*ResponseClose) ProtoMessage()
func (*ResponseClose) Reset ¶
func (m *ResponseClose) Reset()
func (*ResponseClose) Size ¶
func (m *ResponseClose) Size() (n int)
func (*ResponseClose) String ¶
func (m *ResponseClose) String() string
func (*ResponseClose) Unmarshal ¶
func (m *ResponseClose) Unmarshal(dAtA []byte) error
type ResponseColumnTypeDatabaseTypeName ¶
type ResponseColumnTypeDatabaseTypeName struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}
func (*ResponseColumnTypeDatabaseTypeName) Descriptor ¶
func (*ResponseColumnTypeDatabaseTypeName) Descriptor() ([]byte, []int)
func (*ResponseColumnTypeDatabaseTypeName) GetName ¶
func (m *ResponseColumnTypeDatabaseTypeName) GetName() string
func (*ResponseColumnTypeDatabaseTypeName) Marshal ¶
func (m *ResponseColumnTypeDatabaseTypeName) Marshal() (dAtA []byte, err error)
func (*ResponseColumnTypeDatabaseTypeName) MarshalTo ¶
func (m *ResponseColumnTypeDatabaseTypeName) MarshalTo(dAtA []byte) (int, error)
func (*ResponseColumnTypeDatabaseTypeName) ProtoMessage ¶
func (*ResponseColumnTypeDatabaseTypeName) ProtoMessage()
func (*ResponseColumnTypeDatabaseTypeName) Reset ¶
func (m *ResponseColumnTypeDatabaseTypeName) Reset()
func (*ResponseColumnTypeDatabaseTypeName) Size ¶
func (m *ResponseColumnTypeDatabaseTypeName) Size() (n int)
func (*ResponseColumnTypeDatabaseTypeName) String ¶
func (m *ResponseColumnTypeDatabaseTypeName) String() string
func (*ResponseColumnTypeDatabaseTypeName) Unmarshal ¶
func (m *ResponseColumnTypeDatabaseTypeName) Unmarshal(dAtA []byte) error
type ResponseColumnTypeScanType ¶
type ResponseColumnTypeScanType struct {
Code ValueCode `protobuf:"varint,1,opt,name=code,proto3,enum=protocol.ValueCode" json:"code,omitempty"`
}
func (*ResponseColumnTypeScanType) Descriptor ¶
func (*ResponseColumnTypeScanType) Descriptor() ([]byte, []int)
func (*ResponseColumnTypeScanType) GetCode ¶
func (m *ResponseColumnTypeScanType) GetCode() ValueCode
func (*ResponseColumnTypeScanType) Marshal ¶
func (m *ResponseColumnTypeScanType) Marshal() (dAtA []byte, err error)
func (*ResponseColumnTypeScanType) MarshalTo ¶
func (m *ResponseColumnTypeScanType) MarshalTo(dAtA []byte) (int, error)
func (*ResponseColumnTypeScanType) ProtoMessage ¶
func (*ResponseColumnTypeScanType) ProtoMessage()
func (*ResponseColumnTypeScanType) Reset ¶
func (m *ResponseColumnTypeScanType) Reset()
func (*ResponseColumnTypeScanType) Size ¶
func (m *ResponseColumnTypeScanType) Size() (n int)
func (*ResponseColumnTypeScanType) String ¶
func (m *ResponseColumnTypeScanType) String() string
func (*ResponseColumnTypeScanType) Unmarshal ¶
func (m *ResponseColumnTypeScanType) Unmarshal(dAtA []byte) error
type ResponseCommit ¶
type ResponseCommit struct { }
func (*ResponseCommit) Descriptor ¶
func (*ResponseCommit) Descriptor() ([]byte, []int)
func (*ResponseCommit) Marshal ¶
func (m *ResponseCommit) Marshal() (dAtA []byte, err error)
func (*ResponseCommit) ProtoMessage ¶
func (*ResponseCommit) ProtoMessage()
func (*ResponseCommit) Reset ¶
func (m *ResponseCommit) Reset()
func (*ResponseCommit) Size ¶
func (m *ResponseCommit) Size() (n int)
func (*ResponseCommit) String ¶
func (m *ResponseCommit) String() string
func (*ResponseCommit) Unmarshal ¶
func (m *ResponseCommit) Unmarshal(dAtA []byte) error
type ResponseExec ¶
type ResponseExec struct { LastInsertId int64 `protobuf:"varint,1,opt,name=LastInsertId,json=lastInsertId,proto3" json:"LastInsertId,omitempty"` RowsAffected int64 `protobuf:"varint,2,opt,name=RowsAffected,json=rowsAffected,proto3" json:"RowsAffected,omitempty"` }
func (*ResponseExec) Descriptor ¶
func (*ResponseExec) Descriptor() ([]byte, []int)
func (*ResponseExec) GetLastInsertId ¶
func (m *ResponseExec) GetLastInsertId() int64
func (*ResponseExec) GetRowsAffected ¶
func (m *ResponseExec) GetRowsAffected() int64
func (*ResponseExec) Marshal ¶
func (m *ResponseExec) Marshal() (dAtA []byte, err error)
func (*ResponseExec) ProtoMessage ¶
func (*ResponseExec) ProtoMessage()
func (*ResponseExec) Reset ¶
func (m *ResponseExec) Reset()
func (*ResponseExec) Size ¶
func (m *ResponseExec) Size() (n int)
func (*ResponseExec) String ¶
func (m *ResponseExec) String() string
func (*ResponseExec) Unmarshal ¶
func (m *ResponseExec) Unmarshal(dAtA []byte) error
type ResponseNext ¶
type ResponseNext struct { Eof bool `protobuf:"varint,1,opt,name=eof,proto3" json:"eof,omitempty"` Values []*Value `protobuf:"bytes,2,rep,name=values" json:"values,omitempty"` }
func (*ResponseNext) Descriptor ¶
func (*ResponseNext) Descriptor() ([]byte, []int)
func (*ResponseNext) GetEof ¶
func (m *ResponseNext) GetEof() bool
func (*ResponseNext) GetValues ¶
func (m *ResponseNext) GetValues() []*Value
func (*ResponseNext) Marshal ¶
func (m *ResponseNext) Marshal() (dAtA []byte, err error)
func (*ResponseNext) ProtoMessage ¶
func (*ResponseNext) ProtoMessage()
func (*ResponseNext) Reset ¶
func (m *ResponseNext) Reset()
func (*ResponseNext) Size ¶
func (m *ResponseNext) Size() (n int)
func (*ResponseNext) String ¶
func (m *ResponseNext) String() string
func (*ResponseNext) Unmarshal ¶
func (m *ResponseNext) Unmarshal(dAtA []byte) error
type ResponseOpen ¶
type ResponseOpen struct { }
func (*ResponseOpen) Descriptor ¶
func (*ResponseOpen) Descriptor() ([]byte, []int)
func (*ResponseOpen) Marshal ¶
func (m *ResponseOpen) Marshal() (dAtA []byte, err error)
func (*ResponseOpen) ProtoMessage ¶
func (*ResponseOpen) ProtoMessage()
func (*ResponseOpen) Reset ¶
func (m *ResponseOpen) Reset()
func (*ResponseOpen) Size ¶
func (m *ResponseOpen) Size() (n int)
func (*ResponseOpen) String ¶
func (m *ResponseOpen) String() string
func (*ResponseOpen) Unmarshal ¶
func (m *ResponseOpen) Unmarshal(dAtA []byte) error
type ResponsePrepare ¶
type ResponsePrepare struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` NumInput int64 `protobuf:"varint,2,opt,name=numInput,proto3" json:"numInput,omitempty"` }
func (*ResponsePrepare) Descriptor ¶
func (*ResponsePrepare) Descriptor() ([]byte, []int)
func (*ResponsePrepare) GetId ¶
func (m *ResponsePrepare) GetId() int64
func (*ResponsePrepare) GetNumInput ¶
func (m *ResponsePrepare) GetNumInput() int64
func (*ResponsePrepare) Marshal ¶
func (m *ResponsePrepare) Marshal() (dAtA []byte, err error)
func (*ResponsePrepare) ProtoMessage ¶
func (*ResponsePrepare) ProtoMessage()
func (*ResponsePrepare) Reset ¶
func (m *ResponsePrepare) Reset()
func (*ResponsePrepare) Size ¶
func (m *ResponsePrepare) Size() (n int)
func (*ResponsePrepare) String ¶
func (m *ResponsePrepare) String() string
func (*ResponsePrepare) Unmarshal ¶
func (m *ResponsePrepare) Unmarshal(dAtA []byte) error
type ResponseQuery ¶
type ResponseQuery struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Columns []string `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"` }
func (*ResponseQuery) Descriptor ¶
func (*ResponseQuery) Descriptor() ([]byte, []int)
func (*ResponseQuery) GetColumns ¶
func (m *ResponseQuery) GetColumns() []string
func (*ResponseQuery) GetId ¶
func (m *ResponseQuery) GetId() int64
func (*ResponseQuery) Marshal ¶
func (m *ResponseQuery) Marshal() (dAtA []byte, err error)
func (*ResponseQuery) ProtoMessage ¶
func (*ResponseQuery) ProtoMessage()
func (*ResponseQuery) Reset ¶
func (m *ResponseQuery) Reset()
func (*ResponseQuery) Size ¶
func (m *ResponseQuery) Size() (n int)
func (*ResponseQuery) String ¶
func (m *ResponseQuery) String() string
func (*ResponseQuery) Unmarshal ¶
func (m *ResponseQuery) Unmarshal(dAtA []byte) error
type ResponseRollback ¶
type ResponseRollback struct { }
func (*ResponseRollback) Descriptor ¶
func (*ResponseRollback) Descriptor() ([]byte, []int)
func (*ResponseRollback) Marshal ¶
func (m *ResponseRollback) Marshal() (dAtA []byte, err error)
func (*ResponseRollback) ProtoMessage ¶
func (*ResponseRollback) ProtoMessage()
func (*ResponseRollback) Reset ¶
func (m *ResponseRollback) Reset()
func (*ResponseRollback) Size ¶
func (m *ResponseRollback) Size() (n int)
func (*ResponseRollback) String ¶
func (m *ResponseRollback) String() string
func (*ResponseRollback) Unmarshal ¶
func (m *ResponseRollback) Unmarshal(dAtA []byte) error
type ResponseRowsClose ¶
type ResponseRowsClose struct { }
func (*ResponseRowsClose) Descriptor ¶
func (*ResponseRowsClose) Descriptor() ([]byte, []int)
func (*ResponseRowsClose) Marshal ¶
func (m *ResponseRowsClose) Marshal() (dAtA []byte, err error)
func (*ResponseRowsClose) MarshalTo ¶
func (m *ResponseRowsClose) MarshalTo(dAtA []byte) (int, error)
func (*ResponseRowsClose) ProtoMessage ¶
func (*ResponseRowsClose) ProtoMessage()
func (*ResponseRowsClose) Reset ¶
func (m *ResponseRowsClose) Reset()
func (*ResponseRowsClose) Size ¶
func (m *ResponseRowsClose) Size() (n int)
func (*ResponseRowsClose) String ¶
func (m *ResponseRowsClose) String() string
func (*ResponseRowsClose) Unmarshal ¶
func (m *ResponseRowsClose) Unmarshal(dAtA []byte) error
type ResponseSQLiteError ¶
type ResponseSQLiteError struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` ExtendedCode int32 `protobuf:"varint,2,opt,name=extended_code,json=extendedCode,proto3" json:"extended_code,omitempty"` Err string `protobuf:"bytes,3,opt,name=err,proto3" json:"err,omitempty"` }
func (*ResponseSQLiteError) Descriptor ¶
func (*ResponseSQLiteError) Descriptor() ([]byte, []int)
func (*ResponseSQLiteError) GetCode ¶
func (m *ResponseSQLiteError) GetCode() int32
func (*ResponseSQLiteError) GetErr ¶
func (m *ResponseSQLiteError) GetErr() string
func (*ResponseSQLiteError) GetExtendedCode ¶
func (m *ResponseSQLiteError) GetExtendedCode() int32
func (*ResponseSQLiteError) Marshal ¶
func (m *ResponseSQLiteError) Marshal() (dAtA []byte, err error)
func (*ResponseSQLiteError) MarshalTo ¶
func (m *ResponseSQLiteError) MarshalTo(dAtA []byte) (int, error)
func (*ResponseSQLiteError) ProtoMessage ¶
func (*ResponseSQLiteError) ProtoMessage()
func (*ResponseSQLiteError) Reset ¶
func (m *ResponseSQLiteError) Reset()
func (*ResponseSQLiteError) Size ¶
func (m *ResponseSQLiteError) Size() (n int)
func (*ResponseSQLiteError) String ¶
func (m *ResponseSQLiteError) String() string
func (*ResponseSQLiteError) Unmarshal ¶
func (m *ResponseSQLiteError) Unmarshal(dAtA []byte) error
type ResponseStmtClose ¶
type ResponseStmtClose struct { }
func (*ResponseStmtClose) Descriptor ¶
func (*ResponseStmtClose) Descriptor() ([]byte, []int)
func (*ResponseStmtClose) Marshal ¶
func (m *ResponseStmtClose) Marshal() (dAtA []byte, err error)
func (*ResponseStmtClose) MarshalTo ¶
func (m *ResponseStmtClose) MarshalTo(dAtA []byte) (int, error)
func (*ResponseStmtClose) ProtoMessage ¶
func (*ResponseStmtClose) ProtoMessage()
func (*ResponseStmtClose) Reset ¶
func (m *ResponseStmtClose) Reset()
func (*ResponseStmtClose) Size ¶
func (m *ResponseStmtClose) Size() (n int)
func (*ResponseStmtClose) String ¶
func (m *ResponseStmtClose) String() string
func (*ResponseStmtClose) Unmarshal ¶
func (m *ResponseStmtClose) Unmarshal(dAtA []byte) error
type SQLClient ¶
type SQLClient interface {
Conn(ctx context.Context, opts ...grpc.CallOption) (SQL_ConnClient, error)
}
func NewSQLClient ¶
func NewSQLClient(cc *grpc.ClientConn) SQLClient
type SQLServer ¶
type SQLServer interface {
Conn(SQL_ConnServer) error
}
type SQL_ConnClient ¶
type SQL_ConnServer ¶
type Value ¶
type Value struct { Code ValueCode `protobuf:"varint,1,opt,name=code,proto3,enum=protocol.ValueCode" json:"code,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` }
Value of a single statement argument or row column.
func FromDriverValues ¶
FromDriverValues converts a slice of Go driver.Value objects of supported types to a slice of protobuf Value objects.
func ToValueSlice ¶
ToValueSlice converts a slice of Go objects of supported types to a slice of protobuf Value objects.
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
type ValueBool ¶
type ValueBool struct {
Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*ValueBool) Descriptor ¶
func (*ValueBool) Interface ¶
func (v *ValueBool) Interface() interface{}
Interface implements valueMessage.
func (*ValueBool) ProtoMessage ¶
func (*ValueBool) ProtoMessage()
type ValueBytes ¶
type ValueBytes struct {
Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*ValueBytes) Descriptor ¶
func (*ValueBytes) Descriptor() ([]byte, []int)
func (*ValueBytes) GetValue ¶
func (m *ValueBytes) GetValue() []byte
func (*ValueBytes) Interface ¶
func (v *ValueBytes) Interface() interface{}
Interface implements valueMessage.
func (*ValueBytes) Marshal ¶
func (m *ValueBytes) Marshal() (dAtA []byte, err error)
func (*ValueBytes) ProtoMessage ¶
func (*ValueBytes) ProtoMessage()
func (*ValueBytes) Reset ¶
func (m *ValueBytes) Reset()
func (*ValueBytes) Size ¶
func (m *ValueBytes) Size() (n int)
func (*ValueBytes) String ¶
func (m *ValueBytes) String() string
func (*ValueBytes) Unmarshal ¶
func (m *ValueBytes) Unmarshal(dAtA []byte) error
type ValueCode ¶
type ValueCode int32
ValueCode is a numberic code identifying the Go type of a value.
It supports all types that should be handle by driver.Value in database/sql/driver.
func ToValueCode ¶
ToValueCode converts a Go type object into its serialized code number.
func (ValueCode) EnumDescriptor ¶
type ValueFloat64 ¶
type ValueFloat64 struct {
Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*ValueFloat64) Descriptor ¶
func (*ValueFloat64) Descriptor() ([]byte, []int)
func (*ValueFloat64) GetValue ¶
func (m *ValueFloat64) GetValue() float64
func (*ValueFloat64) Interface ¶
func (v *ValueFloat64) Interface() interface{}
Interface implements valueMessage.
func (*ValueFloat64) Marshal ¶
func (m *ValueFloat64) Marshal() (dAtA []byte, err error)
func (*ValueFloat64) ProtoMessage ¶
func (*ValueFloat64) ProtoMessage()
func (*ValueFloat64) Reset ¶
func (m *ValueFloat64) Reset()
func (*ValueFloat64) Size ¶
func (m *ValueFloat64) Size() (n int)
func (*ValueFloat64) String ¶
func (m *ValueFloat64) String() string
func (*ValueFloat64) Unmarshal ¶
func (m *ValueFloat64) Unmarshal(dAtA []byte) error
type ValueInt64 ¶
type ValueInt64 struct {
Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*ValueInt64) Descriptor ¶
func (*ValueInt64) Descriptor() ([]byte, []int)
func (*ValueInt64) GetValue ¶
func (m *ValueInt64) GetValue() int64
func (*ValueInt64) Interface ¶
func (v *ValueInt64) Interface() interface{}
Interface implements valueMessage.
func (*ValueInt64) Marshal ¶
func (m *ValueInt64) Marshal() (dAtA []byte, err error)
func (*ValueInt64) ProtoMessage ¶
func (*ValueInt64) ProtoMessage()
func (*ValueInt64) Reset ¶
func (m *ValueInt64) Reset()
func (*ValueInt64) Size ¶
func (m *ValueInt64) Size() (n int)
func (*ValueInt64) String ¶
func (m *ValueInt64) String() string
func (*ValueInt64) Unmarshal ¶
func (m *ValueInt64) Unmarshal(dAtA []byte) error
type ValueNull ¶
type ValueNull struct { }
func (*ValueNull) Descriptor ¶
func (*ValueNull) Interface ¶
func (v *ValueNull) Interface() interface{}
Interface implements valueMessage.
func (*ValueNull) ProtoMessage ¶
func (*ValueNull) ProtoMessage()
type ValueString ¶
type ValueString struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*ValueString) Descriptor ¶
func (*ValueString) Descriptor() ([]byte, []int)
func (*ValueString) GetValue ¶
func (m *ValueString) GetValue() string
func (*ValueString) Interface ¶
func (v *ValueString) Interface() interface{}
Interface implements valueMessage.
func (*ValueString) Marshal ¶
func (m *ValueString) Marshal() (dAtA []byte, err error)
func (*ValueString) ProtoMessage ¶
func (*ValueString) ProtoMessage()
func (*ValueString) Reset ¶
func (m *ValueString) Reset()
func (*ValueString) Size ¶
func (m *ValueString) Size() (n int)
func (*ValueString) String ¶
func (m *ValueString) String() string
func (*ValueString) Unmarshal ¶
func (m *ValueString) Unmarshal(dAtA []byte) error
type ValueTime ¶
type ValueTime struct {
Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}
func (*ValueTime) Descriptor ¶
func (*ValueTime) Interface ¶
func (v *ValueTime) Interface() interface{}
Interface implements valueMessage.
func (*ValueTime) ProtoMessage ¶
func (*ValueTime) ProtoMessage()