processor

Documentation

Index

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

Types

type KongCluster

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

KongCluster represents an instance of a cluster setup via TPR

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) WatchKongEvents

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

WatchKongEvents watches for changes to tpr kong events