avro

Documentation

Index

• type KafkaDockerEnv
  • func NewKafkaDockerEnv(dockerComposeFile string) *KafkaDockerEnv
  • func (d *KafkaDockerEnv) Reset()
  • func (d *KafkaDockerEnv) Setup()
• type SingleTableTask
  • func (a *SingleTableTask) GetCDCProfile() *framework.CDCProfile
  • func (a *SingleTableTask) Name() string
  • func (a *SingleTableTask) Prepare(taskContext *framework.TaskContext) error
  • func (a *SingleTableTask) Run(taskContext *framework.TaskContext) error

Types

type KafkaDockerEnv

type KafkaDockerEnv struct {
	framework.DockerEnv
}

KafkaDockerEnv represents the docker-compose service defined in docker-compose-avro.yml

func NewKafkaDockerEnv

func NewKafkaDockerEnv(dockerComposeFile string) *KafkaDockerEnv

NewKafkaDockerEnv creates a new KafkaDockerEnv

func (*KafkaDockerEnv) Reset

func (d *KafkaDockerEnv) Reset()

Reset implements Environment

func (*KafkaDockerEnv) Setup

func (d *KafkaDockerEnv) Setup()

Setup brings up a docker-compose service

type SingleTableTask

type SingleTableTask struct {
	TableName string
}

SingleTableTask provides a basic implementation for an Avro test case

func (*SingleTableTask) GetCDCProfile

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

GetCDCProfile implements Task

func (*SingleTableTask) Name

func (a *SingleTableTask) Name() string

Name implements Task

func (*SingleTableTask) Prepare

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

Prepare implements Task

func (*SingleTableTask) Run

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

Run implements Task