discover

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
  • func (c *UDPNotifier) Close() error
  • func (c *UDPNotifier) IsZombie() bool
  • func (c *UDPNotifier) Notify(d *core.PushData) error
• type UdpPushCenter
  • func (p *UdpPushCenter) AddSubscriber(s core.Subscriber)
  • func (p *UdpPushCenter) EnablePush(s core.Subscriber) bool
  • func (p *UdpPushCenter) RemoveSubscriber(s core.Subscriber)
  • func (p *UdpPushCenter) Type() core.PushType

Functions

func BuildClientBeat

func BuildClientBeat(req *restful.Request) (*model.ClientBeat, error)

func BuildInstance

func BuildInstance(namespace string, req *restful.Request, onlybase bool) (*model.Instance, error)

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 UDPAckPacket struct {
	Type        string
	LastRefTime int64
	Data        string
}

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

func (*UDPNotifier) Notify

func (c *UDPNotifier) Notify(d *core.PushData) error

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