mcs

Documentation

Index

• func CheckMultiKeyspacesTSO(ctx context.Context, re *require.Assertions, clients []pd.Client, ...)
• func SetupClientWithAPIContext(ctx context.Context, re *require.Assertions, apiCtx pd.APIContext, ...) pd.Client
• func SetupClientWithKeyspaceID(ctx context.Context, re *require.Assertions, keyspaceID uint32, ...) pd.Client
• func WaitForMultiKeyspacesTSOAvailable(ctx context.Context, re *require.Assertions, keyspaceIDs []uint32, ...) []pd.Client
• func WaitForTSOServiceAvailable(ctx context.Context, re *require.Assertions, client pd.Client)

Functions

func CheckMultiKeyspacesTSO

func CheckMultiKeyspacesTSO(
	ctx context.Context, re *require.Assertions,
	clients []pd.Client, parallelAct func(),
)

CheckMultiKeyspacesTSO checks the correctness of TSO for multiple keyspaces.

func SetupClientWithAPIContext

func SetupClientWithAPIContext(
	ctx context.Context, re *require.Assertions, apiCtx pd.APIContext, endpoints []string, opts ...pd.ClientOption,
) pd.Client

SetupClientWithAPIContext creates a TSO client with api context name for test.

func SetupClientWithKeyspaceID

func SetupClientWithKeyspaceID(
	ctx context.Context, re *require.Assertions,
	keyspaceID uint32, endpoints []string, opts ...pd.ClientOption,
) pd.Client

SetupClientWithKeyspaceID creates a TSO client with the given keyspace id for test.

func WaitForMultiKeyspacesTSOAvailable

func WaitForMultiKeyspacesTSOAvailable(
	ctx context.Context, re *require.Assertions,
	keyspaceIDs []uint32, backendEndpoints []string,
) []pd.Client

WaitForMultiKeyspacesTSOAvailable waits for the given keyspaces being served by the tso server side

func WaitForTSOServiceAvailable

func WaitForTSOServiceAvailable(
	ctx context.Context, re *require.Assertions, client pd.Client,
)

WaitForTSOServiceAvailable waits for the pd client being served by the tso server side