model

package

Go to main page

Versions in this module

v1

v1.6.0

Jan 21, 2025

Changes in this version

+ var EmptyServiceKey = &ServiceKey

+ var ErrorCallAborted = errors.New("call aborted")

+ type BaseCircuitBreakerStatus struct

+ func (c *BaseCircuitBreakerStatus) GetCircuitBreaker() string

+ func (c *BaseCircuitBreakerStatus) GetFallbackInfo() *FallbackInfo

+ func (c *BaseCircuitBreakerStatus) GetStartTime() time.Time

+ func (c *BaseCircuitBreakerStatus) GetStatus() Status

+ func (c *BaseCircuitBreakerStatus) IsAvailable() bool

+ func (c *BaseCircuitBreakerStatus) SetFallbackInfo(info *FallbackInfo)

+ type CallAborted struct

+ func NewCallAborted(err error, rule string, fallback *FallbackInfo) *CallAborted

+ func (c *CallAborted) GetError() error

+ func (c *CallAborted) GetFallbackBody() string

+ func (c *CallAborted) GetFallbackCode() int

+ func (c *CallAborted) GetFallbackHeaders() map[string]string

+ func (c *CallAborted) HasFallback() bool

+ type CheckResult struct

+ FallbackInfo *FallbackInfo

+ Pass bool

+ RuleName string

type CircuitBreakerStatus

+ func NewCircuitBreakerStatus(name string, status Status, startTime time.Time, ...) CircuitBreakerStatus

+ func NewHalfOpenStatus(name string, start time.Time, maxRequest int) CircuitBreakerStatus

+ GetFallbackInfo func() *FallbackInfo

+ SetFallbackInfo func(*FallbackInfo)

+ type CircuitBreakerStatusImpl struct

+ CircuitBreaker string

+ StartTime time.Time

+ Status Status

+ func (c *CircuitBreakerStatusImpl) GetCircuitBreaker() string

+ func (c *CircuitBreakerStatusImpl) GetStartTime() time.Time

+ func (c *CircuitBreakerStatusImpl) GetStatus() Status

+ func (c CircuitBreakerStatusImpl) String() string

+ type CircuitBreakerStatusWrapper struct

+ Val CircuitBreakerStatus

type ConfigFile

+ GetLabels func() map[string]string

+ GetPersistent func() Persistent

type ConfigFileChangeEvent

+ Persistent Persistent

type ConfigFileMetadata

+ GetFileMode func() GetConfigFileRequestMode

+ type CustomerFunction func(ctx context.Context, args interface{}) (interface{}, error)

+ type DecoratorFunction func(ctx context.Context, args interface{}) (interface{}, *CallAborted, error)

type DefaultConfigFileMetadata

+ Mode GetConfigFileRequestMode

+ func (m *DefaultConfigFileMetadata) GetFileMode() GetConfigFileRequestMode

type Engine

+ Check func(Resource) (*CheckResult, error)

+ MakeFunctionDecorator func(CustomerFunction, *RequestContext) DecoratorFunction

+ MakeInvokeHandler func(*RequestContext) InvokeHandler

+ Report func(*ResourceStat) error

+ SyncGetConfigGroupWithReq func(req *GetConfigGroupRequest) (ConfigFileGroup, error)

type EventType

+ const EventCircuitBreaker

+ const EventFaultDetect

+ type FallbackInfo struct

+ Body string

+ Code int

+ Headers map[string]string

+ type GetConfigFileRequest struct

+ FileGroup string

+ FileName string

+ Mode GetConfigFileRequestMode

+ Namespace string

+ Subscribe bool

+ type GetConfigFileRequestMode int

+ const AgentMode

+ const SDKMode

+ type GetConfigGroupRequest struct

+ FileGroup string

+ Mode GetConfigFileRequestMode

+ Namespace string

+ Subscribe bool

type GetOneInstanceRequest

+ IncludeCircuitBreakInstances bool

+ type HalfOpenStatus struct

+ func (c *HalfOpenStatus) CalNextStatus() Status

+ func (c *HalfOpenStatus) IsAvailable() bool

+ func (c *HalfOpenStatus) Report(success bool) bool

+ func (c *HalfOpenStatus) Schedule() bool

+ type InitCircuitBreakerStatus func(CircuitBreakerStatus)

type InstanceRegisterRequest

+ AutoHeartbeat bool

+ type InstanceResource struct

+ func NewInstanceResource(svc, caller *ServiceKey, protocol, host string, port uint32) (*InstanceResource, error)

+ func (ar InstanceResource) GetCallerService() *ServiceKey

+ func (ar InstanceResource) GetLevel() fault_tolerance.Level

+ func (ar InstanceResource) GetService() *ServiceKey

+ func (r *InstanceResource) GetNode() Node

+ func (r *InstanceResource) GetProtocol() string

+ func (r *InstanceResource) String() string

+ type InvokeHandler interface

+ AcquirePermission func() (bool, *CallAborted, error)

+ OnError func(*ResponseContext)

+ OnSuccess func(*ResponseContext)

+ type MethodResource struct

+ Method string

+ func NewMethodResource(svc, caller *ServiceKey, method string) (*MethodResource, error)

+ func (ar MethodResource) GetCallerService() *ServiceKey

+ func (ar MethodResource) GetLevel() fault_tolerance.Level

+ func (ar MethodResource) GetService() *ServiceKey

+ func (r *MethodResource) String() string

+ type Node struct

+ Host string

+ Port uint32

+ func (n Node) String() string

+ type Persistent struct

+ Encoding string

+ Path string

+ PostCmd string

+ func (persistent Persistent) GetEncoding() string

+ func (persistent Persistent) GetPath() string

+ func (persistent Persistent) GetPostCmd() string

+ type RequestContext struct

+ Callee *ServiceKey

+ Caller *ServiceKey

+ CodeConvert ResultToErrorCode

+ Method string

+ type Resource interface

+ GetCallerService func() *ServiceKey

+ GetLevel func() fault_tolerance.Level

+ GetService func() *ServiceKey

+ type ResourceStat struct

+ Delay time.Duration

+ Resource Resource

+ RetCode string

+ RetStatus RetStatus

+ type ResponseContext struct

+ Duration time.Duration

+ Err error

+ Result interface{}

+ type ResultToErrorCode interface

+ OnError func(err error) string

+ OnSuccess func(val interface{}) string

type SDKToken

+ func (sdkToken *SDKToken) InitUID()

type ServiceClusters

+ GetInstancesWithMetaValuesNotEqual func(location Location, metaKey string, metavalue string) map[string]string

+ type ServiceResource struct

+ func NewServiceResource(svc, caller *ServiceKey) (*ServiceResource, error)

+ func (ar ServiceResource) GetCallerService() *ServiceKey

+ func (ar ServiceResource) GetLevel() fault_tolerance.Level

+ func (ar ServiceResource) GetService() *ServiceKey

+ func (r *ServiceResource) String() string

v1.6.0-beta.5

Jun 21, 2024

v1.6.0-beta.4

Jan 8, 2024

v1.6.0-beta.3

Dec 19, 2023

v1.6.0-beta.2

Dec 18, 2023

v1.6.0-beta.1

Dec 18, 2023

v1.6.0-beta

Nov 19, 2023

v1.6.0-alpha.9

Aug 11, 2024

v1.6.0-alpha.8

Jul 19, 2024

v1.6.0-alpha.7

Jul 17, 2024

v1.6.0-alpha.6

Jul 15, 2024

v1.5.8

Aug 26, 2024

v1.5.8-beta.0

Aug 26, 2024

v1.5.7

Aug 17, 2024

v1.5.6

Nov 4, 2023

Changes in this version

+ type ConfigFileGroup interface

+ AddChangeListener func(cb OnConfigGroupChange)

