discovery

Documentation

Overview

Package discovery implements the logic of the discovery of other clusters, both on local networks and in wide area networks

Index

• type AuthData
  • func NewAuthData(address string, port int, ttl uint32) *AuthData
  • func (authData *AuthData) Get(discovery *Controller, entry *zeroconf.ServiceEntry) error
  • func (authData *AuthData) IsComplete() bool
• type Controller
  • func NewDiscoveryCtrl(cl, namespacedClient client.Client, namespace string, ...) *Controller
  • func (discovery *Controller) Start(ctx context.Context) error
  • func (discovery *Controller) UpdateForeignWAN(data []*AuthData, sd *v1alpha1.SearchDomain) []*v1alpha1.ForeignCluster
• type MDNSConfig

Types

type AuthData

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

AuthData contains the information exchanged with the discovery methods on how to contact a remote Authentication Service.

func NewAuthData

func NewAuthData(address string, port int, ttl uint32) *AuthData

NewAuthData creates a new AuthData struct.

func (*AuthData) Get

func (authData *AuthData) Get(discovery *Controller, entry *zeroconf.ServiceEntry) error

Get decodes and populates the AuthData struct given a discovery Controller and a DNS entry.

func (*AuthData) IsComplete

func (authData *AuthData) IsComplete() bool

IsComplete checks if both address and port are correctly set.

type Controller

type Controller struct {
	client.Client

	LocalClusterID clusterid.ClusterID
	// contains filtered or unexported fields
}

Controller is the controller for the discovery functionalities.

func NewDiscoveryCtrl

func NewDiscoveryCtrl(cl, namespacedClient client.Client, namespace string,
	localClusterID clusterid.ClusterID, config MDNSConfig, dialTCPTimeout time.Duration) *Controller

NewDiscoveryCtrl returns a new discovery controller.

func (*Controller) Start

func (discovery *Controller) Start(ctx context.Context) error

Start starts the discovery logic.

func (*Controller) UpdateForeignWAN

func (discovery *Controller) UpdateForeignWAN(data []*AuthData, sd *v1alpha1.SearchDomain) []*v1alpha1.ForeignCluster

UpdateForeignWAN updates the list of known foreign clusters: for each cluster retrieved with DNS discovery, if it is not the local cluster, check if it is already known, if not create it. In both cases update the ForeignCluster TTL This function also sets an owner reference and a label to the ForeignCluster pointing to the SearchDomain CR.

type MDNSConfig

type MDNSConfig struct {
	EnableAdvertisement bool
	EnableDiscovery     bool

	Service string
	Domain  string
	TTL     time.Duration

	ResolveRefreshTime time.Duration
}

MDNSConfig defines the configuration parameters for the mDNS service.