processor

Documentation

Index

• type Processor
  • func New(image string, crdClient controller.CustomResourceController, control chan int, ...) (*Processor, error)
  • func (p *Processor) DetectChangeType(event spec.KafkaclusterWatchEvent) spec.KafkaclusterEvent
  • func (p *Processor) Run() error

Types

type Processor

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

func New

func New(image string,
	crdClient controller.CustomResourceController,
	control chan int,
	kube kube.Kubernetes,
) (*Processor, error)

func (*Processor) DetectChangeType

func (p *Processor) DetectChangeType(event spec.KafkaclusterWatchEvent) spec.KafkaclusterEvent

We detect basic change through the event type, beyond that we use the API server to find differences. Functions compares the KafkaClusterSpec with the real Pods/Services which are there. We do that because otherwise we would have to use a local state to track changes.

func (*Processor) Run

func (p *Processor) Run() error