ssdr

type Handler func()

type MsgRegistry struct {
	Type RegistryMsgType
	// MsgRegisterReq
	Service string
	Id      string
	Addr    string
	// MsgServiceListResp
	PushStart bool
	PushEnd   bool
	Services  ServiceListValue
	// resp
	Success bool
	Error   error
}

type Registry struct {
	Addr        string
	ServiceList *ServiceList
	// contains filtered or unexported fields
}

type RegistryClient struct {
	RegistryAddr     string
	Conn             *websocket.Conn
	ServiceListValue ServiceListValue

	ServiceListUpdate chan ServiceListValue
	Quit              chan struct{}
	// contains filtered or unexported fields
}

type RegistryMsgType int

type RegistryService struct {
	Service string
	Id      string
	Addr    string
}

type RegistryServiceList map[string][]RegistryService

type Service []*ServiceNode

type ServiceList struct {
	Services ServiceListValue

	OnAddService Handler
	// contains filtered or unexported fields
}

type ServiceListValue map[string]Service

type ServiceNode struct {
	Id   string
	Addr string
}

type SubscribeHandler func(list ServiceListValue)