protocol

package
v0.0.0-...-181d263 Latest Latest
Warning

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

Go to latest
Published: Jul 11, 2018 License: Apache-2.0 Imports: 11 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthSql = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSql   = fmt.Errorf("proto: integer overflow")
)
View Source
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",
}
View Source
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,
}
View Source
var ValueCode_name = map[int32]string{
	0: "INT64",
	1: "FLOAT64",
	2: "BOOL",
	3: "BYTES",
	4: "STRING",
	5: "TIME",
	6: "NULL",
}
View Source
var ValueCode_value = map[string]int32{
	"INT64":   0,
	"FLOAT64": 1,
	"BOOL":    2,
	"BYTES":   3,
	"STRING":  4,
	"TIME":    5,
	"NULL":    6,
}

Functions

func FromValueCode

func FromValueCode(code ValueCode) reflect.Type

FromValueCode converts a serialized value type code into a Go type object.

func FromValueSlice

func FromValueSlice(values []*Value) ([]interface{}, error)

FromValueSlice converts a slice of protobuf Value objects to a slice of Go interface{} objects.

func RegisterSQLServer

func RegisterSQLServer(s *grpc.Server, srv SQLServer)

func ToDriverValues

func ToDriverValues(values []*Value) ([]driver.Value, error)

ToDriverValues converts a slice of protobuf Value objects to a slice of Go driver.Value objects.

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

func NewRequestColumnTypeDatabaseTypeName(id int64, column int64) *Request

NewRequestColumnTypeDatabaseTypeName creates a new Request of type ColumnTypeDatabaseTypeName.

func NewRequestColumnTypeScanType

func NewRequestColumnTypeScanType(id int64, column int64) *Request

NewRequestColumnTypeScanType creates a new Request of type ColumnTypeScanType.

func NewRequestCommit

func NewRequestCommit(id int64) *Request

NewRequestCommit creates a new Request of type RequestCommit.

func NewRequestConnExec

func NewRequestConnExec(query string, args []*Value) *Request

NewRequestConnExec creates a new Request of type RequestConnExec.

func NewRequestExec

func NewRequestExec(id int64, args []*Value) *Request

NewRequestExec creates a new Request of type RequestExec.

func NewRequestNext

func NewRequestNext(id int64, n int64) *Request

NewRequestNext creates a new Request of type RequestNext.

func NewRequestOpen

func NewRequestOpen(name string) *Request

NewRequestOpen creates a new Request of type RequestOpen.

func NewRequestPrepare

func NewRequestPrepare(query string) *Request

NewRequestPrepare creates a new Request of type RequestPrepare.

func NewRequestQuery

func NewRequestQuery(id int64, args []*Value) *Request

NewRequestQuery creates a new Request of type RequestQuery.

func NewRequestRollback

func NewRequestRollback(id int64) *Request

NewRequestRollback creates a new Request of type RequestRollback.

func NewRequestRowsClose

func NewRequestRowsClose(id int64) *Request

NewRequestRowsClose creates a new Request of type RequestRowsClose.

func NewRequestStmtClose

func NewRequestStmtClose(id int64) *Request

NewRequestStmtClose creates a new Request of type RequestStmtClose.

func (*Request) Descriptor

func (*Request) Descriptor() ([]byte, []int)

func (*Request) GetCode

func (m *Request) GetCode() RequestCode

func (*Request) GetData

func (m *Request) GetData() []byte

func (*Request) Marshal

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) Size

func (m *Request) Size() (n int)

func (*Request) String

func (m *Request) String() string

func (*Request) Unmarshal

func (m *Request) Unmarshal(dAtA []byte) error

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) MarshalTo

func (m *RequestBegin) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestClose) MarshalTo(dAtA []byte) (int, 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 (*RequestColumnTypeDatabaseTypeName) GetId

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 (*RequestColumnTypeDatabaseTypeName) Size

func (m *RequestColumnTypeDatabaseTypeName) Size() (n int)

func (*RequestColumnTypeDatabaseTypeName) 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) MarshalTo

