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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
WaitForTSOServiceAvailable waits for the pd client being served by the tso server side
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.