Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for OnSecretUpdate (0.15 sec)

  1. security/pkg/nodeagent/sds/server.go

    	s := &Server{stopped: atomic.NewBool(false)}
    	s.workloadSds = newSDSService(workloadSecretCache, options, pkpConf)
    	s.initWorkloadSdsService()
    	return s
    }
    
    func (s *Server) OnSecretUpdate(resourceName string) {
    	if s.workloadSds == nil {
    		return
    	}
    
    	sdsServiceLog.Debugf("Trigger on secret update, resource name: %s", resourceName)
    	s.workloadSds.push(resourceName)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 07 17:44:41 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. pkg/istio-agent/agent.go

    )
    
    var _ ready.Prober = &Agent{}
    
    type LifecycleEvent string
    
    const (
    	DrainLifecycleEvent LifecycleEvent = "drain"
    	ExitLifecycleEvent  LifecycleEvent = "exit"
    )
    
    type SDSService interface {
    	OnSecretUpdate(resourceName string)
    	Stop()
    }
    
    type SDSServiceFactory = func(_ *security.Options, _ security.SecretManager, _ *mesh.PrivateKeyProvider) SDSService
    
    // Shared properties with Pilot Proxy struct.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  3. security/pkg/nodeagent/cache/secretcache_test.go

    	}
    	// Immediately update the proxyConfig root cert
    	sc.UpdateConfigTrustBundle(rootCert)
    	time.Sleep(time.Millisecond * 200)
    	// The rotation task actually will not call `OnSecretUpdate`, otherwise the WorkloadKeyCertResourceName event number should be 2
    	u.Expect(map[string]int{security.RootCertReqResourceName: 2, security.WorkloadKeyCertResourceName: 1})
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 23.9K bytes
    - Viewed (0)
Back to top