processor

Documentation

Index

• type Processor
  • func New(client k8sclient.Clientset, image string, util util.ClientUtil, ...) (*Processor, error)
  • func (p *Processor) CreateKafkaCluster(clusterSpec spec.Kafkacluster)
  • 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(client k8sclient.Clientset, image string, util util.ClientUtil, crdClient controller.CustomResourceController, control chan int) (*Processor, error)

func (*Processor) CreateKafkaCluster

func (p *Processor) CreateKafkaCluster(clusterSpec spec.Kafkacluster)

CreateKafkaCluster with the following components: Service, Volumes, StatefulSet. Maybe move this also into util

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