INNER CODE UNIT · Go

syncTunnelLicense

inlets/inlets-operator · controller.go:478

func syncTunnelLicense(c *Controller, operatorNs string, namespace string) error {
	licenseToken, err := c.kubeclientset.CoreV1().
		Secrets(operatorNs).
		Get(context.Background(), "inlets-license", metav1.GetOptions{})
	if err != nil || licenseToken == nil {
		return fmt.Errorf("unable to read inlets license: %s", err.Error())
	}

	existing, err := c.kubeclientset.CoreV1().
		Secrets(namespace).
		Get(context.Background(), "inlets-license", metav1.GetOptions{})
	if err == nil {
		if cmp.Equal(existing.Data["license"], licenseToken.Data["license"]) {
			return nil
		}

		copyExisting := existing.DeepCopy()
		copyExisting.Data = licenseToken.Data

View source record →