server

Documentation

Index

• func StartEndpointKubeHandler(client *kubernetes.Clientset, triggerfunc func(), ...) context.CancelFunc
• func StartSvcKubeHandler(client *kubernetes.Clientset, ...) context.CancelFunc
• type Xds
  • func New(config cache.SnapshotCache, port uint) *Xds
  • func (xd *Xds) Report()
  • func (xd *Xds) Run(ctx context.Context)
  • func (xd *Xds) WaitForRequests()

Functions

func StartEndpointKubeHandler

func StartEndpointKubeHandler(client *kubernetes.Clientset, triggerfunc func(), endpointLabel, namespace string) context.CancelFunc

func StartSvcKubeHandler

func StartSvcKubeHandler(client *kubernetes.Clientset, triggerfunc func(eventType envoy.LBEventType, svc *v1.Service), upstreamLabel, namespace string) context.CancelFunc

Types

type Xds

type Xds struct {
	Server xds.Server
	Port   uint
	// contains filtered or unexported fields
}

Xds has the grpc wrapper for xds api on a given port

func New

func New(config cache.SnapshotCache, port uint) *Xds

func (*Xds) Report

func (xd *Xds) Report()

func (*Xds) Run

func (xd *Xds) Run(ctx context.Context)

Run starts the xDS server.

func (*Xds) WaitForRequests

func (xd *Xds) WaitForRequests()