router

Documentation

Index

• func BuildServiceDiscovery(name, namespace string, labels map[string]string, ...) ([]resource.Resourcer, error)
• func ConvertChainsToResourcers(name, namespace string, labels map[string]string, cs map[string][]*Chain) (map[string][]resource.Resourcer, error)
• type Chain
• type HubsChain
  • func NewHubsChain(conf HubsChainConfig) *HubsChain
  • func (h *HubsChain) Build(name string, origin, destination objref.ObjectRef, originPort, peerPort int32, ...) (hubsChains map[string][]*Chain, err error)
• type HubsChainConfig
• type Router
  • func NewRouter(conf RouterConfig) *Router
  • func (d *Router) BuildResource(ways []string) (out map[string][]resource.Resourcer, err error)
  • func (d *Router) SetRoutes(rules []*v1alpha2.Route)
• type RouterConfig
• type Solution
  • func NewSolution(conf SolutionConfig) *Solution
  • func (s *Solution) CalculateWays(exportHub, importHub string) ([]string, error)
• type SolutionConfig

Functions

func BuildServiceDiscovery

func BuildServiceDiscovery(name, namespace string, labels map[string]string, peerPortMapping map[int32]int32, spec *corev1.ServiceSpec) ([]resource.Resourcer, error)

BuildServiceDiscovery the Egress Discovery resource, perhaps Service or DNS

func ConvertChainsToResourcers

func ConvertChainsToResourcers(name, namespace string, labels map[string]string, cs map[string][]*Chain) (map[string][]resource.Resourcer, error)

Types

type Chain

type Chain struct {
	Bind  []string `json:"bind"`
	Proxy []string `json:"proxy"`
}

type HubsChain

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

func NewHubsChain

func NewHubsChain(conf HubsChainConfig) *HubsChain

func (*HubsChain) Build

func (h *HubsChain) Build(name string, origin, destination objref.ObjectRef, originPort, peerPort int32, ways []string) (hubsChains map[string][]*Chain, err error)

type HubsChainConfig

type HubsChainConfig struct {
	GetIdentity func(hubName string) string

	GetHubGateway func(hubName string, forHub string) v1alpha2.HubSpecGateway
}

type Router

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

func NewRouter

func NewRouter(conf RouterConfig) *Router

func (*Router) BuildResource

func (d *Router) BuildResource(ways []string) (out map[string][]resource.Resourcer, err error)

func (*Router) SetRoutes

func (d *Router) SetRoutes(rules []*v1alpha2.Route)

type RouterConfig

type RouterConfig struct {
	Namespace     string
	Labels        map[string]string
	ExportHubName string
	ImportHubName string
	GetIdentity   func(hubName string) string
	GetHubGateway func(hubName string, forHub string) v1alpha2.HubSpecGateway
	ListServices  func(name string) []*corev1.Service
	GetPortPeer   func(importHubName string, cluster, namespace, name string, port int32) int32
}

type Solution

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

func NewSolution

func NewSolution(conf SolutionConfig) *Solution

func (*Solution) CalculateWays

func (s *Solution) CalculateWays(exportHub, importHub string) ([]string, error)

CalculateWays is calculated the ways based on the export hub and import hub

type SolutionConfig

type SolutionConfig struct {
	GetHubGateway func(hubName string, forHub string) v1alpha2.HubSpecGateway
}