gorpcqueryservice

Documentation

Index

• type SqlQuery
  • func New(server queryservice.QueryService) *SqlQuery
  • func (sq *SqlQuery) Begin(ctx context.Context, session *proto.Session, txInfo *proto.TransactionInfo) (err error)
  • func (sq *SqlQuery) Begin2(ctx context.Context, beginRequest *proto.BeginRequest, ...) (err error)
  • func (sq *SqlQuery) Commit(ctx context.Context, session *proto.Session, noOutput *rpc.Unused) (err error)
  • func (sq *SqlQuery) Commit2(ctx context.Context, commitRequest *proto.CommitRequest, ...) (err error)
  • func (sq *SqlQuery) Execute(ctx context.Context, query *proto.Query, reply *mproto.QueryResult) (err error)
  • func (sq *SqlQuery) Execute2(ctx context.Context, executeRequest *proto.ExecuteRequest, ...) (err error)
  • func (sq *SqlQuery) ExecuteBatch(ctx context.Context, queryList *proto.QueryList, reply *proto.QueryResultList) (err error)
  • func (sq *SqlQuery) ExecuteBatch2(ctx context.Context, req *proto.ExecuteBatchRequest, ...) (err error)
  • func (sq *SqlQuery) GetSessionId(sessionParams *proto.SessionParams, sessionInfo *proto.SessionInfo) (err error)
  • func (sq *SqlQuery) GetSessionId2(sessionIdReq *proto.GetSessionIdRequest, sessionInfo *proto.SessionInfo) (err error)
  • func (sq *SqlQuery) Rollback(ctx context.Context, session *proto.Session, noOutput *rpc.Unused) (err error)
  • func (sq *SqlQuery) Rollback2(ctx context.Context, rollbackRequest *proto.RollbackRequest, ...) (err error)
  • func (sq *SqlQuery) SplitQuery(ctx context.Context, req *proto.SplitQueryRequest, ...) (err error)
  • func (sq *SqlQuery) StreamExecute(ctx context.Context, query *proto.Query, ...) (err error)
  • func (sq *SqlQuery) StreamExecute2(ctx context.Context, req *proto.StreamExecuteRequest, ...) (err error)
  • func (sq *SqlQuery) StreamHealth(ctx context.Context, query *rpc.Unused, ...) (err error)

Types

type SqlQuery

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

SqlQuery is the server object for gorpc SqlQuery

func New

func New(server queryservice.QueryService) *SqlQuery

New returns a new SqlQuery based on the QueryService implementation

func (*SqlQuery) Begin

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

Begin is exposing tabletserver.SqlQuery.Begin

func (*SqlQuery) Begin2

func (sq *SqlQuery) Begin2(ctx context.Context, beginRequest *proto.BeginRequest, beginResponse *proto.BeginResponse) (err error)

Begin2 should not be used by anything other than tests. It will eventually replace Begin, but it breaks compatibility with older clients. Once all clients are upgraded, it can be replaced.

func (*SqlQuery) Commit

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

Commit is exposing tabletserver.SqlQuery.Commit

func (*SqlQuery) Commit2

func (sq *SqlQuery) Commit2(ctx context.Context, commitRequest *proto.CommitRequest, commitResponse *proto.CommitResponse) (err error)

Commit2 should not be used by anything other than tests. It will eventually replace Commit, but it breaks compatibility with older clients. Once all clients are upgraded, it can be replaced.

func (*SqlQuery) Execute

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

Execute is exposing tabletserver.SqlQuery.Execute

func (*SqlQuery) Execute2

func (sq *SqlQuery) Execute2(ctx context.Context, executeRequest *proto.ExecuteRequest, reply *mproto.QueryResult) (err error)

Execute2 should not be used by anything other than tests It will eventually replace Execute, but it breaks compatibility with older clients Once all clients are upgraded, it can be replaced

func (*SqlQuery) ExecuteBatch

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

ExecuteBatch is exposing tabletserver.SqlQuery.ExecuteBatch

func (*SqlQuery) ExecuteBatch2

func (sq *SqlQuery) ExecuteBatch2(ctx context.Context, req *proto.ExecuteBatchRequest, reply *proto.QueryResultList) (err error)

ExecuteBatch2 should not be used by anything other than tests It will eventually replace ExecuteBatch, but it breaks compatibility with older clients. Once all clients are upgraded, it can be replaced.

func (*SqlQuery) GetSessionId

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

GetSessionId is exposing tabletserver.SqlQuery.GetSessionId

func (*SqlQuery) GetSessionId2

func (sq *SqlQuery) GetSessionId2(sessionIdReq *proto.GetSessionIdRequest, sessionInfo *proto.SessionInfo) (err error)

GetSessionId2 should not be used by anything other than tests. It will eventually replace GetSessionId, but it breaks compatibility with older clients. Once all clients are upgraded, it can be replaced.

func (*SqlQuery) Rollback

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

Rollback is exposing tabletserver.SqlQuery.Rollback

func (*SqlQuery) Rollback2

func (sq *SqlQuery) Rollback2(ctx context.Context, rollbackRequest *proto.RollbackRequest, rollbackResponse *proto.RollbackResponse) (err error)

Rollback2 should not be used by anything other than tests. It will eventually replace Rollback, but it breaks compatibility with older clients. Once all clients are upgraded, it can be replaced.

func (*SqlQuery) SplitQuery

func (sq *SqlQuery) SplitQuery(ctx context.Context, req *proto.SplitQueryRequest, reply *proto.SplitQueryResult) (err 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) (err error)

StreamExecute is exposing tabletserver.SqlQuery.StreamExecute

func (*SqlQuery) StreamExecute2

func (sq *SqlQuery) StreamExecute2(ctx context.Context, req *proto.StreamExecuteRequest, sendReply func(reply interface{}) error) (err error)

StreamExecute2 should not be used by anything other than tests. It will eventually replace Rollback, but it breaks compatibility with older clients. Once all clients are upgraded, it can be replaced.

func (*SqlQuery) StreamHealth

func (sq *SqlQuery) StreamHealth(ctx context.Context, query *rpc.Unused, sendReply func(reply interface{}) error) (err error)

StreamHealth is exposing tabletserver.SqlQuery.StreamHealthRegister and tabletserver.SqlQuery.StreamHealthUnregister