aggregate

Documentation

Index

• type Controller
  • func NewController() *Controller
  • func (c *Controller) AddRegistry(registry Registry)
  • func (c *Controller) AppendInstanceHandler(f func(*model.ServiceInstance, model.Event)) error
  • func (c *Controller) AppendServiceHandler(f func(*model.Service, model.Event)) error
  • func (c *Controller) GetIstioServiceAccounts(hostname string, ports []string) []string
  • func (c *Controller) GetProxyServiceInstances(node model.Proxy) ([]*model.ServiceInstance, error)
  • func (c *Controller) GetService(hostname string) (*model.Service, error)
  • func (c *Controller) Instances(hostname string, ports []string, labels model.LabelsCollection) ([]*model.ServiceInstance, error)
  • func (c *Controller) ManagementPorts(addr string) model.PortList
  • func (c *Controller) Run(stop <-chan struct{})
  • func (c *Controller) Services() ([]*model.Service, error)
• type Registry

Types

type Controller

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

Controller aggregates data across different registries and monitors for changes

func NewController

func NewController() *Controller

NewController creates a new Aggregate controller

func (*Controller) AddRegistry

func (c *Controller) AddRegistry(registry Registry)

AddRegistry adds registries into the aggregated controller

func (*Controller) AppendInstanceHandler

func (c *Controller) AppendInstanceHandler(f func(*model.ServiceInstance, model.Event)) error

AppendInstanceHandler implements a service instance catalog operation

func (*Controller) AppendServiceHandler

func (c *Controller) AppendServiceHandler(f func(*model.Service, model.Event)) error

AppendServiceHandler implements a service catalog operation

func (*Controller) GetIstioServiceAccounts

func (c *Controller) GetIstioServiceAccounts(hostname string, ports []string) []string

GetIstioServiceAccounts implements model.ServiceAccounts operation

func (*Controller) GetProxyServiceInstances

func (c *Controller) GetProxyServiceInstances(node model.Proxy) ([]*model.ServiceInstance, error)

GetProxyServiceInstances lists service instances co-located with a given proxy

func (*Controller) GetService

func (c *Controller) GetService(hostname string) (*model.Service, error)

GetService retrieves a service by hostname if exists

func (*Controller) Instances

func (c *Controller) Instances(hostname string, ports []string,
	labels model.LabelsCollection) ([]*model.ServiceInstance, error)

Instances retrieves instances for a service and its ports that match any of the supplied labels. All instances match an empty label list.

func (*Controller) ManagementPorts

func (c *Controller) ManagementPorts(addr string) model.PortList

ManagementPorts retrieves set of health check ports by instance IP Return on the first hit.

func (*Controller) Run

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

Run starts all the controllers

func (*Controller) Services

func (c *Controller) Services() ([]*model.Service, error)

Services lists services from all platforms

type Registry

type Registry struct {
	Name        serviceregistry.ServiceRegistry
	ClusterName string
	model.Controller
	model.ServiceDiscovery
	model.ServiceAccounts
}

Registry specifies the collection of service registry related interfaces