config

Documentation

Index

• Constants
• type ConfigServer
  • func (h *ConfigServer) BuildGrpcWatchCtx(ctx context.Context) config.WatchContextFactory
  • func (h *ConfigServer) Initialize(opt *ServerOption) error
  • func (h *ConfigServer) ListGRPCHandlers() map[string]*remote.RequestHandlerWarrper
• type ConnectionClientManager
  • func NewConnectionClientManager(configSvr *config.Server) (*ConnectionClientManager, error)
  • func (c *ConnectionClientManager) OnEvent(ctx context.Context, a any) error
  • func (cm *ConnectionClientManager) PreProcess(_ context.Context, a any) any
• type ServerOption
• type StreamWatchContext
  • func (c *StreamWatchContext) AppendInterest(item *apiconfig.ClientConfigFileInfo)
  • func (c *StreamWatchContext) ClientID() string
  • func (c *StreamWatchContext) ClientLabels() map[string]string
  • func (c *StreamWatchContext) Close() error
  • func (c *StreamWatchContext) IsOnce() bool
  • func (c *StreamWatchContext) ListWatchFiles() []*apiconfig.ClientConfigFileInfo
  • func (c *StreamWatchContext) RemoveInterest(item *apiconfig.ClientConfigFileInfo)
  • func (c *StreamWatchContext) Reply(event *apiconfig.ConfigClientResponse)
  • func (c *StreamWatchContext) ShouldExpire(now time.Time) bool
  • func (c *StreamWatchContext) ShouldNotify(event *model.SimpleConfigFileRelease) bool

Constants

const (
	ErrorConfigNotFound      = 300
	ErrorConfigQueryConflict = 400
)

Types

type ConfigServer

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

func (*ConfigServer) BuildGrpcWatchCtx

func (h *ConfigServer) BuildGrpcWatchCtx(ctx context.Context) config.WatchContextFactory

BuildGrpcWatchCtx .

func (*ConfigServer) Initialize

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

func (*ConfigServer) ListGRPCHandlers

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

type ConnectionClientManager

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

func NewConnectionClientManager

func NewConnectionClientManager(configSvr *config.Server) (*ConnectionClientManager, error)

func (*ConnectionClientManager) OnEvent

func (c *ConnectionClientManager) OnEvent(ctx context.Context, a any) error

OnEvent event process logic

func (*ConnectionClientManager) PreProcess

func (cm *ConnectionClientManager) PreProcess(_ context.Context, a any) any

PreProcess do preprocess logic for event

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
}

type StreamWatchContext

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

func (*StreamWatchContext) AppendInterest

func (c *StreamWatchContext) AppendInterest(item *apiconfig.ClientConfigFileInfo)

AppendInterest .

func (*StreamWatchContext) ClientID

func (c *StreamWatchContext) ClientID() string

ClientID .

func (*StreamWatchContext) ClientLabels

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

func (*StreamWatchContext) Close

func (c *StreamWatchContext) Close() error

Close .

func (*StreamWatchContext) IsOnce

func (c *StreamWatchContext) IsOnce() bool

IsOnce

func (*StreamWatchContext) ListWatchFiles

func (c *StreamWatchContext) ListWatchFiles() []*apiconfig.ClientConfigFileInfo

ListWatchFiles .

func (*StreamWatchContext) RemoveInterest

func (c *StreamWatchContext) RemoveInterest(item *apiconfig.ClientConfigFileInfo)

RemoveInterest .

func (*StreamWatchContext) Reply

func (c *StreamWatchContext) Reply(event *apiconfig.ConfigClientResponse)

Reply .

func (*StreamWatchContext) ShouldExpire

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

func (*StreamWatchContext) ShouldNotify

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

ShouldNotify .