- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for Confirm (5.38 sec)
-
cmd/sts-handlers_test.go
if err != nil { c.Fatalf("Unable to set user: %v", err) } err = s.adm.SetPolicy(ctx, policy, accessKey, false) if err != nil { c.Fatalf("Unable to set policy: %v", err) } // confirm that the user is able to access the bucket uClient := s.getUserClient(c, accessKey, secretKey, "") versions := c.mustUploadReturnVersions(ctx, uClient, bucket) c.mustNotDelete(ctx, uClient, bucket, versions[0])
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/erasure-server-pool.go
} defPool = pinfo if !isErrObjectNotFound(pinfo.Err) { return pinfo, noReadQuorumPools, pinfo.Err } // No object exists or its a delete marker, // check objInfo to confirm. if pinfo.ObjInfo.DeleteMarker && pinfo.ObjInfo.Name != "" { return pinfo, noReadQuorumPools, nil } } if opts.ReplicationRequest && opts.DeleteMarker && defPool.Index >= 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if target.client != nil { return nil } clientV7, err := newClientV7(target.args) if err != nil { return err } // Check es version to confirm if it is supported. serverSupportStatus, version, err := clientV7.getServerSupportStatus(ctx) if err != nil { return err } switch serverSupportStatus { case ESSUnknown:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
cmd/testdata/undeleteable-object.tgz
outing_key","value":""},{"key":"mandatory","value":"off"},{"key":"durable","value":"off"},{"key":"no_wait","value":"off"},{"key":"internal","value":"off"},{"key":"auto_deleted","value":"off"},{"key":"delivery_mode","value":"0"},{"key":"publisher_confirms","value":"off"},{"key":"queue_limit","value":"0"},{"key":"queue_dir","value":""}]},"notify_elasticsearch":{"_":[{"key":"enable","value":"off"},{"key":"url","value":""},{"key":"format","value":"namespace"},{"key":"index","value":""},{"key":"queue...
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Viewed (0) -
internal/grid/muxserver.go
m.handleInbound(c, inbound, handlerIn) }(m.inbound) } // Fill outbound block. // Each token represents a message that can be sent to the client without blocking. // The client will refill the tokens as they confirm delivery of the messages. for i := 0; i < outboundCap; i++ { m.outBlock <- struct{}{} } // Handler goroutine. var handlerErr atomic.Pointer[RemoteErr] go func() { wg.Wait()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
internal/config/notify/help.go
Optional: true, Type: "number", }, config.HelpKV{ Key: target.AmqpPublisherConfirms, Description: "enable consumer acknowledgement and publisher confirms, use this along with queue_dir for guaranteed delivery of all events", Optional: true, Type: "on|off", }, config.HelpKV{ Key: target.AmqpQueueDir, Description: queueDirComment,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 18.8K bytes - Viewed (0)