sync

package

v0.9.0 Latest Latest Go to latest Published: Apr 27, 2026 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Syncer watches Run CRDs in Kubernetes and syncs them into ingestion_schedules.

func NewSyncer(scheduleSvc *runs.ScheduleService, namespace string) (*Syncer, error)

NewSyncer creates a new Run CRD syncer.

func (s *Syncer) Start(ctx context.Context) error

Start begins watching Run CRDs and syncing them to schedules.

func (s *Syncer) Stop()

Stop halts the syncer.

func (s *Syncer) TriggerRun(ctx context.Context, name string) error

TriggerRun patches the Run CRD with the trigger annotation.