repositoryevents

type CursorStore struct{ Path string }

type Enqueuer interface {
	Enqueue(context.Context, repositoryevent.Event) (string, error)
}

type ProcessResult struct {
	Detail          string
	CleanupStateSet bool
	CleanupReceipt  string
	RecoveryCommand string
}

type ProcessState struct {
	CleanupReceipt   string
	RecoveryCommand  string
	OnCleanupPending func(receiptPath, recoveryCommand string) error
}

type Processor interface {
	Process(context.Context, repositoryevent.Event, ProcessState) (ProcessResult, error)
}

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

type Receiver struct {
	Source        Source
	Queue         Enqueuer
	Cursor        CursorStore
	PollWait      time.Duration
	RetryDelay    time.Duration
	Progress      func(string)
	ProgressEvery time.Duration
}

type Source interface {
	PollRepositoryEvents(context.Context, string, int, time.Duration) (repositoryevent.PollResponse, error)
	AckRepositoryEvents(context.Context, repositoryevent.AckRequest) (repositoryevent.AckResponse, error)
}

type SyncProcessor struct {
	ProjectsRoot string
	// contains filtered or unexported fields
}