core

type Dispatcher interface {
	Dispatch(sess Session, req Request)
}

type Hub interface {
	Start() error
	Stop() error
	Subscribe(ssid string, sub Subscriber) (*Subscription, error)
	UnSubscribe(subscription *Subscription)
	Publish(kv *KV)
}

type HubDispatcher interface {
	Hub
	Dispatcher
}

type KV struct {
	Key []byte
	Val []byte
}

type LocalPeer interface {
	Name() string
	SetRouter(Router)
	Notify(PeerRouter, ...MethodPath)
	Request(PeerRouter, proto.Message) (proto.Message, error)
}

type MethodPath interface {
	String() string
}

type PeerRouter interface {
	PeerName() string
	SetPeerName(name string)
	AppName() string
	Equals(pr PeerRouter) bool
	String() string
}

type PeerRouters []PeerRouter

type Request []byte

type RequestCheck struct {
	LoginMP   MethodPath
	WhiteList []MethodPath
	// contains filtered or unexported fields
}

type Router interface {
	//获取路由分流指向
	RouteIn(mp MethodPath, id string, request proto.Message) (response proto.Message, err error)
	//根据peerRouter将request定向到指定Grpc服务并返回结果
	RouteOut(pr PeerRouter, request proto.Message) (response proto.Message, err error)
	//注册单个
	//appName 资源服务名称
	//peer 节点名称（空字符串为本地）
	//address  资源服务连接地址（ps:www.example.com:8080）
	Register(mps []MethodPath, pr PeerRouter, address string) error
	//注销app下所有
	UnRegisterApp(pr PeerRouter)
	//注销peer下所有
	UnRegisterPeer(peerName string)
}

type Session interface {
	io.WriteCloser
	GetID() string
	GetUserId() string
	Send(message proto.Message) error
	LoggedIn() bool
	SetUserId(userId string)
}

type Subscriber = Session

type Subscription struct {
	Ssid string
	Sub  Subscriber
}