cluster

Documentation

Index

• type Cluster
  • func New(config Config, cl *spec.NatsCluster, stopC <-chan struct{}, wg *sync.WaitGroup) *Cluster
  • func (c *Cluster) Delete()
  • func (c *Cluster) Update(cl *spec.NatsCluster)
• type Config
• type Status

Types

type Cluster

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

func New

func New(config Config, cl *spec.NatsCluster, stopC <-chan struct{}, wg *sync.WaitGroup) *Cluster

func (*Cluster) Delete

func (c *Cluster) Delete()

func (*Cluster) Update

func (c *Cluster) Update(cl *spec.NatsCluster)

type Config

type Config struct {
	ServiceAccount string
	KubeCli        corev1client.CoreV1Interface
	OperatorCli    natsalphav2client.PkgSpecInterface
}

type Status

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