staging

type Batch struct {
	ID               BatchID
	Resources        []rules.WSAResource
	StartTime        time.Time
	Plan             *ReconciliationPlan
	ValidationResult *ValidationResult
	LastError        error
	RequeueAfter     time.Duration
}

type BatchID uuid.UUID

type BatchQueue interface {
	Add(batch *Batch)
	AddRateLimited(batch *Batch)
	Get() (*Batch, bool)
	Done(batch *Batch)
	Forget(batch *Batch)
	NumRequeues(batch *Batch) int
	ShutDown()
}

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

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

type EventInfo struct {
	Resource        rules.WSAResource
	EventType       EventType
	Generation      int64
	ResourceVersion string
	Timestamp       time.Time
}

type EventType string

type ReconciliationPlan struct {
	ScopeToSA        map[rules.Scope]rules.ServiceAccountName
	SAToWSAMap       map[rules.ServiceAccountName]map[types.NamespacedName]rules.WSAResource
	WSAToSANames     map[types.NamespacedName][]rules.ServiceAccountName
	Vocabulary       *rules.GlobalVocabulary
	UniqueAccounts   []*v1.ServiceAccount
	AllResources     []rules.WSAResource
	TargetNamespaces []string
}

type Stage interface {
	Name() string
	Execute(ctx context.Context, batch *Batch) error
}

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

type ValidationError struct {
	Type     string
	Resource string
	Message  string
}

type ValidationResult struct {
	Valid    bool
	Errors   []ValidationError
	Warnings []ValidationWarning
}

type ValidationWarning struct {
	Type     string
	Resource string
	Message  string
}