core

Documentation

Index

• func SimpleKubeClient(config *viper.Viper) (*kubernetes.Clientset, error)
• type Application
  • func InitApplication(config *viper.Viper) *Application
  • func (a *Application) Endpoints2ClusterLoadAssignment(endpoints *k8sApiV1Core.Endpoints, healthStatus envoyApiV2Core.HealthStatus) *envoyApiV2.ClusterLoadAssignment
  • func (a *Application) RunXds()
  • func (a *Application) Serve()
  • func (a *Application) WatchEndpoints()
• type Hasher
  • func (h Hasher) ID(node *envoyApiV2Core.Node) string

Functions

func SimpleKubeClient

func SimpleKubeClient(config *viper.Viper) (*kubernetes.Clientset, error)

SimpleKubeClient create a *kubernetes.Clientset by using viper config

Types

type Application

type Application struct {
	Config *viper.Viper

	KubeClient *kubernetes.Clientset
	// contains filtered or unexported fields
}

Application is program entry

func InitApplication

func InitApplication(config *viper.Viper) *Application

InitApplication init an application, the program only execute once

func (*Application) Endpoints2ClusterLoadAssignment

func (a *Application) Endpoints2ClusterLoadAssignment(endpoints *k8sApiV1Core.Endpoints, healthStatus envoyApiV2Core.HealthStatus) *envoyApiV2.ClusterLoadAssignment

Endpoints2ClusterLoadAssignment convert Endpoints to ClusterLoadAssignment

func (*Application) RunXds

func (a *Application) RunXds()

RunXds run xds server

func (*Application) Serve

func (a *Application) Serve()

Serve start and block the main process

func (*Application) WatchEndpoints

func (a *Application) WatchEndpoints()

WatchEndpoints watch kubernetes endpoint changes

type Hasher

type Hasher struct {
}

Hasher is a single cache key hash.

func (Hasher) ID

func (h Hasher) ID(node *envoyApiV2Core.Node) string

ID function that always returns the same value.