1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
package agent
import (
"context"
"k8s.io/client-go/informers"
)
type controller interface {
Run(ctx context.Context)
}
type controllerFactory func(ctx context.Context, gitRepositoryInformer informers.GenericInformer, receiverInformer informers.GenericInformer, projectReconciler projectReconciler) (controller, error)
type reconciliationResult struct {
status reconciliationStatus
error error
}
type reconciliationStatus int
const (
RetryRateLimited reconciliationStatus = iota
Success
Error
)
|
