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 {
    XdsUpdater model.XDSUpdater
    // contains filtered or unexported fields
}

ServiceEntryStore communicates with ServiceEntry CRDs and monitors for changes

func NewServiceDiscovery Uses

func NewServiceDiscovery(configController model.ConfigStoreCache, store model.IstioConfigStore, xdsUpdater model.XDSUpdater) *ServiceEntryStore

NewServiceDiscovery creates a new ServiceEntry discovery service

func (*ServiceEntryStore) AppendInstanceHandler Uses

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

AppendInstanceHandler adds instance event handler. Service Entries does not use these handlers.

func (*ServiceEntryStore) AppendServiceHandler Uses

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

AppendServiceHandler adds service resource event handler. Service Entries does not use these handlers.

func (*ServiceEntryStore) Cluster Uses

func (d *ServiceEntryStore) Cluster() string

func (*ServiceEntryStore) GetIstioServiceAccounts Uses

func (d *ServiceEntryStore) GetIstioServiceAccounts(*model.Service, []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(_ 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) Provider Uses

func (d *ServiceEntryStore) Provider() serviceregistry.ProviderID

func (*ServiceEntryStore) Run Uses

func (d *ServiceEntryStore) Run(_ <-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(_ 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 16 packages (graph) and is imported by 2 packages. Updated 2020-04-03. Refresh now. Tools for package owners.