sync

type DBRunner struct {
	// contains filtered or unexported fields
}

type Lock interface {
	ScopeKind() string
	ScopeName() string
	StartHeartbeat(ctx context.Context, onLost func(error)) (stop func())
	Release(ctx context.Context) error
}

type LockManager interface {
	TryAcquire(ctx context.Context, scopeKind, scopeName string) (Lock, bool, error)
	Acquire(ctx context.Context, scopeKind, scopeName string) (Lock, error)
}

type LockManagerConfig struct {
	Mode              string
	InstanceID        string
	TTL               time.Duration
	HeartbeatInterval time.Duration
	HeartbeatTimeout  time.Duration
}

type LogReporter struct {
	Logger              *slog.Logger
	ProgressInterval    time.Duration
	ProgressPercentStep int64
	// contains filtered or unexported fields
}

type Orchestrator struct {
	// contains filtered or unexported fields
}

type ResyncQueueRunner struct {
	// contains filtered or unexported fields
}

type RunPolicy struct {
	IntervalByKind       map[string]time.Duration
	FailureBackoffBase   time.Duration
	FailureBackoffMax    time.Duration
	RecentFinishedRunCap int
	Now                  func() time.Time
}

type Runner interface {
	RunOnce(context.Context) error
}

type Scheduler struct {
	Runner   Runner
	Interval time.Duration
	Trigger  <-chan TriggerRequest
}

type SyncJobConsumer struct {
	// contains filtered or unexported fields
}

type SyncJobConsumerConfig struct {
	Mode              registry.RunMode
	PollInterval      time.Duration
	LeaseTTL          time.Duration
	HeartbeatInterval time.Duration
	RetryBaseDelay    time.Duration
	RetryMaxDelay     time.Duration
	ClaimedBy         string
	Wakeups           <-chan struct{}
}

type TriggerRequest struct {
	ConnectorKind string `json:"connector_kind,omitempty"`
	SourceName    string `json:"source_name,omitempty"`
}