hub

type ActionMessage struct {
	Action  string      `json:"action"`
	Payload interface{} `json:"payload"`
}

type Broker struct {
	Hub
}

type BrokerOption func(*Broker)

type Client struct {
	ID string

	Topics []string
	// contains filtered or unexported fields
}

type ConnMessage struct {
	AuthID          string `json:"AuthID"`
	AccessToken     string `json:"access_token"`
	ImpersonationID int    `json:"impersonationID"`
	Topics          []string
}

type Hub struct {

	// protects connections
	sync.Mutex

	OnSubscribe func(*Subscription)
	// contains filtered or unexported fields
}

type MailMessage struct {
	Action   string      `json:"action"`
	Topic    string      `json:"topic"`
	SubTopic string      `json:"subtopic"`
	Message  interface{} `json:"message"`
}

type Notifier interface {
	Notify(s string)
}

type PublishMessage struct {
	Topic   string `json:"topic"`
	Payload []byte `json:"payload"`
}

type Subscription struct {
	Topic  string
	Client *Client
}

type SubscriptionsMessage struct {
	Topics []string `json:"payload"`
}