Documentation
¶
Index ¶
- func BuildClientBeat(req *restful.Request) (*model.ClientBeat, error)
- func BuildInstance(namespace string, req *restful.Request, onlybase bool) (*model.Instance, error)
- func NewUDPPushCenter(store *core.NacosDataStorage) (core.PushCenter, error)
- type DiscoverServer
- func (n *DiscoverServer) AddServiceAccess(ws *restful.WebService)
- func (n *DiscoverServer) DeRegisterInstance(req *restful.Request, rsp *restful.Response)
- func (n *DiscoverServer) GetClientServer() (*restful.WebService, error)
- func (n *DiscoverServer) Heartbeat(req *restful.Request, rsp *restful.Response)
- func (h *DiscoverServer) Initialize(opt *ServerOption) error
- func (n *DiscoverServer) ListInstances(req *restful.Request, rsp *restful.Response)
- func (n *DiscoverServer) ListServices(req *restful.Request, rsp *restful.Response)
- func (n *DiscoverServer) RegisterInstance(req *restful.Request, rsp *restful.Response)
- func (n *DiscoverServer) ServerHealthStatus(req *restful.Request, rsp *restful.Response)
- func (n *DiscoverServer) UpdateInstance(req *restful.Request, rsp *restful.Response)
- type ServerOption
- type UDPAckPacket
- type UDPNotifier
- type UdpPushCenter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildClientBeat ¶
func BuildClientBeat(req *restful.Request) (*model.ClientBeat, error)
func BuildInstance ¶
func NewUDPPushCenter ¶
func NewUDPPushCenter(store *core.NacosDataStorage) (core.PushCenter, error)
Types ¶
type DiscoverServer ¶
type DiscoverServer struct {
// contains filtered or unexported fields
}
func (*DiscoverServer) AddServiceAccess ¶
func (n *DiscoverServer) AddServiceAccess(ws *restful.WebService)
func (*DiscoverServer) DeRegisterInstance ¶
func (n *DiscoverServer) DeRegisterInstance(req *restful.Request, rsp *restful.Response)
func (*DiscoverServer) GetClientServer ¶
func (n *DiscoverServer) GetClientServer() (*restful.WebService, error)
func (*DiscoverServer) Heartbeat ¶
func (n *DiscoverServer) Heartbeat(req *restful.Request, rsp *restful.Response)
func (*DiscoverServer) Initialize ¶
func (h *DiscoverServer) Initialize(opt *ServerOption) error
func (*DiscoverServer) ListInstances ¶
func (n *DiscoverServer) ListInstances(req *restful.Request, rsp *restful.Response)
func (*DiscoverServer) ListServices ¶
func (n *DiscoverServer) ListServices(req *restful.Request, rsp *restful.Response)
func (*DiscoverServer) RegisterInstance ¶
func (n *DiscoverServer) RegisterInstance(req *restful.Request, rsp *restful.Response)
func (*DiscoverServer) ServerHealthStatus ¶
func (n *DiscoverServer) ServerHealthStatus(req *restful.Request, rsp *restful.Response)
func (*DiscoverServer) UpdateInstance ¶
func (n *DiscoverServer) UpdateInstance(req *restful.Request, rsp *restful.Response)
type ServerOption ¶
type ServerOption struct {
// nacos
ConnectionManager *remote.ConnectionManager
Store *core.NacosDataStorage
// polaris
UserSvr auth.UserServer
CheckerSvr auth.StrategyServer
NamespaceSvr namespace.NamespaceOperateServer
DiscoverSvr service.DiscoverServer
OriginDiscoverSvr service.DiscoverServer
HealthSvr *healthcheck.Server
}
type UDPAckPacket ¶
type UDPNotifier ¶
type UDPNotifier struct {
// contains filtered or unexported fields
}
func (*UDPNotifier) Close ¶
func (c *UDPNotifier) Close() error
func (*UDPNotifier) IsZombie ¶
func (c *UDPNotifier) IsZombie() bool
type UdpPushCenter ¶
type UdpPushCenter struct {
*core.BasePushCenter
// contains filtered or unexported fields
}
func (*UdpPushCenter) AddSubscriber ¶
func (p *UdpPushCenter) AddSubscriber(s core.Subscriber)
func (*UdpPushCenter) EnablePush ¶
func (p *UdpPushCenter) EnablePush(s core.Subscriber) bool
func (*UdpPushCenter) RemoveSubscriber ¶
func (p *UdpPushCenter) RemoveSubscriber(s core.Subscriber)
func (*UdpPushCenter) Type ¶
func (p *UdpPushCenter) Type() core.PushType
Source Files
Click to show internal directories.
Click to hide internal directories.