busutils

Documentation

Index

• func DisableSchedule(logger *zap.Logger, bus busTY.Plugin, id string)
• func DisableTask(logger *zap.Logger, bus busTY.Plugin, id string)
• func EnableTask(logger *zap.Logger, bus busTY.Plugin, id string)
• func PostEvent(logger *zap.Logger, bus busTY.Plugin, eventTopic, eventType, entityType string, ...)
• func PostServiceEvent(logger *zap.Logger, bus busTY.Plugin, ...)
• func PostShutdownEvent(logger *zap.Logger, bus busTY.Plugin)
• func PostToHandler(logger *zap.Logger, bus busTY.Plugin, handlers []string, ...)
• func PostToResourceService(logger *zap.Logger, bus busTY.Plugin, id string, data interface{}, ...)
• func PostToService(logger *zap.Logger, bus busTY.Plugin, serviceTopic, id string, ...)
• func SetGatewayState(logger *zap.Logger, bus busTY.Plugin, id string, state types.State)
• func SetHandlerState(logger *zap.Logger, bus busTY.Plugin, id string, state types.State)
• func SetScheduleState(logger *zap.Logger, bus busTY.Plugin, id string, state schedulerTY.State)
• func SetTaskState(logger *zap.Logger, bus busTY.Plugin, id string, state taskTY.State)
• func SetVirtualAssistantState(logger *zap.Logger, bus busTY.Plugin, id string, state types.State)

Functions

func DisableSchedule

func DisableSchedule(logger *zap.Logger, bus busTY.Plugin, id string)

DisableSchedule sends id to resource service

func DisableTask

func DisableTask(logger *zap.Logger, bus busTY.Plugin, id string)

DisableTask sends id to resource service

func EnableTask

func EnableTask(logger *zap.Logger, bus busTY.Plugin, id string)

EnableTask sends id to resource service

func PostEvent

func PostEvent(logger *zap.Logger, bus busTY.Plugin, eventTopic, eventType, entityType string, entity interface{})

PostEvent sends resource as event.

func PostServiceEvent

func PostServiceEvent(logger *zap.Logger, bus busTY.Plugin, topic, serviceType, serviceCommand, data string)

PostEvent sends job change notification.

func PostShutdownEvent

func PostShutdownEvent(logger *zap.Logger, bus busTY.Plugin)

PostShutdownEvent asks the system to shutdown

func PostToHandler

func PostToHandler(logger *zap.Logger, bus busTY.Plugin, handlers []string, parameters map[string]interface{})

PostToHandler send data to handlers

func PostToResourceService

func PostToResourceService(logger *zap.Logger, bus busTY.Plugin, id string, data interface{}, serviceType, command, replyTopic string)

PostToResourceService to resource service

func PostToService

func PostToService(logger *zap.Logger, bus busTY.Plugin, serviceTopic, id string, data interface{}, serviceType, command, replyTopic string)

PostToService posts to a service

func SetGatewayState

func SetGatewayState(logger *zap.Logger, bus busTY.Plugin, id string, state types.State)

SetGatewayState send gateway status into bus

func SetHandlerState

func SetHandlerState(logger *zap.Logger, bus busTY.Plugin, id string, state types.State)

SetHandlerState send handler status into bus

func SetScheduleState

func SetScheduleState(logger *zap.Logger, bus busTY.Plugin, id string, state schedulerTY.State)

SetScheduleState send handler status into bus

func SetTaskState

func SetTaskState(logger *zap.Logger, bus busTY.Plugin, id string, state taskTY.State)

SetTaskState send handler status into bus

func SetVirtualAssistantState

func SetVirtualAssistantState(logger *zap.Logger, bus busTY.Plugin, id string, state types.State)

SetVirtualAssistantState send assistant status into bus