bus

Documentation

Index

• func New(cfg *config.Config) (*bus, error)
• type Bus
• type Message
  • func (msg *Message) Validate() error
• type Subscription

Functions

func New

func New(cfg *config.Config) (*bus, error)

Types

type Bus

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

type Message

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"`
}

func (*Message) Validate

func (msg *Message) Validate() error

type Subscription

type Subscription struct {
	CustomerID string
	Chan       chan *Message
}