gorpcqueryservice

package
v2.0.0-alpha2+incompat... Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 28, 2015 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL