gorpctabletconn

Documentation

Index

• func DialTablet(context interface{}, endPoint topo.EndPoint, keyspace, shard string) (tabletconn.TabletConn, error)
• type TabletBson
  • func (conn *TabletBson) Begin(context interface{}) (transactionId int64, err error)
  • func (conn *TabletBson) Close()
  • func (conn *TabletBson) Commit(context interface{}, transactionId int64) error
  • func (conn *TabletBson) EndPoint() topo.EndPoint
  • func (conn *TabletBson) Execute(context interface{}, query string, bindVars map[string]interface{}, ...) (*mproto.QueryResult, error)
  • func (conn *TabletBson) ExecuteBatch(context interface{}, queries []tproto.BoundQuery, transactionId int64) (*tproto.QueryResultList, error)
  • func (conn *TabletBson) Rollback(context interface{}, transactionId int64) error
  • func (conn *TabletBson) StreamExecute(context interface{}, query string, bindVars map[string]interface{}, ...) (<-chan *mproto.QueryResult, tabletconn.ErrFunc)

Functions

func DialTablet

func DialTablet(context interface{}, endPoint topo.EndPoint, keyspace, shard string) (tabletconn.TabletConn, error)

Types

type TabletBson

type TabletBson struct {
	// contains filtered or unexported fields
}

TabletBson implements a bson rpcplus implementation for TabletConn

func (*TabletBson) Begin

func (conn *TabletBson) Begin(context interface{}) (transactionId int64, err error)

func (*TabletBson) Close

func (conn *TabletBson) Close()

func (*TabletBson) Commit

func (conn *TabletBson) Commit(context interface{}, transactionId int64) error

func (*TabletBson) EndPoint

func (conn *TabletBson) EndPoint() topo.EndPoint

func (*TabletBson) Execute

func (conn *TabletBson) Execute(context interface{}, query string, bindVars map[string]interface{}, transactionId int64) (*mproto.QueryResult, error)

func (*TabletBson) ExecuteBatch

func (conn *TabletBson) ExecuteBatch(context interface{}, queries []tproto.BoundQuery, transactionId int64) (*tproto.QueryResultList, error)

func (*TabletBson) Rollback

func (conn *TabletBson) Rollback(context interface{}, transactionId int64) error

func (*TabletBson) StreamExecute

func (conn *TabletBson) StreamExecute(context interface{}, query string, bindVars map[string]interface{}, transactionId int64) (<-chan *mproto.QueryResult, tabletconn.ErrFunc)