Documentation
¶
Index ¶
- func AllocateVIPs(global *vips.GlobalView, voView *vips.VirtualOutboundMeshView) (errs error)
- func BuildVirtualOutboundMeshView(rm manager.ReadOnlyResourceManager, serviceVipEnabled bool, mesh string) (*vips.VirtualOutboundMeshView, error)
- func DnsNameToKumaCompliant(name string) (string, error)
- func Match(vos []*core_mesh.VirtualOutboundResource, tags map[string]string) []*core_mesh.VirtualOutboundResource
- func NewVIPsSynchronizer(resolver resolver.DNSResolver, rm manager.ReadOnlyResourceManager, ...) component.Component
- func Setup(rt runtime.Runtime) error
- type DNSServer
- type NameModifier
- type SimpleDNSServer
- type VIPsAllocator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AllocateVIPs ¶ added in v1.8.1
func AllocateVIPs(global *vips.GlobalView, voView *vips.VirtualOutboundMeshView) (errs error)
func BuildVirtualOutboundMeshView ¶
func BuildVirtualOutboundMeshView(rm manager.ReadOnlyResourceManager, serviceVipEnabled bool, mesh string) (*vips.VirtualOutboundMeshView, error)
func DnsNameToKumaCompliant ¶
func Match ¶ added in v1.8.1
func Match(vos []*core_mesh.VirtualOutboundResource, tags map[string]string) []*core_mesh.VirtualOutboundResource
func NewVIPsSynchronizer ¶
func NewVIPsSynchronizer(resolver resolver.DNSResolver, rm manager.ReadOnlyResourceManager, configManager config_manager.ConfigManager, leadInfo component.LeaderInfo) component.Component
Types ¶
type DNSServer ¶
func NewDNSServer ¶
func NewDNSServer(port uint32, resolver resolver.DNSResolver, metrics core_metrics.Metrics, modifier NameModifier) (DNSServer, error)
type NameModifier ¶
type SimpleDNSServer ¶
type SimpleDNSServer struct {
// contains filtered or unexported fields
}
func (*SimpleDNSServer) NeedLeaderElection ¶
func (d *SimpleDNSServer) NeedLeaderElection() bool
func (*SimpleDNSServer) Start ¶
func (d *SimpleDNSServer) Start(stop <-chan struct{}) error
type VIPsAllocator ¶
type VIPsAllocator struct {
// contains filtered or unexported fields
}
func NewVIPsAllocator ¶
func NewVIPsAllocator(rm manager.ReadOnlyResourceManager, configManager config_manager.ConfigManager, serviceVipEnabled bool, cidr string, resolver resolver.DNSResolver) (*VIPsAllocator, error)
NewVIPsAllocator creates new object of VIPsAllocator. You can either call method CreateOrUpdateVIPConfig manually or start VIPsAllocator as a component. In the latter scenario it will call CreateOrUpdateVIPConfig every 'tickInterval' for all meshes in the store.
func (*VIPsAllocator) CreateOrUpdateVIPConfig ¶
func (d *VIPsAllocator) CreateOrUpdateVIPConfig(mesh string) error
func (*VIPsAllocator) CreateOrUpdateVIPConfigs ¶
func (d *VIPsAllocator) CreateOrUpdateVIPConfigs() error
func (*VIPsAllocator) NeedLeaderElection ¶
func (d *VIPsAllocator) NeedLeaderElection() bool
func (*VIPsAllocator) Start ¶
func (d *VIPsAllocator) Start(stop <-chan struct{}) error
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.