eventsourcing

Documentation

Index

• Variables
• func InitEventHandling(db interfaces.Persistence) (err error)
• func PublisGatewayRemove(id string) (err error)
• func PublishDeviceInstance(persistence interfaces.Persistence, instance model.DeviceInstance, ...) (err error)
• func PublishDeviceInstanceRemove(id string) (err error)
• func PublishDeviceInstances(persistence interfaces.Persistence, instances []model.DeviceInstance, ...) (err error)
• func PublishDeviceType(db interfaces.Persistence, dt model.DeviceType, owner string) (err error)
• func PublishDeviceTypeRemove(id string) (err error)
• func PublishGateway(gw model.Gateway, owner string) (err error)
• func PublishGatewayCommand(gw GatewayCommand) (err error)
• func PublishGatewayRef(gw model.GatewayRef, name string, owner string) (err error)
• func PublishHub(hub model.Hub, owner string, jwt jwt_http_router.Jwt, ...) (internalError error, userError error)
• func PublishValueType(vt model.ValueType, owner string) (err error)
• func PublishValueTypeRemove(id string) (err error)
• type DeviceTypeCommand
• type DeviceinstanceCommand
• type GatewayCommand
• type ValueTypeCommand

Variables

var AmqpConn *amqp_wrapper_lib.Connection

Functions

func InitEventHandling

func InitEventHandling(db interfaces.Persistence) (err error)

func PublisGatewayRemove

func PublisGatewayRemove(id string) (err error)

func PublishDeviceInstance

func PublishDeviceInstance(persistence interfaces.Persistence, instance model.DeviceInstance, creator string) (err error)

func PublishDeviceInstanceRemove

func PublishDeviceInstanceRemove(id string) (err error)

func PublishDeviceInstances

func PublishDeviceInstances(persistence interfaces.Persistence, instances []model.DeviceInstance, creator string) (err error)

func PublishDeviceType

func PublishDeviceType(db interfaces.Persistence, dt model.DeviceType, owner string) (err error)

func PublishDeviceTypeRemove

func PublishDeviceTypeRemove(id string) (err error)

func PublishGateway

func PublishGateway(gw model.Gateway, owner string) (err error)

func PublishGatewayCommand

func PublishGatewayCommand(gw GatewayCommand) (err error)

func PublishGatewayRef

func PublishGatewayRef(gw model.GatewayRef, name string, owner string) (err error)

func PublishHub

func PublishHub(hub model.Hub, owner string, jwt jwt_http_router.Jwt, db interfaces.Persistence) (internalError error, userError error)

func PublishValueType

func PublishValueType(vt model.ValueType, owner string) (err error)

func PublishValueTypeRemove

func PublishValueTypeRemove(id string) (err error)

Types

type DeviceTypeCommand

type DeviceTypeCommand struct {
	Command    string           `json:"command"`
	Id         string           `json:"id"`
	Owner      string           `json:"owner"`
	DeviceType model.DeviceType `json:"device_type"`
}

type DeviceinstanceCommand

type DeviceinstanceCommand struct {
	Command        string               `json:"command"`
	Id             string               `json:"id"`
	Owner          string               `json:"owner"`
	DeviceInstance model.DeviceInstance `json:"device_instance"`
}

type GatewayCommand

type GatewayCommand struct {
	Command string   `json:"command"`
	Id      string   `json:"id"`
	Owner   string   `json:"owner"`
	Name    string   `json:"name"`
	Hash    string   `json:"hash"`
	Devices []string `json:"devices"`
}

type ValueTypeCommand

type ValueTypeCommand struct {
	Command   string          `json:"command"`
	Id        string          `json:"id"`
	Owner     string          `json:"owner"`
	ValueType model.ValueType `json:"value_type"`
}