Search Options

Results per page
Sort
Preferred Languages
Advance

Results 881 - 890 of 1,020 for err (0.02 sec)

  1. docs/lambda/README.md

    	"fmt"
    
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    func main() {
    	s3Client, err := minio.New("localhost:9000", &minio.Options{
    		Creds:  credentials.NewStaticV4("minioadmin", "minioadmin", ""),
    		Secure: false,
    	})
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	// Set lambda function target via `lambdaArn`
    	reqParams := make(url.Values)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Apr 04 19:15:28 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  2. docs/auditlog/auditlog-echo.go

    var port int
    
    func init() {
    	flag.IntVar(&port, "port", 8080, "Port to listen on")
    }
    
    func mainHandler(w http.ResponseWriter, r *http.Request) {
    	body, err := io.ReadAll(r.Body)
    	defer r.Body.Close()
    	if err != nil {
    		log.Printf("Error reading request body: %v", err)
    		w.WriteHeader(http.StatusBadRequest)
    		return
    	}
    
    	log.Printf(">>> %s %s\n", r.Method, r.URL.Path)
    	var out bytes.Buffer
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    	if err := registry.Register(prometheus.NewProcessCollector(prometheus.ProcessCollectorOpts{
    		Namespace:    minioNamespace,
    		ReportErrors: true,
    	})); err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	if err := registry.Register(prometheus.NewGoCollector()); err != nil {
    		logger.CriticalIf(GlobalContext, err)
    	}
    	gatherers := prometheus.Gatherers{
    		registry,
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/and.go

    		predCount++
    	}
    
    	if predCount < 2 {
    		return errXMLNotWellFormed
    	}
    
    	if a.ContainsDuplicateTag() {
    		return errDuplicateTagKey
    	}
    	for _, t := range a.Tags {
    		if err := t.Validate(); err != nil {
    			return err
    		}
    	}
    
    	if a.ObjectSizeGreaterThan < 0 || a.ObjectSizeLessThan < 0 {
    		return errXMLNotWellFormed
    	}
    	return nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. callbacks/delete.go

    			if !ok {
    				result, err := db.Statement.ConnPool.ExecContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...)
    				if db.AddError(err) == nil {
    					db.RowsAffected, _ = result.RowsAffected()
    				}
    
    				return
    			}
    
    			if rows, err := db.Statement.ConnPool.QueryContext(db.Statement.Context, db.Statement.SQL.String(), db.Statement.Vars...); db.AddError(err) == nil {
    				gorm.Scan(rows, db, mode)
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Fri Feb 25 02:48:23 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  6. internal/bucket/lifecycle/delmarker-expiration.go

    func (de *DelMarkerExpiration) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) error {
    	type delMarkerExpiration DelMarkerExpiration
    	var dexp delMarkerExpiration
    	err := dec.DecodeElement(&dexp, &start)
    	if err != nil {
    		return err
    	}
    
    	if dexp.Days <= 0 {
    		return errInvalidDaysDelMarkerExpiration
    	}
    
    	*de = DelMarkerExpiration(dexp)
    	return nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  7. cmd/metrics-v3-types.go

    func JoinLoaders(loaders ...MetricsLoaderFn) MetricsLoaderFn {
    	return func(ctx context.Context, m MetricValues, c *metricsCache) error {
    		for _, loader := range loaders {
    			if err := loader(ctx, m, c); err != nil {
    				return err
    			}
    		}
    		return nil
    	}
    }
    
    // BucketMetricsLoaderFn - represents a function to load metrics from the
    // metricsCache and the system for a given list of buckets.
    //
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 30 22:28:46 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. cmd/kms-router.go

    	kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter()
    
    	KMSVersions := []string{
    		kmsAPIVersionPrefix,
    	}
    
    	gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed))
    	if err != nil {
    		// Static params, so this is very unlikely.
    		logger.Fatal(err, "Unable to initialize server")
    	}
    
    	for _, version := range KMSVersions {
    		// KMS Status APIs
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  9. cmd/admin-server-info.go

    				continue
    			}
    			_, present := network[nodeName]
    			if !present {
    				if err := isServerResolvable(endpoint, 5*time.Second); err == nil {
    					network[nodeName] = string(madmin.ItemOnline)
    				} else {
    					if xnet.IsNetworkOrHostDown(err, false) {
    						network[nodeName] = string(madmin.ItemOffline)
    					} else if xnet.IsNetworkOrHostDown(err, true) {
    						network[nodeName] = "connection attempt timedout"
    					}
    				}
    			}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. src/cmd/asm/main.go

    		ctxt.Retpoline = true
    	}
    
    	ctxt.Bso = bufio.NewWriter(os.Stdout)
    	defer ctxt.Bso.Flush()
    
    	architecture.Init(ctxt)
    
    	// Create object file, write header.
    	buf, err := bio.Create(*flags.OutputFile)
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer buf.Close()
    
    	if !*flags.SymABIs {
    		buf.WriteString(objabi.HeaderString())
    		fmt.Fprintf(buf, "!\n")
    	}
    
    	// Set macros for GOEXPERIMENTs so we can easily switch
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Jun 21 19:58:04 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top