negotiate

type CompletedDelegate[T any] func([]T, error) error

type InputDelegate[T any] func() ([]T, error)

type OutputDelegate[T any] func(i T) error

type SyncJob[T any] struct {
	SyncJobOptions[T]
	// contains filtered or unexported fields
}

type SyncJobOptions[T any] struct {
	NumWorkers          int
	InputDelegate       InputDelegate[T]
	OutputDelegate      threading.Handler[T]
	CompletedDelegate   CompletedDelegate[T]
	ErrorCallback       threading.ErrorCallback[T]
	SyncInterval        time.Duration
	CronSchedule        string
	NextRunDelegate     func() time.Time
	BufferSize          int
	Name                string
	Elector             leaderElection.Elector
	RetryPolicy         threading.RetryPolicy
	MaxRetries          int
	RetryAfterDuration  time.Duration
	OnLeadershipLost    func() // Called when transitioning from leader to non-leader
	FirstRunImmediately bool   // If true, run immediately on startup, otherwise wait for SyncInterval or CronSchedule
}