Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for isConfig (0.08 sec)

  1. gorm.go

    func Open(dialector Dialector, opts ...Option) (db *DB, err error) {
    	config := &Config{}
    
    	sort.Slice(opts, func(i, j int) bool {
    		_, isConfig := opts[i].(*Config)
    		_, isConfig2 := opts[j].(*Config)
    		return isConfig && !isConfig2
    	})
    
    	for _, opt := range opts {
    		if opt != nil {
    			if applyErr := opt.Apply(config); applyErr != nil {
    				return nil, applyErr
    			}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  2. internal/logger/target/kafka/kafka.go

    	sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs
    
    	// These settings are needed to ensure that kafka client doesn't hang on brokers
    	// refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355
    	sconfig.Producer.Retry.Max = 2
    	sconfig.Producer.Retry.Backoff = (10 * time.Second)
    	sconfig.Producer.Return.Successes = true
    	sconfig.Producer.Return.Errors = true
    	sconfig.Producer.RequiredAcks = 1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  3. cni/pkg/plugin/cnieventclient_test.go

    	ContainerID: "bbb-eee-www",
    }
    
    var (
    	fakeIP                 = net.ParseIP("99.9.9.9")
    	fakeGW                 = net.ParseIP("88.9.9.9")
    	fakeIDX                = 0
    	fakePrevResultIPConfig = cniv1.IPConfig{
    		Interface: &fakeIDX,
    		Address: net.IPNet{
    			IP: fakeIP,
    		},
    		Gateway: fakeGW,
    	}
    )
    
    func TestPushCNIAddEventSucceed(t *testing.T) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. cni/pkg/plugin/cnieventclient.go

    }
    
    func PushCNIEvent(cniClient CNIEventClient, event *skel.CmdArgs, prevResIps []*cniv1.IPConfig, podName, podNamespace string) error {
    	if event == nil {
    		return fmt.Errorf("unable to push CNI event, CmdArgs event was nil")
    	}
    
    	var ncconfigs []nodeagent.IPConfig
    	for _, ipc := range prevResIps {
    		ncconfigs = append(ncconfigs, nodeagent.IPConfig{Interface: ipc.Interface, Address: ipc.Address, Gateway: ipc.Gateway})
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. cni/pkg/nodeagent/cni-watcher.go

    	Netns        string
    	PodName      string
    	PodNamespace string
    	IPs          []IPConfig
    }
    
    // IPConfig contains an interface/gateway/address combo defined for a newly-started pod by CNI.
    // This is "from the horse's mouth" so to speak and will be populated before Kube is informed of the
    // pod IP.
    type IPConfig struct {
    	Interface *int
    	Address   net.IPNet
    	Gateway   net.IP
    }
    
    type CniPluginServer struct {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/cni-watcher_test.go

    	fakePodIP := "11.1.1.12"
    	_, addr, _ := net.ParseCIDR(fakePodIP + "/32")
    	valid := CNIPluginAddEvent{
    		Netns:        "/var/netns/foo",
    		PodName:      "pod-bingo",
    		PodNamespace: "funkyns",
    		IPs: []IPConfig{{
    			Address: *addr,
    		}},
    	}
    
    	setupLogging()
    	NodeName = "testnode"
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. cni/pkg/plugin/plugin.go

    		podIsAmbient, err := isAmbientPod(kClient, podName, podNamespace)
    		if err != nil {
    			log.Errorf("istio-cni cmdAdd failed to check ambient: %s", err)
    		}
    
    		var prevResIps []*cniv1.IPConfig
    		if conf.PrevResult != nil {
    			prevResult := conf.PrevResult.(*cniv1.Result)
    			prevResIps = prevResult.IPs
    		}
    
    		// Only send event if this pod "would be" an ambient-watched pod - otherwise skip
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.32.md

    - cloud.google.com/go/optimization: v1.4.1 → v1.6.2
    - cloud.google.com/go/orchestration: v1.8.1 → v1.8.4
    - cloud.google.com/go/orgpolicy: v1.11.1 → v1.12.0
    - cloud.google.com/go/osconfig: v1.12.1 → v1.12.4
    - cloud.google.com/go/oslogin: v1.10.1 → v1.13.0
    - cloud.google.com/go/phishingprotection: v0.8.1 → v0.8.4
    - cloud.google.com/go/policytroubleshooter: v1.8.0 → v1.10.2
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.29.md

    - cloud.google.com/go/optimization: v1.3.1 → v1.4.1
    - cloud.google.com/go/orchestration: v1.6.0 → v1.8.1
    - cloud.google.com/go/orgpolicy: v1.10.0 → v1.11.1
    - cloud.google.com/go/osconfig: v1.11.0 → v1.12.1
    - cloud.google.com/go/oslogin: v1.9.0 → v1.10.1
    - cloud.google.com/go/phishingprotection: v0.7.0 → v0.8.1
    - cloud.google.com/go/policytroubleshooter: v1.6.0 → v1.8.0
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:37:31 UTC 2024
    - 375.1K bytes
    - Viewed (1)
  10. CHANGELOG/CHANGELOG-1.28.md

    - cloud.google.com/go/notebooks: v1.8.0
    - cloud.google.com/go/optimization: v1.3.1
    - cloud.google.com/go/orchestration: v1.6.0
    - cloud.google.com/go/orgpolicy: v1.10.0
    - cloud.google.com/go/osconfig: v1.11.0
    - cloud.google.com/go/oslogin: v1.9.0
    - cloud.google.com/go/phishingprotection: v0.7.0
    - cloud.google.com/go/policytroubleshooter: v1.6.0
    - cloud.google.com/go/privatecatalog: v0.8.0
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Oct 23 04:34:59 UTC 2024
    - 456.9K bytes
    - Viewed (0)
Back to top