+ GetFiles func() ([]*SimpleConfigFile, string, bool)

+ type ConfigGroupChangeEvent struct

+ After []*SimpleConfigFile

+ Before []*SimpleConfigFile

type Engine

+ SyncGetConfigGroup func(namespace, fileGroup string) (ConfigFileGroup, error)

+ type OnConfigGroupChange func(event *ConfigGroupChangeEvent)

+ type SimpleConfigFile struct

+ FileGroup string

+ FileName string

+ Md5 string

+ Namespace string

+ ReleaseTime time.Time

+ Version uint64

v1.5.6-beta

Oct 16, 2023

v1.5.5

Oct 15, 2023

Changes in this version

+ func CheckConfigFileMetadata(configFileMetadata ConfigFileMetadata) error

type Engine

+ SyncCreateConfigFile func(namespace, fileGroup, fileName, content string) error

+ SyncPublishConfigFile func(namespace, fileGroup, fileName string) error

+ SyncUpdateConfigFile func(namespace, fileGroup, fileName, content string) error

v1.5.4

Sep 18, 2023

Changes in this version

+ func ToBoolPtr(v bool) *bool

v1.5.3

Aug 22, 2023

v1.5.2

Aug 7, 2023

Changes in this version

type RateLimitGauge

+ RuleName string

type RetStatus

+ const RetFlowControl

+ const RetReject

+ const RetUnknown

type ServiceCallResult

+ CalledIP string

+ RuleName string

+ func (s *ServiceCallResult) GetMethod() string

+ func (s *ServiceCallResult) SetMethod(method string)

v1.5.1

Jun 19, 2023

v1.5.0

Jun 14, 2023

Changes in this version

type Instance

+ DeepClone func() Instance

+ GetTtl func() int64

+ SetHealthy func(status bool)

type ServiceInstances

+ func NewDefaultServiceInstancesWithRegistryValue(service ServiceInfo, registryValue RegistryValue, instances []Instance) ServiceInstances

v1.4.4-alpha.0

May 25, 2023

v1.4.3

Apr 27, 2023

v1.4.2

Apr 13, 2023

v1.4.1

Apr 12, 2023

Changes in this version

type Engine

+ WatchAllServices func(request *WatchAllServicesRequest) (*WatchAllServicesResponse, error)

+ type ServicesListener interface

+ OnServicesUpdate func(*ServicesResponse)

+ type WatchAllServicesRequest struct

+ Namespace string

+ ServicesListener ServicesListener

+ WaitIndex uint64

+ WaitTime time.Duration

+ WatchMode WatchMode

+ func (req *WatchAllServicesRequest) Validate() error

+ type WatchAllServicesResponse struct

+ func NewWatchAllServicesResponse(watchId uint64, response *ServicesResponse, cancelWatch func(uint642 uint64)) *WatchAllServicesResponse

+ func (w *WatchAllServicesResponse) CancelWatch()

+ func (w *WatchAllServicesResponse) ServicesResponse() *ServicesResponse

+ func (w *WatchAllServicesResponse) WatchId() uint64

v1.4.0

Apr 6, 2023

Changes in this version

+ const ContextKeySelfIP

+ func GetCrc64Hash(value string) (uint64, error)

type DefaultServiceInstances

+ func (d *DefaultServiceInstances) GetHashValue() uint64

+ func (d *DefaultServiceInstances) IsNotExists() bool

type Engine

+ WatchAllInstances func(request *WatchAllInstancesRequest) (*WatchAllInstancesResponse, error)

type InstanceRegisterRequest

+ InstanceId string

+ type InstancesListener interface

+ OnInstancesUpdate func(*InstancesResponse)

type InstancesResponse

+ HashValue uint64

+ NotExists bool

+ func (i *InstancesResponse) GetHashValue() uint64

+ func (i *InstancesResponse) IsNotExists() bool

type RegistryValue

+ GetHashValue func() uint64

+ IsNotExists func() bool

+ type ServiceRuleListener interface

+ OnServiceRuleUpdate func(*ServiceRuleResponse)

type ServiceRuleResponse

+ HashValue uint64

+ NotExists bool

+ func (s *ServiceRuleResponse) GetHashValue() uint64

+ func (s *ServiceRuleResponse) IsNotExists() bool

type ServicesResponse

+ HashValue uint64

+ func (s *ServicesResponse) GetHashValue() uint64

+ func (s *ServicesResponse) IsNotExists() bool

+ type WatchAllInstancesRequest struct

+ InstancesListener InstancesListener

+ WaitIndex uint64

+ WaitTime time.Duration

+ WatchMode WatchMode

+ func (req *WatchAllInstancesRequest) Validate() error

+ type WatchAllInstancesResponse struct

+ func NewWatchAllInstancesResponse(watchId uint64, response *InstancesResponse, cancelWatch func(uint642 uint64)) *WatchAllInstancesResponse

+ func (w *WatchAllInstancesResponse) CancelWatch()

+ func (w *WatchAllInstancesResponse) InstancesResponse() *InstancesResponse

+ func (w *WatchAllInstancesResponse) WatchId() uint64

+ type WatchMode int

+ const WatchModeLongPull

+ const WatchModeNotify

+ type WatchRequest struct

+ InstancesListener []InstancesListener

+ ServiceRuleListener []ServiceRuleListener

+ WaitIndex uint64

+ WaitTime time.Duration

+ WatchMode WatchMode

+ func (req *WatchRequest) Validate() error

+ type WatchResponse struct

+ InstancesResponse *InstancesResponse

+ ServiceRuleResponse *ServiceRuleResponse

v1.4.0-alpha

Mar 6, 2023

v1.3.0

Nov 24, 2022

Changes in this version

+ const ArgumentTypeCookie

+ const ArgumentTypePath

+ const LabelKeyCookie

+ const LabelKeyPath

type Argument

+ func BuildCookieArgument(key, value string) Argument

+ func BuildPathArgument(path string) Argument

type GetInstancesRequest

+ Arguments []Argument

+ func (g *GetInstancesRequest) AddArguments(argumet ...Argument)

type GetOneInstanceRequest

+ Arguments []Argument

+ func (g *GetOneInstanceRequest) AddArguments(argumet ...Argument)

type ProcessRoutersRequest

+ Arguments []Argument

+ func (p *ProcessRoutersRequest) AddArguments(arg ...Argument)

type ServiceInfo

+ func (i *ServiceInfo) AddArgument(arg Argument)

v1.3.0-alpha

Nov 24, 2022

v1.2.0

Oct 31, 2022

Changes in this version

+ const ArgumentTypeCallerIP

+ const ArgumentTypeCallerService

+ const ArgumentTypeCustom

+ const ArgumentTypeHeader

+ const ArgumentTypeMethod

+ const ArgumentTypeQuery

+ const DefaultHeartbeatTtl

+ const LabelKeyCallerIp

+ const LabelKeyCallerService

+ const LabelKeyHeader

+ const LabelKeyMethod

+ const LabelKeyQuery

+ func ConvertDuration(d *duration.Duration) (time.Duration, error)

+ func DescMetricType(t MetricType) string

+ func ProtoDurationToMS(dur *duration.Duration) int64

type ApiOperation

+ const ApiProcessLoadBalance

+ const ApiProcessRouters

+ const ApiServices

+ type Argument struct

+ func BuildArgumentFromLabel(labelKey string, labelValue string) Argument

+ func BuildCallerIPArgument(callerIP string) Argument

+ func BuildCallerServiceArgument(namespace string, service string) Argument

+ func BuildCustomArgument(key string, value string) Argument

+ func BuildHeaderArgument(key string, value string) Argument

+ func BuildMethodArgument(method string) Argument

+ func BuildQueryArgument(key string, value string) Argument

+ func (a Argument) ArgumentType() int

