routing

type Auth struct {
	UID  string
	Role string
}

type Client struct {

	// User ID if authorized
	Auth Auth
	// contains filtered or unexported fields
}

type Event struct {
	Scope  string      // global, public, private
	Stream string      // channel routing key
	Type   string      // event type
	Topic  string      // topic routing key (stream.type)
	Body   interface{} // event json body
}

type Hub struct {
	// Register Requests from the clients.
	Requests chan Request

	// Unregister requests from clients.
	Unregister chan IClient

	// List of clients registered to public topics
	PublicTopics map[string]*Topic

	// List of clients registered to private topics
	PrivateTopics map[string]map[string]*Topic

	// map[prefix -> map[topic -> *Topic]]
	PrefixedTopics map[string]map[string]*Topic

	// Storage for incremental objects
	IncrementalObjects map[string]*IncrementalObject

	// map[prefix -> allowed roles]
	RBAC map[string][]string
	// contains filtered or unexported fields
}

type IClient interface {
	Send(string)
	Close()
	GetAuth() Auth
	GetSubscriptions() []string
	SubscribePublic(string)
	SubscribePrivate(string)
	UnsubscribePublic(string)
	UnsubscribePrivate(string)
}

type IncrementalObject struct {
	Snapshot   string
	Increments []string
}

type Request struct {
	msg.Request
	// contains filtered or unexported fields
}

type Topic struct {
	// contains filtered or unexported fields
}