mcs

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

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

func WaitForPrimaryServing(re *require.Assertions, serverMap map[string]bs.Server) string

WaitForPrimaryServing waits for one of servers being elected to be the primary/leader

func WaitForTSOServiceAvailable

func WaitForTSOServiceAvailable(ctx context.Context, pdClient pd.Client) error

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