Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 289 for saveCh (0.16 sec)

  1. internal/event/target/nats.go

    				return false, store.ErrNotConnected
    			}
    			return false, connErr
    		}
    	}
    
    	return true, nil
    }
    
    // Save - saves the events to the store which will be replayed when the Nats connection is active.
    func (target *NATSTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    
    	if err := target.init(); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/services/InterpolatorException.java

         * automatically incorporated in this exception's detail message.</p>
         *
         * @param message the detail message (which is saved for later retrieval
         *                by the {@link #getMessage()} method).
         * @param cause   the cause (which is saved for later retrieval by the
         *                {@link #getCause()} method). A {@code null} value is
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Wed Oct 02 21:26:05 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    				User:    req.User,
    				Elapsed: time.Since(req.Started),
    			})
    		}
    	}
    
    	batchLogIf(ctx, json.NewEncoder(w).Encode(&listResult))
    }
    
    // BatchJobStatus - returns the status of a batch job saved in the disk
    func (a adminAPIHandlers) BatchJobStatus(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.ListBatchJobsAction)
    	if objectAPI == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. internal/event/target/elasticsearch.go

    	if err != nil {
    		return false, err
    	}
    
    	return target.client.ping(ctx, target.args)
    }
    
    // Save - saves the events to the store if queuestore is configured, which will be replayed when the elasticsearch connection is active.
    func (target *ElasticsearchTarget) Save(eventData event.Event) error {
    	if target.store != nil {
    		_, err := target.store.Put(eventData)
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  5. cmd/signature-v4-parser.go

    	var s3Err APIErrorCode
    	// Save credential values.
    	signV4Values.Credential, s3Err = parseCredentialHeader(strings.TrimSpace(credElement), region, stype)
    	if s3Err != ErrNone {
    		return sv, s3Err
    	}
    
    	// Save signed headers.
    	signV4Values.SignedHeaders, s3Err = parseSignedHeader(authFields[1])
    	if s3Err != ErrNone {
    		return sv, s3Err
    	}
    
    	// Save signature.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  6. tests/update_belongs_to_test.go

    	user.Manager = &User{Name: "manager-belongs-to-association"}
    	if err := DB.Save(&user).Error; err != nil {
    		t.Fatalf("errors happened when update: %v", err)
    	}
    
    	var user2 User
    	DB.Preload("Company").Preload("Manager").Find(&user2, "id = ?", user.ID)
    	CheckUser(t, user2, user)
    
    	user.Company.Name += "new"
    	user.Manager.Name += "new"
    	if err := DB.Save(&user).Error; err != nil {
    		t.Fatalf("errors happened when update: %v", err)
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jul 14 06:55:54 UTC 2022
    - 1.6K bytes
    - Viewed (0)
  7. docs_src/extra_models/tutorial002.py

    
    def fake_save_user(user_in: UserIn):
        hashed_password = fake_password_hasher(user_in.password)
        user_in_db = UserInDB(**user_in.dict(), hashed_password=hashed_password)
        print("User saved! ..not really")
        return user_in_db
    
    
    @app.post("/user/", response_model=UserOut)
    async def create_user(user_in: UserIn):
        user_saved = fake_save_user(user_in)
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat May 14 11:59:59 UTC 2022
    - 824 bytes
    - Viewed (0)
  8. cmd/server-startup-msg.go

    	}
    	return newAPIEndpoints
    }
    
    // Prints common server startup message. Prints credential, region and browser access.
    func printServerCommonMsg(apiEndpoints []string) {
    	// Get saved credentials.
    	cred := globalActiveCred
    
    	// Get saved region.
    	region := globalSite.Region()
    
    	apiEndpointStr := strings.TrimSpace(strings.Join(apiEndpoints, "  "))
    	// Colorize the message and print.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 23 14:11:35 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  9. tests/update_has_many_test.go

    	}
    
    	user.Pets = []*Pet{{Name: "pet1"}, {Name: "pet2"}}
    	if err := DB.Save(&user).Error; err != nil {
    		t.Fatalf("errors happened when update: %v", err)
    	}
    
    	var user2 User
    	DB.Preload("Pets").Find(&user2, "id = ?", user.ID)
    	CheckUser(t, user2, user)
    
    	for _, pet := range user.Pets {
    		pet.Name += "new"
    	}
    
    	if err := DB.Save(&user).Error; err != nil {
    		t.Fatalf("errors happened when update: %v", err)
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 2K bytes
    - Viewed (0)
  10. tests/non_std_test.go

    	if err := DB.AutoMigrate(&Animal{}); err != nil {
    		t.Fatalf("no error should happen when migrate but got %v", err)
    	}
    
    	animal := Animal{Name: "Ferdinand"}
    	DB.Save(&animal)
    	updatedAt1 := animal.UpdatedAt
    
    	DB.Save(&animal).Update("name", "Francis")
    	if updatedAt1.Format(time.RFC3339Nano) == animal.UpdatedAt.Format(time.RFC3339Nano) {
    		t.Errorf("UpdatedAt should be updated")
    	}
    
    	var animals []Animal
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
Back to top