Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AbstractTrigger ¶
type AbstractTrigger struct { trigger.AbstractTrigger MQTTClient mqttclient.Client // contains filtered or unexported fields }
func NewAbstractTrigger ¶
func NewAbstractTrigger(parentLogger logger.Logger, workerAllocator worker.Allocator, configuration *Configuration, restartTriggerChan chan trigger.Trigger) (*AbstractTrigger, error)
func (*AbstractTrigger) Connect ¶
func (t *AbstractTrigger) Connect() error
func (*AbstractTrigger) GetConfig ¶
func (t *AbstractTrigger) GetConfig() map[string]interface{}
func (*AbstractTrigger) Start ¶
func (t *AbstractTrigger) Start(checkpoint functionconfig.Checkpoint) error
func (*AbstractTrigger) Stop ¶
func (t *AbstractTrigger) Stop(force bool) (functionconfig.Checkpoint, error)
type Configuration ¶
type Configuration struct { trigger.Configuration Subscriptions []Subscription ClientID string ProtocolVersion int }
func NewConfiguration ¶
func NewConfiguration(id string, triggerConfiguration *functionconfig.Trigger, runtimeConfiguration *runtime.Configuration) (*Configuration, error)
type Event ¶
type Event struct { nuclio.AbstractEvent // contains filtered or unexported fields }
Event allows access to the MQTT message
type Subscription ¶
Click to show internal directories.
Click to hide internal directories.