listener

Documentation

Index

• func HandleError(err error, _ *consumer.Consumer)
• func ImportTypesListenerFactory(control Controller) func(topic string, msg []byte, time time.Time) error
• func UsersListenerFactory(control Controller) func(topic string, msg []byte, time time.Time) error
• type Controller
• type UserCommandMsg

Functions

func HandleError

func HandleError(err error, _ *consumer.Consumer)

func ImportTypesListenerFactory

func ImportTypesListenerFactory(control Controller) func(topic string, msg []byte, time time.Time) error

func UsersListenerFactory

func UsersListenerFactory(control Controller) func(topic string, msg []byte, time time.Time) error

Types

type Controller

type Controller interface {
	SetImportTypeInDB(device model.ImportType) error
	DeleteImportTypeFromDB(id string) error
	DeleteUser(id string) error
}

type UserCommandMsg

type UserCommandMsg struct {
	Command string `json:"command"`
	Id      string `json:"id"`
}