baseconsole

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: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Console 

type Console struct {
	Client k8sclient.Client
	Scheme *runtime.Scheme
	Config *config.Config

	DeploymentManager        resources.Manager
	ServiceManager           resources.Manager
	DeployerServiceManager   resources.Manager
	PVCManager               resources.Manager
	ConfigMapManager         resources.Manager
	ConsoleConfigMapManager  resources.Manager
	DeployerConfigMapManager resources.Manager
	RoleManager              resources.Manager
	RoleBindingManager       resources.Manager
	ServiceAccountManager    resources.Manager

	Override Override

	Restart RestartManager
}

func New 

func New(client k8sclient.Client, scheme *runtime.Scheme, config *config.Config, o Override) *Console

func (*Console) CheckForConfigMapUpdates 

func (c *Console) CheckForConfigMapUpdates(instance *current.IBPConsole, update Update) error

func (*Console) CheckStates 

func (c *Console) CheckStates(instance *current.IBPConsole, update bool) error

func (*Console) CreateCouchdbCredentials 

func (c *Console) CreateCouchdbCredentials(instance *current.IBPConsole) bool

func (*Console) CreateKubeconfigSecret 

func (c *Console) CreateKubeconfigSecret(instance *current.IBPConsole, kubeocnfigSecretName string, kubeconfig *[]byte) error

func (*Console) CreateKubernetesSecretIfRequired 

func (c *Console) CreateKubernetesSecretIfRequired(instance *current.IBPConsole) (bool, error)

func (*Console) CreateManagers 

func (c *Console) CreateManagers()

func (*Console) CreateNetworkPolicyIfNotExists 

func (c *Console) CreateNetworkPolicyIfNotExists(instance *current.IBPConsole, filename string, policyname string) error

func (*Console) CreatePasswordSecretIfRequired 

func (c *Console) CreatePasswordSecretIfRequired(instance *current.IBPConsole) (bool, error)

func (*Console) CreateUserSecret 

func (c *Console) CreateUserSecret(instance *current.IBPConsole, passwordSecretName, password string) error

func (*Console) GetLabels 

func (c *Console) GetLabels(instance v1.Object) map[string]string

func (*Console) GetLabelsForNetworkPolicy 

func (c *Console) GetLabelsForNetworkPolicy(instance v1.Object) map[string]string

func (*Console) HandleActions 

func (c *Console) HandleActions(instance *current.IBPConsole, update Update) error

func (*Console) HandleRestart 

func (c *Console) HandleRestart(instance *current.IBPConsole, update Update) error

func (*Console) NetworkPolicyReconcile 

func (c *Console) NetworkPolicyReconcile(instance *current.IBPConsole) error

func (*Console) PreReconcileChecks 

func (c *Console) PreReconcileChecks(instance *current.IBPConsole) (bool, error)

func (*Console) Reconcile 

func (c *Console) Reconcile(instance *current.IBPConsole, update Update) (common.Result, error)

func (*Console) ReconcileManagers 

func (c *Console) ReconcileManagers(instance *current.IBPConsole, update bool) error

func (*Console) ReconcileRBAC 

func (c *Console) ReconcileRBAC(instance *current.IBPConsole) error

func (*Console) SelectRegion 

func (c *Console) SelectRegion(instance *current.IBPConsole) (bool, error)

func (*Console) SelectZone 

func (c *Console) SelectZone(instance *current.IBPConsole) (bool, error)

func (*Console) SetVersion 

func (c *Console) SetVersion(instance *current.IBPConsole) (bool, error)

func (*Console) ValidateSpec 

func (c *Console) ValidateSpec(instance *current.IBPConsole) error

type IBPConsole 

type IBPConsole interface {
	PreReconcileChecks(instance *current.IBPConsole) (bool, error)
	CheckStates(instance *current.IBPConsole, update bool) error
	ReconcileManagers(instance *current.IBPConsole, update bool) error
	Reconcile(instance *current.IBPConsole, update Update) (common.Result, error)
}

type Override 

type Override interface {
	Deployment(v1.Object, *appsv1.Deployment, resources.Action) error
	Service(v1.Object, *corev1.Service, resources.Action) error
	DeployerService(v1.Object, *corev1.Service, resources.Action) error
	ServiceAccount(v1.Object, *corev1.ServiceAccount, resources.Action) error
	PVC(v1.Object, *corev1.PersistentVolumeClaim, resources.Action) error
	CM(v1.Object, *corev1.ConfigMap, resources.Action, map[string]interface{}) error
	ConsoleCM(v1.Object, *corev1.ConfigMap, resources.Action, map[string]interface{}) error
	DeployerCM(v1.Object, *corev1.ConfigMap, resources.Action, map[string]interface{}) error
}

type RestartManager 

type RestartManager interface {
	ForConfigMapUpdate(instance v1.Object) error
	TriggerIfNeeded(instance restart.Instance) error
	ForRestartAction(instance v1.Object) error
}

type Update 

type Update interface {
	SpecUpdated() bool
	DeployerCMUpdated() bool
	ConsoleCMUpdated() bool
	EnvCMUpdated() bool
	RestartNeeded() 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.