+ func (a Argument) Key() string

+ func (a Argument) String() string

+ func (a Argument) ToLabels(labels map[string]string)

+ func (a Argument) Value() string

type CacheValueQuery

+ SetServices func(mc Services)

+ type ClusterOwner interface

+ GetCluster func() *Cluster

+ type DefaultInstance struct

+ Namespace string

+ Service string

+ type DefaultServiceInstances struct

+ func (d *DefaultServiceInstances) GetInstance(id string) Instance

+ func (d *DefaultServiceInstances) GetInstances() []Instance

+ func (d *DefaultServiceInstances) GetMetadata() map[string]string

+ func (d *DefaultServiceInstances) GetNamespace() string

+ func (d *DefaultServiceInstances) GetRevision() string

+ func (d *DefaultServiceInstances) GetService() string

+ func (d *DefaultServiceInstances) GetServiceClusters() ServiceClusters

+ func (d *DefaultServiceInstances) GetTotalWeight() int

+ func (d *DefaultServiceInstances) GetType() EventType

+ func (d *DefaultServiceInstances) IsCacheLoaded() bool

+ func (d *DefaultServiceInstances) IsInitialized() bool

+ func (d *DefaultServiceInstances) ReloadServiceClusters()

type Engine

+ ProcessLoadBalance func(req *ProcessLoadBalanceRequest) (*OneInstanceResponse, error)

+ ProcessRouters func(req *ProcessRoutersRequest) (*InstancesResponse, error)

+ SyncRegisterV2 func(Instance *InstanceRegisterRequest) (*InstanceRegisterResponse, error)

type InstanceRegisterRequest

+ func (g *InstanceRegisterRequest) SetDefaultTTL()

type InstancesResponse

+ func (i *InstancesResponse) GetCluster() *Cluster

+ type ProcessLoadBalanceRequest struct

+ DstInstances ServiceInstances

+ HashKey []byte

+ LbPolicy string

+ ReplicateCount int

+ func (p *ProcessLoadBalanceRequest) GetResponse() *InstancesResponse

+ func (p *ProcessLoadBalanceRequest) Validate() error

+ type ProcessRoutersRequest struct

+ DstInstances ServiceInstances

+ Method string

+ RetryCount *int

+ Routers []string

+ SourceService ServiceInfo

+ Timeout *time.Duration

+ func (p *ProcessRoutersRequest) GetResponse() *InstancesResponse

+ func (p *ProcessRoutersRequest) GetRetryCountPtr() *int

+ func (p *ProcessRoutersRequest) GetTimeoutPtr() *time.Duration

+ func (p *ProcessRoutersRequest) SetRetryCount(v int)

+ func (p *ProcessRoutersRequest) SetTimeout(duration time.Duration)

+ func (p *ProcessRoutersRequest) Validate() error

type QuotaFutureImpl

+ func QuotaFutureWithResponse(resp *QuotaResponse) *QuotaFutureImpl

+ func (q *QuotaFutureImpl) GetImmediately() *QuotaResponse

type QuotaRequestImpl

+ Token uint32

+ func (q *QuotaRequestImpl) AddArgument(argument Argument)

+ func (q *QuotaRequestImpl) Arguments() []Argument

+ func (q *QuotaRequestImpl) GetMethod() string

+ func (q *QuotaRequestImpl) GetToken() uint32

+ func (q *QuotaRequestImpl) SetMethod(method string)

+ func (q *QuotaRequestImpl) SetToken(token uint32)

type QuotaResponse

+ WaitMs int64

type RateLimitGauge

+ Arguments []Argument

+ Method string

type SDKError

+ func NewSDKErrorWithServerInfo(errCode ErrCode, cause error, serverCode uint32, serverInfo string, msg string, ...) SDKError

type ServiceCallResult

+ SourceService *ServiceInfo

+ func (s *ServiceCallResult) GetCallerNamespace() string

+ func (s *ServiceCallResult) GetCallerService() string

type ServiceInfo

+ func (i *ServiceInfo) HasService() bool

+ func (i *ServiceInfo) IsEmpty() bool

type ServiceInstances

+ func NewDefaultServiceInstances(service ServiceInfo, instances []Instance) ServiceInstances

v1.2.0-beta.4

Oct 25, 2022

v1.2.0-beta.3

Sep 22, 2022

v1.2.0-beta.2

Jul 16, 2022

v1.2.0-beta.1

Jul 14, 2022

v1.2.0-beta.0

May 10, 2022

v1.1.0

May 7, 2022

Changes in this version

+ func WithQuotaFutureDeadline(deadline time.Time) quotaFutureOption

+ func WithQuotaFutureHooks(hooks ...finishHook) quotaFutureOption

+ func WithQuotaFutureQuotaAllocator(allocator QuotaAllocator) quotaFutureOption

+ func WithQuotaFutureReq(req *QuotaRequestImpl) quotaFutureOption

+ func WithQuotaFutureResp(resp *QuotaResponse) quotaFutureOption

+ type ChangeType int

+ const Added

+ const Deleted

+ const Modified

+ const NotChanged

+ type CircuitBreakGauge struct

+ CBStatus CircuitBreakerStatus

+ ChangeInstance Instance

+ Method string

+ func (cbg *CircuitBreakGauge) GetCalledInstance() Instance

+ func (cbg *CircuitBreakGauge) GetCircuitBreakerStatus() CircuitBreakerStatus

+ func (cbg *CircuitBreakGauge) Validate() error

+ type ConfigFile interface

+ AddChangeListener func(cb OnConfigFileChange)

+ AddChangeListenerWithChannel func(chan ConfigFileChangeEvent)

+ GetContent func() string

+ HasContent func() bool

+ type ConfigFileChangeEvent struct

+ ChangeType ChangeType

+ ConfigFileMetadata ConfigFileMetadata

+ NewValue string

+ OldValue string

+ type ConfigFileMetadata interface

+ GetFileGroup func() string

+ GetFileName func() string

+ GetNamespace func() string

+ type DefaultConfigFileMetadata struct

+ FileGroup string

+ FileName string

+ Namespace string

+ func (m *DefaultConfigFileMetadata) GetFileGroup() string

+ func (m *DefaultConfigFileMetadata) GetFileName() string

+ func (m *DefaultConfigFileMetadata) GetNamespace() string

type Engine

+ SyncGetConfigFile func(namespace, fileGroup, fileName string) (ConfigFile, error)

type InstanceRegisterRequest

+ Location *Location

+ func (g *InstanceRegisterRequest) GetLocation() *Location

+ func (g *InstanceRegisterRequest) SetLocation(loc *Location)

+ type OnConfigFileChange func(event ConfigFileChangeEvent)

+ type RateLimitGauge struct

+ Labels map[string]string

+ Namespace string

+ Result QuotaResultCode

+ Service string

type ReportClientRequest

+ ID string

+ Location *Location

+ StatInfos []StatInfo

+ Type string

type RetStatus

+ const RetTimeout

type ServiceCallResult

+ Method string

+ type StatInfo struct

+ Path string

+ Port uint32

+ Protocol string

+ Target string

+ func (s StatInfo) Empty() bool

v1.1.0-beta.0

Apr 26, 2022

v1.0.2

Apr 14, 2022

v1.0.1

Dec 5, 2021

v1.0.0

Sep 18, 2021

Changes in this version

+ const BaseIndexErrCode

+ const BaseSDKInternalErrCode

+ const BaseServerErrCode

+ const CanaryMetaKey

+ const CanaryMetadataEnable

+ const ContextKeyEngine

+ const ContextKeyFinishInitTime

+ const ContextKeyPlugins

+ const ContextKeyTakeEffectTime

+ const ContextKeyToken

+ const ErrCodeDiskError

+ const HealthCheckTypeHeartBeat

