package cdc

import (
	"time"

	"github.com/segmentio/kafka-go"
	dpCommon "github.com/tidbcloud/qa-PlatformAPIAuto/webScene/common"
)

type KafkaManagerCommand func(conn *kafka.Conn) error
type KafkaReadDataCommand func(reader *kafka.Reader) error

type CommonSceneTest struct {
	dpCommon.SceneTest

	DfPrivatelinkId string
	ChangefeedId    string
	StartUTC        time.Time
	Version         string
}

type CommonTidbToKafkaSceneTest struct {
	CommonSceneTest
	Topic                string
	GroupID              string
	FullStageCheckCount  int
	IncreStageCheckCount int
}

type CommonTidbToGCSSceneTest struct {
	CommonSceneTest
}

type CommonTidbToS3SceneTest struct {
	CommonSceneTest
}