package biz_changefeed

import (
	"context"

	"github.com/tidbcloud/dataflow-service-ng/app/container"
	"go.uber.org/multierr"
)

func RunBizChangefeedMeteringWorker(ctx context.Context) error {
	return multierr.Combine(
		container.Global().BizChangefeedMeteringWorker.GenBillingRecordsByCluster(ctx),
	)
}