+ const HomeVar

+ const LocationEmpty

+ const LocationError

+ const LocationInit

+ const LocationReady

+ const MaxPriority

+ const MaxWeight

+ const MeshDestinationRule

+ const MeshEnvoyFilter

+ const MeshGateway

+ const MeshServiceEntry

+ const MeshVirtualService

+ const MinPriority

+ const MinWeight

+ const ModeNoAgent

+ const ModeWithAgent

+ const NearbyMetadataEnable

+ const RateLimitGlobal

+ const RateLimitLocal

+ const RetCodeDivFactor

+ const ServerExceptionRetCode

+ const SuccessRetCode

+ var MeshKeyLen int = 3

+ var MeshKeySpliter string = "MESHa071a34fecSPLITER"

+ var MeshPrefix string = "mesh_resource"

+ func CurrentMicrosecond() int64

+ func CurrentMillisecond() int64

+ func CurrentNanosecond() int64

+ func EnsureAndVerifyDir(dir string) error

+ func ErrCodeToString(ec ErrCode) string

+ func GetIP(name string) (string, error)

+ func HashMessage(message proto.Message) uint64

+ func HashStr(key string) (uint64, error)

+ func IsDir(path string) bool

+ func IsFile(path string) bool

+ func IsInstanceAvailable(instance Instance) bool

+ func IsNearbyMatch(dst, src string) bool

+ func IsServerException(retCode uint32) bool

+ func IsSuccessResultCode(retCode uint32) bool

+ func ParseMilliSeconds(v int64) int64

+ func PathExist(path string) bool

+ func PoolGetByteBuffer(size int) *bytes.Buffer

+ func PoolGetStringSlice(size int) []string

+ func PoolPutByteBuffer(size int, buf *bytes.Buffer)

+ func PoolPutStringSlice(size int, slice []string)

+ func ReplaceHomeVar(path string) string

+ func SortMap(values map[string]string, keys []string) ([]string, int)

+ func TimestampMsToUtcIso8601(timestamp int64) string

+ func ToDurationPtr(v time.Duration) *time.Duration

+ func ToMilliSeconds(v time.Duration) int64

+ func ToNetIP(val uint32) net.IP

+ func ToStringService(svc ServiceMetadata, printMeta bool) string

+ func ValidMetircType(t MetricType) bool

+ type APICallKey struct

+ APIName ApiOperation

+ DelayRange ApiDelayRange

+ RetCode ErrCode

+ type APICallResult struct

+ RetStatus RetStatus

+ func (a *APICallResult) GetAPI() ApiOperation

+ func (a *APICallResult) GetDelay() *time.Duration

+ func (a *APICallResult) GetDelayRange() ApiDelayRange

+ func (a *APICallResult) GetRetCode() *int32

+ func (a *APICallResult) GetRetCodeValue() int32

+ func (a *APICallResult) GetRetStatus() RetStatus

+ func (a *APICallResult) SetDelay(delay time.Duration)

+ func (a *APICallResult) SetFail(retCode ErrCode, delay time.Duration)

+ func (a *APICallResult) SetSuccess(delay time.Duration)

+ type ActiveDetectStatus interface

+ GetStartTime func() time.Time

+ GetStatus func() HealthCheckStatus

+ type ApiDelayRange int

+ const ApiDelayBelow100

+ const ApiDelayBelow150

+ const ApiDelayBelow200

+ const ApiDelayBelow50

+ const ApiDelayMax

+ const ApiDelayOver200

+ func GetApiDelayRange(delay time.Duration) ApiDelayRange

+ func (a ApiDelayRange) String() string

+ type ApiOperation int

+ const ApiDeregister

+ const ApiGetAllInstances

+ const ApiGetInstances

+ const ApiGetOneInstance

+ const ApiGetQuota

+ const ApiGetRouteRule

+ const ApiHeartbeat

+ const ApiInitCalleeServices

+ const ApiMesh

+ const ApiMeshConfig

+ const ApiOperationMax

+ const ApiRegister

+ const ApiUpdateServiceCallResult

+ func (a ApiOperation) String() string

+ type CacheValueQuery interface

+ GetCallResult func() *APICallResult

+ GetControlParam func() *ControlParam

+ GetDstService func() *ServiceKey

+ GetNotifierTrigger func() *NotifyTrigger

+ GetSrcService func() *ServiceKey

+ SetDstInstances func(instances ServiceInstances)

+ SetDstRateLimit func(rule ServiceRule)

+ SetDstRoute func(rule ServiceRule)

+ SetMeshConfig func(mc MeshConfig)

+ SetSrcRoute func(rule ServiceRule)

+ type CircuitBreakerStatus interface

+ AcquireStatusLock func() bool

+ AddRequestCountAfterHalfOpen func(n int32, success bool) int32

+ Allocate func() bool

+ AllocatedRequestsAfterHalfOpen func() int32

+ GetCircuitBreaker func() string

+ GetFailRequestsAfterHalfOpen func() int32

+ GetFinalAllocateTimeInt64 func() int64

+ GetRequestsAfterHalfOpen func() int32

+ GetStartTime func() time.Time

+ GetStatus func() Status

+ IsAvailable func() bool

+ type Cluster struct

+ HasLimitedInstances bool

+ IncludeHalfOpen bool

+ LocationMatchInfo string

+ MetaCount int

+ Metadata map[string]map[string]string

+ MissLocationInstances bool

+ func NewCluster(clusters ServiceClusters, cls *Cluster) *Cluster

+ func (c *Cluster) AddMetadata(key string, value string) bool

+ func (c *Cluster) ClearClusterValue()

+ func (c *Cluster) GetAllInstances() ([]Instance, int)

+ func (c *Cluster) GetClusterValue() *ClusterValue

+ func (c *Cluster) GetClusters() ServiceClusters

+ func (c *Cluster) GetContainMetaKeyClusterValue() *ClusterValue

+ func (c *Cluster) GetContainNotMatchMetaKeyClusterValue() *ClusterValue

+ func (c *Cluster) GetInstances() ([]Instance, int)

+ func (c *Cluster) GetInstancesWhenSkipRouteFilter() ([]Instance, int)

+ func (c *Cluster) GetNotContainMetaKeyClusterValue() *ClusterValue

+ func (c *Cluster) MatchContainMetaKeyData(instance Instance) bool

+ func (c *Cluster) PoolPut()

+ func (c *Cluster) ReloadComposeMetaValue()

+ func (c *Cluster) RuleAddMetadata(key string, value string, composedValue string) bool

+ func (c *Cluster) SetReuse(value bool)

+ func (c Cluster) String() string

+ type ClusterEventHandler struct

+ PostClusterValueBuilt func(value *ClusterValue)

+ type ClusterKey struct

+ ComposeMetaValue string

+ Location Location

+ func (k ClusterKey) String() string

+ type ClusterValue struct

+ func (v *ClusterValue) Count() int

+ func (v *ClusterValue) GetAllInstanceSet() *InstanceSet

+ func (v *ClusterValue) GetInstancesSet(hasLimitedInstances bool, includeHalfOpen bool) *InstanceSet

+ func (v *ClusterValue) GetInstancesSetWhenSkipRouteFilter(hasLimitedInstances bool, includeHalfOpen bool) *InstanceSet

+ func (v ClusterValue) String() string

+ type ConfigMode int

+ const ConfigQuotaGlobalMode

+ const ConfigQuotaLocalMode

+ type ControlParam struct

+ MaxRetry int

+ RetryInterval time.Duration

+ Timeout time.Duration

+ type EmptyInstanceGauge struct

+ func (e EmptyInstanceGauge) GetAPI() ApiOperation

+ func (e EmptyInstanceGauge) GetCalledInstance() Instance

