core

package
v0.0.0-...-43ce250 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 26, 2018 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL