fakerpcvtgateconn

Documentation

Overview

Package fakerpcvtgateconn provides a fake implementation of vtgateconn.Impl that doesn't do any RPC, but uses a local map to return results.

Index

• type FakeVTGateConn
  • func RegisterFakeVTGateConnDialer() (*FakeVTGateConn, string)
  • func (conn *FakeVTGateConn) AddQuery(sql string, bindVariables map[string]interface{}, ...)
  • func (conn *FakeVTGateConn) AddShardQuery(sql string, bindVariables map[string]interface{}, keyspace string, ...)
  • func (conn *FakeVTGateConn) AddSplitQuery(keyspace string, sql string, bindVariables map[string]interface{}, ...)
  • func (conn *FakeVTGateConn) AddSplitQueryV2(keyspace string, sql string, bindVariables map[string]interface{}, ...)
  • func (conn *FakeVTGateConn) Begin(ctx context.Context) (interface{}, error)
  • func (conn *FakeVTGateConn) Close()
  • func (conn *FakeVTGateConn) Commit(ctx context.Context, session interface{}) error
  • func (conn *FakeVTGateConn) Execute(ctx context.Context, sql string, bindVars map[string]interface{}, ...) (*sqltypes.Result, interface{}, error)
  • func (conn *FakeVTGateConn) ExecuteBatchKeyspaceIds(ctx context.Context, queries []*vtgatepb.BoundKeyspaceIdQuery, ...) ([]sqltypes.Result, interface{}, error)
  • func (conn *FakeVTGateConn) ExecuteBatchShards(ctx context.Context, queries []*vtgatepb.BoundShardQuery, ...) ([]sqltypes.Result, interface{}, error)
  • func (conn *FakeVTGateConn) ExecuteEntityIds(ctx context.Context, query string, keyspace string, entityColumnName string, ...) (*sqltypes.Result, interface{}, error)
  • func (conn *FakeVTGateConn) ExecuteKeyRanges(ctx context.Context, query string, keyspace string, ...) (*sqltypes.Result, interface{}, error)
  • func (conn *FakeVTGateConn) ExecuteKeyspaceIds(ctx context.Context, query string, keyspace string, keyspaceIds [][]byte, ...) (*sqltypes.Result, interface{}, error)
  • func (conn *FakeVTGateConn) ExecuteShards(ctx context.Context, sql string, keyspace string, shards []string, ...) (*sqltypes.Result, interface{}, error)
  • func (conn *FakeVTGateConn) GetSrvKeyspace(ctx context.Context, keyspace string) (*topodatapb.SrvKeyspace, error)
  • func (conn *FakeVTGateConn) Rollback(ctx context.Context, session interface{}) error
  • func (conn *FakeVTGateConn) SplitQuery(ctx context.Context, keyspace string, query string, ...) ([]*vtgatepb.SplitQueryResponse_Part, error)
  • func (conn *FakeVTGateConn) SplitQueryV2(ctx context.Context, keyspace string, query string, ...) ([]*vtgatepb.SplitQueryResponse_Part, error)
  • func (conn *FakeVTGateConn) StreamExecute(ctx context.Context, sql string, bindVars map[string]interface{}, ...) (sqltypes.ResultStream, error)
  • func (conn *FakeVTGateConn) StreamExecuteKeyRanges(ctx context.Context, query string, keyspace string, ...) (sqltypes.ResultStream, error)
  • func (conn *FakeVTGateConn) StreamExecuteKeyspaceIds(ctx context.Context, query string, keyspace string, keyspaceIds [][]byte, ...) (sqltypes.ResultStream, error)
  • func (conn *FakeVTGateConn) StreamExecuteShards(ctx context.Context, query string, keyspace string, shards []string, ...) (sqltypes.ResultStream, error)

Types

type FakeVTGateConn

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

FakeVTGateConn provides a fake implementation of vtgateconn.Impl

func RegisterFakeVTGateConnDialer

func RegisterFakeVTGateConnDialer() (*FakeVTGateConn, string)

RegisterFakeVTGateConnDialer registers the proper dialer for this fake, and returns the underlying instance that will be returned by the dialer, and the protocol to use to get this fake.

