envoy

package
v5.1.4-release+incompa... Latest Latest
Warning

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

Go to latest
Published: May 20, 2019 License: LGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DiscoverServerManager

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

DiscoverServerManager envoy discover server

func CreateDiscoverServerManager

func CreateDiscoverServerManager(kubecli kubecache.KubeClient, conf option.Conf) (*DiscoverServerManager, error)

CreateDiscoverServerManager create discover server manager

func (*DiscoverServerManager) AddNodeConfig

func (d *DiscoverServerManager) AddNodeConfig(nc *NodeConfig)

AddNodeConfig add node config cache

func (*DiscoverServerManager) DeleteNodeConfig

func (d *DiscoverServerManager) DeleteNodeConfig(nodeID string)

DeleteNodeConfig delete node config cache

func (*DiscoverServerManager) GetDependService

func (d *DiscoverServerManager) GetDependService(namespace, depServiceAlias string) ([]*corev1.Service, []*corev1.Endpoints)

GetDependService get depend service

func (*DiscoverServerManager) GetSelfService

func (d *DiscoverServerManager) GetSelfService(namespace, serviceAlias string) ([]*corev1.Service, []*corev1.Endpoints)

GetSelfService get self service

func (*DiscoverServerManager) NewNodeConfig

func (d *DiscoverServerManager) NewNodeConfig(config *corev1.ConfigMap) (*NodeConfig, error)

NewNodeConfig new NodeConfig

func (*DiscoverServerManager) OnAdd

func (d *DiscoverServerManager) OnAdd(obj interface{})

OnAdd on add for k8s

func (*DiscoverServerManager) OnDelete

func (d *DiscoverServerManager) OnDelete(obj interface{})

OnDelete on delete resource

func (*DiscoverServerManager) OnUpdate

func (d *DiscoverServerManager) OnUpdate(oldObj, newObj interface{})

OnUpdate on update resource

func (*DiscoverServerManager) Start

func (d *DiscoverServerManager) Start(errch chan error) error

Start server start

func (*DiscoverServerManager) Stop

func (d *DiscoverServerManager) Stop()

Stop stop grpc server

func (*DiscoverServerManager) UpdateNodeConfig

func (d *DiscoverServerManager) UpdateNodeConfig(nc *NodeConfig) error

UpdateNodeConfig update node config

type Event

type Event struct {
	MethodType string
	Source     interface{}
}

Event event

type Hasher

type Hasher struct {
}

Hasher returns node ID as an ID

func (Hasher) ID

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

ID function

type NodeConfig

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

NodeConfig envoy node config cache struct

func (*NodeConfig) GetID

func (n *NodeConfig) GetID() string

GetID get envoy node config id

func (*NodeConfig) GetVersion

func (n *NodeConfig) GetVersion() string

GetVersion get version

func (*NodeConfig) TryUpdate

func (n *NodeConfig) TryUpdate(obj interface{}) (needUpdate bool)

TryUpdate try update resources, if don't care about,direct return false if return true, snapshot need update

func (*NodeConfig) VersionUpdate

func (n *NodeConfig) VersionUpdate()

VersionUpdate add version index

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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