pubsub

type IPubSub interface {
	AddSubscriber(conn *SubscriberConnectionOpts) *Subscriber
	RemoveSubscriber(conn *SubscriberConnectionOpts) *Subscriber
	CountTopicSubscribers(topic string) int
	Sub(topics []string, conn *SubscriberConnectionOpts)
	Unsub(topics []string, conn *SubscriberConnectionOpts)
	Publish(topic []string, msg string)
	Broadcast(msg string)
}

type ISubscriber interface {
	GetSubID() string
	GetID() string
	GetUID() string
	AddTopic(topic string)
	AddTopics(topics []string)
	RemoveTopic(topic string)
	GetTopics() []string
	Destroy()
	Notify(msg *Message)
	Listen()
}

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

type OnNotifyFn = func(conn *SubscriberConnectionOpts, msg *Message)

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

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

type SubscriberConnectionOpts struct {
	CID string // ws connection uuid
	UID string // associated user id
}

type Subscribers map[string]*Subscriber

type Topics map[string]Subscribers