ibppeer

package
v1.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 13, 2022 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KIND = "IBPPeer"
)

Variables

This section is empty.

Functions

func Add 

func Add(mgr manager.Manager, config *config.Config) error

Add creates a new IBPPeer Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func GetUpdateStack 

func GetUpdateStack(allUpdates map[string][]Update) string

Types

type CoreConfig 

type CoreConfig interface {
	GetMaxNameLength() *int
}

type ReconcileIBPPeer 

type ReconcileIBPPeer struct {
	Offering       peerReconcile
	Config         *config.Config
	RestartService *staggerrestarts.StaggerRestartsService
	// contains filtered or unexported fields
}

ReconcileIBPPeer reconciles a IBPPeer object

func (*ReconcileIBPPeer) AddOwnerReferenceToSecret 

func (r *ReconcileIBPPeer) AddOwnerReferenceToSecret(secret *corev1.Secret) (bool, error)

func (*ReconcileIBPPeer) AppendUpdateIfMissing 

func (r *ReconcileIBPPeer) AppendUpdateIfMissing(updates []Update, update Update) []Update

func (*ReconcileIBPPeer) CreateFunc 

func (r *ReconcileIBPPeer) CreateFunc(e event.CreateEvent) bool

func (*ReconcileIBPPeer) DeleteFunc 

func (r *ReconcileIBPPeer) DeleteFunc(e event.DeleteEvent) bool

DeleteFunc will perform any necessary clean up, such as removing artificates that were left dangling after the deletion of the peer resource

func (*ReconcileIBPPeer) GetPodStatus 

func (r *ReconcileIBPPeer) GetPodStatus(instance *current.IBPPeer) (bool, error)

func (*ReconcileIBPPeer) GetSpecState 

func (r *ReconcileIBPPeer) GetSpecState(instance *current.IBPPeer) (*corev1.ConfigMap, error)

func (*ReconcileIBPPeer) GetUpdateStatus 

func (r *ReconcileIBPPeer) GetUpdateStatus(instance *current.IBPPeer) *Update

func (*ReconcileIBPPeer) GetUpdateStatusAtElement 

func (r *ReconcileIBPPeer) GetUpdateStatusAtElement(instance *current.IBPPeer, index int) *Update

func (*ReconcileIBPPeer) PopUpdate 

func (r *ReconcileIBPPeer) PopUpdate(instanceName string) *Update

func (*ReconcileIBPPeer) PushUpdate 

func (r *ReconcileIBPPeer) PushUpdate(instanceName string, update Update)

func (*ReconcileIBPPeer) Reconcile 

func (r *ReconcileIBPPeer) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a IBPPeer object and makes changes based on the state read and what is in the IBPPeer.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

func (*ReconcileIBPPeer) ReconcileRestart 

func (r *ReconcileIBPPeer) ReconcileRestart(namespace string) (bool, error)

func (*ReconcileIBPPeer) SaveSpecState 

func (r *ReconcileIBPPeer) SaveSpecState(instance *current.IBPPeer) error

func (*ReconcileIBPPeer) SetStatus 

func (r *ReconcileIBPPeer) SetStatus(instance *current.IBPPeer, reconcileStatus *current.CRStatus, reconcileErr error) error

func (*ReconcileIBPPeer) SetupWithManager 

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

func (*ReconcileIBPPeer) UpdateFunc 

func (r *ReconcileIBPPeer) UpdateFunc(e event.UpdateEvent) bool

type Update 

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

func (*Update) CertificateCreated 

func (u *Update) CertificateCreated() bool

func (*Update) CertificateUpdated 

func (u *Update) CertificateUpdated() bool

func (*Update) ConfigOverridesUpdated 

func (u *Update) ConfigOverridesUpdated() bool

func (*Update) CryptoBackupNeeded 

func (u *Update) CryptoBackupNeeded() bool

func (*Update) DindArgsUpdated 

func (u *Update) DindArgsUpdated() bool

func (*Update) EcertCreated 

func (u *Update) EcertCreated() bool

func (*Update) EcertEnroll 

func (u *Update) EcertEnroll() bool

func (*Update) EcertNewKeyReenroll 

func (u *Update) EcertNewKeyReenroll() bool

func (*Update) EcertReenrollNeeded 

func (u *Update) EcertReenrollNeeded() bool

func (*Update) EcertUpdated 

func (u *Update) EcertUpdated() bool

func (*Update) FabricVersionUpdated 

func (u *Update) FabricVersionUpdated() bool

FabricVersionUpdated returns true if fabric version updated

func (*Update) GetCreatedCertType 

func (u *Update) GetCreatedCertType() commoninit.SecretType

func (*Update) GetUpdateStackWithTrues 

func (u *Update) GetUpdateStackWithTrues() string

func (*Update) GetUpdatedCertType 

func (u *Update) GetUpdatedCertType() commoninit.SecretType

func (*Update) ImagesUpdated 

func (u *Update) ImagesUpdated() bool

ImagesUpdated returns true if images updated

func (*Update) MSPUpdated 

func (u *Update) MSPUpdated() bool

func (*Update) MigrateToV2 

func (u *Update) MigrateToV2() bool

func (*Update) MigrateToV24 

func (u *Update) MigrateToV24() bool

func (*Update) Needed 

func (u *Update) Needed() bool

func (*Update) NodeOUUpdated 

func (u *Update) NodeOUUpdated() bool

func (*Update) PeerTagUpdated 

func (u *Update) PeerTagUpdated() bool

func (*Update) RestartNeeded 

func (u *Update) RestartNeeded() bool

func (*Update) SetDindArgsUpdated 

func (u *Update) SetDindArgsUpdated(updated bool)

func (*Update) SpecUpdated 

func (u *Update) SpecUpdated() bool

func (*Update) TLSCertCreated 

func (u *Update) TLSCertCreated() bool

func (*Update) TLSCertEnroll 

func (u *Update) TLSCertEnroll() bool

func (*Update) TLSCertUpdated 

func (u *Update) TLSCertUpdated() bool

func (*Update) TLSReenrollNeeded 

func (u *Update) TLSReenrollNeeded() bool

func (*Update) TLScertNewKeyReenroll 

func (u *Update) TLScertNewKeyReenroll() bool

func (*Update) UpgradeDBs 

func (u *Update) UpgradeDBs() bool

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.