e2e

package

v0.0.0-...-ba6db07 Latest Latest Go to latest Published: Apr 28, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tiflow

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CreateJobViaHTTP(ctx context.Context, masterAddr, tenantID, projectID string, ...) (string, error)
func QueryJobViaHTTP(ctx context.Context, masterAddr, tenantID, projectID, jobID string) (*pb.Job, error)
type ChaosCli
- func NewUTCli(ctx context.Context, masterAddrs, businessMetaAddrs []string, ...) (*ChaosCli, error)
type FakeJobConfig

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrLeaderNotFound = errors.New("leader not found")

ErrLeaderNotFound is returned when the leader is not found.

Functions ¶

func CreateJobViaHTTP ¶

func CreateJobViaHTTP(ctx context.Context, masterAddr, tenantID, projectID string, jobType pb.Job_Type, config []byte) (string, error)

CreateJobViaHTTP creates a job via http.

func QueryJobViaHTTP ¶

func QueryJobViaHTTP(ctx context.Context, masterAddr, tenantID, projectID, jobID string) (*pb.Job, error)

QueryJobViaHTTP queries a job via http.

Types ¶

type ChaosCli ¶

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

ChaosCli is used to interact with server master, fake job and provides ways to adding chaos in e2e test.

func NewUTCli ¶

func NewUTCli(ctx context.Context, masterAddrs, businessMetaAddrs []string, project tenant.ProjectInfo,
	cfg *FakeJobConfig,
) (*ChaosCli, error)

NewUTCli creates a new ChaosCli instance

func (*ChaosCli) CancelJob ¶

func (cli *ChaosCli) CancelJob(ctx context.Context, jobID string) error

CancelJob sends CancelJob command to servermaster

func (*ChaosCli) CheckFakeJobKey ¶

func (cli *ChaosCli) CheckFakeJobKey(
	ctx context.Context, masterID string, jobIndex int, expectedMvcc int, expectedValue string,
) error

CheckFakeJobKey queries the checkpoint of a fake job, checks the value and mvcc count are as expected. If error happens or check is not passed, return error.

func (*ChaosCli) CheckFakeJobTick ¶

func (cli *ChaosCli) CheckFakeJobTick(
	ctx context.Context, masterID string, jobIndex int, target int64,
) error

CheckFakeJobTick queries the checkpoint of a fake job and checks the tick count is as expected.

func (*ChaosCli) CheckJobStatus ¶

func (cli *ChaosCli) CheckJobStatus(
	ctx context.Context, jobID string, expectedStatus pb.Job_State,
) (bool, error)

CheckJobStatus checks job status is as expected.

func (*ChaosCli) ContainerRestart ¶

func (cli *ChaosCli) ContainerRestart(name string)

ContainerRestart restarts a docker container

func (*ChaosCli) ContainerStart ¶

func (cli *ChaosCli) ContainerStart(name string)

ContainerStart starts a docker container

func (*ChaosCli) ContainerStop ¶

func (cli *ChaosCli) ContainerStop(name string)

ContainerStop stops a docker container

func (*ChaosCli) CreateJob ¶

func (cli *ChaosCli) CreateJob(ctx context.Context, jobType pb.Job_Type, config []byte) (string, error)

CreateJob sends SubmitJob command to servermaster

func (*ChaosCli) GetLeaderAddr ¶

func (cli *ChaosCli) GetLeaderAddr(ctx context.Context) (string, error)

GetLeaderAddr gets the address of the leader of the server master.

func (*ChaosCli) GetRevision ¶

func (cli *ChaosCli) GetRevision(ctx context.Context) (int64, error)

GetRevision puts a key gets the latest revision of etcd cluster

func (*ChaosCli) InitializeMetaClient ¶

func (cli *ChaosCli) InitializeMetaClient(jobID string) error

InitializeMetaClient initializes the business kvclient

func (*ChaosCli) ResignLeader ¶

func (cli *ChaosCli) ResignLeader(ctx context.Context, addr string) error

ResignLeader resigns the leader at the given addr.

func (*ChaosCli) UpdateFakeJobKey ¶

func (cli *ChaosCli) UpdateFakeJobKey(ctx context.Context, id int, value string) error

UpdateFakeJobKey updates the etcd value of a worker belonging to a fake job

type FakeJobConfig ¶

type FakeJobConfig struct {
	EtcdEndpoints []string
	WorkerCount   int
	KeyPrefix     string
}

FakeJobConfig is used to construct a fake job configuration

Source Files ¶

View all Source files

e2e_test_cli.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL