eds

Documentation

Index

• type Endpoint
  • func NewEndpoint(services []Service, a agent.ConsulAgent, ...) Endpoint
• type MockEndpoint
  • func (m *MockEndpoint) CLA() []*cp.ClusterLoadAssignment
  • func (m *MockEndpoint) Clusters() []*cp.Cluster
  • func (m *MockEndpoint) Routes() []*cp.RouteConfiguration
  • func (m *MockEndpoint) WatchPlan(publish func(*pubsub.Event)) (*watch.Plan, error)
• type Service
• type ServiceHost
  • func NewServiceHost(s *api.CatalogService) ServiceHost
  • func (h ServiceHost) LbEndpoint() eds.LbEndpoint

Types

type Endpoint

type Endpoint interface {
	Clusters() []*cp.Cluster
	Routes() []*cp.RouteConfiguration
	CLA() []*cp.ClusterLoadAssignment
	WatchPlan(publish func(*pubsub.Event)) (*watch.Plan, error)
}

Endpoint is an agent catalog service

func NewEndpoint

func NewEndpoint(services []Service, a agent.ConsulAgent, httpRateLimitConfig *config.HTTPHeaderRateLimitConfig, enableHealthCheck bool) Endpoint

NewEndpoint creates an ServiceEndpoint representation

type MockEndpoint

type MockEndpoint struct {
	mock.Mock
}

func (*MockEndpoint) CLA

func (m *MockEndpoint) CLA() []*cp.ClusterLoadAssignment

func (*MockEndpoint) Clusters

func (m *MockEndpoint) Clusters() []*cp.Cluster

func (*MockEndpoint) Routes

func (m *MockEndpoint) Routes() []*cp.RouteConfiguration

func (*MockEndpoint) WatchPlan

func (m *MockEndpoint) WatchPlan(publish func(*pubsub.Event)) (*watch.Plan, error)

type Service

type Service struct {
	Name      string
	Whitelist []string
}

type ServiceHost

type ServiceHost struct {
	Service     string
	IPAddress   string
	Port        int
	Tags        []string
	CreateIndex uint64
	ModifyIndex uint64
}

ServiceHost represents a single host for a service

func NewServiceHost

func NewServiceHost(s *api.CatalogService) ServiceHost

NewServiceHost creates a new service host from a consul catalog service

func (ServiceHost) LbEndpoint

func (h ServiceHost) LbEndpoint() eds.LbEndpoint

LbEndpoint translates a consul agent service endpoint to an envoy control plane LbEndpoint. If the ServiceHost's port is < 1, the endpoint is assumed to be a Pipe and the IPAddress represents the Pipe's Path.