listener

Documentation

Index

• Variables
• type Controller
• type Listener
  • func ProcessListenerFactory(config config.Config, control Controller) (topic string, listener Listener, err error)
  • func UsersListenerFactory(config config.Config, control Controller) (topic string, listener Listener, err error)
• type UserCommandMsg

Variables

var Factories = []func(config config.Config, control Controller) (topic string, listener Listener, err error){}

Types

type Controller

type Controller interface {
	SetProcess(process model.Process) error
	DeleteProcess(id string) error
	HandleUserDelete(userId string) error
}

type Listener

type Listener func(msg []byte) (err error)

func ProcessListenerFactory

func ProcessListenerFactory(config config.Config, control Controller) (topic string, listener Listener, err error)

func UsersListenerFactory

func UsersListenerFactory(config config.Config, control Controller) (topic string, listener Listener, err error)

type UserCommandMsg

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