xds

Documentation

Index

• type CacheMgr
  • func NewCacheMgr(istioClientset *istioclient.Clientset, store istiomodel.ConfigStore) *CacheMgr
  • func (c *CacheMgr) Cache() cachev3.SnapshotCache
  • func (c *CacheMgr) ConfigUpdated(_ istioconfig.Config, curr istioconfig.Config, event istiomodel.Event)
  • func (c *CacheMgr) Run(stop <-chan struct{})
  • func (c *CacheMgr) UpdateRoute()
• type Server
  • func NewServer(addr string, cacheMgr cacheMgr) *Server
  • func (s *Server) Run(stopCh <-chan struct{})

Types

type CacheMgr

type CacheMgr struct {
	ControllerClient client.Client
	// contains filtered or unexported fields
}

CacheMgr contains the runtime configuration for the envoyFilter controller.

func NewCacheMgr

func NewCacheMgr(istioClientset *istioclient.Clientset, store istiomodel.ConfigStore) *CacheMgr

NewCacheMgr creates a new controller instance based on the provided arguments.

func (*CacheMgr) Cache

func (c *CacheMgr) Cache() cachev3.SnapshotCache

Cache return th route cache

func (*CacheMgr) ConfigUpdated

func (c *CacheMgr) ConfigUpdated(_ istioconfig.Config, curr istioconfig.Config, event istiomodel.Event)

ConfigUpdated sends a config change event to the pushChannel when Istio config changed

func (*CacheMgr) Run

func (c *CacheMgr) Run(stop <-chan struct{})

Run until a signal is received, this function won't block

func (*CacheMgr) UpdateRoute

func (c *CacheMgr) UpdateRoute()

UpdateRoute sends a config change event to the pushChannel when Meta Router changed

type Server

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

Server serves xDS resources to Envoy sidecars

func NewServer

func NewServer(addr string, cacheMgr cacheMgr) *Server

NewServer creates a xDS server

func (*Server) Run

func (s *Server) Run(stopCh <-chan struct{})

Run an xDS server until an event is received over stopCh.