Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 296 for save3_ (0.05 sec)

  1. cmd/erasure-server-pool-decom.go

    		}
    		p.Pools[idx].LastUpdate = now
    		if err := p.save(ctx, pools); err != nil {
    			return false, err
    		}
    		return true, nil
    	}
    	return false, nil
    }
    
    func (p poolMeta) save(ctx context.Context, pools []*erasureSets) error {
    	if p.dontSave {
    		return nil
    	}
    	data := make([]byte, 4, p.Msgsize()+4)
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 42.2K bytes
    - Viewed (1)
  2. cmd/site-replication-utils.go

    	}
    	for b, st := range rs.BucketStatuses {
    		if st == ResyncFailed {
    			m.FailedBuckets = append(m.FailedBuckets, b)
    		}
    	}
    	return &m
    }
    
    // save in-memory stats to disk
    func (sm *siteResyncMetrics) save(ctx context.Context) {
    	sTimer := time.NewTimer(siteResyncSaveInterval)
    	defer sTimer.Stop()
    	for {
    		select {
    		case <-sTimer.C:
    			if globalSiteReplicationSys.isEnabled() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. internal/event/target/nsq.go

    		if xnet.IsConnRefusedErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the nsq connection is active.
    func (target *NSQTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    	if err := target.init(); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  4. internal/event/target/redis.go

    			return false, store.ErrNotConnected
    		}
    		return false, pingErr
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the redis connection is active.
    func (target *RedisTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  5. internal/event/target/mqtt.go

    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will
    // be replayed when the mqtt connection is active.
    func (target *MQTTTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  6. docs/en/docs/tutorial/body-updates.md

        "price": 3,
        "description": None,
    }
    ```
    
    because it doesn't include the already stored attribute `"tax": 20.2`, the input model would take the default value of `"tax": 10.5`.
    
    And the data would be saved with that "new" `tax` of `10.5`.
    
    ## Partial updates with `PATCH` { #partial-updates-with-patch }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Dec 20 15:55:38 UTC 2025
    - 4.1K bytes
    - Viewed (0)
  7. internal/event/target/kafka.go

    	brokers := target.client.Brokers()
    	if len(brokers) == 0 {
    		return false, store.ErrNotConnected
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the Kafka connection is active.
    func (target *KafkaTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		if target.batch != nil {
    			return target.batch.Add(eventData)
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  8. internal/event/target/amqp.go

    		if !confirmed.Ack {
    			return fmt.Errorf("failed delivery of delivery tag: %d", confirmed.DeliveryTag)
    		}
    	}
    
    	return nil
    }
    
    // Save - saves the events to the store which will be replayed when the amqp connection is active.
    func (target *AMQPTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    	if err := target.init(); err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 21 04:25:07 UTC 2025
    - 10K bytes
    - Viewed (0)
  9. internal/event/target/postgresql.go

    		if IsConnErr(err) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	return true, nil
    }
    
    // Save - saves the events to the store if questore is configured, which will be replayed when the PostgreSQL connection is active.
    func (target *PostgreSQLTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  10. cmd/bucket-metadata-sys.go

    	}
    
    	return updatedAt, sys.save(ctx, meta)
    }
    
    func (sys *BucketMetadataSys) save(ctx context.Context, meta BucketMetadata) error {
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	if isMinioMetaBucketName(meta.Name) {
    		return errInvalidArgument
    	}
    
    	if err := meta.Save(ctx, objAPI); err != nil {
    		return err
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.4K bytes
    - Viewed (0)
Back to top