module

type App interface {
	Options() Options
	Registry() registry.Registry
	Run(mods ...Module) error
	Logger() *glog.Logger
	GetRouteServer(filter string) (ServerSession, error) //获取经过筛选过的服务
	Call(ctx context.Context, serviceName string, fnc func(context.Context, *grpc.ClientConn) error) error
}

type Module interface {
	GetType() string //模块类型
	OnDestroy()
	OnInit(app App)
	Run(closeSig chan bool)
}

type Option func(*Options)

type Options struct {
	Version          string
	Debug            bool
	Tracing          Trace
	Log              *glog.Logger
	KillWaitTTL      time.Duration
	RegistryEnable   bool //是否使用注册中心
	Registry         registry.Registry
	RegisterInterval time.Duration
	RegisterTTL      time.Duration
	Port             int
	Selector         selector.Selector
	RPCExpired       time.Duration
}

type RPCModule interface {
	context.Context
	Module
}

type ServerSession interface {
	GetID() string
	GetName() string
	GetClient() *grpc.ClientConn
	GetApp() App
	GetNode() *registry.Node
	SetNode(node *registry.Node) (err error)
	Call(serviceName string, fnc func(*grpc.ClientConn, context.Context)) error
}

type Trace struct {
	Status bool
	Name   string
	URL    string
}