v1

Documentation

Index

• Variables
• func RegistryDebugRoute(name string, rb func(*restful.WebService) *restful.RouteBuilder) error
• func WithAuthSvr(userSvr auth.UserServer, checkerSvr auth.StrategyServer) option
• func WithConfigSvr(configSvr config.ConfigCenterServer, originSvr config.ConfigCenterServer) option
• func WithConnLimitConfig(connLimitConfig *connlimit.Config) option
• func WithDiscoverSvr(discoverSvr service.DiscoverServer, originSvr service.DiscoverServer, ...) option
• func WithNamespaceSvr(namespaceSvr namespace.NamespaceOperateServer) option
• func WithTLS(tlsInfo *secure.TLSInfo) option
• type NacosV1Server
  • func NewNacosV1Server(store *core.NacosDataStorage, options ...option) (*NacosV1Server, error)
  • func (n *NacosV1Server) GetAuthServer() (*restful.WebService, error)
  • func (n *NacosV1Server) GetDebugServer() (*restful.WebService, error)
  • func (h *NacosV1Server) GetProtocol() string
  • func (h *NacosV1Server) Initialize(_ context.Context, option map[string]interface{}, port uint32, ...) error
  • func (n *NacosV1Server) Login(req *restful.Request, rsp *restful.Response)
  • func (h *NacosV1Server) Run(errCh chan error)
  • func (n *NacosV1Server) ServerHealthStatus(req *restful.Request, rsp *restful.Response)
  • func (h *NacosV1Server) Stop()

Variables

var (
	ErrorDuplicateDebugRoute = errors.New("duplicate debug route")
)

Functions

func RegistryDebugRoute

func RegistryDebugRoute(name string, rb func(*restful.WebService) *restful.RouteBuilder) error

func WithAuthSvr

func WithAuthSvr(userSvr auth.UserServer, checkerSvr auth.StrategyServer) option

func WithConfigSvr

func WithConfigSvr(configSvr config.ConfigCenterServer, originSvr config.ConfigCenterServer) option

func WithConnLimitConfig

func WithConnLimitConfig(connLimitConfig *connlimit.Config) option

func WithDiscoverSvr

func WithDiscoverSvr(discoverSvr service.DiscoverServer, originSvr service.DiscoverServer,
	healthSvr *healthcheck.Server) option

func WithNamespaceSvr

func WithNamespaceSvr(namespaceSvr namespace.NamespaceOperateServer) option

func WithTLS

func WithTLS(tlsInfo *secure.TLSInfo) option

Types

type NacosV1Server

type NacosV1Server struct {
	// contains filtered or unexported fields
}

NacosV1Server HTTP API服务器

func NewNacosV1Server

func NewNacosV1Server(store *core.NacosDataStorage, options ...option) (*NacosV1Server, error)

func (*NacosV1Server) GetAuthServer

func (n *NacosV1Server) GetAuthServer() (*restful.WebService, error)

func (*NacosV1Server) GetDebugServer

func (n *NacosV1Server) GetDebugServer() (*restful.WebService, error)

func (*NacosV1Server) GetProtocol

func (h *NacosV1Server) GetProtocol() string

GetProtocol 获取Server的协议

func (*NacosV1Server) Initialize

func (h *NacosV1Server) Initialize(_ context.Context, option map[string]interface{}, port uint32,
	apiConf map[string]apiserver.APIConfig) error

Initialize 初始化HTTP API服务器

func (*NacosV1Server) Login

func (n *NacosV1Server) Login(req *restful.Request, rsp *restful.Response)

func (*NacosV1Server) Run

func (h *NacosV1Server) Run(errCh chan error)

Run 启动HTTP API服务器

func (*NacosV1Server) ServerHealthStatus

func (n *NacosV1Server) ServerHealthStatus(req *restful.Request, rsp *restful.Response)

func (*NacosV1Server) Stop

func (h *NacosV1Server) Stop()

Stop shutdown server