cluster

Documentation

Index

• type Cluster
  • func New(config Config, cl *v1alpha2.NatsCluster) *Cluster
  • func (c *Cluster) Reconcile() error
• type Config
• type Status

Types

type Cluster

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

func New

func New(config Config, cl *v1alpha2.NatsCluster) *Cluster

New returns a new instance of the reconciler for NatsCluster resources.

func (*Cluster) Reconcile

func (c *Cluster) Reconcile() error

Reconcile looks at the current state of the associated NatsCluster resource and attempts to drive it towards the desired state.

type Config

type Config struct {
	// Deprecated: Use KubeClient and its CoreV1() function instead.
	KubeCli corev1client.CoreV1Interface
	// Deprecated: Use NatsClient and its NatsV1alpha2() function instead.
	OperatorCli           natsalphav2client.NatsV1alpha2Interface
	PodLister             corev1listers.PodLister
	SecretLister          corev1listers.SecretLister
	ServiceLister         corev1listers.ServiceLister
	NatsServiceRoleLister natslisters.NatsServiceRoleLister

	KubeClient kubernetes.Interface
	KubeConfig *rest.Config
	NatsClient natsclient.Interface
}

type Status

type Status struct {
	CurrentVersion string `json:"currentVersion"`
	TargetVersion  string `json:"targetVersion"`
}