- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 66 for cfg (0.12 sec)
-
cni/pkg/nodeagent/server.go
if err != nil { return nil, fmt.Errorf("error initializing kube client: %w", err) } cfg := &iptables.Config{ RestoreFormat: true, RedirectDNS: args.DNSCapture, EnableIPv6: args.EnableIPv6, } log.Debug("creating ipsets in the node netns") set, err := createHostsideProbeIpset(cfg.EnableIPv6) if err != nil { return nil, fmt.Errorf("error initializing hostside probe ipset: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
package kafka import ( "crypto/sha512" "strings" "github.com/IBM/sarama" "github.com/xdg/scram" "github.com/minio/minio/internal/hash/sha256" ) func initScramClient(cfg Config, config *sarama.Config) { switch strings.ToLower(cfg.SASL.Mechanism) { case "sha512": config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: KafkaSHA512} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1) -
cmd/bucket-quota.go
type BucketQuotaSys struct{} // Get - Get quota configuration. func (sys *BucketQuotaSys) Get(ctx context.Context, bucketName string) (*madmin.BucketQuota, error) { cfg, _, err := globalBucketMetadataSys.GetQuotaConfig(ctx, bucketName) return cfg, err } // NewBucketQuotaSys returns initialized BucketQuotaSys func NewBucketQuotaSys() *BucketQuotaSys { return &BucketQuotaSys{} }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.3K bytes - Viewed (0) -
src/test/java/jcifs/tests/NamingTest.java
prop.setProperty("jcifs.resolveOrder", "WINS"); prop.setProperty("jcifs.netbios.wins", getRequiredProperty("jcifs.netbios.wins")); PropertyConfiguration cfg = new PropertyConfiguration(prop); BaseContext c = new BaseContext(cfg); c.getNameServiceClient().getByName(getRequiredProperty("test.server.netbios")); c.getNameServiceClient().getAllByName(getRequiredProperty("test.server.netbios"), true);
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sat Jun 06 10:48:05 GMT 2020 - 7K bytes - Viewed (0) -
internal/bucket/replication/rule_test.go
expectedResult: true, }, } for i, tc := range testCases { tc := tc t.Run(fmt.Sprintf("Test_%d", i+1), func(t *testing.T) { cfg, err := ParseConfig(bytes.NewReader([]byte(tc.inputConfig))) if err != nil { t.Fatalf("Got unexpected error: %v", err) } if got := cfg.Rules[0].MetadataReplicate(tc.opts); got != tc.expectedResult {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.6K bytes - Viewed (0) -
cmd/config.go
}) if err != nil { return err } } return saveConfig(ctx, objAPI, historyFile, kv) } func saveServerConfig(ctx context.Context, objAPI ObjectLayer, cfg interface{}) error { data, err := json.Marshal(cfg) if err != nil { return err } configFile := path.Join(minioConfigPrefix, minioConfigFile) if GlobalKMS != nil { data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComOpenAndX.java
else { this.openFunction = OPEN_FN_OPEN; } } } @Override protected int getBatchLimit ( Configuration cfg, byte cmd ) { return cmd == SMB_COM_READ_ANDX ? cfg.getBatchLimit("OpenAndX.ReadAndX") : 0; } @Override protected int writeParameterWordsWireFormat ( byte[] dst, int dstIndex ) { int start = dstIndex;
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 7K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10ExpressionInfoProvider.kt
import org.jetbrains.kotlin.analysis.api.lifetime.KtLifetimeToken import org.jetbrains.kotlin.analysis.api.lifetime.withValidityAssertion import org.jetbrains.kotlin.analysis.utils.printer.parentOfType import org.jetbrains.kotlin.cfg.WhenChecker import org.jetbrains.kotlin.diagnostics.WhenMissingCase import org.jetbrains.kotlin.psi.* import org.jetbrains.kotlin.resolve.BindingContext import org.jetbrains.kotlin.resolve.bindingContextUtil.isUsedAsExpression
Plain Text - Registered: Fri May 03 08:18:13 GMT 2024 - Last Modified: Wed Oct 05 15:06:52 GMT 2022 - 2.4K bytes - Viewed (0) -
.gitignore
/doc/articles/wiki/*.bin /goinstall.log /last-change /misc/cgo/life/run.out /misc/cgo/stdio/run.out /misc/cgo/testso/main /pkg/ /src/*.*/ /src/cmd/cgo/zdefaultcc.go /src/cmd/dist/dist /src/cmd/go/internal/cfg/zdefaultcc.go /src/cmd/internal/objabi/zbootstrap.go /src/go/build/zcgo.go /src/go/doc/headscan /src/internal/buildcfg/zbootstrap.go /src/runtime/internal/sys/zversion.go /src/unicode/maketables
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Thu Jun 22 19:44:52 GMT 2023 - 958 bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComSessionSetupAndX.java
} else { throw new SmbException("Unsupported"); } } @Override protected int getBatchLimit ( Configuration cfg, byte cmd ) { return cmd == SMB_COM_TREE_CONNECT_ANDX ? cfg.getBatchLimit("SessionSetupAndX.TreeConnectAndX") : 0; } @Override protected int writeParameterWordsWireFormat ( byte[] dst, int dstIndex ) {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Mar 17 10:20:23 GMT 2019 - 8.8K bytes - Viewed (0)