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 ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.