Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for InitOnce (0.13 sec)

  1. internal/event/target/mqtt.go

    		}
    		if m.QoS == 0 {
    			return errors.New("qos should be set to 1 or 2 if queueDir is set")
    		}
    	}
    
    	return nil
    }
    
    // MQTTTarget - MQTT target.
    type MQTTTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       MQTTArgs
    	client     mqtt.Client
    	store      store.Store[event.Event]
    	quitCh     chan struct{}
    	loggerOnce logger.LogOnce
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Oct 07 15:07:38 GMT 2023
    - 8.2K bytes
    - Viewed (0)
Back to top