func (*FakeVTGateConn) AddQuery

func (conn *FakeVTGateConn) AddQuery(
	sql string,
	bindVariables map[string]interface{},
	tabletType topodatapb.TabletType,
	session *vtgatepb.Session,
	notInTransaction bool,
	expectedResult *sqltypes.Result)

AddQuery adds a query and expected result.

func (*FakeVTGateConn) AddShardQuery

func (conn *FakeVTGateConn) AddShardQuery(
	sql string,
	bindVariables map[string]interface{},
	keyspace string,
	shards []string,
	tabletType topodatapb.TabletType,
	session *vtgatepb.Session,
	notInTransaction bool,
	expectedResult *sqltypes.Result)

AddShardQuery adds a shard query and expected result.

func (*FakeVTGateConn) AddSplitQuery

func (conn *FakeVTGateConn) AddSplitQuery(
	keyspace string,
	sql string,
	bindVariables map[string]interface{},
	splitColumn string,
	splitCount int64,
	expectedResult []*vtgatepb.SplitQueryResponse_Part)

AddSplitQuery adds a split query and expected result.

func (*FakeVTGateConn) AddSplitQueryV2

func (conn *FakeVTGateConn) AddSplitQueryV2(
	keyspace string,
	sql string,
	bindVariables map[string]interface{},
	splitColumns []string,
	splitCount int64,
	numRowsPerQueryPart int64,
	algorithm querypb.SplitQueryRequest_Algorithm,
	expectedResult []*vtgatepb.SplitQueryResponse_Part)

AddSplitQueryV2 adds a split query and expected result. TODO(erez): Rename after migration to SplitQuery V2 is done.

func (*FakeVTGateConn) Begin

func (conn *FakeVTGateConn) Begin(ctx context.Context) (interface{}, error)

Begin please see vtgateconn.Impl.Begin

func (*FakeVTGateConn) Close

func (conn *FakeVTGateConn) Close()

Close please see vtgateconn.Impl.Close

func (*FakeVTGateConn) Commit

func (conn *FakeVTGateConn) Commit(ctx context.Context, session interface{}) error

Commit please see vtgateconn.Impl.Commit

func (*FakeVTGateConn) Execute

func (conn *FakeVTGateConn) Execute(ctx context.Context, sql string, bindVars map[string]interface{}, keyspace string, tabletType topodatapb.TabletType, session interface{}) (*sqltypes.Result, interface{}, error)

Execute please see vtgateconn.Impl.Execute

func (*FakeVTGateConn) ExecuteBatchKeyspaceIds

func (conn *FakeVTGateConn) ExecuteBatchKeyspaceIds(ctx context.Context, queries []*vtgatepb.BoundKeyspaceIdQuery, tabletType topodatapb.TabletType, asTransaction bool, session interface{}) ([]sqltypes.Result, interface{}, error)

ExecuteBatchKeyspaceIds please see vtgateconn.Impl.ExecuteBatchKeyspaceIds

func (*FakeVTGateConn) ExecuteBatchShards

func (conn *FakeVTGateConn) ExecuteBatchShards(ctx context.Context, queries []*vtgatepb.BoundShardQuery, tabletType topodatapb.TabletType, asTransaction bool, session interface{}) ([]sqltypes.Result, interface{}, error)

ExecuteBatchShards please see vtgateconn.Impl.ExecuteBatchShards

func (*FakeVTGateConn) ExecuteEntityIds

func (conn *FakeVTGateConn) ExecuteEntityIds(ctx context.Context, query string, keyspace string, entityColumnName string, entityKeyspaceIDs []*vtgatepb.ExecuteEntityIdsRequest_EntityId, bindVars map[string]interface{}, tabletType topodatapb.TabletType, session interface{}) (*sqltypes.Result, interface{}, error)

ExecuteEntityIds please see vtgateconn.Impl.ExecuteEntityIds

func (*FakeVTGateConn) ExecuteKeyRanges

