Documentation ¶
Index ¶
- type ConfigGRPCServer
- func (g *ConfigGRPCServer) CreateConfigFile(ctx context.Context, configFile *apiconfig.ConfigFile) (*apiconfig.ConfigClientResponse, error)
- func (g *ConfigGRPCServer) Discover(svr apiconfig.PolarisConfigGRPC_DiscoverServer) error
- func (g *ConfigGRPCServer) GetConfigFile(ctx context.Context, req *apiconfig.ClientConfigFileInfo) (*apiconfig.ConfigClientResponse, error)
- func (g *ConfigGRPCServer) GetConfigFileMetadataList(ctx context.Context, req *apiconfig.ConfigFileGroupRequest) (*apiconfig.ConfigClientListResponse, error)
- func (g *ConfigGRPCServer) GetPort() uint32
- func (g *ConfigGRPCServer) GetProtocol() string
- func (g *ConfigGRPCServer) Initialize(ctx context.Context, option map[string]interface{}, ...) error
- func (g *ConfigGRPCServer) PublishConfigFile(ctx context.Context, configFile *apiconfig.ConfigFileRelease) (*apiconfig.ConfigClientResponse, error)
- func (g *ConfigGRPCServer) Restart(option map[string]interface{}, apiConf map[string]apiserver.APIConfig, ...) error
- func (g *ConfigGRPCServer) Run(errCh chan error)
- func (g *ConfigGRPCServer) Stop()
- func (g *ConfigGRPCServer) UpdateConfigFile(ctx context.Context, configFile *apiconfig.ConfigFile) (*apiconfig.ConfigClientResponse, error)
- func (g *ConfigGRPCServer) UpsertAndPublishConfigFile(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) (*apiconfig.ConfigClientResponse, error)
- func (g *ConfigGRPCServer) WatchConfigFiles(ctx context.Context, request *apiconfig.ClientWatchConfigFileRequest) (*apiconfig.ConfigClientResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigGRPCServer ¶
type ConfigGRPCServer struct { grpcserver.BaseGrpcServer // contains filtered or unexported fields }
ConfigGRPCServer 配置中心 GRPC API 服务器
func (*ConfigGRPCServer) CreateConfigFile ¶ added in v1.17.2
func (g *ConfigGRPCServer) CreateConfigFile(ctx context.Context, configFile *apiconfig.ConfigFile) (*apiconfig.ConfigClientResponse, error)
CreateConfigFile 创建或更新配置
func (*ConfigGRPCServer) Discover ¶ added in v1.18.0
func (g *ConfigGRPCServer) Discover(svr apiconfig.PolarisConfigGRPC_DiscoverServer) error
func (*ConfigGRPCServer) GetConfigFile ¶
func (g *ConfigGRPCServer) GetConfigFile(ctx context.Context, req *apiconfig.ClientConfigFileInfo) (*apiconfig.ConfigClientResponse, error)
GetConfigFile 拉取配置
func (*ConfigGRPCServer) GetConfigFileMetadataList ¶ added in v1.17.3
func (g *ConfigGRPCServer) GetConfigFileMetadataList(ctx context.Context, req *apiconfig.ConfigFileGroupRequest) (*apiconfig.ConfigClientListResponse, error)
func (*ConfigGRPCServer) GetProtocol ¶
func (g *ConfigGRPCServer) GetProtocol() string
GetProtocol 获取Server的协议
func (*ConfigGRPCServer) Initialize ¶
func (g *ConfigGRPCServer) Initialize(ctx context.Context, option map[string]interface{}, apiConf map[string]apiserver.APIConfig) error
Initialize 初始化GRPC API服务器
func (*ConfigGRPCServer) PublishConfigFile ¶ added in v1.17.2
func (g *ConfigGRPCServer) PublishConfigFile(ctx context.Context, configFile *apiconfig.ConfigFileRelease) (*apiconfig.ConfigClientResponse, error)
PublishConfigFile 发布配置
func (*ConfigGRPCServer) Restart ¶
func (g *ConfigGRPCServer) Restart(option map[string]interface{}, apiConf map[string]apiserver.APIConfig, errCh chan error) error
Restart 重启Server
func (*ConfigGRPCServer) UpdateConfigFile ¶ added in v1.17.2
func (g *ConfigGRPCServer) UpdateConfigFile(ctx context.Context, configFile *apiconfig.ConfigFile) (*apiconfig.ConfigClientResponse, error)
UpdateConfigFile 创建或更新配置
func (*ConfigGRPCServer) UpsertAndPublishConfigFile ¶ added in v1.18.0
func (g *ConfigGRPCServer) UpsertAndPublishConfigFile(ctx context.Context, req *apiconfig.ConfigFilePublishInfo) (*apiconfig.ConfigClientResponse, error)
func (*ConfigGRPCServer) WatchConfigFiles ¶
func (g *ConfigGRPCServer) WatchConfigFiles(ctx context.Context, request *apiconfig.ClientWatchConfigFileRequest) (*apiconfig.ConfigClientResponse, error)
WatchConfigFiles 订阅配置变更
Click to show internal directories.
Click to hide internal directories.