Documentation ¶
Index ¶
- func New(nextServer config.ConfigCenterServer, cacheMgr cachetypes.CacheManager, ...) config.ConfigCenterServer
- type ServerAuthability
- func (s *ServerAuthability) After(ctx context.Context, resourceType model.Resource, res *config.ResourceEvent) error
- func (s *ServerAuthability) BatchDeleteConfigFile(ctx context.Context, req []*apiconfig.ConfigFile) *apiconfig.ConfigResponse
- func (s *ServerAuthability) Before(ctx context.Context, resourceType model.Resource)
- func (s *ServerAuthability) CasUpsertAndReleaseConfigFileFromClient(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) *apiconfig.ConfigResponse
- func (s *ServerAuthability) CreateConfigFile(ctx context.Context, configFile *apiconfig.ConfigFile) *apiconfig.ConfigResponse
- func (s *ServerAuthability) CreateConfigFileFromClient(ctx context.Context, fileInfo *apiconfig.ConfigFile) *apiconfig.ConfigClientResponse
- func (s *ServerAuthability) CreateConfigFileGroup(ctx context.Context, configFileGroup *apiconfig.ConfigFileGroup) *apiconfig.ConfigResponse
- func (s *ServerAuthability) CreateConfigFileTemplate(ctx context.Context, template *apiconfig.ConfigFileTemplate) *apiconfig.ConfigResponse
- func (s *ServerAuthability) DeleteConfigFile(ctx context.Context, req *apiconfig.ConfigFile) *apiconfig.ConfigResponse
- func (s *ServerAuthability) DeleteConfigFileFromClient(ctx context.Context, req *apiconfig.ConfigFile) *apiconfig.ConfigResponse
- func (s *ServerAuthability) DeleteConfigFileGroup(ctx context.Context, namespace, name string) *apiconfig.ConfigResponse
- func (s *ServerAuthability) DeleteConfigFileReleases(ctx context.Context, reqs []*apiconfig.ConfigFileRelease) *apiconfig.ConfigBatchWriteResponse
- func (s *ServerAuthability) ExportConfigFile(ctx context.Context, configFileExport *apiconfig.ConfigFileExportRequest) *apiconfig.ConfigExportResponse
- func (s *ServerAuthability) GetAllConfigEncryptAlgorithms(ctx context.Context) *apiconfig.ConfigEncryptAlgorithmResponse
- func (s *ServerAuthability) GetAllConfigFileTemplates(ctx context.Context) *apiconfig.ConfigBatchQueryResponse
- func (s *ServerAuthability) GetConfigFileNamesWithCache(ctx context.Context, req *apiconfig.ConfigFileGroupRequest) *apiconfig.ConfigClientListResponse
- func (s *ServerAuthability) GetConfigFileRelease(ctx context.Context, req *apiconfig.ConfigFileRelease) *apiconfig.ConfigResponse
- func (s *ServerAuthability) GetConfigFileReleaseHistories(ctx context.Context, filter map[string]string) *apiconfig.ConfigBatchQueryResponse
- func (s *ServerAuthability) GetConfigFileReleaseVersions(ctx context.Context, filters map[string]string) *apiconfig.ConfigBatchQueryResponse
- func (s *ServerAuthability) GetConfigFileReleases(ctx context.Context, filters map[string]string) *apiconfig.ConfigBatchQueryResponse
- func (s *ServerAuthability) GetConfigFileRichInfo(ctx context.Context, req *apiconfig.ConfigFile) *apiconfig.ConfigResponse
- func (s *ServerAuthability) GetConfigFileTemplate(ctx context.Context, name string) *apiconfig.ConfigResponse
- func (s *ServerAuthability) GetConfigFileWithCache(ctx context.Context, fileInfo *apiconfig.ClientConfigFileInfo) *apiconfig.ConfigClientResponse
- func (s *ServerAuthability) GetConfigGroupsWithCache(ctx context.Context, req *apiconfig.ClientConfigFileInfo) *apiconfig.ConfigDiscoverResponse
- func (s *ServerAuthability) ImportConfigFile(ctx context.Context, configFiles []*apiconfig.ConfigFile, ...) *apiconfig.ConfigImportResponse
- func (s *ServerAuthability) LongPullWatchFile(ctx context.Context, request *apiconfig.ClientWatchConfigFileRequest) (config.WatchCallback, error)
- func (s *ServerAuthability) PublishConfigFile(ctx context.Context, configFileRelease *apiconfig.ConfigFileRelease) *apiconfig.ConfigResponse
- func (s *ServerAuthability) PublishConfigFileFromClient(ctx context.Context, fileInfo *apiconfig.ConfigFileRelease) *apiconfig.ConfigClientResponse
- func (s *ServerAuthability) QueryConfigFileGroups(ctx context.Context, filter map[string]string) *apiconfig.ConfigBatchQueryResponse
- func (s *ServerAuthability) RollbackConfigFileReleases(ctx context.Context, reqs []*apiconfig.ConfigFileRelease) *apiconfig.ConfigBatchWriteResponse
- func (s *ServerAuthability) SearchConfigFile(ctx context.Context, filter map[string]string) *apiconfig.ConfigBatchQueryResponse
- func (s *ServerAuthability) StopGrayConfigFileReleases(ctx context.Context, reqs []*apiconfig.ConfigFileRelease) *apiconfig.ConfigBatchWriteResponse
- func (s *ServerAuthability) UpdateConfigFile(ctx context.Context, configFile *apiconfig.ConfigFile) *apiconfig.ConfigResponse
- func (s *ServerAuthability) UpdateConfigFileFromClient(ctx context.Context, fileInfo *apiconfig.ConfigFile) *apiconfig.ConfigClientResponse
- func (s *ServerAuthability) UpdateConfigFileGroup(ctx context.Context, configFileGroup *apiconfig.ConfigFileGroup) *apiconfig.ConfigResponse
- func (s *ServerAuthability) UpsertAndReleaseConfigFile(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) *apiconfig.ConfigResponse
- func (s *ServerAuthability) UpsertAndReleaseConfigFileFromClient(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) *apiconfig.ConfigResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(nextServer config.ConfigCenterServer, cacheMgr cachetypes.CacheManager, userMgr auth.UserServer, strategyMgr auth.StrategyServer) config.ConfigCenterServer
Types ¶
type ServerAuthability ¶
type ServerAuthability struct {
// contains filtered or unexported fields
}
Server 配置中心核心服务
func (*ServerAuthability) After ¶
func (s *ServerAuthability) After(ctx context.Context, resourceType model.Resource, res *config.ResourceEvent) error
After this function is called after the resource operation
func (*ServerAuthability) BatchDeleteConfigFile ¶
func (s *ServerAuthability) BatchDeleteConfigFile(ctx context.Context, req []*apiconfig.ConfigFile) *apiconfig.ConfigResponse
BatchDeleteConfigFile 批量删除配置文件
func (*ServerAuthability) Before ¶
func (s *ServerAuthability) Before(ctx context.Context, resourceType model.Resource)
Before this function is called before the resource operation
func (*ServerAuthability) CasUpsertAndReleaseConfigFileFromClient ¶
func (s *ServerAuthability) CasUpsertAndReleaseConfigFileFromClient(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) *apiconfig.ConfigResponse
CasUpsertAndReleaseConfigFileFromClient 创建/更新配置文件并发布
func (*ServerAuthability) CreateConfigFile ¶
func (s *ServerAuthability) CreateConfigFile(ctx context.Context, configFile *apiconfig.ConfigFile) *apiconfig.ConfigResponse
CreateConfigFile 创建配置文件
func (*ServerAuthability) CreateConfigFileFromClient ¶
func (s *ServerAuthability) CreateConfigFileFromClient(ctx context.Context, fileInfo *apiconfig.ConfigFile) *apiconfig.ConfigClientResponse
CreateConfigFileFromClient 调用config_file的方法创建配置文件
func (*ServerAuthability) CreateConfigFileGroup ¶
func (s *ServerAuthability) CreateConfigFileGroup(ctx context.Context, configFileGroup *apiconfig.ConfigFileGroup) *apiconfig.ConfigResponse
CreateConfigFileGroup 创建配置文件组
func (*ServerAuthability) CreateConfigFileTemplate ¶
func (s *ServerAuthability) CreateConfigFileTemplate(ctx context.Context, template *apiconfig.ConfigFileTemplate) *apiconfig.ConfigResponse
CreateConfigFileTemplate create config file template
func (*ServerAuthability) DeleteConfigFile ¶
func (s *ServerAuthability) DeleteConfigFile(ctx context.Context, req *apiconfig.ConfigFile) *apiconfig.ConfigResponse
DeleteConfigFile 删除配置文件,删除配置文件同时会通知客户端 Not_Found
func (*ServerAuthability) DeleteConfigFileFromClient ¶
func (s *ServerAuthability) DeleteConfigFileFromClient(ctx context.Context, req *apiconfig.ConfigFile) *apiconfig.ConfigResponse
DeleteConfigFileFromClient 删除配置文件,删除配置文件同时会通知客户端 Not_Found
func (*ServerAuthability) DeleteConfigFileGroup ¶
func (s *ServerAuthability) DeleteConfigFileGroup( ctx context.Context, namespace, name string) *apiconfig.ConfigResponse
DeleteConfigFileGroup 删除配置文件组
func (*ServerAuthability) DeleteConfigFileReleases ¶
func (s *ServerAuthability) DeleteConfigFileReleases(ctx context.Context, reqs []*apiconfig.ConfigFileRelease) *apiconfig.ConfigBatchWriteResponse
DeleteConfigFileReleases implements ConfigCenterServer.
func (*ServerAuthability) ExportConfigFile ¶
func (s *ServerAuthability) ExportConfigFile(ctx context.Context, configFileExport *apiconfig.ConfigFileExportRequest) *apiconfig.ConfigExportResponse
func (*ServerAuthability) GetAllConfigEncryptAlgorithms ¶
func (s *ServerAuthability) GetAllConfigEncryptAlgorithms( ctx context.Context) *apiconfig.ConfigEncryptAlgorithmResponse
func (*ServerAuthability) GetAllConfigFileTemplates ¶
func (s *ServerAuthability) GetAllConfigFileTemplates(ctx context.Context) *apiconfig.ConfigBatchQueryResponse
GetAllConfigFileTemplates get all config file templates
func (*ServerAuthability) GetConfigFileNamesWithCache ¶
func (s *ServerAuthability) GetConfigFileNamesWithCache(ctx context.Context, req *apiconfig.ConfigFileGroupRequest) *apiconfig.ConfigClientListResponse
GetConfigFileNamesWithCache 获取某个配置分组下的配置文件
func (*ServerAuthability) GetConfigFileRelease ¶
func (s *ServerAuthability) GetConfigFileRelease(ctx context.Context, req *apiconfig.ConfigFileRelease) *apiconfig.ConfigResponse
GetConfigFileRelease 获取配置文件发布内容
func (*ServerAuthability) GetConfigFileReleaseHistories ¶
func (s *ServerAuthability) GetConfigFileReleaseHistories(ctx context.Context, filter map[string]string) *apiconfig.ConfigBatchQueryResponse
GetConfigFileReleaseHistory 获取配置文件发布历史记录
func (*ServerAuthability) GetConfigFileReleaseVersions ¶
func (s *ServerAuthability) GetConfigFileReleaseVersions(ctx context.Context, filters map[string]string) *apiconfig.ConfigBatchQueryResponse
GetConfigFileReleaseVersions implements ConfigCenterServer.
func (*ServerAuthability) GetConfigFileReleases ¶
func (s *ServerAuthability) GetConfigFileReleases(ctx context.Context, filters map[string]string) *apiconfig.ConfigBatchQueryResponse
GetConfigFileReleases implements ConfigCenterServer.
func (*ServerAuthability) GetConfigFileRichInfo ¶
func (s *ServerAuthability) GetConfigFileRichInfo(ctx context.Context, req *apiconfig.ConfigFile) *apiconfig.ConfigResponse
GetConfigFileRichInfo 获取单个配置文件基础信息,包含发布状态等信息
func (*ServerAuthability) GetConfigFileTemplate ¶
func (s *ServerAuthability) GetConfigFileTemplate(ctx context.Context, name string) *apiconfig.ConfigResponse
GetConfigFileTemplate get config file template
func (*ServerAuthability) GetConfigFileWithCache ¶
func (s *ServerAuthability) GetConfigFileWithCache(ctx context.Context, fileInfo *apiconfig.ClientConfigFileInfo) *apiconfig.ConfigClientResponse
GetConfigFileWithCache 从缓存中获取配置文件,如果客户端的版本号大于服务端,则服务端重新加载缓存
func (*ServerAuthability) GetConfigGroupsWithCache ¶
func (s *ServerAuthability) GetConfigGroupsWithCache(ctx context.Context, req *apiconfig.ClientConfigFileInfo) *apiconfig.ConfigDiscoverResponse
func (*ServerAuthability) ImportConfigFile ¶
func (s *ServerAuthability) ImportConfigFile(ctx context.Context, configFiles []*apiconfig.ConfigFile, conflictHandling string) *apiconfig.ConfigImportResponse
func (*ServerAuthability) LongPullWatchFile ¶
func (s *ServerAuthability) LongPullWatchFile(ctx context.Context, request *apiconfig.ClientWatchConfigFileRequest) (config.WatchCallback, error)
WatchConfigFiles 监听配置文件变化
func (*ServerAuthability) PublishConfigFile ¶
func (s *ServerAuthability) PublishConfigFile(ctx context.Context, configFileRelease *apiconfig.ConfigFileRelease) *apiconfig.ConfigResponse
PublishConfigFile 发布配置文件
func (*ServerAuthability) PublishConfigFileFromClient ¶
func (s *ServerAuthability) PublishConfigFileFromClient(ctx context.Context, fileInfo *apiconfig.ConfigFileRelease) *apiconfig.ConfigClientResponse
PublishConfigFileFromClient 调用config_file_release的方法发布配置文件
func (*ServerAuthability) QueryConfigFileGroups ¶
func (s *ServerAuthability) QueryConfigFileGroups(ctx context.Context, filter map[string]string) *apiconfig.ConfigBatchQueryResponse
QueryConfigFileGroups 查询配置文件组
func (*ServerAuthability) RollbackConfigFileReleases ¶
func (s *ServerAuthability) RollbackConfigFileReleases(ctx context.Context, reqs []*apiconfig.ConfigFileRelease) *apiconfig.ConfigBatchWriteResponse
RollbackConfigFileReleases implements ConfigCenterServer.
func (*ServerAuthability) SearchConfigFile ¶
func (s *ServerAuthability) SearchConfigFile(ctx context.Context, filter map[string]string) *apiconfig.ConfigBatchQueryResponse
SearchConfigFile 查询配置文件
func (*ServerAuthability) StopGrayConfigFileReleases ¶
func (s *ServerAuthability) StopGrayConfigFileReleases(ctx context.Context, reqs []*apiconfig.ConfigFileRelease) *apiconfig.ConfigBatchWriteResponse
func (*ServerAuthability) UpdateConfigFile ¶
func (s *ServerAuthability) UpdateConfigFile( ctx context.Context, configFile *apiconfig.ConfigFile) *apiconfig.ConfigResponse
UpdateConfigFile 更新配置文件
func (*ServerAuthability) UpdateConfigFileFromClient ¶
func (s *ServerAuthability) UpdateConfigFileFromClient(ctx context.Context, fileInfo *apiconfig.ConfigFile) *apiconfig.ConfigClientResponse
UpdateConfigFileFromClient 调用config_file的方法更新配置文件
func (*ServerAuthability) UpdateConfigFileGroup ¶
func (s *ServerAuthability) UpdateConfigFileGroup(ctx context.Context, configFileGroup *apiconfig.ConfigFileGroup) *apiconfig.ConfigResponse
UpdateConfigFileGroup 更新配置文件组
func (*ServerAuthability) UpsertAndReleaseConfigFile ¶
func (s *ServerAuthability) UpsertAndReleaseConfigFile(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) *apiconfig.ConfigResponse
UpsertAndReleaseConfigFile .
func (*ServerAuthability) UpsertAndReleaseConfigFileFromClient ¶
func (s *ServerAuthability) UpsertAndReleaseConfigFileFromClient(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) *apiconfig.ConfigResponse
UpsertAndReleaseConfigFileFromClient 创建/更新配置文件并发布