package cdc

import (
	"github.com/pingcap/dbaas/central/db/entity"
)

type CDCDaoFacade interface {
	UpdateCdcTask(task entity.CDCTask, schemas []entity.CDCTaskDBSchemaField) error
	FindCDCTasks(filter CdcFilter) ([]entity.CDCTask, error)
	GetCdcKafkaTask(taskID entity.ID) (*entity.CDCKafkaTask, error)
	GetCdcSqlTask(taskID entity.ID) (*entity.CDCSQLTask, error)
	GetCdcTaskByID(taskID, clusterID, projectID entity.ID) (*entity.CDCTask, error)
}