openshift

Documentation

Index

• Constants
• Variables
• type ClusterOperator
  • func NewClusterOperator(name string) *ClusterOperator
  • func (c *ClusterOperator) GetCondition(conditionType configv1.ClusterStatusConditionType) *configv1.ClusterOperatorStatusCondition
  • func (c *ClusterOperator) GetOperatorVersion() string
  • func (c *ClusterOperator) SetCondition(condition *configv1.ClusterOperatorStatusCondition)
• type ClusterOperatorReconciler
  • func NewClusterOperatorReconciler(opts ...ReconcilerOption) (*ClusterOperatorReconciler, error)
  • func (r *ClusterOperatorReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)
  • func (r *ClusterOperatorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MutateFunc
  • func (m MutateFunc) Mutate(ctx context.Context, co *ClusterOperator) error
• type Mutator
• type NowFunc
• type ReconcilerConfig
• type ReconcilerOption
  • func WithClient(cli client.Client) ReconcilerOption
  • func WithLog(log logr.Logger) ReconcilerOption
  • func WithName(name string) ReconcilerOption
  • func WithNamespace(namespace string) ReconcilerOption
  • func WithNow(now NowFunc) ReconcilerOption
  • func WithOLMOperator() ReconcilerOption
  • func WithScheme(scheme *runtime.Scheme) ReconcilerOption
  • func WithSyncChannel(syncCh <-chan error) ReconcilerOption
  • func WithTargetVersions(targetVersions ...configv1.OperandVersion) ReconcilerOption
• type SerialMutations
  • func (s SerialMutations) Mutate(ctx context.Context, co *ClusterOperator) error
• type SyncTracker
  • func NewSyncTracker(syncCh <-chan error, co *configv1.ClusterOperator) *SyncTracker
  • func (s *SyncTracker) Events() <-chan event.GenericEvent
  • func (s *SyncTracker) Start(ctx context.Context) error
  • func (s *SyncTracker) SuccessfulSyncs() int
  • func (s *SyncTracker) TotalSyncs() int

Constants

const (
	IncompatibleOperatorsInstalled = "IncompatibleOperatorsInstalled"
)

const (
	MaxOpenShiftVersionProperty = "olm.maxOpenShiftVersion"
)

Variables

var (

	// AddToScheme adds all types necessary for the controller to operate.
	AddToScheme = localSchemeBuilder.AddToScheme
)

Types

type ClusterOperator

type ClusterOperator struct {
	*configv1.ClusterOperator
}

func NewClusterOperator

func NewClusterOperator(name string) *ClusterOperator

func (*ClusterOperator) GetCondition

func (c *ClusterOperator) GetCondition(conditionType configv1.ClusterStatusConditionType) *configv1.ClusterOperatorStatusCondition

func (*ClusterOperator) GetOperatorVersion

func (c *ClusterOperator) GetOperatorVersion() string

func (*ClusterOperator) SetCondition

func (c *ClusterOperator) SetCondition(condition *configv1.ClusterOperatorStatusCondition)

type ClusterOperatorReconciler

type ClusterOperatorReconciler struct {
	*ReconcilerConfig
	// contains filtered or unexported fields
}

func NewClusterOperatorReconciler

func NewClusterOperatorReconciler(opts ...ReconcilerOption) (*ClusterOperatorReconciler, error)

func (*ClusterOperatorReconciler) Reconcile

func (r *ClusterOperatorReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

func (*ClusterOperatorReconciler) SetupWithManager

func (r *ClusterOperatorReconciler) SetupWithManager(mgr ctrl.Manager) error

type MutateFunc

type MutateFunc func(context.Context, *ClusterOperator) error

func (MutateFunc) Mutate

func (m MutateFunc) Mutate(ctx context.Context, co *ClusterOperator) error

type Mutator

type Mutator interface {
	Mutate(context.Context, *ClusterOperator) error
}

type NowFunc

type NowFunc func() metav1.Time

type ReconcilerConfig

type ReconcilerConfig struct {
	Client       client.Client
	Scheme       *runtime.Scheme
	Log          logr.Logger
	RequeueDelay time.Duration
	TweakBuilder func(*builder.Builder) *builder.Builder
	Now          NowFunc

	Name           string
	Namespace      string
	SyncCh         <-chan error
	TargetVersions []configv1.OperandVersion

	Mutator Mutator
}

type ReconcilerOption

type ReconcilerOption func(*ReconcilerConfig)

func WithClient

func WithClient(cli client.Client) ReconcilerOption

func WithLog

func WithLog(log logr.Logger) ReconcilerOption

func WithName

func WithName(name string) ReconcilerOption

func WithNamespace

func WithNamespace(namespace string) ReconcilerOption

func WithNow

func WithNow(now NowFunc) ReconcilerOption

func WithOLMOperator

func WithOLMOperator() ReconcilerOption

func WithScheme

func WithScheme(scheme *runtime.Scheme) ReconcilerOption

func WithSyncChannel

func WithSyncChannel(syncCh <-chan error) ReconcilerOption

func WithTargetVersions

func WithTargetVersions(targetVersions ...configv1.OperandVersion) ReconcilerOption

type SerialMutations

type SerialMutations []Mutator

func (SerialMutations) Mutate

func (s SerialMutations) Mutate(ctx context.Context, co *ClusterOperator) error

type SyncTracker

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

func NewSyncTracker

func NewSyncTracker(syncCh <-chan error, co *configv1.ClusterOperator) *SyncTracker

func (*SyncTracker) Events

func (s *SyncTracker) Events() <-chan event.GenericEvent

func (*SyncTracker) Start

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

func (*SyncTracker) SuccessfulSyncs

func (s *SyncTracker) SuccessfulSyncs() int

func (*SyncTracker) TotalSyncs

func (s *SyncTracker) TotalSyncs() int