driver

package
v0.0.0-...-e3900cc Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2015 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package driver is a generated protocol buffer package.

It is generated from these files: 

cockroach/sql/driver/wire.proto

It has these top-level messages: 

Datum
Result
Request
Response

Index

Constants

View Source 
const (
	// Endpoint is the URL path prefix which accepts incoming
	// HTTP requests for the SQL API.
	Endpoint = "/sql/"
)
View Source 
const (
	// StatusTooManyRequests indicates client should retry due to
	// server having too many requests.
	StatusTooManyRequests = 429
)

Variables

View Source 
var (
	ErrInvalidLengthWire = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWire   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterSender 

func RegisterSender(scheme string, f NewSenderFunc)

RegisterSender registers the specified function to be used for creation of a new sender when the specified scheme is encountered.

Types

type Datum 

type Datum struct {
	// Using explicit proto types provides convenient access when using json. If
	// we used a Kind+Bytes approach the json interface would involve base64
	// encoded data.
	//
	// Types that are valid to be assigned to Payload:
	//	*Datum_BoolVal
	//	*Datum_IntVal
	//	*Datum_FloatVal
	//	*Datum_BytesVal
	//	*Datum_StringVal
	//	*Datum_TimeVal
	Payload isDatum_Payload `protobuf_oneof:"payload"`
}

func (*Datum) GetBoolVal 

func (m *Datum) GetBoolVal() bool

func (*Datum) GetBytesVal 

func (m *Datum) GetBytesVal() []byte

func (*Datum) GetFloatVal 

func (m *Datum) GetFloatVal() float64

func (*Datum) GetIntVal 

func (m *Datum) GetIntVal() int64

func (*Datum) GetPayload 

func (m *Datum) GetPayload() isDatum_Payload

func (*Datum) GetStringVal 

func (m *Datum) GetStringVal() string

func (*Datum) GetTimeVal 

func (m *Datum) GetTimeVal() *Datum_Timestamp

func (*Datum) Marshal 

func (m *Datum) Marshal() (data []byte, err error)

func (*Datum) MarshalTo 

func (m *Datum) MarshalTo(data []byte) (int, error)

func (*Datum) ProtoMessage 

func (*Datum) ProtoMessage()

func (*Datum) Reset 

func (m *Datum) Reset()

func (*Datum) Size 

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

func (Datum) String 

func (d Datum) String() string

func (*Datum) Unmarshal 

func (m *Datum) Unmarshal(data []byte) error

func (Datum) Value 

func (d Datum) Value() (driver.Value, error)

Value implements the driver.Valuer interface.

func (*Datum) XXX_OneofFuncs 

func (*Datum) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Datum_BoolVal 

type Datum_BoolVal struct {
	BoolVal bool `protobuf:"varint,1,opt,name=bool_val,oneof"`
}

func (*Datum_BoolVal) MarshalTo 

func (m *Datum_BoolVal) MarshalTo(data []byte) (int, error)

func (*Datum_BoolVal) Size 

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

type Datum_BytesVal 

type Datum_BytesVal struct {
	BytesVal []byte `protobuf:"bytes,4,opt,name=bytes_val,oneof"`
}

func (*Datum_BytesVal) MarshalTo 

func (m *Datum_BytesVal) MarshalTo(data []byte) (int, error)

func (*Datum_BytesVal) Size 

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

type Datum_FloatVal 

type Datum_FloatVal struct {
	FloatVal float64 `protobuf:"fixed64,3,opt,name=float_val,oneof"`
}

func (*Datum_FloatVal) MarshalTo 

func (m *Datum_FloatVal) MarshalTo(data []byte) (int, error)

func (*Datum_FloatVal) Size 

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

type Datum_IntVal 

type Datum_IntVal struct {
	IntVal int64 `protobuf:"varint,2,opt,name=int_val,oneof"`
}

func (*Datum_IntVal) MarshalTo 

func (m *Datum_IntVal) MarshalTo(data []byte) (int, error)

func (*Datum_IntVal) Size 

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

type Datum_StringVal 

type Datum_StringVal struct {
	StringVal string `protobuf:"bytes,5,opt,name=string_val,oneof"`
}

func (*Datum_StringVal) MarshalTo 

func (m *Datum_StringVal) MarshalTo(data []byte) (int, error)

func (*Datum_StringVal) Size 

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

type Datum_TimeVal 

type Datum_TimeVal struct {
	TimeVal *Datum_Timestamp `protobuf:"bytes,6,opt,name=time_val,oneof"`
}

func (*Datum_TimeVal) MarshalTo 

func (m *Datum_TimeVal) MarshalTo(data []byte) (int, error)

func (*Datum_TimeVal) Size 

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

type Datum_Timestamp 

type Datum_Timestamp struct {
	// The time in seconds since, January 1, 1970 UTC (Unix time).
	Sec int64 `protobuf:"varint,1,opt,name=sec" json:"sec"`
	// nsec specifies a non-negative nanosecond offset within sec.
	// It must be in the range [0, 999999999].
	Nsec uint32 `protobuf:"varint,2,opt,name=nsec" json:"nsec"`
}

Timestamp represents an absolute timestamp devoid of time-zone.

func (*Datum_Timestamp) GetNsec 

func (m *Datum_Timestamp) GetNsec() uint32

func (*Datum_Timestamp) GetSec 

func (m *Datum_Timestamp) GetSec() int64

func (Datum_Timestamp) GoTime 

func (t Datum_Timestamp) GoTime() time.Time

GoTime converts the timestamp to a time.Time.

func (*Datum_Timestamp) Marshal 

func (m *Datum_Timestamp) Marshal() (data []byte, err error)

func (*Datum_Timestamp) MarshalTo 

func (m *Datum_Timestamp) MarshalTo(data []byte) (int, error)

func (*Datum_Timestamp) ProtoMessage 

func (*Datum_Timestamp) ProtoMessage()

func (*Datum_Timestamp) Reset 

func (m *Datum_Timestamp) Reset()

func (*Datum_Timestamp) Size 

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

func (*Datum_Timestamp) String 

func (m *Datum_Timestamp) String() string

func (*Datum_Timestamp) Unmarshal 

func (m *Datum_Timestamp) Unmarshal(data []byte) error

type Method 

type Method int

Method is the enumerated type for methods. 

const (
	// Execute runs all the sql statements in a SQLRequest and
	// returns a SQLResponse.
	Execute Method = iota
)

func (Method) String 

func (i Method) String() string

type NewSenderFunc 

type NewSenderFunc func(u *url.URL, ctx *base.Context, retryOpts retry.Options) (Sender, error)

NewSenderFunc creates a new sender for the registered scheme.

type Request 

type Request struct {
	// User is the originating user.
	User string `protobuf:"bytes,1,opt,name=user" json:"user"`
	// Session settings that were returned in the last response that
	// contained them, being reflected back to the server.
	Session []byte `protobuf:"bytes,2,opt,name=session" json:"session,omitempty"`
	// SQL statement(s) to be serially executed by the server. Multiple
	// statements are passed as a single string separated by semicolons.
	Sql string `protobuf:"bytes,3,opt,name=sql" json:"sql"`
	// Parameters referred to in the above SQL statement(s) using "?".
	Params []Datum `protobuf:"bytes,4,rep,name=params" json:"params"`
}

An SQL request to cockroach. A transaction can consist of multiple requests.

func (Request) CreateReply 

func (Request) CreateReply() Response

CreateReply creates an empty response for the request.

func (*Request) GetParams 

func (m *Request) GetParams() []Datum

func (*Request) GetSession 

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

func (*Request) GetSql 

func (m *Request) GetSql() string

func (*Request) GetUser 

func (m *Request) GetUser() string

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (Request) Method 

func (Request) Method() Method

Method returns the method.

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 Response 

type Response struct {
	// Setting that should be reflected back in all subsequent requests.
	// When not set, future requests should continue to use existing settings.
	Session []byte `protobuf:"bytes,1,opt,name=session" json:"session,omitempty"`
	// The list of results. There is one result object per SQL statement in the
	// request.
	Results []Result `protobuf:"bytes,2,rep,name=results" json:"results"`
}

func (*Response) GetResults 

func (m *Response) GetResults() []Result

func (*Response) GetSession 

func (m *Response) GetSession() []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) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

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 Result 

