Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for Chaves (0.42 sec)

  1. callbacks.go

    				} else if curIdx < sortedIdx {
    					return fmt.Errorf("conflicting callback %s with before %s", c.name, c.after)
    				}
    			} else if idx := getRIndex(names, c.after); idx != -1 {
    				// if after callback exists but haven't sorted
    				// set after callback's before callback to current callback
    				after := cs[idx]
    
    				if after.before == "" {
    					after.before = c.name
    				}
    
    				if err := sortCallback(after); err != nil {
    Go
    - Registered: Sun Apr 28 09:35:09 GMT 2024
    - Last Modified: Tue Mar 26 03:33:36 GMT 2024
    - 8.6K bytes
    - Viewed (1)
  2. internal/event/target/mqtt.go

    			return nil
    		}
    		return err
    	}
    
    	if err = target.send(eventData); err != nil {
    		return err
    	}
    
    	// Delete the event from store.
    	return target.store.Del(key.Name)
    }
    
    // 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 8.2K bytes
    - Viewed (0)
Back to top