subscription

type Chan struct {
}

type ChanID string

type ChanInfo struct {
	ID   ChanID
	Type ChanType

	Parent *ChanID
	Child  []ChanID
}

type ChanType int32

type Channel interface {
	Subscribe(id SubscriberID, extra interface{}) error

	Unsubscribe(id SubscriberID) error

	UpdateSubscribe(id SubscriberID, extra interface{}) error

	Update(extra interface{}) error

	Publish(msg Message) error

	Close() error
}

type ChannelUpdate struct {
	Flag int64

	Extra interface{}
}

type Interface interface {
	PublishMessage(id ChanID, message Message) error
}

type Message interface {
}

type Server interface {
	Subscribe

	Run() error
}

type Subscribe interface {
	Interface

	SetGateInterface(gate gate.Interface)

	UpdateSubscriber(id ChanID, updates []Update) error

	UpdateChannel(id ChanID, update ChannelUpdate) error
}

type Subscriber struct {
	ID   string
	Type string
}

type SubscriberID string

type Update struct {
	Flag int64
	ID   SubscriberID

	Extra interface{}
}