func (m *RequestCommit) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestConnExec) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestExec) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestNext) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestOpen) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestPrepare) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestQuery) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestRollback) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestRowsClose) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *RequestStmtClose) MarshalTo(dAtA []byte) (int, 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

func NewResponseBegin(id int64) *Response

NewResponseBegin creates a new Response of type ResponseBegin.

func NewResponseClose

func NewResponseClose() *Response

NewResponseClose creates a new Response of type ResponseClose.

func NewResponseColumnTypeDatabaseTypeName

func NewResponseColumnTypeDatabaseTypeName(name string) *Response

NewResponseColumnTypeDatabaseTypeName creates a new Response of type ResponseColumnTypeDatabaseTypeName.

func NewResponseColumnTypeScanType

func NewResponseColumnTypeScanType(code ValueCode) *Response

NewResponseColumnTypeScanType creates a new Response of type ResponseColumnTypeScanType.

func NewResponseCommit

func NewResponseCommit() *Response

NewResponseCommit creates a new Response of type ResponseCommit.

func NewResponseExec

func NewResponseExec(lastInsertID, rowsAffected int64) *Response

NewResponseExec creates a new Response of type ResponseExec.

func NewResponseNext

func NewResponseNext(eof bool, values []*Value) *Response

NewResponseNext creates a new Response of type ResponseNext.

func NewResponseOpen

func NewResponseOpen() *Response

NewResponseOpen creates a new Response of type ResponseOpen.

func NewResponsePrepare

func NewResponsePrepare(id int64, numInput int) *Response

NewResponsePrepare creates a new Response of type ResponsePrepare.

func NewResponseQuery

func NewResponseQuery(id int64, columns []string) *Response

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) Descriptor() ([]byte, []int)

func (*Response) Exec

func (r *Response) Exec() *ResponseExec

Exec returns a ResponseExec payload.

func (*Response) GetCode

func (m *Response) GetCode() RequestCode

func (*Response) GetData

func (m *Response) GetData() []byte

func (*Response) Marshal

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo

func (m *Response) MarshalTo(dAtA []byte) (int, error)

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) Reset

func (m *Response) Reset()

func (*Response) SQLiteError

func (r *Response) SQLiteError() sqlite3.Error

SQLiteError returns a ResponseSQLiteError payload.

func (*Response) Size

func (m *Response) Size() (n int)

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

func (m *Response) Unmarshal(dAtA []byte) error

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) MarshalTo

func (m *ResponseBegin) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ResponseClose) MarshalTo(dAtA []byte) (int, 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 (*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 (*ResponseColumnTypeDatabaseTypeName) Size

func (*ResponseColumnTypeDatabaseTypeName) 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 (*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) MarshalTo

func (m *ResponseCommit) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ResponseExec) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ResponseNext) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ResponseOpen) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ResponsePrepare) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ResponseQuery) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ResponseRollback) MarshalTo(dAtA []byte) (int, 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_ConnClient interface {
	Send(*Request) error
	Recv() (*Response, error)
	grpc.ClientStream
}

type SQL_ConnServer

type SQL_ConnServer interface {
	Send(*Response) error
	Recv() (*Request, error)
	grpc.ServerStream
}

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

func FromDriverValues(objects []driver.Value) ([]*Value, error)

FromDriverValues converts a slice of Go driver.Value objects of supported types to a slice of protobuf Value objects.

func ToValueSlice

func ToValueSlice(objects []interface{}) ([]*Value, error)

ToValueSlice converts a slice of Go objects of supported types to a slice of protobuf Value objects.

func (*Value) Descriptor

func (*Value) Descriptor() ([]byte, []int)

func (*Value) GetCode

func (m *Value) GetCode() ValueCode

func (*Value) GetData

func (m *Value) GetData() []byte

func (*Value) Marshal

func (m *Value) Marshal() (dAtA []byte, err error)

func (*Value) MarshalTo

func (m *Value) MarshalTo(dAtA []byte) (int, error)

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) Reset

