processor

Documentation

Index

• type Cluster
• type Processor
  • func New(kclient *k8sutil.K8sutil, baseImage string) (*Processor, error)
  • func (p *Processor) Run() error
  • func (p *Processor) WatchDataPodEvents(done chan struct{}, wg *sync.WaitGroup)
  • func (p *Processor) WatchElasticSearchClusterEvents(done chan struct{}, wg *sync.WaitGroup)

Types

type Cluster

type Cluster struct {
	ESCluster *myspec.ElasticsearchCluster
	Scheduler *snapshot.Scheduler
}

type Processor

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

Processor object

func New

func New(kclient *k8sutil.K8sutil, baseImage string) (*Processor, error)

New creates new instance of Processor

func (*Processor) Run

func (p *Processor) Run() error

Run starts the processor

func (*Processor) WatchDataPodEvents

func (p *Processor) WatchDataPodEvents(done chan struct{}, wg *sync.WaitGroup)

WatchDataPodEvents watches for changes to pods

func (*Processor) WatchElasticSearchClusterEvents

func (p *Processor) WatchElasticSearchClusterEvents(done chan struct{}, wg *sync.WaitGroup)

WatchElasticSearchClusterEvents watches for changes to tpr elasticsearch events