Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 246 for rubbish (0.1 sec)

  1. cmd/ftp-server-driver.go

    		},
    	}
    }
    
    func (m *ftpMetrics) log(s *ftp.Context, paths ...string) func(sz int64, err error) {
    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(ftpTrace(s, startTime, source, strings.Join(paths, " "), err, sz))
    	}
    }
    
    // Stat implements ftpDriver
    func (driver *ftpDriver) Stat(ctx *ftp.Context, objPath string) (fi os.FileInfo, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  2. licenses/sigs.k8s.io/yaml/LICENSE

    of this software and associated documentation files (the "Software"), to deal
    in the Software without restriction, including without limitation the rights
    to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
    copies of the Software, and to permit persons to whom the Software is
    furnished to do so, subject to the following conditions:
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 31 19:53:28 UTC 2023
    - 15.8K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    	var wg sync.WaitGroup
    	publish := func(in <-chan MetricV2) {
    		defer wg.Done()
    		for metric := range in {
    			labels, values := getOrderedLabelValueArrays(metric.VariableLabels)
    			collectMetric(metric, labels, values, "bucket", out)
    		}
    	}
    
    	// Call peer api to fetch metrics
    	wg.Add(2)
    	go publish(ReportMetrics(GlobalContext, c.metricsGroups))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  4. cmd/data-scanner-metric.go

    		atomic.AddUint64(&p.operations[s], 1)
    		if s < scannerMetricLastRealtime {
    			p.latency[s].add(duration)
    		}
    
    		if s > scannerMetricStartTrace && globalTrace.NumSubscribers(madmin.TraceScanner) > 0 {
    			globalTrace.Publish(scannerTrace(s, startTime, duration, strings.Join(paths, " "), custom))
    		}
    	}
    }
    
    // time a scanner action.
    // Use for s < scannerMetricLastRealtime
    func (p *scannerMetrics) time(s scannerMetric) func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 25 05:15:31 UTC 2023
    - 9.1K bytes
    - Viewed (0)
  5. internal/event/target/amqp.go

    	if err = ch.ExchangeDeclare(target.args.Exchange, target.args.ExchangeType, target.args.Durable,
    		target.args.AutoDeleted, target.args.Internal, target.args.NoWait, nil); err != nil {
    		return err
    	}
    
    	if err = ch.Publish(target.args.Exchange, target.args.RoutingKey, target.args.Mandatory,
    		target.args.Immediate, amqp091.Publishing{
    			Headers:      headers,
    			ContentType:  "application/json",
    			DeliveryMode: target.args.DeliveryMode,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  6. cmd/sftp-server-driver.go

    		},
    	}
    }
    
    func (m *sftpMetrics) log(s *sftp.Request, user string) func(sz int64, err error) {
    	startTime := time.Now()
    	source := getSource(2)
    	return func(sz int64, err error) {
    		globalTrace.Publish(sftpTrace(s, startTime, source, user, err, sz))
    	}
    }
    
    // NewSFTPDriver initializes sftp.Handlers implementation of following interfaces
    //
    // - sftp.Fileread
    // - sftp.Filewrite
    // - sftp.Filelist
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  7. apache-maven/src/main/appended-resources/licenses/CDDL+GPLv2-with-classpath-exception.txt

        sure the requirements of this License are fulfilled for the Covered
        Software.
    
    4. Versions of the License.
    
        4.1. New Versions.
    
        Oracle is the initial license steward and may publish revised and/or
        new versions of this License from time to time. Each version will be
        given a distinguishing version number. Except as provided in Section
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri May 17 19:14:22 UTC 2024
    - 38.5K bytes
    - Viewed (0)
  8. apache-maven/src/main/appended-resources/licenses/EPL-2.0.txt

    Everyone is permitted to copy and distribute copies of this Agreement,
    but in order to avoid inconsistency the Agreement is copyrighted and
    may only be modified in the following manner. The Agreement Steward
    reserves the right to publish new versions (including revisions) of
    this Agreement from time to time. No one other than the Agreement
    Steward has the right to modify this Agreement. The Eclipse Foundation
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Tue Jun 04 06:45:16 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  9. CREDITS

    of this software and associated documentation files (the "Software"), to deal
    in the Software without restriction, including without limitation the rights
    to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
    copies of the Software, and to permit persons to whom the Software is
    furnished to do so, subject to the following conditions:
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 1.6M bytes
    - Viewed (0)
  10. LICENSE

    technological measures.
    
      4. Conveying Verbatim Copies.
    
      You may convey verbatim copies of the Program's source code as you
    receive it, in any medium, provided that you conspicuously and
    appropriately publish on each copy an appropriate copyright notice;
    keep intact all notices stating that this License and any
    non-permissive terms added in accord with section 7 apply to the code;
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 33.7K bytes
    - Viewed (0)
Back to top