bus

type Bus interface {
	Start()
	Publish(*Message) error
	Subscribe(*schema.User) *Subscription
	Unsubscribe(*Subscription)
	Stop() error
}

type Message struct {
	Command    string                 `json:"command"`
	State      string                 `json:"state"`
	Message    string                 `json:"message"`
	Attributes map[string]interface{} `json:"attributes"`
	CustomerID string                 `json:"customer_id"`
	BastionID  string                 `json:"bastion_id"`
}

type Subscription struct {
	CustomerID string
	Chan       chan *Message
}