- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 3,975 for nile (0.16 sec)
-
cmd/post-policy_test.go
w.WriteField(k, v) } // Set the File formData but don't if we want send an incomplete multipart request if !corruptedMultipart { var writer io.Writer var err error if noFilename { writer, err = w.CreateFormField("file") } else { writer, err = w.CreateFormFile("file", "upload.txt") } if err != nil { // return nil, err return nil, err } writer.Write(objData)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
internal/event/target/redis.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/notification.go
ng.Go(ctx, func() error { if client == nil { return errPeerNotReachable } bs, err := client.GetBucketStats(bucketName) if err != nil { return err } bucketStats[index] = bs return nil }, index, *client.host) } for _, nErr := range ng.Wait() { reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress", nErr.Host.String()) if nErr.Err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelProblemCollector.java
/* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at *
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 6.3K bytes - Viewed (0) -
cmd/ftp-server.go
} switch tokens[0] { case "address": host, portStr, err := net.SplitHostPort(tokens[1]) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s (%v)", arg, err), "unable to start FTP server") } port, err = strconv.Atoi(portStr) if err != nil { logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s (%v)", arg, err), "unable to start FTP server") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 4.8K bytes - Viewed (2) -
internal/disk/stat_linux_s390x.go
//go:build linux && s390x // +build linux,s390x // Copyright (c) 2015-2021 MinIO, Inc. // // This file is part of MinIO Object Storage stack // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU Affero General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 26 19:34:50 GMT 2024 - 2.6K bytes - Viewed (2) -
internal/config/notify/legacy.go
Value: strconv.Itoa(cfg.Producer.CompressionLevel), }, } return nil } // SetNotifyAMQP - helper for config migration from older config. func SetNotifyAMQP(s config.Config, amqpName string, cfg target.AMQPArgs) error { if !cfg.Enable { return nil } if err := cfg.Validate(); err != nil { return err } s[config.NotifyAMQPSubSys][amqpName] = config.KVS{ config.KV{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 13.1K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
if len(args) != 0 { return nil, cobra.ShellCompDirectiveNoFileComp } client, err := ctx.CLIClient() if err != nil { return nil, cobra.ShellCompDirectiveNoFileComp } nsName, err := getNamespacesName(client, toComplete) if err != nil { return nil, cobra.ShellCompDirectiveNoFileComp } return nsName, cobra.ShellCompDirectiveNoFileComp }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
ns := s.namespaces.Get(podNamespace, "") if ns == nil { return nil, fmt.Errorf("failed to find namespace %v", ns) } pod := s.pods.Get(podName, podNamespace) if util.PodRedirectionEnabled(ns, pod) { return pod, nil } return nil, nil } func (s *InformerHandlers) Start() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
var rights []byte if fd != nil { rights = unix.UnixRights(*fd) } err := z.u.SetWriteDeadline(time.Now().Add(readWriteDeadline)) if err != nil { return nil, err } _, _, err = z.u.WriteMsgUnix(data, rights, nil) if err != nil { return nil, err } // wait for ack return z.readMessage(readWriteDeadline) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0)