group_subscription

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

type PublishMessage struct {
	From    subscription.SubscriberID
	Seq     int64
	Type    int
	Message *messages.GlideMessage
}

type SubscribeWrap interface {
	Subscribe(ch subscription.ChanID, id subscription.SubscriberID, update interface{}) error

	UnSubscribe(ch subscription.ChanID, id subscription.SubscriberID) error

	UpdateSubscriber(ch subscription.ChanID, id subscription.SubscriberID, update interface{}) error

	RemoveChannel(ch subscription.ChanID) error

	CreateChannel(ch subscription.ChanID, update *subscription.ChanInfo) error

	UpdateChannel(ch subscription.ChanID, update *subscription.ChanInfo) error

	Publish(ch subscription.ChanID, msg subscription.Message) error
}