type Result struct {
	// Error is non-nil if an error occurred while executing the statement.
	Error *string `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	// The names of the columns returned in the result set in the order specified
	// in the SQL statement. The number of columns will equal the number of
	// values in each Row.
	Columns []string `protobuf:"bytes,2,rep,name=columns" json:"columns,omitempty"`
	// The rows in the result set.
	Rows []Result_Row `protobuf:"bytes,3,rep,name=rows" json:"rows"`
}

A Result is a collection of rows.

func (*Result) GetColumns 

func (m *Result) GetColumns() []string

func (*Result) GetError 

func (m *Result) GetError() string

func (*Result) GetRows 

func (m *Result) GetRows() []Result_Row

func (*Result) Marshal 

func (m *Result) Marshal() (data []byte, err error)

func (*Result) MarshalTo 

func (m *Result) MarshalTo(data []byte) (int, error)

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) Reset 

func (m *Result) Reset()

func (*Result) Size 

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

func (*Result) String 

func (m *Result) String() string

func (*Result) Unmarshal 

func (m *Result) Unmarshal(data []byte) error

type Result_Row 

type Result_Row struct {
	Values []Datum `protobuf:"bytes,1,rep,name=values" json:"values"`
}

A Row is a collection of values representing a row in a result.

func (*Result_Row) GetValues 

func (m *Result_Row) GetValues() []Datum

func (*Result_Row) Marshal 

func (m *Result_Row) Marshal() (data []byte, err error)

func (*Result_Row) MarshalTo 

func (m *Result_Row) MarshalTo(data []byte) (int, error)

func (*Result_Row) ProtoMessage 

func (*Result_Row) ProtoMessage()

func (*Result_Row) Reset 

func (m *Result_Row) Reset()

func (*Result_Row) Size 

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

func (*Result_Row) String 

func (m *Result_Row) String() string

func (*Result_Row) Unmarshal 

func (m *Result_Row) Unmarshal(data []byte) error

type Sender 

type Sender interface {
	// Send dispatches a `Request` and returns the resulting `Response` with an
	// optional transmission error.
	Send(Request) (Response, error)
}

Sender is an interface for sending a request to a SQL database backend.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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