Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 134 for successfully (0.16 sec)

  1. internal/event/target/kafka.go

    		return target.addToBatch(key)
    	}
    
    	eventData, eErr := target.store.Get(key.Name)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 20 08:16:35 GMT 2024
    - 13K bytes
    - Viewed (0)
  2. internal/event/target/nats.go

    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key.Name)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    		return err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 27 18:11:55 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	var (
    		// We check every 15 seconds if the disk is writable and we can read back.
    		checkEvery = 15 * time.Second
    
    		// If the disk has completed an operation successfully within last 5 seconds, don't check it.
    		skipIfSuccessBefore = 5 * time.Second
    	)
    
    	// if disk max timeout is smaller than checkEvery window
    	// reduce checks by a second.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. internal/event/target/amqp.go

    		return err
    	}
    	defer ch.Close()
    
    	eventData, eErr := target.store.Get(key.Name)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData, ch, confirms); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 10K bytes
    - Viewed (0)
  5. internal/event/target/postgresql.go

    			}
    			return err
    		}
    	}
    
    	eventData, eErr := target.store.Get(key.Name)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:51:07 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  6. cmd/api-response.go

    	UserTags     string    `xml:"UserTags,omitempty"`
    
    	Internal *ObjectInternalInfo `xml:"Internal,omitempty"`
    }
    
    // CopyObjectResponse container returns ETag and LastModified of the successfully copied object
    type CopyObjectResponse struct {
    	XMLName      xml.Name `xml:"http://s3.amazonaws.com/doc/2006-03-01/ CopyObjectResult" json:"-"`
    	LastModified string   // time string of format "2006-01-02T15:04:05.000Z"
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 33.3K bytes
    - Viewed (2)
  7. internal/event/target/elasticsearch.go

    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key.Name)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 15K bytes
    - Viewed (0)
  8. cmd/format-erasure.go

    		}
    		// Migrate successful v1 => v2, proceed to v2 => v3
    		version = formatErasureVersionV2
    		fallthrough
    	case formatErasureVersionV2:
    		formatData, err = formatErasureMigrateV2ToV3(formatData, export, version)
    		if err != nil {
    			return nil, nil, fmt.Errorf("Drive %s: %w", export, err)
    		}
    		// Migrate successful v2 => v3, v3 is latest
    		// version = formatXLVersionV3
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  9. docs/sts/web-identity.md

    `MINIO_IDENTITY_OPENID_DISPLAY_NAME` value is shown here). The user is then redirected to the OpenID provider's login page and performs necessary login actions (e.g. entering credentials, responding to MFA authentication challenges, etc). After successful login, the user is redirected back to the MinIO console. This redirect URL is specified as a parameter by MinIO when the user is redirected to the OpenID Provider in the beginning. For some setups, extra configuration may be required for this step...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  10. cmd/erasure-object_test.go

    		gr.Close()
    	}
    
    	// Test use case 2: Make 9 disks offline, which leaves less than quorum number of disks
    	// in a 16 disk Erasure setup. The original disks are 'replaced' with
    	// naughtyDisks that fail after 'f' successful StorageAPI method
    	// invocations, where f - [0,2)
    
    	// Create "object" under "bucket".
    	_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader(buf), int64(len(buf)), "", ""), opts)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
Back to top