Documentation
¶
Index ¶
- func SetupTSOClient(ctx context.Context, re *require.Assertions, endpoints []string, ...) pd.Client
- func StartSingleResourceManagerTestServer(ctx context.Context, re *require.Assertions, ...) (*rm.Server, func())
- func StartSingleTSOTestServer(ctx context.Context, re *require.Assertions, ...) (*tso.Server, func())
- func WaitForPrimaryServing(re *require.Assertions, serverMap map[string]bs.Server) string
- func WaitForTSOServiceAvailable(ctx context.Context, pdClient pd.Client) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetupTSOClient ¶
func SetupTSOClient(ctx context.Context, re *require.Assertions, endpoints []string, opts ...pd.ClientOption) pd.Client
SetupTSOClient creates a TSO client for test.
func StartSingleResourceManagerTestServer ¶
func StartSingleResourceManagerTestServer(ctx context.Context, re *require.Assertions, backendEndpoints, listenAddrs string) (*rm.Server, func())
StartSingleResourceManagerTestServer creates and starts a resource manager server with default config for testing.
func StartSingleTSOTestServer ¶
func StartSingleTSOTestServer(ctx context.Context, re *require.Assertions, backendEndpoints, listenAddrs string) (*tso.Server, func())
StartSingleTSOTestServer creates and starts a tso server with default config for testing.
func WaitForPrimaryServing ¶
WaitForPrimaryServing waits for one of servers being elected to be the primary/leader
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.