repo

Documentation

Overview

Package repo contains the repository for the ingress controller

Index

• type IngressConfGeneratorJob
  • func (job *IngressConfGeneratorJob) GetDoneCh() <-chan struct{}
  • func (job *IngressConfGeneratorJob) JobName() string
  • func (job *IngressConfGeneratorJob) Run()
• type Server
  • func NewServer(cfg configurator.Configurator, msgBroker *messaging.Broker, cache *cache.Cache) *Server
  • func (s *Server) BroadcastListener()

Types

type IngressConfGeneratorJob

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

IngressConfGeneratorJob is the job to generate pipy policy json

func (*IngressConfGeneratorJob) GetDoneCh

func (job *IngressConfGeneratorJob) GetDoneCh() <-chan struct{}

GetDoneCh returns the channel, which when closed, indicates the job has been finished.

func (*IngressConfGeneratorJob) JobName

func (job *IngressConfGeneratorJob) JobName() string

JobName implementation for this job, for logging purposes

func (*IngressConfGeneratorJob) Run

func (job *IngressConfGeneratorJob) Run()

Run is the logic unit of job

type Server

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

Server is the ingress controller server

func NewServer

func NewServer(cfg configurator.Configurator, msgBroker *messaging.Broker, cache *cache.Cache) *Server

NewServer creates a new ingress controller server

func (*Server) BroadcastListener

func (s *Server) BroadcastListener()

BroadcastListener listens for broadcast messages from the message broker