+ func (e EmptyInstanceGauge) GetCircuitBreakerStatus() CircuitBreakerStatus

+ func (e EmptyInstanceGauge) GetDelay() *time.Duration

+ func (e EmptyInstanceGauge) GetDelayRange() ApiDelayRange

+ func (e EmptyInstanceGauge) GetHost() string

+ func (e EmptyInstanceGauge) GetNamespace() string

+ func (e EmptyInstanceGauge) GetPort() int

+ func (e EmptyInstanceGauge) GetRetCodeValue() int32

+ func (e EmptyInstanceGauge) GetRetStatus() RetStatus

+ func (e EmptyInstanceGauge) GetService() string

+ func (e EmptyInstanceGauge) Validate() error

+ type Engine interface

+ AsyncGetQuota func(request *QuotaRequestImpl) (*QuotaFutureImpl, error)

+ Destroy func() error

+ GetContext func() ValueContext

+ InitCalleeService func(req *InitCalleeServiceRequest) error

+ ScheduleTask func(task *PeriodicTask) (chan<- *PriorityTask, TaskValues)

+ SyncDeregister func(instance *InstanceDeRegisterRequest) error

+ SyncGetAllInstances func(req *GetAllInstancesRequest) (*InstancesResponse, error)

+ SyncGetInstances func(req *GetInstancesRequest) (*InstancesResponse, error)

+ SyncGetMesh func(eventType EventType, req *GetMeshRequest) (*MeshResponse, error)

+ SyncGetMeshConfig func(eventType EventType, req *GetMeshConfigRequest) (*MeshConfigResponse, error)

+ SyncGetOneInstance func(req *GetOneInstanceRequest) (*OneInstanceResponse, error)

+ SyncGetResources func(req CacheValueQuery) error

+ SyncGetServiceRule func(eventType EventType, req *GetServiceRuleRequest) (*ServiceRuleResponse, error)

+ SyncGetServices func(eventType EventType, req *GetServicesRequest) (*ServicesResponse, error)

+ SyncHeartbeat func(instance *InstanceHeartbeatRequest) error

+ SyncRegister func(instance *InstanceRegisterRequest) (*InstanceRegisterResponse, error)

+ SyncReportStat func(typ MetricType, stat InstanceGauge) error

+ SyncUpdateServiceCallResult func(result *ServiceCallResult) error

+ WatchService func(request *WatchServiceRequest) (*WatchServiceResponse, error)

+ type ErrCode int32

+ const ErrCodeAPIInstanceNotFound

+ const ErrCodeAPIInvalidArgument

+ const ErrCodeAPIInvalidConfig

+ const ErrCodeAPITimeoutError

+ const ErrCodeCircuitBreakerError

+ const ErrCodeCmdbNotFound

+ const ErrCodeConnectError

+ const ErrCodeConsumerInitCalleeError

+ const ErrCodeCount

+ const ErrCodeDstMetaMismatch

+ const ErrCodeInstanceInfoError

+ const ErrCodeInternalError

+ const ErrCodeInvalidRequest

+ const ErrCodeInvalidResponse

+ const ErrCodeInvalidRule

+ const ErrCodeInvalidServerResponse

+ const ErrCodeInvalidStateError

+ const ErrCodeLocationMismatch

+ const ErrCodeLocationNotFound

+ const ErrCodeMeshConfigNotFound

+ const ErrCodeNetworkError

+ const ErrCodePluginError

+ const ErrCodeRequestLimit

+ const ErrCodeRouteRuleNotMatch

+ const ErrCodeServerError

+ const ErrCodeServerException

+ const ErrCodeServerUserError

+ const ErrCodeServiceNotFound

+ const ErrCodeSuccess

+ const ErrCodeUnauthorized

+ const ErrCodeUnknown

+ const ErrCodeUnknownServerError

+ const ErrorCodeRpcError

+ const ErrorCodeRpcTimeout

+ func ErrCodeFromIndex(i int) ErrCode

+ func GetErrorCodeFromError(e error) ErrCode

+ func (e ErrCode) Retryable() bool

+ type ErrCodeType int

+ const PolarisError

+ const UserError

+ func GetErrCodeType(e ErrCode) ErrCodeType

+ type EventType uint32

+ const EventInstances

+ const EventMesh

+ const EventMeshConfig

+ const EventRateLimiting

+ const EventRouting

+ const EventServices

+ const EventUnknown

+ func ToEventType(value string) EventType

+ func (e EventType) String() string

+ type ExtendedSelector interface

+ ID func() int32

+ Select func(criteria interface{}) (int, *ReplicateNodes, error)

+ type FailOverDefaultMetaConfig struct

+ Meta map[string]string

+ Type FailOverHandler

+ type FailOverHandler int

+ const CustomMeta

+ const GetOneHealth

+ const NotContainMetaKey

+ type FilteredInstanceCounter struct

+ func (f *FilteredInstanceCounter) AddIsolatedInstances(n int32)

+ func (f *FilteredInstanceCounter) AddRouteFilteredInstances(routerName string, n int32)

+ func (f *FilteredInstanceCounter) AddUnhealthyInstances(n int32)

+ func (f *FilteredInstanceCounter) GetIsolatedInstances() int32

+ func (f *FilteredInstanceCounter) GetUnhealthyInstances() int32

+ type GetAllInstancesRequest struct

+ FlowID uint64

+ Namespace string

+ RetryCount *int

+ Service string

+ Timeout *time.Duration

+ func (g *GetAllInstancesRequest) GetMetadata() map[string]string

+ func (g *GetAllInstancesRequest) GetNamespace() string

+ func (g *GetAllInstancesRequest) GetResponse() *InstancesResponse

+ func (g *GetAllInstancesRequest) GetRetryCountPtr() *int

+ func (g *GetAllInstancesRequest) GetService() string

+ func (g *GetAllInstancesRequest) GetTimeoutPtr() *time.Duration

+ func (g *GetAllInstancesRequest) SetRetryCount(retryCount int)

+ func (g *GetAllInstancesRequest) SetTimeout(duration time.Duration)

+ func (g *GetAllInstancesRequest) Validate() error

+ type GetInstancesRequest struct

+ Canary string

+ FlowID uint64

+ IncludeCircuitBreakInstances bool

+ IncludeUnhealthyInstances bool

+ Metadata map[string]string

+ Namespace string

+ RetryCount *int

+ Service string

+ SkipRouteFilter bool

+ SourceService *ServiceInfo

+ Timeout *time.Duration

+ func (g *GetInstancesRequest) GetCanary() string

+ func (g *GetInstancesRequest) GetMetadata() map[string]string

+ func (g *GetInstancesRequest) GetNamespace() string

+ func (g *GetInstancesRequest) GetResponse() *InstancesResponse

+ func (g *GetInstancesRequest) GetRetryCountPtr() *int

+ func (g *GetInstancesRequest) GetService() string

+ func (g *GetInstancesRequest) GetTimeoutPtr() *time.Duration

+ func (g *GetInstancesRequest) SetCanary(canary string)

+ func (g *GetInstancesRequest) SetRetryCount(retryCount int)

+ func (g *GetInstancesRequest) SetTimeout(duration time.Duration)

+ func (g *GetInstancesRequest) Validate() error

+ type GetMeshConfigRequest struct

+ Business string

+ FlowID uint64

+ MeshId string

+ MeshType string

+ Namespace string

+ RetryCount *int

+ Timeout *time.Duration

+ func (g *GetMeshConfigRequest) GetBusiness() string

+ func (g *GetMeshConfigRequest) GetMeshType() string

+ func (g *GetMeshConfigRequest) GetNamespace() string

+ func (g *GetMeshConfigRequest) GetRetryCountPtr() *int

+ func (g *GetMeshConfigRequest) GetTimeoutPtr() *time.Duration

