istio: istio.io/istio/pilot/pkg/serviceregistry/external Index | Files

package external

import "istio.io/istio/pilot/pkg/serviceregistry/external"

Index

Package Files

conversion.go servicediscovery.go

type ServiceEntryStore Uses

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

ServiceEntryStore communicates with ServiceEntry CRDs and monitors for changes

func NewServiceDiscovery Uses

func NewServiceDiscovery(callbacks model.ConfigStoreCache, store model.IstioConfigStore) *ServiceEntryStore

NewServiceDiscovery creates a new ServiceEntry discovery service

func (*ServiceEntryStore) AppendInstanceHandler Uses

func (d *ServiceEntryStore) AppendInstanceHandler(f func(*model.ServiceInstance, model.Event)) error

AppendInstanceHandler adds instance event handler.

func (*ServiceEntryStore) AppendServiceHandler Uses

func (d *ServiceEntryStore) AppendServiceHandler(f func(*model.Service, model.Event)) error

AppendServiceHandler adds service resource event handler

func (*ServiceEntryStore) GetIstioServiceAccounts Uses

func (d *ServiceEntryStore) GetIstioServiceAccounts(svc *model.Service, ports []int) []string

GetIstioServiceAccounts implements model.ServiceAccounts operation TODOg

func (*ServiceEntryStore) GetProxyServiceInstances Uses

func (d *ServiceEntryStore) GetProxyServiceInstances(node *model.Proxy) ([]*model.ServiceInstance, error)

GetProxyServiceInstances lists service instances co-located with a given proxy

func (*ServiceEntryStore) GetProxyWorkloadLabels Uses

func (d *ServiceEntryStore) GetProxyWorkloadLabels(proxy *model.Proxy) (labels.Collection, error)

func (*ServiceEntryStore) GetService Uses

func (d *ServiceEntryStore) GetService(hostname host.Name) (*model.Service, error)

GetService retrieves a service by host name if it exists THIS IS A LINEAR SEARCH WHICH CAUSES ALL SERVICE ENTRIES TO BE RECONVERTED - DO NOT USE

func (*ServiceEntryStore) InstancesByPort Uses

func (d *ServiceEntryStore) InstancesByPort(svc *model.Service, port int,
    labels labels.Collection) ([]*model.ServiceInstance, error)

InstancesByPort retrieves instances for a service on the given ports with labels that match any of the supplied labels. All instances match an empty tag list.

func (*ServiceEntryStore) ManagementPorts Uses

func (d *ServiceEntryStore) ManagementPorts(addr string) model.PortList

ManagementPorts retrieves set of health check ports by instance IP. This does not apply to Service Entry registry, as Service entries do not manage the service instances.

func (*ServiceEntryStore) Run Uses

func (d *ServiceEntryStore) Run(stop <-chan struct{})

Run is used by some controllers to execute background jobs after init is done.

func (*ServiceEntryStore) Services Uses

func (d *ServiceEntryStore) Services() ([]*model.Service, error)

Services list declarations of all services in the system

func (*ServiceEntryStore) WorkloadHealthCheckInfo Uses

func (d *ServiceEntryStore) WorkloadHealthCheckInfo(addr string) model.ProbeList

WorkloadHealthCheckInfo retrieves set of health check info by instance IP. This does not apply to Service Entry registry, as Service entries do not manage the service instances.

Package external imports 13 packages (graph) and is imported by 2 packages. Updated 2019-10-17. Refresh now. Tools for package owners.