package biz_changefeed

import (
	"time"

	"github.com/tidbcloud/dataflow-service-ng/app/repo/entity"
)

type (
	CDCInstanceTypeOP func(qs entity.CDCInstanceTypeQuerySet) entity.CDCInstanceTypeQuerySet
	CDCMachineTypeOP  func(qs entity.CDCMachineTypeQuerySet) entity.CDCMachineTypeQuerySet
)

type ChangefeedFilter struct {
	ClusterID          uint64
	Statuss            []entity.CDCStatus
	StatussNotIn       []entity.CDCStatus
	Deleted            *bool
	Creating           *bool
	Cleared            *bool
	Internal           *bool
	DownStreamTypes    []entity.CDCDownStreamType
	UpdatedAtStartTime *time.Time
	UpdatedAtEndTime   *time.Time
}

type ChangefeedSpecificationFilter struct {
	BusinessType string
	Name         string
	ID           *entity.ID
}