+ func (g *GetMeshConfigRequest) SetRetryCount(retryCount int)

+ func (g *GetMeshConfigRequest) SetTimeout(duration time.Duration)

+ type GetMeshRequest struct

+ Business string

+ FlowID uint64

+ MeshId string

+ Namespace string

+ RetryCount *int

+ Timeout *time.Duration

+ func (g *GetMeshRequest) GetBusiness() string

+ func (g *GetMeshRequest) GetMeshId() string

+ func (g *GetMeshRequest) GetNamespace() string

+ func (g *GetMeshRequest) GetRetryCountPtr() *int

+ func (g *GetMeshRequest) GetTimeoutPtr() *time.Duration

+ func (g *GetMeshRequest) SetRetryCount(retryCount int)

+ func (g *GetMeshRequest) SetTimeout(duration time.Duration)

+ type GetOneInstanceRequest struct

+ Canary string

+ EnableFailOverDefaultMeta bool

+ FailOverDefaultMeta FailOverDefaultMetaConfig

+ FlowID uint64

+ HashKey []byte

+ HashValue uint64

+ LbPolicy string

+ Metadata map[string]string

+ Namespace string

+ ReplicateCount int

+ RetryCount *int

+ Service string

+ SourceService *ServiceInfo

+ Timeout *time.Duration

+ func (g *GetOneInstanceRequest) GetCanary() string

+ func (g *GetOneInstanceRequest) GetMetadata() map[string]string

+ func (g *GetOneInstanceRequest) GetNamespace() string

+ func (g *GetOneInstanceRequest) GetResponse() *InstancesResponse

+ func (g *GetOneInstanceRequest) GetRetryCountPtr() *int

+ func (g *GetOneInstanceRequest) GetService() string

+ func (g *GetOneInstanceRequest) GetTimeoutPtr() *time.Duration

+ func (g *GetOneInstanceRequest) SetCanary(canary string)

+ func (g *GetOneInstanceRequest) SetRetryCount(retryCount int)

+ func (g *GetOneInstanceRequest) SetTimeout(duration time.Duration)

+ func (g *GetOneInstanceRequest) Validate() error

+ type GetServiceRuleRequest struct

+ FlowID uint64

+ Namespace string

+ RetryCount *int

+ Service string

+ Timeout *time.Duration

+ func (g *GetServiceRuleRequest) GetMetadata() map[string]string

+ func (g *GetServiceRuleRequest) GetNamespace() string

+ func (g *GetServiceRuleRequest) GetResponse() *ServiceRuleResponse

+ func (g *GetServiceRuleRequest) GetRetryCountPtr() *int

+ func (g *GetServiceRuleRequest) GetService() string

+ func (g *GetServiceRuleRequest) GetTimeoutPtr() *time.Duration

+ func (g *GetServiceRuleRequest) SetRetryCount(retryCount int)

+ func (g *GetServiceRuleRequest) SetTimeout(duration time.Duration)

+ func (g *GetServiceRuleRequest) Validate() error

+ type GetServicesRequest struct

+ Business string

+ EnableBusiness bool

+ FlowID uint64

+ Metadata map[string]string

+ Namespace string

+ RetryCount *int

+ Timeout *time.Duration

+ func (g *GetServicesRequest) GetRetryCountPtr() *int

+ func (g *GetServicesRequest) GetTimeoutPtr() *time.Duration

+ func (g *GetServicesRequest) SetRetryCount(retryCount int)

+ func (g *GetServicesRequest) SetTimeout(duration time.Duration)

+ func (g *GetServicesRequest) Validate() error

+ type HashSet map[interface{}]bool

+ func (h HashSet) Add(value interface{})

+ func (h HashSet) Contains(value interface{}) bool

+ func (h HashSet) Copy() HashSet

+ func (h HashSet) Delete(value interface{}) bool

+ type HealthCheckStatus int

+ const Dead

+ const Healthy

+ type InitCalleeServiceRequest struct

+ Namespace string

+ Service string

+ Timeout *time.Duration

+ func (g *InitCalleeServiceRequest) Validate() error

+ type Instance interface

+ GetCampus func() string

+ GetCircuitBreakerStatus func() CircuitBreakerStatus

+ GetHost func() string

+ GetIDC func() string

+ GetId func() string

+ GetInstanceKey func() InstanceKey

+ GetLogicSet func() string

+ GetMetadata func() map[string]string

+ GetNamespace func() string

+ GetPort func() uint32

+ GetPriority func() uint32

+ GetProtocol func() string

+ GetRegion func() string

+ GetRevision func() string

+ GetService func() string

+ GetVersion func() string

+ GetVpcId func() string

+ GetWeight func() int

+ GetZone func() string

+ IsEnableHealthCheck func() bool

+ IsHealthy func() bool

+ IsIsolated func() bool

+ type InstanceAddEvent struct

+ Instances []Instance

+ type InstanceDeRegisterRequest struct

+ Host string

+ InstanceID string

+ Namespace string

+ Port int

+ RetryCount *int

+ Service string

+ ServiceToken string

+ Timeout *time.Duration

+ func (g *InstanceDeRegisterRequest) GetRetryCountPtr() *int

+ func (g *InstanceDeRegisterRequest) GetTimeoutPtr() *time.Duration

+ func (g *InstanceDeRegisterRequest) SetRetryCount(retryCount int)

+ func (g *InstanceDeRegisterRequest) SetTimeout(duration time.Duration)

+ func (g InstanceDeRegisterRequest) String() string

+ func (i *InstanceDeRegisterRequest) Validate() error

+ type InstanceDeleteEvent struct

+ Instances []Instance

+ type InstanceEvent struct

+ AddEvent *InstanceAddEvent

+ DeleteEvent *InstanceDeleteEvent

+ UpdateEvent *InstanceUpdateEvent

+ func (e *InstanceEvent) GetSubScribeEventType() SubScribeEventType

+ type InstanceGauge interface

+ GetAPI func() ApiOperation

+ GetCalledInstance func() Instance

+ GetCircuitBreakerStatus func() CircuitBreakerStatus

+ GetDelay func() *time.Duration

+ GetDelayRange func() ApiDelayRange

+ GetHost func() string

+ GetNamespace func() string

+ GetPort func() int

+ GetRetCodeValue func() int32

+ GetRetStatus func() RetStatus

+ GetService func() string

+ Validate func() error

+ type InstanceHeartbeatRequest struct

+ Host string

+ InstanceID string

+ Namespace string

+ Port int

+ RetryCount *int

+ Service string

+ ServiceToken string

+ Timeout *time.Duration

+ func (g *InstanceHeartbeatRequest) GetRetryCountPtr() *int

+ func (g *InstanceHeartbeatRequest) GetTimeoutPtr() *time.Duration

+ func (g *InstanceHeartbeatRequest) SetRetryCount(retryCount int)

+ func (g *InstanceHeartbeatRequest) SetTimeout(duration time.Duration)

+ func (g InstanceHeartbeatRequest) String() string

+ func (i *InstanceHeartbeatRequest) Validate() error

+ type InstanceKey struct

+ Host string

+ Port int

+ func (i InstanceKey) String() string

+ type InstanceRegisterRequest struct

+ Healthy *bool

+ Host string

+ Isolate *bool

+ Metadata map[string]string

+ Namespace string

+ Port int

+ Priority *int

+ Protocol *string

+ RetryCount *int

+ Service string

+ ServiceToken string

+ TTL *int

+ Timeout *time.Duration

+ Version *string

+ Weight *int

+ func (g *InstanceRegisterRequest) GetRetryCountPtr() *int

+ func (g *InstanceRegisterRequest) GetTimeoutPtr() *time.Duration

+ func (g *InstanceRegisterRequest) SetHealthy(healthy bool)

+ func (g *InstanceRegisterRequest) SetIsolate(isolate bool)

+ func (g *InstanceRegisterRequest) SetRetryCount(retryCount int)

+ func (g *InstanceRegisterRequest) SetTTL(ttl int)

+ func (g *InstanceRegisterRequest) SetTimeout(duration time.Duration)

+ func (g *InstanceRegisterRequest) Validate() error

+ func (g InstanceRegisterRequest) String() string

+ type InstanceRegisterResponse struct

+ Existed bool

+ InstanceID string

+ type InstanceSet struct

+ func (i *InstanceSet) Count() int

+ func (i *InstanceSet) GetInstances() WeightIndexSlice

+ func (i *InstanceSet) GetLock() sync.Locker

+ func (i *InstanceSet) GetRealInstances() []Instance

+ func (i *InstanceSet) GetSelector(id int32) ExtendedSelector

+ func (i *InstanceSet) GetServiceClusters() ServiceClusters

+ func (i *InstanceSet) GetValue(index int) uint64

+ func (i *InstanceSet) MaxWeight() int

+ func (i *InstanceSet) SetSelector(selector ExtendedSelector)

+ func (i *InstanceSet) String() string

+ func (i *InstanceSet) TotalWeight() int

+ type InstanceUpdateEvent struct

+ UpdateList []OneInstanceUpdate

+ type InstanceWeight struct

+ DynamicWeight uint32

+ InstanceID string

+ type InstancesResponse struct

+ Cluster *Cluster

+ FlowID uint64

+ Instances []Instance

+ Revision string

+ TotalWeight int

+ func (i *InstancesResponse) GetInstance(instanceId string) Instance

+ func (i *InstancesResponse) GetInstances() []Instance

+ func (i *InstancesResponse) GetRevision() string

+ func (i *InstancesResponse) GetServiceClusters() ServiceClusters

+ func (i *InstancesResponse) GetTotalWeight() int

+ func (i *InstancesResponse) GetType() EventType

+ func (i *InstancesResponse) IsCacheLoaded() bool

+ func (i *InstancesResponse) IsInitialized() bool

+ func (i *InstancesResponse) ReloadServiceClusters()

+ type Location struct

+ Campus string

+ Region string

+ Zone string

+ func (l *Location) IsEmpty() bool

+ func (l Location) String() string

+ type LocationBasedMetaKey struct

+ type LocationInfo interface

+ GetLastError func() SDKError

+ GetLocation func() *Location

+ GetStatus func() uint32

+ IsLocationInitialized func() bool

+ IsLocationReady func() bool

+ type Mesh interface

+ GetNamespace func() string

+ GetService func() string

+ GetValue func() interface{}

+ type MeshConfig interface

+ GetNamespace func() string

+ GetService func() string

+ GetValue func() interface{}

+ type MeshConfigResponse struct

+ Revision string

+ Service ServiceKey

+ Type EventType

+ ValidateError error

+ Value interface{}

+ func (s *MeshConfigResponse) GetNamespace() string

+ func (s *MeshConfigResponse) GetRevision() string

+ func (s *MeshConfigResponse) GetService() string

+ func (s *MeshConfigResponse) GetType() EventType

+ func (s *MeshConfigResponse) GetValidateError() error

+ func (s *MeshConfigResponse) GetValue() interface{}

+ func (s *MeshConfigResponse) IsInitialized() bool

+ type MeshKey struct

+ Business string

+ TypeUrl string

+ func (s MeshKey) String() string

+ type MeshResponse struct

+ Revision string

+ Service ServiceKey

+ Type EventType

+ ValidateError error

+ Value interface{}

+ func (s *MeshResponse) GetNamespace() string

+ func (s *MeshResponse) GetRevision() string

+ func (s *MeshResponse) GetService() string

+ func (s *MeshResponse) GetType() EventType

+ func (s *MeshResponse) GetValidateError() error

+ func (s *MeshResponse) GetValue() interface{}

+ func (s *MeshResponse) IsInitialized() bool

+ type MetaComposedValue struct

+ type MetricType int

+ const CircuitBreakStat

+ const InstanceStat

+ const LoadBalanceStat

+ const PluginAPIStat

+ const RateLimitStat

+ const RouteStat

+ const SDKAPIStat

+ const SDKCfgStat

+ const ServiceStat

+ type NotifyTrigger struct

+ EnableDstInstances bool

+ EnableDstRateLimit bool

+ EnableDstRoute bool

+ EnableMesh bool

+ EnableMeshConfig bool

+ EnableServices bool

+ EnableSrcRoute bool

+ func (n *NotifyTrigger) Clear()

+ type OneInstanceResponse struct

+ func (o *OneInstanceResponse) GetInstance() Instance

+ type OneInstanceUpdate struct

+ After Instance

+ Before Instance

+ type PeriodicCallBack interface

+ OnTaskEvent func(event TaskEvent)

+ Process func(taskKey interface{}, taskValue interface{}, lastProcessTime time.Time) TaskResult

+ type PeriodicTask struct

+ CallBack PeriodicCallBack

+ DelayStart bool

+ LongRun bool

+ Name string

+ Period time.Duration

+ TakePriority bool

+ type PriorityCallBack interface

+ Process func()

+ type PriorityTask struct

+ CallBack PriorityCallBack

+ Name string

+ type QuotaAllocator interface

+ Allocate func() *QuotaResponse

+ Release func()

+ type QuotaFutureImpl struct

+ func NewQuotaFuture(resp *QuotaResponse, deadline time.Time, allocator QuotaAllocator) *QuotaFutureImpl

+ func (q *QuotaFutureImpl) Done() <-chan struct{}

+ func (q *QuotaFutureImpl) Get() *QuotaResponse

+ func (q *QuotaFutureImpl) Release()

+ type QuotaRequestImpl struct

+ RetryCount *int

+ Timeout *time.Duration

+ func (q *QuotaRequestImpl) GetCluster() string

+ func (q *QuotaRequestImpl) GetLabels() map[string]string

+ func (q *QuotaRequestImpl) GetNamespace() string

+ func (q *QuotaRequestImpl) GetRetryCountPtr() *int

+ func (q *QuotaRequestImpl) GetService() string

+ func (q *QuotaRequestImpl) GetTimeoutPtr() *time.Duration

+ func (q *QuotaRequestImpl) SetCluster(cluster string)

+ func (q *QuotaRequestImpl) SetLabels(labels map[string]string)

+ func (q *QuotaRequestImpl) SetNamespace(namespace string)

+ func (q *QuotaRequestImpl) SetRetryCount(retryCount int)

+ func (q *QuotaRequestImpl) SetService(svc string)

+ func (q *QuotaRequestImpl) SetTimeout(timeout time.Duration)

+ func (q *QuotaRequestImpl) Validate() error

+ type QuotaResponse struct

+ Code QuotaResultCode

+ Info string

+ type QuotaResultCode int

+ const QuotaResultLimited

+ const QuotaResultOk

+ type RegistryValue interface

+ GetRevision func() string

+ GetType func() EventType

+ IsInitialized func() bool

+ type ReplicateNodes struct

+ Count int

+ Indexes []int

+ Instances atomic.Value

+ SvcClusters ServiceClusters

+ func (r *ReplicateNodes) GetInstances() []Instance

+ type ReportClientRequest struct

+ Host string

+ PersistHandler func(message proto.Message) error

+ Timeout time.Duration

+ Version string

+ func (r *ReportClientRequest) Validate() error

+ type ReportClientResponse struct

+ Campus string

+ Mode RunMode

+ Region string

+ Version string

+ Zone string

+ type RetStatus int

+ const RetFail

+ const RetSuccess

+ type RuleCache interface

+ GetMessageCache func(message proto.Message) interface{}

+ GetRegexMatcher func(message string) *regexp.Regexp

