worker

Documentation

Overview

Package worker ensure the expected named ports are set on all node pools.

Index

• type PortMapper
  • func NewWorker(config *config.KnpConfig) *PortMapper
  • func (p *PortMapper) Add(name string, port int64)
  • func (p *PortMapper) AddMap(ports np.PortList)
  • func (p *PortMapper) Start()
  • func (p *PortMapper) Stop()
• type Worker

Types

type PortMapper

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

PortMapper is worker synchronizing GCP named ports and services annotations

func NewWorker

func NewWorker(config *config.KnpConfig) *PortMapper

NewWorker returns a PortMapper worker

func (*PortMapper) Add

func (p *PortMapper) Add(name string, port int64)

Add declares a named port we want to keep in sync with GCP

func (*PortMapper) AddMap

func (p *PortMapper) AddMap(ports np.PortList)

AddMap add several ports in one go

func (*PortMapper) Start

func (p *PortMapper) Start()

Start launchs the PortMapper worker

func (*PortMapper) Stop

func (p *PortMapper) Stop()

Stop stops the PortMapper worker

type Worker

type Worker interface {
	Start()
	Stop()
	Add(name string, port int64)
	AddMap(ports np.PortList)
}

Worker ensure the expected named ports are set on all node pools.