func (m *Value) Reset()

func (*Value) Size

func (m *Value) Size() (n int)

func (*Value) String

func (m *Value) String() string

func (*Value) Unmarshal

func (m *Value) Unmarshal(dAtA []byte) error

type ValueBool

type ValueBool struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
}

func (*ValueBool) Descriptor

func (*ValueBool) Descriptor() ([]byte, []int)

func (*ValueBool) GetValue

func (m *ValueBool) GetValue() bool

func (*ValueBool) Interface

func (v *ValueBool) Interface() interface{}

Interface implements valueMessage.

func (*ValueBool) Marshal

func (m *ValueBool) Marshal() (dAtA []byte, err error)

func (*ValueBool) MarshalTo

func (m *ValueBool) MarshalTo(dAtA []byte) (int, error)

func (*ValueBool) ProtoMessage

func (*ValueBool) ProtoMessage()

func (*ValueBool) Reset

func (m *ValueBool) Reset()

func (*ValueBool) Size

func (m *ValueBool) Size() (n int)

func (*ValueBool) String

func (m *ValueBool) String() string

func (*ValueBool) Unmarshal

func (m *ValueBool) Unmarshal(dAtA []byte) error

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) MarshalTo

func (m *ValueBytes) MarshalTo(dAtA []byte) (int, 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.

const (
	ValueCode_INT64   ValueCode = 0
	ValueCode_FLOAT64 ValueCode = 1
	ValueCode_BOOL    ValueCode = 2
	ValueCode_BYTES   ValueCode = 3
	ValueCode_STRING  ValueCode = 4
	ValueCode_TIME    ValueCode = 5
	ValueCode_NULL    ValueCode = 6
)

func ToValueCode

func ToValueCode(t reflect.Type) ValueCode

ToValueCode converts a Go type object into its serialized code number.

func (ValueCode) EnumDescriptor

func (ValueCode) EnumDescriptor() ([]byte, []int)

func (ValueCode) String

func (x ValueCode) String() string

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) MarshalTo

func (m *ValueFloat64) MarshalTo(dAtA []byte) (int, 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) MarshalTo

func (m *ValueInt64) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*ValueNull) Interface

func (v *ValueNull) Interface() interface{}

Interface implements valueMessage.

func (*ValueNull) Marshal

func (m *ValueNull) Marshal() (dAtA []byte, err error)

func (*ValueNull) MarshalTo

func (m *ValueNull) MarshalTo(dAtA []byte) (int, error)

func (*ValueNull) ProtoMessage

func (*ValueNull) ProtoMessage()

func (*ValueNull) Reset

func (m *ValueNull) Reset()

func (*ValueNull) Size

func (m *ValueNull) Size() (n int)

func (*ValueNull) String

func (m *ValueNull) String() string

func (*ValueNull) Unmarshal

func (m *ValueNull) Unmarshal(dAtA []byte) error

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) MarshalTo

func (m *ValueString) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*ValueTime) GetValue

func (m *ValueTime) GetValue() int64

func (*ValueTime) Interface

func (v *ValueTime) Interface() interface{}

Interface implements valueMessage.

func (*ValueTime) Marshal

func (m *ValueTime) Marshal() (dAtA []byte, err error)

func (*ValueTime) MarshalTo

func (m *ValueTime) MarshalTo(dAtA []byte) (int, error)

func (*ValueTime) ProtoMessage

func (*ValueTime) ProtoMessage()

func (*ValueTime) Reset

func (m *ValueTime) Reset()

func (*ValueTime) Size

func (m *ValueTime) Size() (n int)

func (*ValueTime) String

func (m *ValueTime) String() string

func (*ValueTime) Unmarshal

func (m *ValueTime) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL