Versions in this module Expand all Collapse all v1 v1.5.4 Oct 26, 2023 Changes in this version + const DebugLog + const DefaultBaseLogLevel + const DefaultCacheLogLevel + const DefaultDetectLogLevel + const DefaultNetworkLogLevel + const DefaultStatLogLevel + const DefaultStatReportLogLevel + const ErrorLog + const EventInstance + const FatalLog + const InfoLog + const LBPolicyL5CST + const LBPolicyMaglev + const LBPolicyRingHash + const LBPolicyWeightedRandom + const NoneLog + const QuotaResultLimited + const QuotaResultOk + const RetFail + const RetSuccess + const TraceLog + const WarnLog + const WatchModeLongPull + const WatchModeNotify + var NewConfigFileAPI = newConfigFileAPI + var NewConfigFileAPIByConfig = newConfigFileAPIByConfig + var NewConfigFileAPIByFile = newConfigFileAPIByFile + var NewConfigFileAPIBySDKContext = newConfigFileAPIBySDKContext + var NewConsumerAPI = newConsumerAPI + var NewConsumerAPIByAddress = newConsumerAPIByAddress + var NewConsumerAPIByConfig = newConsumerAPIByConfig + var NewConsumerAPIByContext = newConsumerAPIByContext + var NewConsumerAPIByDefaultConfigFile = newConsumerAPIByDefaultConfigFile + var NewConsumerAPIByFile = newConsumerAPIByFile + var NewLimitAPI = newLimitAPI + var NewLimitAPIByAddress = newLimitAPIByAddress + var NewLimitAPIByConfig = newLimitAPIByConfig + var NewLimitAPIByContext = newLimitAPIByContext + var NewLimitAPIByFile = newLimitAPIByFile + var NewProviderAPI = newProviderAPI + var NewProviderAPIByAddress = newProviderAPIByAddress + var NewProviderAPIByConfig = newProviderAPIByConfig + var NewProviderAPIByContext = newProviderAPIByContext + var NewProviderAPIByDefaultConfigFile = newProviderAPIByDefaultConfigFile + var NewProviderAPIByFile = newProviderAPIByFile + var NewServiceCallResult = newServiceCallResult + func CheckAvailable(owner SDKOwner) error + func ConfigBaseLogger(logDir string, logLevel int) error + func ConfigCacheLogger(logDir string, logLevel int) error + func ConfigDetectLogger(logDir string, logLevel int) error + func ConfigLoggers(logDir string, logLevel int) error + func ConfigNetworkLogger(logDir string, logLevel int) error + func ConfigStatLogger(logDir string, logLevel int) error + func ConfigStatReportLogger(logDir string, logLevel int) error + func NewConfiguration() config.Configuration + func SetBaseLogger(logger Logger) + func SetCacheLogger(logger Logger) + func SetDetectLogger(logger Logger) + func SetLoggersDir(logDir string) error + func SetLoggersLevel(loglevel int) error + func SetStatLogger(logger Logger) + func SetStatReportLogger(logger Logger) + type ConfigFileAPI interface + GetConfigFile func(namespace, fileGroup, fileName string) (model.ConfigFile, error) + type ConsumerAPI interface + Destroy func() + GetAllInstances func(req *GetAllInstancesRequest) (*model.InstancesResponse, error) + GetInstances func(req *GetInstancesRequest) (*model.InstancesResponse, error) + GetOneInstance func(req *GetOneInstanceRequest) (*model.OneInstanceResponse, error) + GetRouteRule func(req *GetServiceRuleRequest) (*model.ServiceRuleResponse, error) + GetServices func(req *GetServicesRequest) (*model.ServicesResponse, error) + InitCalleeService func(req *InitCalleeServiceRequest) error + UpdateServiceCallResult func(req *ServiceCallResult) error + WatchAllInstances func(req *WatchAllInstancesRequest) (*model.WatchAllInstancesResponse, error) + WatchAllServices func(req *WatchAllServicesRequest) (*model.WatchAllServicesResponse, error) + WatchService func(req *WatchServiceRequest) (*model.WatchServiceResponse, error) + type GetAllInstancesRequest struct + type GetInstancesRequest struct + type GetOneInstanceRequest struct + type GetServiceRuleRequest struct + type GetServicesRequest struct + type InitCalleeServiceRequest struct + type InstanceDeRegisterRequest struct + type InstanceHeartbeatRequest struct + type InstanceRegisterRequest struct + type InstanceRequest struct + IP string + InstanceID string + Port uint16 + func (g InstanceRequest) Validate() error + type LimitAPI interface + Destroy func() + GetQuota func(request QuotaRequest) (QuotaFuture, error) + type Logger log.Logger + func GetBaseLogger() Logger + func GetCacheLogger() Logger + func GetDetectLogger() Logger + func GetStatLogger() Logger + func GetStatReportLogger() Logger + type ProviderAPI interface + Deregister func(instance *InstanceDeRegisterRequest) error + Destroy func() + Heartbeat func(instance *InstanceHeartbeatRequest) error + Register func(instance *InstanceRegisterRequest) (*model.InstanceRegisterResponse, error) + RegisterInstance func(instance *InstanceRegisterRequest) (*model.InstanceRegisterResponse, error) + type QuotaFuture interface + Done func() <-chan struct{} + Get func() *model.QuotaResponse + GetImmediately func() *model.QuotaResponse + Release func() + type QuotaRequest interface + AddArgument func(argument model.Argument) + SetLabels func(map[string]string) + SetMethod func(method string) + SetNamespace func(string) + SetRetryCount func(retryCount int) + SetService func(string) + SetTimeout func(timeout time.Duration) + SetToken func(uint32) + func NewQuotaRequest() QuotaRequest + type SDKContext interface + Destroy func() + GetConfig func() config.Configuration + GetEngine func() model.Engine + GetPlugins func() plugin.Manager + GetValueContext func() model.ValueContext + IsDestroyed func() bool + func InitContextByConfig(cfg config.Configuration) (SDKContext, error) + func InitContextByFile(path string) (SDKContext, error) + func InitContextByStream(buf []byte) (SDKContext, error) + type SDKOwner interface + SDKContext func() SDKContext + type ServiceCallResult struct + type WatchAllInstancesRequest struct + type WatchAllServicesRequest struct + type WatchServiceRequest struct
Go to main page