mysql

Documentation

Index

• type DockerEnv
  • func NewDockerEnv(dockerComposeFile string) *DockerEnv
• type SingleTableTask
  • func (c *SingleTableTask) GetCDCProfile() *framework.CDCProfile
  • func (c *SingleTableTask) Name() string
  • func (c *SingleTableTask) Prepare(taskContext *framework.TaskContext) error
  • func (c *SingleTableTask) Run(taskContext *framework.TaskContext) error

Types

type DockerEnv

type DockerEnv struct {
	framework.DockerEnv
}

DockerEnv represents the docker-compose service defined in docker-compose-canal.yml

func NewDockerEnv

func NewDockerEnv(dockerComposeFile string) *DockerEnv

NewDockerEnv creates a new KafkaDockerEnv

type SingleTableTask

type SingleTableTask struct {
	TableName     string
	CheckOleValue bool
}

SingleTableTask provides a basic implementation for an Avro test case

func (*SingleTableTask) GetCDCProfile

func (c *SingleTableTask) GetCDCProfile() *framework.CDCProfile

GetCDCProfile implements Task

func (*SingleTableTask) Name

func (c *SingleTableTask) Name() string

Name implements Task

func (*SingleTableTask) Prepare

func (c *SingleTableTask) Prepare(taskContext *framework.TaskContext) error

Prepare implements Task

func (*SingleTableTask) Run

func (c *SingleTableTask) Run(taskContext *framework.TaskContext) error

Run implements Task