proto

Documentation

Index

• type BoundQuery
  • func (boundQuery *BoundQuery) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (boundQuery *BoundQuery) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type Query
  • func (query *Query) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (query *Query) String() string
  • func (query *Query) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type QueryList
  • func (queryList *QueryList) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (queryList *QueryList) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type QueryResultList
  • func (queryResultList *QueryResultList) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (queryResultList *QueryResultList) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type QuerySplit
• type Session
  • func (session *Session) MarshalBson(buf *bytes2.ChunkedWriter, key string)
  • func (session *Session) UnmarshalBson(buf *bytes.Buffer, kind byte)
• type SessionInfo
• type SessionParams
• type SplitQueryRequest
• type SplitQueryResult
• type TransactionInfo

Types

type BoundQuery

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

func (*BoundQuery) MarshalBson

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

MarshalBson bson-encodes BoundQuery.

func (*BoundQuery) UnmarshalBson

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

UnmarshalBson bson-decodes into BoundQuery.

type Query

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

func (*Query) MarshalBson

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

MarshalBson bson-encodes Query.

func (*Query) String

func (query *Query) String() string

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

func (*Query) UnmarshalBson

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

UnmarshalBson bson-decodes into Query.

type QueryList

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

func (*QueryList) MarshalBson

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

MarshalBson bson-encodes QueryList.

func (*QueryList) UnmarshalBson

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

UnmarshalBson bson-decodes into QueryList.

type QueryResultList

type QueryResultList struct {
	List []mproto.QueryResult
}

func (*QueryResultList) MarshalBson

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

MarshalBson bson-encodes QueryResultList.

func (*QueryResultList) UnmarshalBson

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

UnmarshalBson bson-decodes into QueryResultList.

type QuerySplit

type QuerySplit struct {
	Query    BoundQuery
	RowCount int64
}

QuerySplit represents a split of SplitQueryRequest.Query. RowCount is only approximate.

type Session

type Session struct {
	SessionId     int64
	TransactionId int64
}

func (*Session) MarshalBson

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

MarshalBson bson-encodes Session.

func (*Session) UnmarshalBson

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

UnmarshalBson bson-decodes into Session.

type SessionInfo

type SessionInfo struct {
	SessionId int64
}

type SessionParams

type SessionParams struct {
	Keyspace string
	Shard    string
}

type SplitQueryRequest

type SplitQueryRequest struct {
	Query      BoundQuery
	SplitCount int
}

SplitQueryRequest represents a request to split a Query into queries that each return a subset of the original query.

type SplitQueryResult

type SplitQueryResult struct {
	Queries []QuerySplit
}

SplitQueryResult represents the result of a SplitQueryRequest

type TransactionInfo

type TransactionInfo struct {
	TransactionId int64
}