envoy

Documentation

Index

• type DiscoverServerManager
  • func CreateDiscoverServerManager(kubecli kubecache.KubeClient, conf option.Conf) (*DiscoverServerManager, error)
  • func (d *DiscoverServerManager) AddNodeConfig(nc *NodeConfig)
  • func (d *DiscoverServerManager) DeleteNodeConfig(nodeID string)
  • func (d *DiscoverServerManager) GetDependService(namespace, depServiceAlias string) ([]*corev1.Service, []*corev1.Endpoints)
  • func (d *DiscoverServerManager) GetSelfService(namespace, serviceAlias string) ([]*corev1.Service, []*corev1.Endpoints)
  • func (d *DiscoverServerManager) NewNodeConfig(config *corev1.ConfigMap) (*NodeConfig, error)
  • func (d *DiscoverServerManager) OnAdd(obj interface{})
  • func (d *DiscoverServerManager) OnDelete(obj interface{})
  • func (d *DiscoverServerManager) OnUpdate(oldObj, newObj interface{})
  • func (d *DiscoverServerManager) Start(errch chan error) error
  • func (d *DiscoverServerManager) Stop()
  • func (d *DiscoverServerManager) UpdateNodeConfig(nc *NodeConfig) error
• type Event
• type Hasher
  • func (h Hasher) ID(node *core.Node) string
• type NodeConfig
  • func (n *NodeConfig) GetID() string
  • func (n *NodeConfig) GetVersion() string
  • func (n *NodeConfig) TryUpdate(obj interface{}) (needUpdate bool)
  • func (n *NodeConfig) VersionUpdate()

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