Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 385 for jobs (0.42 sec)

  1. cmd/batch-rotate.go

    )
    
    // Start the batch key rottion job, resumes if there was a pending job via "job.ID"
    func (r *BatchJobKeyRotateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    		StartTime: job.Started,
    	}
    	if err := ri.loadOrInit(ctx, api, job); err != nil {
    		return err
    	}
    	if ri.Complete {
    		return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. cmd/metrics-v2_test.go

    	}
    	ticker := time.NewTicker(1 * time.Millisecond)
    	defer ticker.Stop()
    	for _, obs := range observations {
    		// Send observations once every 1ms, to simulate delay between
    		// observations. This is to test the channel based
    		// synchronization used internally.
    		select {
    		case <-ticker.C:
    			ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 04 18:05:56 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/es/config/exentity/ScheduledJob.java

            ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).ifPresent(job -> {
                job.launchNow();
            }).orElse(() -> {
                throw new JobNotFoundException(this);
            });
        }
    
        public void stop() {
            ComponentUtil.getJobManager().findJobByUniqueOf(LaJobUnique.of(getId())).ifPresent(job -> {
                job.stopNow();
            }).orElse(() -> {
                throw new JobNotFoundException(this);
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. cmd/batch-expire_test.go

        endpoint: https://notify.endpoint # notification endpoint to receive job completion status
        token: Bearer xxxxx # optional authentication token for the notification endpoint
      
      retry:
        attempts: 10 # number of retries for the job before giving up
        delay: 500ms # least amount of delay between each retry
    `
    	var job BatchJobRequest
    	err := yaml.Unmarshal([]byte(expireYaml), &job)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  5. tests/serializer_test.go

    	Roles3                 *Roles                 `gorm:"serializer:json;not null"`
    	Contracts              map[string]interface{} `gorm:"serializer:json"`
    	JobInfo                Job                    `gorm:"type:bytes;serializer:gob"`
    	CreatedTime            int64                  `gorm:"serializer:unixtime;type:datetime"` // store time in db, use int as field type
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Apr 21 14:09:38 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/job/PurgeLogJob.java

                resultBuf.append(e.getMessage()).append("\n");
            }
    
            // purge job logs
            try {
                final int days = ComponentUtil.getFessConfig().getPurgeJobLogDay();
                if (days >= 0) {
                    jobLogService.deleteBefore(days);
                } else {
                    resultBuf.append("Skipped to purge job logs.\n");
                }
            } catch (final Exception e) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  7. docs/metrics/prometheus/alerts.md

            "alertname": "MinIOClusterTolerance",
            "instance": "localhost:9000",
            "job": "minio-job-node",
            "pool": "0",
            "server": "127.0.0.1:9000",
            "set": "0",
            "severity": "critical"
          },
          "annotations": {
            "description": "MinIO instance 127.0.0.1:9000 of job minio-job has tolerance <=0 for more than 5 minutes.",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 28 20:53:59 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.18.md

    ### Other notable announcements
    
    SIG Network is moving IPv6 to Beta in Kubernetes 1.18, after incrementing significantly the test coverage with new CI jobs.
    
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jun 16 17:18:28 UTC 2021
    - 373.2K bytes
    - Viewed (0)
  9. docs/metrics/prometheus/grafana/bucket/minio-bucket.json

        "list": [
          {
            "current": {
              "selected": true,
              "text": "minio-job-bucket",
              "value": "minio-job-bucket"
            },
            "datasource": {
              "type": "prometheus",
              "uid": "${DS_PROMETHEUS}"
            },
            "definition": "label_values(job)",
            "hide": 0,
            "includeAll": false,
            "multi": false,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 11:11:51 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  10. src/main/resources/fess_message_ru.properties

    errors.docid_not_found=Not found Doc ID:{0}
    errors.document_not_found=Not found URL of Doc ID:{0}
    errors.not_load_from_server=Could not load from this server: {0}
    errors.failed_to_start_job=Failed to start job {0}.
    errors.failed_to_stop_job=Failed to stop job {0}.
    errors.failed_to_download_synonym_file=Failed to download the Synonym file.
    errors.failed_to_upload_synonym_file=Failed to upload the Synonym file.
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri May 20 12:12:28 UTC 2022
    - 10.2K bytes
    - Viewed (0)
Back to top