processor

Documentation

Index

• 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 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