discovery

Documentation

Index

• type DiscoveryCtrl
  • func GetDiscoveryCtrl(namespace string, crdClient *crdClient.CRDClient, ...) DiscoveryCtrl
  • func NewDiscoveryCtrl(namespace string, clusterId *clusterID.ClusterID, kubeconfigPath string) (*DiscoveryCtrl, error)
  • func (discovery *DiscoveryCtrl) CheckUpdate(txtData *TxtData, fc *v1alpha1.ForeignCluster, ...) (*v1alpha1.ForeignCluster, error)
  • func (discovery *DiscoveryCtrl) GetAPIUrl() (string, error)
  • func (discovery *DiscoveryCtrl) GetDiscoveryConfig(crdClient *crdClient.CRDClient, kubeconfigPath string) error
  • func (discovery *DiscoveryCtrl) GetTxtData() (*TxtData, error)
  • func (discovery *DiscoveryCtrl) Register()
  • func (discovery *DiscoveryCtrl) Resolve(service string, domain string, waitTime int, testRes *[]*TxtData)
  • func (discovery *DiscoveryCtrl) SetupCaData() error
  • func (discovery *DiscoveryCtrl) StartDiscovery()
  • func (discovery *DiscoveryCtrl) StartResolver()
  • func (discovery *DiscoveryCtrl) UpdateForeign(data []*TxtData, sd *v1alpha1.SearchDomain) []*v1alpha1.ForeignCluster
  • func (discovery *DiscoveryCtrl) UpdateTtl(txts []*TxtData) error
  • func (discovery *DiscoveryCtrl) WatchTrustedCAs() error
• type TxtData
  • func Decode(address string, port string, data []string) (*TxtData, error)
  • func (txtData TxtData) Encode() ([]string, error)
  • func (txtData *TxtData) GetAllowUntrustedCA() string

Types

type DiscoveryCtrl

type DiscoveryCtrl struct {
	Namespace string

	Config *configv1alpha1.DiscoveryConfig

	ClusterId *clusterID.ClusterID
	// contains filtered or unexported fields
}

func GetDiscoveryCtrl

func GetDiscoveryCtrl(namespace string, crdClient *crdClient.CRDClient, advClient *crdClient.CRDClient, clusterId *clusterID.ClusterID) DiscoveryCtrl

func NewDiscoveryCtrl

func NewDiscoveryCtrl(namespace string, clusterId *clusterID.ClusterID, kubeconfigPath string) (*DiscoveryCtrl, error)

func (*DiscoveryCtrl) CheckUpdate

func (discovery *DiscoveryCtrl) CheckUpdate(txtData *TxtData, fc *v1alpha1.ForeignCluster, discoveryType v1alpha1.DiscoveryType) (*v1alpha1.ForeignCluster, error)

func (*DiscoveryCtrl) GetAPIUrl

func (discovery *DiscoveryCtrl) GetAPIUrl() (string, error)

get API Server Url for this cluster if APISERVER env variable is set we read it's ip form this variable

(this can be useful on managed k8s services where we have no master node)

else get the IP of first master if APISERVER_PORT env variable is set we use it has port else we fallback to default port

func (*DiscoveryCtrl) GetDiscoveryConfig

func (discovery *DiscoveryCtrl) GetDiscoveryConfig(crdClient *crdClient.CRDClient, kubeconfigPath string) error

func (*DiscoveryCtrl) GetTxtData

func (discovery *DiscoveryCtrl) GetTxtData() (*TxtData, error)

func (*DiscoveryCtrl) Register

func (discovery *DiscoveryCtrl) Register()

func (*DiscoveryCtrl) Resolve

func (discovery *DiscoveryCtrl) Resolve(service string, domain string, waitTime int, testRes *[]*TxtData)

func (*DiscoveryCtrl) SetupCaData

func (discovery *DiscoveryCtrl) SetupCaData() error

func (*DiscoveryCtrl) StartDiscovery

func (discovery *DiscoveryCtrl) StartDiscovery()

Start register and resolver goroutines

func (*DiscoveryCtrl) StartResolver

func (discovery *DiscoveryCtrl) StartResolver()

func (*DiscoveryCtrl) UpdateForeign

func (discovery *DiscoveryCtrl) UpdateForeign(data []*TxtData, sd *v1alpha1.SearchDomain) []*v1alpha1.ForeignCluster

func (*DiscoveryCtrl) UpdateTtl

func (discovery *DiscoveryCtrl) UpdateTtl(txts []*TxtData) error

func (*DiscoveryCtrl) WatchTrustedCAs

func (discovery *DiscoveryCtrl) WatchTrustedCAs() error

type TxtData

type TxtData struct {
	ID               string
	Namespace        string
	AllowUntrustedCA bool
	ApiUrl           string
}

func Decode

func Decode(address string, port string, data []string) (*TxtData, error)

func (TxtData) Encode

func (txtData TxtData) Encode() ([]string, error)

func (*TxtData) GetAllowUntrustedCA

func (txtData *TxtData) GetAllowUntrustedCA() string