controller

Documentation

Index

• func NewClientSet(kubeconfig string) (*kubernetes.Clientset, error)
• type GWController
  • func NewGWController(ctx context.Context, clientset kubernetes.Interface, cfg *option.Config, ...) (*GWController, error)
  • func (g *GWController) Check(_ *http.Request) error
  • func (gwc *GWController) Close() error
  • func (g GWController) Name() string
  • func (gwc *GWController) Start(errCh chan error) error
• type GWServicer

Functions

func NewClientSet

func NewClientSet(kubeconfig string) (*kubernetes.Clientset, error)

NewClientSet returns a new kubernetes clientSet

Types

type GWController

type GWController struct {
	GWS GWServicer

	EtcdCli *client.Client
	// contains filtered or unexported fields
}

GWController -

func NewGWController

func NewGWController(ctx context.Context, clientset kubernetes.Interface, cfg *option.Config, mc metric.Collector, node *cluster.NodeManager) (*GWController, error)

NewGWController new Gateway controller

func (*GWController) Check

func (g *GWController) Check(_ *http.Request) error

Check returns if the nginx healthz endpoint is returning ok (status code 200)

func (*GWController) Close

func (gwc *GWController) Close() error

Close stops Gateway

func (GWController) Name

func (g GWController) Name() string

Name returns the healthcheck name

func (*GWController) Start

func (gwc *GWController) Start(errCh chan error) error

Start Gateway

type GWServicer

type GWServicer interface {
	Start(errCh chan error) error
	Stop() error
	Check() error
	PersistConfig(conf *v1.Config) error
	UpdatePools(hpools []*v1.Pool, tpools []*v1.Pool) error
	WaitPluginReady()
}

GWServicer