gorpcqueryservice

Documentation

Index

• type SqlQuery
  • func (sq *SqlQuery) Begin(ctx context.Context, session *proto.Session, txInfo *proto.TransactionInfo) error
  • func (sq *SqlQuery) Commit(ctx context.Context, session *proto.Session, noOutput *string) error
  • func (sq *SqlQuery) Execute(ctx context.Context, query *proto.Query, reply *mproto.QueryResult) error
  • func (sq *SqlQuery) ExecuteBatch(ctx context.Context, queryList *proto.QueryList, reply *proto.QueryResultList) error
  • func (sq *SqlQuery) GetSessionId(sessionParams *proto.SessionParams, sessionInfo *proto.SessionInfo) error
  • func (sq *SqlQuery) Rollback(ctx context.Context, session *proto.Session, noOutput *string) error
  • func (sq *SqlQuery) SplitQuery(ctx context.Context, req *proto.SplitQueryRequest, ...) error
  • func (sq *SqlQuery) StreamExecute(ctx context.Context, query *proto.Query, ...) error

Types

type SqlQuery

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

SqlQuery is the server object for gorpc SqlQuery

func (*SqlQuery) Begin

func (sq *SqlQuery) Begin(ctx context.Context, session *proto.Session, txInfo *proto.TransactionInfo) error

Begin is exposing tabletserver.SqlQuery.Begin

func (*SqlQuery) Commit

func (sq *SqlQuery) Commit(ctx context.Context, session *proto.Session, noOutput *string) error

Commit is exposing tabletserver.SqlQuery.Commit

func (*SqlQuery) Execute

func (sq *SqlQuery) Execute(ctx context.Context, query *proto.Query, reply *mproto.QueryResult) error

Execute is exposing tabletserver.SqlQuery.Execute

func (*SqlQuery) ExecuteBatch

func (sq *SqlQuery) ExecuteBatch(ctx context.Context, queryList *proto.QueryList, reply *proto.QueryResultList) error

ExecuteBatch is exposing tabletserver.SqlQuery.ExecuteBatch

func (*SqlQuery) GetSessionId

func (sq *SqlQuery) GetSessionId(sessionParams *proto.SessionParams, sessionInfo *proto.SessionInfo) error

GetSessionId is exposing tabletserver.SqlQuery.GetSessionId

func (*SqlQuery) Rollback

func (sq *SqlQuery) Rollback(ctx context.Context, session *proto.Session, noOutput *string) error

Rollback is exposing tabletserver.SqlQuery.Rollback

func (*SqlQuery) SplitQuery

func (sq *SqlQuery) SplitQuery(ctx context.Context, req *proto.SplitQueryRequest, reply *proto.SplitQueryResult) error

SplitQuery is exposing tabletserver.SqlQuery.SplitQuery

func (*SqlQuery) StreamExecute

func (sq *SqlQuery) StreamExecute(ctx context.Context, query *proto.Query, sendReply func(reply interface{}) error) error

StreamExecute is exposing tabletserver.SqlQuery.StreamExecute