+ PutRegexMatcher func(message string, pattern *regexp.Regexp)

+ SetMessageCache func(message proto.Message, cacheValue interface{})

+ func NewRuleCache() RuleCache

+ type RunMode int

+ type SDKError interface

+ Error func() string

+ ErrorCode func() ErrCode

+ ServerCode func() uint32

+ ServerInfo func() string

+ func NewSDKError(errCode ErrCode, cause error, msg string, args ...interface{}) SDKError

+ func NewServerSDKError(serverCode uint32, serverInfo string, cause error, msg string, ...) SDKError

+ type SDKToken struct

+ Client string

+ HostName string

+ IP string

+ PID int32

+ PodName string

+ UID string

+ Version string

+ type SelectorBase struct

+ Id int32

+ func (s *SelectorBase) ID() int32

+ type ServiceCallResult struct

+ CalledInstance Instance

+ Delay *time.Duration

+ RetCode *int32

+ RetStatus RetStatus

+ func (s *ServiceCallResult) GetCalledInstance() Instance

+ func (s *ServiceCallResult) GetDelay() *time.Duration

+ func (s *ServiceCallResult) GetHost() string

+ func (s *ServiceCallResult) GetID() string

+ func (s *ServiceCallResult) GetNamespace() string

+ func (s *ServiceCallResult) GetPort() int

+ func (s *ServiceCallResult) GetRetCode() *int32

+ func (s *ServiceCallResult) GetRetCodeValue() int32

+ func (s *ServiceCallResult) GetRetStatus() RetStatus

+ func (s *ServiceCallResult) GetService() string

+ func (s *ServiceCallResult) SetCalledInstance(inst Instance) *ServiceCallResult

+ func (s *ServiceCallResult) SetDelay(duration time.Duration) *ServiceCallResult

+ func (s *ServiceCallResult) SetRetCode(value int32) *ServiceCallResult

+ func (s *ServiceCallResult) SetRetStatus(retStatus RetStatus) *ServiceCallResult

+ func (s *ServiceCallResult) Validate() error

+ type ServiceClusters interface

+ AddInstance func(instance Instance)

+ GetClusterInstances func(cacheKey ClusterKey) *ClusterValue

+ GetContainMetaKeyClusterInstances func(cacheKey ClusterKey) *ClusterValue

+ GetContainNotMatchMetaKeyClusterInstances func(cacheKey ClusterKey) *ClusterValue

+ GetExtendedCacheValue func(pluginIndex int) interface{}

+ GetInstanceMetaValues func(location Location, metaKey string) map[string]string

+ GetNearbyCluster func(location Location) (*Cluster, int)

+ GetNotContainMetaKeyClusterInstances func(cacheKey ClusterKey) *ClusterValue

+ GetServiceInstances func() ServiceInstances

+ GetServiceKey func() ServiceKey

+ HasCampus func(campus string) bool

+ HasRegion func(region string) bool

+ HasZone func(zone string) bool

+ IsCanaryEnabled func() bool

+ IsNearbyEnabled func() bool

+ SetExtendedCacheValue func(pluginIndex int, value interface{})

+ SetNearbyCluster func(location Location, cluster *Cluster, matchLevel int)

+ func NewServiceClusters(svcInstances ServiceInstances) ServiceClusters

+ type ServiceEventKey struct

+ Type EventType

+ func (s ServiceEventKey) String() string

+ type ServiceInfo struct

+ Metadata map[string]string

+ Namespace string

+ Service string

+ func (i *ServiceInfo) GetMetadata() map[string]string

+ func (i *ServiceInfo) GetNamespace() string

+ func (i *ServiceInfo) GetService() string

+ func (i ServiceInfo) String() string

+ type ServiceInstances interface

+ GetInstance func(string) Instance

+ GetInstances func() []Instance

+ GetServiceClusters func() ServiceClusters

+ GetTotalWeight func() int

+ IsCacheLoaded func() bool

+ ReloadServiceClusters func()

+ type ServiceKey struct

+ Namespace string

+ Service string

+ func (s ServiceKey) String() string

+ type ServiceMetadata interface

+ GetMetadata func() map[string]string

+ GetNamespace func() string

+ GetService func() string

+ type ServiceRule interface

+ GetNamespace func() string

+ GetRuleCache func() RuleCache

+ GetService func() string

+ GetValidateError func() error

+ GetValue func() interface{}

+ IsCacheLoaded func() bool

+ type ServiceRuleResponse struct

+ Revision string

+ RuleCache RuleCache

+ Service ServiceKey

+ Type EventType

+ ValidateError error

+ Value interface{}

+ func (s *ServiceRuleResponse) GetNamespace() string

+ func (s *ServiceRuleResponse) GetRevision() string

+ func (s *ServiceRuleResponse) GetRuleCache() RuleCache

+ func (s *ServiceRuleResponse) GetService() string

+ func (s *ServiceRuleResponse) GetType() EventType

+ func (s *ServiceRuleResponse) GetValidateError() error

+ func (s *ServiceRuleResponse) GetValue() interface{}

+ func (s *ServiceRuleResponse) IsCacheLoaded() bool

+ func (s *ServiceRuleResponse) IsInitialized() bool

+ type Services interface

+ GetNamespace func() string

+ GetService func() string

+ GetValue func() interface{}

+ type ServicesResponse struct

+ Revision string

+ Service ServiceKey

+ Type EventType

+ ValidateError error

+ Value interface{}

+ func (s *ServicesResponse) GetNamespace() string

+ func (s *ServicesResponse) GetRevision() string

+ func (s *ServicesResponse) GetService() string

+ func (s *ServicesResponse) GetType() EventType

+ func (s *ServicesResponse) GetValidateError() error

+ func (s *ServicesResponse) GetValue() interface{}

+ func (s *ServicesResponse) IsInitialized() bool

+ type Status int

+ const Close

+ const HalfOpen

+ const Open

+ func (s Status) String() string

+ type SubScribeEvent interface

+ GetSubScribeEventType func() SubScribeEventType

+ type SubScribeEventType int

+ const EventInstance

+ type SyncHashSet struct

+ func NewSyncHashSet() *SyncHashSet

+ func (s *SyncHashSet) Add(value interface{})

+ func (s *SyncHashSet) Contains(value interface{}) bool

+ func (s *SyncHashSet) Copy() HashSet

+ func (s *SyncHashSet) Delete(value interface{}) bool

+ type TaskEvent int

+ const EventStart

+ const EventStop

+ type TaskResult int

+ const CONTINUE

+ const SKIP

+ const TERMINATE

+ type TaskValue interface

+ CompareTo func(interface{}) int

+ EnsureDeleted func(value interface{}) bool

+ type TaskValues interface

+ AddValue func(key interface{}, value TaskValue)

+ DeleteValue func(key interface{}, value TaskValue)

+ Started func() bool

+ type ValueContext interface

+ GetClientId func() string

+ GetCurrentLocation func() LocationInfo

+ GetEngine func() Engine

+ GetValue func(key string) (interface{}, bool)

+ Now func() time.Time

+ SetCurrentLocation func(*Location, SDKError) bool

+ SetValue func(key string, value interface{})

+ Since func(time.Time) time.Duration

+ WaitLocationInfo func(ctx context.Context, locationStatus uint32) bool

+ func NewValueContext() ValueContext

+ type WatchServiceRequest struct

+ Key ServiceKey

+ func (req *WatchServiceRequest) Validate() error

+ type WatchServiceResponse struct

+ EventChannel <-chan SubScribeEvent

+ GetAllInstancesResp *InstancesResponse

+ type WeightIndexSlice []WeightedIndex

+ type WeightedIndex struct

+ AccumulateWeight int

+ Index int

v0

v0.9.0

Jul 21, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL