package sink_endpoint

import (
	"context"

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

func SyncSinkEndpointWorker(ctx context.Context) error {
	return container.Global().SinkEndpointWorker.SyncAllEndpoints(ctx)
}

func MeterPrivateLinkWorker(ctx context.Context) error {
	err := container.Global().SinkEndpointWorker.MeterChangefeeds(ctx)
	if err != nil {
		return err
	}
	return nil
}

func BillPrivateLinkWorker(ctx context.Context) error {
	err := container.Global().SinkEndpointWorker.BillChangefeeds(ctx)
	if err != nil {
		return err
	}
	return nil
}