proto

package

v0.0.0-...-9a5932e Latest Latest Go to latest Published: Mar 10, 2014 License: BSD-3-Clause Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func DecodeBindVariablesBson(buf *bytes.Buffer, kind byte) (bindVars map[string]interface{})

func DecodeResultsBson(buf *bytes.Buffer, kind byte) (results []mproto.QueryResult)

func EncodeBindVariablesBson(buf *bytes2.ChunkedWriter, key string, bindVars map[string]interface{})

func EncodeQueriesBson(queries []BoundQuery, key string, buf *bytes2.ChunkedWriter)

func EncodeResultsBson(results []mproto.QueryResult, key string, buf *bytes2.ChunkedWriter)

type BoundQuery struct {
	Sql           string
	BindVariables map[string]interface{}
}

func DecodeQueriesBson(buf *bytes.Buffer, kind byte) (queries []BoundQuery)

func (bdq *BoundQuery) MarshalBson(buf *bytes2.ChunkedWriter, key string)

func (bdq *BoundQuery) UnmarshalBson(buf *bytes.Buffer, kind byte)

type DDLInvalidate struct {
	DDL string
}

type DmlType struct {
	Table string
	Keys  []string
}

type Query struct {
	Sql           string
	BindVariables map[string]interface{}
	SessionId     int64
	TransactionId int64
}

func (query *Query) MarshalBson(buf *bytes2.ChunkedWriter, key string)

func (query *Query) String() string

String prints a readable version of Query, and also truncates data if it's too long

func (query *Query) UnmarshalBson(buf *bytes.Buffer, kind byte)

type QueryList struct {
	Queries       []BoundQuery
	SessionId     int64
	TransactionId int64
}

func (ql *QueryList) MarshalBson(buf *bytes2.ChunkedWriter, key string)

func (ql *QueryList) UnmarshalBson(buf *bytes.Buffer, kind byte)

type QueryResultList struct {
	List []mproto.QueryResult
}

func (qrl *QueryResultList) MarshalBson(buf *bytes2.ChunkedWriter, key string)

func (qrl *QueryResultList) UnmarshalBson(buf *bytes.Buffer, kind byte)

type Session struct {
	SessionId     int64
	TransactionId int64
}

func (session *Session) MarshalBson(buf *bytes2.ChunkedWriter, key string)

func (session *Session) UnmarshalBson(buf *bytes.Buffer, kind byte)

type SessionInfo struct {
	SessionId int64
}

type SessionParams struct {
	Keyspace string
	Shard    string
}

type TransactionInfo struct {
	TransactionId int64
}