datasync

type HAKeeperClientFactory func(
	ctx context.Context,
	sid string,
	cfg logservice.HAKeeperClientConfig,
) logservice.ClusterHAKeeperClient

type LogClient interface {
	// contains filtered or unexported methods
}

type Producer interface {
	Worker
	Enqueue(context.Context, *wrappedData)
}

type TxnClient interface {
	// contains filtered or unexported methods
}

type Worker interface {
	Start(ctx context.Context)
	Close()
}