baseconsole

Documentation

Index

• type Console
  • func New(client k8sclient.Client, scheme *runtime.Scheme, config *config.Config, ...) *Console
  • func (c *Console) CheckForConfigMapUpdates(instance *current.IBPConsole, update Update) error
  • func (c *Console) CheckStates(instance *current.IBPConsole, update bool) error
  • func (c *Console) CreateCouchdbCredentials(instance *current.IBPConsole) bool
  • func (c *Console) CreateKubeconfigSecret(instance *current.IBPConsole, kubeocnfigSecretName string, kubeconfig *[]byte) error
  • func (c *Console) CreateKubernetesSecretIfRequired(instance *current.IBPConsole) (bool, error)
  • func (c *Console) CreateManagers()
  • func (c *Console) CreateNetworkPolicyIfNotExists(instance *current.IBPConsole, filename string, policyname string) error
  • func (c *Console) CreatePasswordSecretIfRequired(instance *current.IBPConsole) (bool, error)
  • func (c *Console) CreateUserSecret(instance *current.IBPConsole, passwordSecretName, password string) error
  • func (c *Console) GetLabels(instance v1.Object) map[string]string
  • func (c *Console) GetLabelsForNetworkPolicy(instance v1.Object) map[string]string
  • func (c *Console) HandleActions(instance *current.IBPConsole, update Update) error
  • func (c *Console) HandleRestart(instance *current.IBPConsole, update Update) error
  • func (c *Console) NetworkPolicyReconcile(instance *current.IBPConsole) error
  • func (c *Console) PreReconcileChecks(instance *current.IBPConsole) (bool, error)
  • func (c *Console) Reconcile(instance *current.IBPConsole, update Update) (common.Result, error)
  • func (c *Console) ReconcileManagers(instance *current.IBPConsole, update bool) error
  • func (c *Console) ReconcileRBAC(instance *current.IBPConsole) error
  • func (c *Console) SelectRegion(instance *current.IBPConsole) (bool, error)
  • func (c *Console) SelectZone(instance *current.IBPConsole) (bool, error)
  • func (c *Console) SetVersion(instance *current.IBPConsole) (bool, error)
  • func (c *Console) ValidateSpec(instance *current.IBPConsole) error
• type IBPConsole
• type Override
• type RestartManager
• type Update

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
}