func (conn *FakeVTGateConn) ExecuteKeyRanges(ctx context.Context, query string, keyspace string, keyRanges []*topodatapb.KeyRange, bindVars map[string]interface{}, tabletType topodatapb.TabletType, session interface{}) (*sqltypes.Result, interface{}, error)

ExecuteKeyRanges please see vtgateconn.Impl.ExecuteKeyRanges

func (*FakeVTGateConn) ExecuteKeyspaceIds

func (conn *FakeVTGateConn) ExecuteKeyspaceIds(ctx context.Context, query string, keyspace string, keyspaceIds [][]byte, bindVars map[string]interface{}, tabletType topodatapb.TabletType, session interface{}) (*sqltypes.Result, interface{}, error)

ExecuteKeyspaceIds please see vtgateconn.Impl.ExecuteKeyspaceIds

func (*FakeVTGateConn) ExecuteShards

func (conn *FakeVTGateConn) ExecuteShards(ctx context.Context, sql string, keyspace string, shards []string, bindVars map[string]interface{}, tabletType topodatapb.TabletType, session interface{}) (*sqltypes.Result, interface{}, error)

ExecuteShards please see vtgateconn.Impl.ExecuteShard

func (*FakeVTGateConn) GetSrvKeyspace

func (conn *FakeVTGateConn) GetSrvKeyspace(ctx context.Context, keyspace string) (*topodatapb.SrvKeyspace, error)

GetSrvKeyspace please see vtgateconn.Impl.GetSrvKeyspace

func (*FakeVTGateConn) Rollback

func (conn *FakeVTGateConn) Rollback(ctx context.Context, session interface{}) error

Rollback please see vtgateconn.Impl.Rollback

func (*FakeVTGateConn) SplitQuery

func (conn *FakeVTGateConn) SplitQuery(ctx context.Context, keyspace string, query string, bindVars map[string]interface{}, splitColumn string, splitCount int64) ([]*vtgatepb.SplitQueryResponse_Part, error)

SplitQuery please see vtgateconn.Impl.SplitQuery

func (*FakeVTGateConn) SplitQueryV2

func (conn *FakeVTGateConn) SplitQueryV2(
	ctx context.Context,
	keyspace string,
	query string,
	bindVars map[string]interface{},
	splitColumns []string,
	splitCount int64,
	numRowsPerQueryPart int64,
	algorithm querypb.SplitQueryRequest_Algorithm) ([]*vtgatepb.SplitQueryResponse_Part, error)

SplitQueryV2 please see vtgateconn.Impl.SplitQueryV2 TODO(erez): Rename after migration to SplitQuery V2 is done.

func (*FakeVTGateConn) StreamExecute

func (conn *FakeVTGateConn) StreamExecute(ctx context.Context, sql string, bindVars map[string]interface{}, keyspace string, tabletType topodatapb.TabletType) (sqltypes.ResultStream, error)

StreamExecute please see vtgateconn.Impl.StreamExecute

func (*FakeVTGateConn) StreamExecuteKeyRanges

func (conn *FakeVTGateConn) StreamExecuteKeyRanges(ctx context.Context, query string, keyspace string, keyRanges []*topodatapb.KeyRange, bindVars map[string]interface{}, tabletType topodatapb.TabletType) (sqltypes.ResultStream, error)

StreamExecuteKeyRanges please see vtgateconn.Impl.StreamExecuteKeyRanges

func (*FakeVTGateConn) StreamExecuteKeyspaceIds

func (conn *FakeVTGateConn) StreamExecuteKeyspaceIds(ctx context.Context, query string, keyspace string, keyspaceIds [][]byte, bindVars map[string]interface{}, tabletType topodatapb.TabletType) (sqltypes.ResultStream, error)

StreamExecuteKeyspaceIds please see vtgateconn.Impl.StreamExecuteKeyspaceIds

func (*FakeVTGateConn) StreamExecuteShards

func (conn *FakeVTGateConn) StreamExecuteShards(ctx context.Context, query string, keyspace string, shards []string, bindVars map[string]interface{}, tabletType topodatapb.TabletType) (sqltypes.ResultStream, error)

StreamExecuteShards please see vtgateconn.Impl.StreamExecuteShards