Documentation
¶
Index ¶
- type 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) GetService(hostname string) (*model.Service, error)
- func (c *Controller) HostInstances(addrs map[string]bool) ([]*model.ServiceInstance, 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
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) GetService ¶
func (c *Controller) GetService(hostname string) (*model.Service, error)
GetService retrieves a service by hostname if exists
func (*Controller) HostInstances ¶
func (c *Controller) HostInstances(addrs map[string]bool) ([]*model.ServiceInstance, error)
HostInstances lists service instances for a given set of IPv4 addresses.
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
type Registry ¶
type Registry struct {
Name platform.ServiceRegistry
model.Controller
model.ServiceDiscovery
model.ServiceAccounts
}
Registry specifies the collection of service registry related interfaces
Source Files