Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for rootTask (0.13 sec)

  1. subprojects/core/src/integTest/groovy/org/gradle/api/DynamicObjectIntegrationTest.groovy

                    "ext.rootProperty = 'root'",
                    "ext.sharedProperty = 'ignore me'",
                    "ext.property = 'value'",
                    "convention.plugins.test = new ConventionBean()",
                    "task rootTask",
                    "task testTask",
                    "class ConventionBean { def getConventionProperty() { 'convention' } }"
            )
            file("child/build.gradle").writelns(
                    "ext.childProperty = 'child'",
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri May 17 13:27:33 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  2. subprojects/core/src/integTest/groovy/org/gradle/api/tasks/TaskInputFilePropertiesIntegrationTest.groovy

        def "allows @InputFiles of task with no actions to be null"() {
            buildFile << """
                class FooTask extends DefaultTask {
                   @InputFiles
                   FileCollection bar
                }
    
                task foo(type: FooTask)
            """
    
            when:
            run "foo"
    
            then:
            executed ":foo"
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 13:04:02 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. internal/config/notify/parse.go

    			if !args.Enable {
    				continue
    			}
    			args.TLS.RootCAs = transport.TLSClientConfig.RootCAs
    			t, err := target.NewKafkaTarget(id, args, logOnceIf)
    			if err != nil {
    				return nil, err
    			}
    			targets = append(targets, t)
    
    		}
    
    	case config.NotifyMQTTSubSys:
    		mqttTargets, err := GetNotifyMQTT(cfg[config.NotifyMQTTSubSys], transport.TLSClientConfig.RootCAs)
    		if err != nil {
    			return nil, err
    		}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  4. internal/event/target/nats.go

    	}
    	if n.Secure || n.TLS && n.TLSSkipVerify {
    		connOpts = append(connOpts, nats.Secure(nil))
    	} else if n.TLS {
    		connOpts = append(connOpts, nats.Secure(&tls.Config{RootCAs: n.RootCAs}))
    	}
    	if n.CertAuthority != "" {
    		connOpts = append(connOpts, nats.RootCAs(n.CertAuthority))
    	}
    	if n.ClientCert != "" && n.ClientKey != "" {
    		connOpts = append(connOpts, nats.ClientCert(n.ClientCert, n.ClientKey))
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  5. internal/kms/config.go

    		if err != nil {
    			return nil, err
    		}
    
    		key, err := kms.ParseAPIKey(env.Get(EnvKMSAPIKey, ""))
    		if err != nil {
    			return nil, err
    		}
    
    		var rootCAs *x509.CertPool
    		if opts != nil && opts.CADir != "" {
    			rootCAs, err = certs.GetRootCAs(opts.CADir)
    			if err != nil {
    				return nil, err
    			}
    		}
    
    		client, err := kms.NewClient(&kms.Config{
    			Endpoints: endpoints,
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Jun 12 14:31:26 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  6. cmd/erasure.go

    			di.DrivePath = info.MountPath
    			di.TotalSpace = info.Total
    			di.UsedSpace = info.Used
    			di.AvailableSpace = info.Free
    			di.UUID = info.ID
    			di.Major = info.Major
    			di.Minor = info.Minor
    			di.RootDisk = info.RootDisk
    			di.Healing = info.Healing
    			di.Scanning = info.Scanning
    			di.State = diskErrToDriveState(err)
    			di.FreeInodes = info.FreeInodes
    			di.UsedInodes = info.UsedInodes
    			if info.Healing {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 16K bytes
    - Viewed (0)
  7. internal/logger/target/kafka/kafka.go

    	sconfig.Net.TLS.Config = tlsConfig
    	sconfig.Net.TLS.Config.InsecureSkipVerify = h.kconfig.TLS.SkipVerify
    	sconfig.Net.TLS.Config.ClientAuth = h.kconfig.TLS.ClientAuth
    	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
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Jun 02 03:03:39 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  8. internal/event/target/kafka.go

    	config.Net.TLS.Config = tlsConfig
    	config.Net.TLS.Config.InsecureSkipVerify = args.TLS.SkipVerify
    	config.Net.TLS.Config.ClientAuth = args.TLS.ClientAuth
    	config.Net.TLS.Config.RootCAs = args.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
    	config.Producer.Retry.Max = 2
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Jun 01 15:02:59 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/endpoints/filters/authentication_test.go

    		},
    		{
    			name:                   "other skip=true",
    			authorizationHeader:    "other",
    			skipHTTP2DOSMitigation: true,
    			expectConnections:      1,
    		},
    	}
    
    	rootCAs := x509.NewCertPool()
    	rootCAs.AddCert(s.Certificate())
    
    	for _, tc := range cases {
    		t.Run(tc.name, func(t *testing.T) {
    			f := func(t *testing.T, nextProto string, expectConnections uint64) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  10. pkg/spiffe/spiffe.go

    		blockBytes = append(blockBytes, block.Bytes...)
    		block, rest = pem.Decode(rest)
    	}
    
    	rootCAs, err := x509.ParseCertificates(blockBytes)
    	if err != nil {
    		spiffeLog.Errorf("parse certificate from rootPEM got error: %v", err)
    		return fmt.Errorf("parse certificate from rootPEM got error: %v", err)
    	}
    
    	v.AddMapping(trustDomain, rootCAs)
    	return nil
    }
    
    // AddMappings merges a trust domain to certs map to the certPools map.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.1K bytes
    - Viewed (0)
Back to top