Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for push (0.15 sec)

  1. cmd/admin-handlers.go

    	local := globalLocalNodeName
    	if local == "" {
    		local = "127.0.0.1"
    	}
    
    	failedClients := make(map[int]struct{})
    
    	if globalIsDistErasure {
    		// Push binary to other servers
    		for idx, nerr := range globalNotificationSys.VerifyBinary(ctx, u, sha256Sum, releaseInfo, binC) {
    			if nerr.Err != nil {
    				peerResults[nerr.Host.String()] = madmin.ServerPeerUpdateStatus{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  2. internal/event/target/redis.go

    	if target.args.Format == event.AccessFormat {
    		data, err := json.Marshal([]RedisAccessEvent{{Event: []event.Event{eventData}, EventTime: eventData.EventTime}})
    		if err != nil {
    			return err
    		}
    		if _, err := conn.Do("RPUSH", target.args.Key, data); err != nil {
    			return err
    		}
    	}
    
    	return nil
    }
    
    // SendFromStore - reads an event from store and sends it to redis.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 19 04:37:54 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  3. cmd/object-handlers_test.go

    			err = decoder.Decode(multipartResponse)
    			if err != nil {
    				t.Errorf("MinIO %s: Error decoding the recorded response Body", instanceType)
    				return
    			}
    			// push the obtained upload ID from the response into the array.
    			testUploads.Lock()
    			testUploads.uploads = append(testUploads.uploads, multipartResponse.UploadID)
    			testUploads.Unlock()
    		}()
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top