handlers

package

v0.0.0-...-1463f4f Latest Latest Go to latest Published: Feb 16, 2019 License: Apache-2.0 Imports: 14 Imported by: 1

Details

Package handlers : handle MQTT message and deploy object to kubernetes.

license: Apache license 2.0
copyright: Nobuyuki Matsui <[email protected]>

Package handlers : handle MQTT message and deploy object to kubernetes.

license: Apache license 2.0
copyright: Nobuyuki Matsui <[email protected]>

Package handlers : handle MQTT message and deploy object to kubernetes.

license: Apache license 2.0
copyright: Nobuyuki Matsui <[email protected]>

Package handlers : handle MQTT message and deploy object to kubernetes.

license: Apache license 2.0
copyright: Nobuyuki Matsui <[email protected]>

Package handlers : handle MQTT message and deploy object to kubernetes.

license: Apache license 2.0
copyright: Nobuyuki Matsui <[email protected]>

Package handlers : handle MQTT message and deploy object to kubernetes.

license: Apache license 2.0
copyright: Nobuyuki Matsui <[email protected]>

This section is empty.

This section is empty.

This section is empty.

type HandlerInf interface {
	Apply(runtime.Object) string
	Delete(runtime.Object) string
}

HandlerInf : a interface to specify the method signatures that an object handler should be implemented.

type MessageHandler struct {
	// contains filtered or unexported fields
}

MessageHandler : a struct handling object handlers to deploy an object generated from MQTT message.

func NewMessageHandler(clientset *kubernetes.Clientset, logger *zap.SugaredLogger, deviceType string, deviceID string) *MessageHandler

NewMessageHandler : a factory method to create MessageHandler.

func (h *MessageHandler) Command() mqtt.MessageHandler

Command : a method which return a function called when receiving a new MQTT message.

func (h *MessageHandler) GetCmdExeTopic() string

GetCmdExeTopic : get the command result topic name

func (h *MessageHandler) GetCmdTopic() string

GetCmdTopic : get the command topic name