Documentation ¶
Index ¶
- type KubernetesPerNodeBackend
- func (b *KubernetesPerNodeBackend) ClearXDSCacheSnapshot(id string) error
- func (b *KubernetesPerNodeBackend) Errorf(format string, args ...interface{})
- func (b *KubernetesPerNodeBackend) ID(node *envoycore.Node) string
- func (b *KubernetesPerNodeBackend) Infof(format string, args ...interface{})
- func (b *KubernetesPerNodeBackend) OnFetchRequest(req *envoyv2.DiscoveryRequest)
- func (b *KubernetesPerNodeBackend) OnFetchResponse(req *envoyv2.DiscoveryRequest, res *envoyv2.DiscoveryResponse)
- func (b *KubernetesPerNodeBackend) OnStreamClosed(id int64)
- func (b *KubernetesPerNodeBackend) OnStreamOpen(id int64, urlType string)
- func (b *KubernetesPerNodeBackend) OnStreamRequest(id int64, req *envoyv2.DiscoveryRequest)
- func (b *KubernetesPerNodeBackend) OnStreamResponse(id int64, req *envoyv2.DiscoveryRequest, res *envoyv2.DiscoveryResponse)
- func (b *KubernetesPerNodeBackend) Ready() bool
- func (b *KubernetesPerNodeBackend) Run(threadiness int) error
- func (b *KubernetesPerNodeBackend) SetXDSCacheSnapshot(id string, endpoints, clusters, routes, listeners []envoycache.Resource) error
- func (b *KubernetesPerNodeBackend) SystemServices(serviceCluster string) (map[tree.Path]*xdsapi.Service, error)
- func (b *KubernetesPerNodeBackend) Worker()
- func (b *KubernetesPerNodeBackend) XDSCache() envoycache.Cache
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KubernetesPerNodeBackend ¶
type KubernetesPerNodeBackend struct {
// contains filtered or unexported fields
}
func NewKubernetesPerNodeBackend ¶
func NewKubernetesPerNodeBackend(kubeconfig string, redirectCIDRBlock *net.IPNet, stopCh <-chan struct{}) (*KubernetesPerNodeBackend, error)
func (*KubernetesPerNodeBackend) ClearXDSCacheSnapshot ¶
func (b *KubernetesPerNodeBackend) ClearXDSCacheSnapshot(id string) error
func (*KubernetesPerNodeBackend) Errorf ¶
func (b *KubernetesPerNodeBackend) Errorf(format string, args ...interface{})
func (*KubernetesPerNodeBackend) ID ¶
func (b *KubernetesPerNodeBackend) ID(node *envoycore.Node) string
func (*KubernetesPerNodeBackend) Infof ¶
func (b *KubernetesPerNodeBackend) Infof(format string, args ...interface{})
func (*KubernetesPerNodeBackend) OnFetchRequest ¶
func (b *KubernetesPerNodeBackend) OnFetchRequest(req *envoyv2.DiscoveryRequest)
func (*KubernetesPerNodeBackend) OnFetchResponse ¶
func (b *KubernetesPerNodeBackend) OnFetchResponse(req *envoyv2.DiscoveryRequest, res *envoyv2.DiscoveryResponse)
func (*KubernetesPerNodeBackend) OnStreamClosed ¶
func (b *KubernetesPerNodeBackend) OnStreamClosed(id int64)
func (*KubernetesPerNodeBackend) OnStreamOpen ¶
func (b *KubernetesPerNodeBackend) OnStreamOpen(id int64, urlType string)
func (*KubernetesPerNodeBackend) OnStreamRequest ¶
func (b *KubernetesPerNodeBackend) OnStreamRequest(id int64, req *envoyv2.DiscoveryRequest)
func (*KubernetesPerNodeBackend) OnStreamResponse ¶
func (b *KubernetesPerNodeBackend) OnStreamResponse(id int64, req *envoyv2.DiscoveryRequest, res *envoyv2.DiscoveryResponse)
func (*KubernetesPerNodeBackend) Ready ¶
func (b *KubernetesPerNodeBackend) Ready() bool
func (*KubernetesPerNodeBackend) Run ¶
func (b *KubernetesPerNodeBackend) Run(threadiness int) error
func (*KubernetesPerNodeBackend) SetXDSCacheSnapshot ¶
func (b *KubernetesPerNodeBackend) SetXDSCacheSnapshot(id string, endpoints, clusters, routes, listeners []envoycache.Resource) error
func (*KubernetesPerNodeBackend) SystemServices ¶
func (*KubernetesPerNodeBackend) Worker ¶
func (b *KubernetesPerNodeBackend) Worker()
func (*KubernetesPerNodeBackend) XDSCache ¶
func (b *KubernetesPerNodeBackend) XDSCache() envoycache.Cache
Click to show internal directories.
Click to hide internal directories.