config

Documentation

Index

• func BuildConfigFile(req *restful.Request) (*model.ConfigFile, error)
• type ConfigServer
  • func (n *ConfigServer) BuildTimeoutWatchCtx(ctx context.Context, watchTimeOut time.Duration) config.WatchContextFactory
  • func (n *ConfigServer) DeleteConfig(req *restful.Request, rsp *restful.Response)
  • func (n *ConfigServer) GetClientServer() (*restful.WebService, error)
  • func (n *ConfigServer) GetConfig(req *restful.Request, rsp *restful.Response)
  • func (h *ConfigServer) Initialize(opt *ServerOption) error
  • func (h *ConfigServer) ListGRPCHandlers() map[string]*remote.RequestHandlerWarrper
  • func (n *ConfigServer) PublishConfig(req *restful.Request, rsp *restful.Response)
  • func (n *ConfigServer) WatchConfigs(req *restful.Request, rsp *restful.Response)
• type LongPollWatchContext
  • func (c *LongPollWatchContext) AppendInterest(item *config_manage.ClientConfigFileInfo)
  • func (c *LongPollWatchContext) ClientID() string
  • func (c *LongPollWatchContext) ClientLabels() map[string]string
  • func (c *LongPollWatchContext) Close() error
  • func (c *LongPollWatchContext) GetNotifieResult() *config_manage.ConfigClientResponse
  • func (c *LongPollWatchContext) GetNotifieResultWithTime(timeout time.Duration) (*config_manage.ConfigClientResponse, error)
  • func (c *LongPollWatchContext) IsOnce() bool
  • func (c *LongPollWatchContext) ListWatchFiles() []*config_manage.ClientConfigFileInfo
  • func (c *LongPollWatchContext) RemoveInterest(item *config_manage.ClientConfigFileInfo)
  • func (c *LongPollWatchContext) Reply(rsp *config_manage.ConfigClientResponse)
  • func (c *LongPollWatchContext) ShouldExpire(now time.Time) bool
  • func (c *LongPollWatchContext) ShouldNotify(event *model.SimpleConfigFileRelease) bool
• type ServerOption

Functions

func BuildConfigFile

func BuildConfigFile(req *restful.Request) (*model.ConfigFile, error)

Types

type ConfigServer

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

func (*ConfigServer) BuildTimeoutWatchCtx

func (n *ConfigServer) BuildTimeoutWatchCtx(ctx context.Context, watchTimeOut time.Duration) config.WatchContextFactory

func (*ConfigServer) DeleteConfig

func (n *ConfigServer) DeleteConfig(req *restful.Request, rsp *restful.Response)

func (*ConfigServer) GetClientServer

func (n *ConfigServer) GetClientServer() (*restful.WebService, error)

func (*ConfigServer) GetConfig

func (n *ConfigServer) GetConfig(req *restful.Request, rsp *restful.Response)

func (*ConfigServer) Initialize

func (h *ConfigServer) Initialize(opt *ServerOption) error

func (*ConfigServer) ListGRPCHandlers

func (h *ConfigServer) ListGRPCHandlers() map[string]*remote.RequestHandlerWarrper

func (*ConfigServer) PublishConfig

func (n *ConfigServer) PublishConfig(req *restful.Request, rsp *restful.Response)

func (*ConfigServer) WatchConfigs

func (n *ConfigServer) WatchConfigs(req *restful.Request, rsp *restful.Response)

type LongPollWatchContext

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

func (*LongPollWatchContext) AppendInterest

func (c *LongPollWatchContext) AppendInterest(item *config_manage.ClientConfigFileInfo)

AppendInterest .

func (*LongPollWatchContext) ClientID

func (c *LongPollWatchContext) ClientID() string

ClientID .

func (*LongPollWatchContext) ClientLabels

func (c *LongPollWatchContext) ClientLabels() map[string]string

func (*LongPollWatchContext) Close

func (c *LongPollWatchContext) Close() error

Close .

func (*LongPollWatchContext) GetNotifieResult

func (c *LongPollWatchContext) GetNotifieResult() *config_manage.ConfigClientResponse

GetNotifieResult .

func (*LongPollWatchContext) GetNotifieResultWithTime

func (c *LongPollWatchContext) GetNotifieResultWithTime(timeout time.Duration) (*config_manage.ConfigClientResponse, error)

GetNotifieResultWithTime .

func (*LongPollWatchContext) IsOnce

func (c *LongPollWatchContext) IsOnce() bool

IsOnce

func (*LongPollWatchContext) ListWatchFiles

func (c *LongPollWatchContext) ListWatchFiles() []*config_manage.ClientConfigFileInfo

func (*LongPollWatchContext) RemoveInterest

func (c *LongPollWatchContext) RemoveInterest(item *config_manage.ClientConfigFileInfo)

RemoveInterest .

func (*LongPollWatchContext) Reply

func (c *LongPollWatchContext) Reply(rsp *config_manage.ConfigClientResponse)

func (*LongPollWatchContext) ShouldExpire

func (c *LongPollWatchContext) ShouldExpire(now time.Time) bool

ShouldExpire .

func (*LongPollWatchContext) ShouldNotify

func (c *LongPollWatchContext) ShouldNotify(event *model.SimpleConfigFileRelease) bool

ShouldNotify .

type ServerOption

type ServerOption struct {
	// nacos
	ConnectionManager *remote.ConnectionManager
	Store             *core.NacosDataStorage

	// polaris
	UserSvr         auth.UserServer
	CheckerSvr      auth.StrategyServer
	NamespaceSvr    namespace.NamespaceOperateServer
	ConfigSvr       config.ConfigCenterServer
	OriginConfigSvr config.ConfigCenterServer
}