v1

package
v1.13.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 31, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 7 Imported by: 3

Documentation

Index

Constants

View Source 
const (
	ExecuteSuccess                  uint32 = 200000
	DataNoChange                    uint32 = 200001
	NoNeedUpdate                    uint32 = 200002
	BadRequest                      uint32 = 400000
	ParseException                  uint32 = 400001
	EmptyRequest                    uint32 = 400002
	BatchSizeOverLimit              uint32 = 400003
	InvalidDiscoverResource         uint32 = 400004
	InvalidRequestID                uint32 = 400100
	InvalidUserName                 uint32 = 400101
	InvalidUserToken                uint32 = 400102
	InvalidParameter                uint32 = 400103
	EmptyQueryParameter             uint32 = 400104
	InvalidQueryInsParameter        uint32 = 400105
	InvalidNamespaceName            uint32 = 400110
	InvalidNamespaceOwners          uint32 = 400111
	InvalidNamespaceToken           uint32 = 400112
	InvalidServiceName              uint32 = 400120
	InvalidServiceOwners            uint32 = 400121
	InvalidServiceToken             uint32 = 400122
	InvalidServiceMetadata          uint32 = 400123
	InvalidServicePorts             uint32 = 400124
	InvalidServiceBusiness          uint32 = 400125
	InvalidServiceDepartment        uint32 = 400126
	InvalidServiceCMDB              uint32 = 400127
	InvalidServiceComment           uint32 = 400128
	InvalidServiceAliasComment      uint32 = 400129
	InvalidInstanceID               uint32 = 400130
	InvalidInstanceHost             uint32 = 400131
	InvalidInstancePort             uint32 = 400132
	InvalidServiceAlias             uint32 = 400133
	InvalidNamespaceWithAlias       uint32 = 400134
	InvalidServiceAliasOwners       uint32 = 400135
	InvalidInstanceProtocol         uint32 = 400136
	InvalidInstanceVersion          uint32 = 400137
	InvalidInstanceLogicSet         uint32 = 400138
	InvalidInstanceIsolate          uint32 = 400139
	HealthCheckNotOpen              uint32 = 400140
	HeartbeatOnDisabledIns          uint32 = 400141
	HeartbeatExceedLimit            uint32 = 400142
	HeartbeatTypeNotFound           uint32 = 400143
	InvalidMetadata                 uint32 = 400150
	InvalidRateLimitID              uint32 = 400151
	InvalidRateLimitLabels          uint32 = 400152
	InvalidRateLimitAmounts         uint32 = 400153
	InvalidRateLimitName            uint32 = 400154
	InvalidCircuitBreakerID         uint32 = 400160
	InvalidCircuitBreakerVersion    uint32 = 400161
	InvalidCircuitBreakerName       uint32 = 400162
	InvalidCircuitBreakerNamespace  uint32 = 400163
	InvalidCircuitBreakerOwners     uint32 = 400164
	InvalidCircuitBreakerToken      uint32 = 400165
	InvalidCircuitBreakerBusiness   uint32 = 400166
	InvalidCircuitBreakerDepartment uint32 = 400167
	InvalidCircuitBreakerComment    uint32 = 400168
	InvalidRoutingID                uint32 = 400700
	InvalidRoutingPolicy            uint32 = 400701
	InvalidRoutingName              uint32 = 400702
	InvalidRoutingPriority          uint32 = 400703

	// 网格相关错误码
	ServicesExistedMesh  uint32 = 400170
	ResourcesExistedMesh uint32 = 400171
	InvalidMeshParameter uint32 = 400172

	// 平台信息相关错误码
	InvalidPlatformID         uint32 = 400180
	InvalidPlatformName       uint32 = 400181
	InvalidPlatformDomain     uint32 = 400182
	InvalidPlatformQPS        uint32 = 400183
	InvalidPlatformToken      uint32 = 400184
	InvalidPlatformOwner      uint32 = 400185
	InvalidPlatformDepartment uint32 = 400186
	InvalidPlatformComment    uint32 = 400187
	NotFoundPlatform          uint32 = 400188

	// flux相关错误码
	InvalidFluxRateLimitId     uint32 = 400190
	InvalidFluxRateLimitQps    uint32 = 400191
	InvalidFluxRateLimitSetKey uint32 = 400192

	ExistedResource                 uint32 = 400201
	NotFoundResource                uint32 = 400202
	NamespaceExistedServices        uint32 = 400203
	ServiceExistedInstances         uint32 = 400204
	ServiceExistedRoutings          uint32 = 400205
	ServiceExistedRateLimits        uint32 = 400206
	ExistReleasedConfig             uint32 = 400207
	SameInstanceRequest             uint32 = 400208
	ServiceExistedCircuitBreakers   uint32 = 400209
	ServiceExistedAlias             uint32 = 400210
	NamespaceExistedMeshResources   uint32 = 400211
	NamespaceExistedCircuitBreakers uint32 = 400212
	ServiceSubscribedByMeshes       uint32 = 400213
	ServiceExistedFluxRateLimits    uint32 = 400214
	NamespaceExistedConfigGroups    uint32 = 400219

	NotFoundService                    uint32 = 400301
	NotFoundRouting                    uint32 = 400302
	NotFoundInstance                   uint32 = 400303
	NotFoundServiceAlias               uint32 = 400304
	NotFoundNamespace                  uint32 = 400305
	NotFoundSourceService              uint32 = 400306
	NotFoundRateLimit                  uint32 = 400307
	NotFoundCircuitBreaker             uint32 = 400308
	NotFoundMasterConfig               uint32 = 400309
	NotFoundTagConfig                  uint32 = 400310
	NotFoundTagConfigOrService         uint32 = 400311
	ClientAPINotOpen                   uint32 = 400401
	NotAllowBusinessService            uint32 = 400402
	NotAllowAliasUpdate                uint32 = 400501
	NotAllowAliasCreateInstance        uint32 = 400502
	NotAllowAliasCreateRouting         uint32 = 400503
	NotAllowCreateAliasForAlias        uint32 = 400504
	NotAllowAliasCreateRateLimit       uint32 = 400505
	NotAllowAliasBindRule              uint32 = 400506
	NotAllowDifferentNamespaceBindRule uint32 = 400507
	Unauthorized                       uint32 = 401000
	NotAllowedAccess                   uint32 = 401001
	IPRateLimit                        uint32 = 403001
	APIRateLimit                       uint32 = 403002
	CMDBNotFindHost                    uint32 = 404001
	DataConflict                       uint32 = 409000
	InstanceTooManyRequests            uint32 = 429001
	ExecuteException                   uint32 = 500000
	StoreLayerException                uint32 = 500001
	CMDBPluginException                uint32 = 500002
	ParseRoutingException              uint32 = 500004
	ParseRateLimitException            uint32 = 500005
	ParseCircuitBreakerException       uint32 = 500006
	HeartbeatException                 uint32 = 500007
	InstanceRegisTimeout               uint32 = 500008

	InvalidConfigFileGroupName     uint32 = 400801
	InvalidConfigFileName          uint32 = 400802
	InvalidConfigFileContentLength uint32 = 400803
	InvalidConfigFileFormat        uint32 = 400804
	InvalidConfigFileTags          uint32 = 400805
	InvalidWatchConfigFileFormat   uint32 = 400806
	NotFoundResourceConfigFile     uint32 = 400807
	InvalidConfigFileTemplateName  uint32 = 400808

	// 鉴权相关错误码
	InvalidUserOwners         uint32 = 400410
	InvalidUserID             uint32 = 400411
	InvalidUserPassword       uint32 = 400412
	InvalidUserMobile         uint32 = 400413
	InvalidUserEmail          uint32 = 400414
	InvalidUserGroupOwners    uint32 = 400420
	InvalidUserGroupID        uint32 = 400421
	InvalidAuthStrategyOwners uint32 = 400430
	InvalidAuthStrategyName   uint32 = 400431
	InvalidAuthStrategyID     uint32 = 400432
	InvalidPrincipalType      uint32 = 400440

	UserExisted                            uint32 = 400215
	UserGroupExisted                       uint32 = 400216
	AuthStrategyRuleExisted                uint32 = 400217
	SubAccountExisted                      uint32 = 400218
	NotFoundUser                           uint32 = 400312
	NotFoundOwnerUser                      uint32 = 400313
	NotFoundUserGroup                      uint32 = 400314
	NotFoundAuthStrategyRule               uint32 = 400315
	NotAllowModifyDefaultStrategyPrincipal uint32 = 400508
	NotAllowModifyOwnerDefaultStrategy     uint32 = 400509

	EmptyAutToken   uint32 = 401002
	TokenDisabled   uint32 = 401003
	TokenNotExisted uint32 = 401004

	AuthTokenVerifyException uint32 = 500100
	OperationRoleException   uint32 = 500101
)

北极星错误码 六位构成，前面三位参照HTTP Status的标准 后面三位，依据内部的具体错误自定义

Variables

View Source 
var AliasType_name = map[int32]string{
	0: "DEFAULT",
	1: "CL5SID",
}
View Source 
var AliasType_value = map[string]int32{
	"DEFAULT": 0,
	"CL5SID":  1,
}
View Source 
var AuthAction_name = map[int32]string{
	0: "ONLY_READ",
	1: "READ_WRITE",
}
View Source 
var AuthAction_value = map[string]int32{
	"ONLY_READ":  0,
	"READ_WRITE": 1,
}
View Source 
var Client_ClientType_name = map[int32]string{
	0: "UNKNOWN",
	1: "SDK",
	2: "AGENT",
}
View Source 
var Client_ClientType_value = map[string]int32{
	"UNKNOWN": 0,
	"SDK":     1,
	"AGENT":   2,
}
View Source 
var DestinationSet_Resource_name = map[int32]string{
	0: "SUBSET",
	1: "INSTANCE",
}
View Source 
var DestinationSet_Resource_value = map[string]int32{
	"SUBSET":   0,
	"INSTANCE": 1,
}
View Source 
var DestinationSet_Scope_name = map[int32]string{
	0: "ALL",
	1: "CURRENT",
}
View Source 
var DestinationSet_Scope_value = map[string]int32{
	"ALL":     0,
	"CURRENT": 1,
}
View Source 
var DestinationSet_Type_name = map[int32]string{
	0: "GLOBAL",
	1: "LOCAL",
}
View Source 
var DestinationSet_Type_value = map[string]int32{
	"GLOBAL": 0,
	"LOCAL":  1,
}
View Source 
var DiscoverRequest_DiscoverRequestType_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "INSTANCE",
	2:  "CLUSTER",
	3:  "ROUTING",
	4:  "RATE_LIMIT",
	5:  "CIRCUIT_BREAKER",
	6:  "SERVICES",
	12: "NAMESPACES",
}
View Source 
var DiscoverRequest_DiscoverRequestType_value = map[string]int32{
	"UNKNOWN":         0,
	"INSTANCE":        1,
	"CLUSTER":         2,
	"ROUTING":         3,
	"RATE_LIMIT":      4,
	"CIRCUIT_BREAKER": 5,
	"SERVICES":        6,
	"NAMESPACES":      12,
}
View Source 
var DiscoverResponse_DiscoverResponseType_name = map[int32]string{
	0:  "UNKNOWN",
	1:  "INSTANCE",
	2:  "CLUSTER",
	3:  "ROUTING",
	4:  "RATE_LIMIT",
	5:  "CIRCUIT_BREAKER",
	6:  "SERVICES",
	12: "NAMESPACES",
}
View Source 
var DiscoverResponse_DiscoverResponseType_value = map[string]int32{
	"UNKNOWN":         0,
	"INSTANCE":        1,
	"CLUSTER":         2,
	"ROUTING":         3,
	"RATE_LIMIT":      4,
	"CIRCUIT_BREAKER": 5,
	"SERVICES":        6,
	"NAMESPACES":      12,
}
View Source 
var HealthCheck_HealthCheckType_name = map[int32]string{
	0: "UNKNOWN",
	1: "HEARTBEAT",
}
View Source 
var HealthCheck_HealthCheckType_value = map[string]int32{
	"UNKNOWN":   0,
	"HEARTBEAT": 1,
}
View Source 
var MatchArgument_Type_name = map[int32]string{
	0: "CUSTOM",
	1: "METHOD",
	2: "HEADER",
	3: "QUERY",
	4: "CALLER_SERVICE",
	5: "CALLER_IP",
}
View Source 
var MatchArgument_Type_value = map[string]int32{
	"CUSTOM":         0,
	"METHOD":         1,
	"HEADER":         2,
	"QUERY":          3,
	"CALLER_SERVICE": 4,
	"CALLER_IP":      5,
}
View Source 
var MatchString_MatchStringType_name = map[int32]string{
	0: "EXACT",
	1: "REGEX",
	2: "NOT_EQUALS",
	3: "IN",
	4: "NOT_IN",
}
View Source 
var MatchString_MatchStringType_value = map[string]int32{
	"EXACT":      0,
	"REGEX":      1,
	"NOT_EQUALS": 2,
	"IN":         3,
	"NOT_IN":     4,
}
View Source 
var MatchString_ValueType_name = map[int32]string{
	0: "TEXT",
	1: "PARAMETER",
	2: "VARIABLE",
}
View Source 
var MatchString_ValueType_value = map[string]int32{
	"TEXT":      0,
	"PARAMETER": 1,
	"VARIABLE":  2,
}
View Source 
var RecoverConfig_OutlierDetectWhen_name = map[int32]string{
	0: "NEVER",
	1: "ON_RECOVER",
	2: "ALWAYS",
}
View Source 
var RecoverConfig_OutlierDetectWhen_value = map[string]int32{
	"NEVER":      0,
	"ON_RECOVER": 1,
	"ALWAYS":     2,
}
View Source 
var ResourceType_name = map[int32]string{
	0: "Namespaces",
	1: "Services",
	2: "ConfigGroups",
}
View Source 
var ResourceType_value = map[string]int32{
	"Namespaces":   0,
	"Services":     1,
	"ConfigGroups": 2,
}
View Source 
var Rule_AmountMode_name = map[int32]string{
	0: "GLOBAL_TOTAL",
	1: "SHARE_EQUALLY",
}
View Source 
var Rule_AmountMode_value = map[string]int32{
	"GLOBAL_TOTAL":  0,
	"SHARE_EQUALLY": 1,
}
View Source 
var Rule_FailoverType_name = map[int32]string{
	0: "FAILOVER_LOCAL",
	1: "FAILOVER_PASS",
}
View Source 
var Rule_FailoverType_value = map[string]int32{
	"FAILOVER_LOCAL": 0,
	"FAILOVER_PASS":  1,
}
View Source 
var Rule_Resource_name = map[int32]string{
	0: "QPS",
	1: "CONCURRENCY",
}
View Source 
var Rule_Resource_value = map[string]int32{
	"QPS":         0,
	"CONCURRENCY": 1,
}
View Source 
var Rule_Type_name = map[int32]string{
	0: "GLOBAL",
	1: "LOCAL",
}
View Source 
var Rule_Type_value = map[string]int32{
	"GLOBAL": 0,
	"LOCAL":  1,
}

Functions

func CalcCode 

func CalcCode(rm ResponseMessage) int

*

  • @brief 获取返回码前三位
  • @note 返回码前三位和HTTP返回码定义一致

func Code2Info 

func Code2Info(code uint32) string

code to info

func RegisterPolarisConfigGRPCServer 

func RegisterPolarisConfigGRPCServer(s *grpc.Server, srv PolarisConfigGRPCServer)

func RegisterPolarisGRPCServer 

func RegisterPolarisGRPCServer(s *grpc.Server, srv PolarisGRPCServer)

Types

type AliasType 

type AliasType int32
const (
	AliasType_DEFAULT AliasType = 0
	AliasType_CL5SID  AliasType = 1
)

func (AliasType) EnumDescriptor 

func (AliasType) EnumDescriptor() ([]byte, []int)

func (AliasType) String 

func (x AliasType) String() string

type Amount 

type Amount struct {
	// 时间周期内的最大配额数
	MaxAmount *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=maxAmount,proto3" json:"maxAmount,omitempty"`
	// 配额生效的时间周期，必须大于等于1s
	ValidDuration *duration.Duration `protobuf:"bytes,2,opt,name=validDuration,proto3" json:"validDuration,omitempty"`
	// 请求统计精度
	Precision *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=precision,proto3" json:"precision,omitempty"`
	// 可选，起始限流阈值，爬坡起始值
	StartAmount *wrappers.UInt32Value `protobuf:"bytes,4,opt,name=startAmount,proto3" json:"startAmount,omitempty"`
	// 可选，最小限流阈值，降低时最小值
	MinAmount            *wrappers.UInt32Value `protobuf:"bytes,5,opt,name=minAmount,proto3" json:"minAmount,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

限流配额

func (*Amount) Descriptor 

func (*Amount) Descriptor() ([]byte, []int)

func (*Amount) GetMaxAmount 

func (m *Amount) GetMaxAmount() *wrappers.UInt32Value

func (*Amount) GetMinAmount 

func (m *Amount) GetMinAmount() *wrappers.UInt32Value

func (*Amount) GetPrecision 

func (m *Amount) GetPrecision() *wrappers.UInt32Value

func (*Amount) GetStartAmount 

func (m *Amount) GetStartAmount() *wrappers.UInt32Value

func (*Amount) GetValidDuration 

func (m *Amount) GetValidDuration() *duration.Duration

func (*Amount) ProtoMessage 

func (*Amount) ProtoMessage()

func (*Amount) Reset 

func (m *Amount) Reset()

func (*Amount) String 

func (m *Amount) String() string

func (*Amount) XXX_DiscardUnknown 

func (m *Amount) XXX_DiscardUnknown()

func (*Amount) XXX_Marshal 

func (m *Amount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Amount) XXX_Merge 

func (dst *Amount) XXX_Merge(src proto.Message)

func (*Amount) XXX_Size 

func (m *Amount) XXX_Size() int

func (*Amount) XXX_Unmarshal 

func (m *Amount) XXX_Unmarshal(b []byte) error

type AmountAdjuster 

type AmountAdjuster struct {
	Climb                *ClimbConfig `protobuf:"bytes,1,opt,name=climb,proto3" json:"climb,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

配额调整算法

func (*AmountAdjuster) Descriptor 

func (*AmountAdjuster) Descriptor() ([]byte, []int)

func (*AmountAdjuster) GetClimb 

func (m *AmountAdjuster) GetClimb() *ClimbConfig

func (*AmountAdjuster) ProtoMessage 

func (*AmountAdjuster) ProtoMessage()

func (*AmountAdjuster) Reset 

func (m *AmountAdjuster) Reset()

func (*AmountAdjuster) String 

func (m *AmountAdjuster) String() string

func (*AmountAdjuster) XXX_DiscardUnknown 

func (m *AmountAdjuster) XXX_DiscardUnknown()

func (*AmountAdjuster) XXX_Marshal 

func (m *AmountAdjuster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AmountAdjuster) XXX_Merge 

func (dst *AmountAdjuster) XXX_Merge(src proto.Message)

func (*AmountAdjuster) XXX_Size 

func (m *AmountAdjuster) XXX_Size() int

func (*AmountAdjuster) XXX_Unmarshal 

func (m *AmountAdjuster) XXX_Unmarshal(b []byte) error

type AuthAction 

type AuthAction int32
const (
	AuthAction_ONLY_READ  AuthAction = 0
	AuthAction_READ_WRITE AuthAction = 1
)

func (AuthAction) EnumDescriptor 

func (AuthAction) EnumDescriptor() ([]byte, []int)

func (AuthAction) String 

func (x AuthAction) String() string

type AuthStrategy 

type AuthStrategy struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Principals           *Principals           `protobuf:"bytes,3,opt,name=principals,proto3" json:"principals,omitempty"`
	Resources            *StrategyResources    `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"`
	Action               AuthAction            `protobuf:"varint,5,opt,name=action,proto3,enum=v1.AuthAction" json:"action,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,6,opt,name=comment,proto3" json:"comment,omitempty"`
	Owner                *wrappers.StringValue `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,8,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,9,opt,name=mtime,proto3" json:"mtime,omitempty"`
	AuthToken            *wrappers.StringValue `protobuf:"bytes,10,opt,name=auth_token,proto3" json:"auth_token,omitempty"`
	DefaultStrategy      *wrappers.BoolValue   `protobuf:"bytes,11,opt,name=default_strategy,proto3" json:"default_strategy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*AuthStrategy) Descriptor 

func (*AuthStrategy) Descriptor() ([]byte, []int)

func (*AuthStrategy) GetAction 

func (m *AuthStrategy) GetAction() AuthAction

func (*AuthStrategy) GetAuthToken 

func (m *AuthStrategy) GetAuthToken() *wrappers.StringValue

func (*AuthStrategy) GetComment 

func (m *AuthStrategy) GetComment() *wrappers.StringValue

func (*AuthStrategy) GetCtime 

func (m *AuthStrategy) GetCtime() *wrappers.StringValue

func (*AuthStrategy) GetDefaultStrategy 

func (m *AuthStrategy) GetDefaultStrategy() *wrappers.BoolValue

func (*AuthStrategy) GetId 

func (m *AuthStrategy) GetId() *wrappers.StringValue

func (*AuthStrategy) GetMtime 

func (m *AuthStrategy) GetMtime() *wrappers.StringValue

func (*AuthStrategy) GetName 

func (m *AuthStrategy) GetName() *wrappers.StringValue

func (*AuthStrategy) GetOwner 

func (m *AuthStrategy) GetOwner() *wrappers.StringValue

func (*AuthStrategy) GetPrincipals 

func (m *AuthStrategy) GetPrincipals() *Principals

func (*AuthStrategy) GetResources 

func (m *AuthStrategy) GetResources() *StrategyResources

func (*AuthStrategy) ProtoMessage 

func (*AuthStrategy) ProtoMessage()

func (*AuthStrategy) Reset 

func (m *AuthStrategy) Reset()

func (*AuthStrategy) String 

func (m *AuthStrategy) String() string

func (*AuthStrategy) XXX_DiscardUnknown 

func (m *AuthStrategy) XXX_DiscardUnknown()

func (*AuthStrategy) XXX_Marshal 

func (m *AuthStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AuthStrategy) XXX_Merge 

func (dst *AuthStrategy) XXX_Merge(src proto.Message)

func (*AuthStrategy) XXX_Size 

func (m *AuthStrategy) XXX_Size() int

func (*AuthStrategy) XXX_Unmarshal 

func (m *AuthStrategy) XXX_Unmarshal(b []byte) error

type BatchQueryResponse 

type BatchQueryResponse struct {
	Code                 *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Amount               *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"`
	Size                 *wrappers.UInt32Value `protobuf:"bytes,4,opt,name=size,proto3" json:"size,omitempty"`
	Namespaces           []*Namespace          `protobuf:"bytes,5,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Services             []*Service            `protobuf:"bytes,6,rep,name=services,proto3" json:"services,omitempty"`
	Instances            []*Instance           `protobuf:"bytes,7,rep,name=instances,proto3" json:"instances,omitempty"`
	Routings             []*Routing            `protobuf:"bytes,8,rep,name=routings,proto3" json:"routings,omitempty"`
	Aliases              []*ServiceAlias       `protobuf:"bytes,9,rep,name=aliases,proto3" json:"aliases,omitempty"`
	RateLimits           []*Rule               `protobuf:"bytes,10,rep,name=rateLimits,proto3" json:"rateLimits,omitempty"`
	ConfigWithServices   []*ConfigWithService  `protobuf:"bytes,11,rep,name=configWithServices,proto3" json:"configWithServices,omitempty"`
	Platforms            []*Platform           `protobuf:"bytes,15,rep,name=platforms,proto3" json:"platforms,omitempty"`
	Users                []*User               `protobuf:"bytes,18,rep,name=users,proto3" json:"users,omitempty"`
	UserGroups           []*UserGroup          `protobuf:"bytes,19,rep,name=userGroups,proto3" json:"userGroups,omitempty"`
	AuthStrategies       []*AuthStrategy       `protobuf:"bytes,20,rep,name=authStrategies,proto3" json:"authStrategies,omitempty"`
	Clients              []*Client             `protobuf:"bytes,21,rep,name=clients,proto3" json:"clients,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func NewBatchQueryResponse 

func NewBatchQueryResponse(code uint32) *BatchQueryResponse

*

  • @brief 创建批量查询回复

func NewBatchQueryResponseWithMsg 

func NewBatchQueryResponseWithMsg(code uint32, msg string) *BatchQueryResponse

*

  • @brief 创建带详细信息的批量查询回复

func (*BatchQueryResponse) AddNamespace 

func (b *BatchQueryResponse) AddNamespace(namespace *Namespace)

*

  • @brief BatchQueryResponse添加命名空间

func (*BatchQueryResponse) Descriptor 

func (*BatchQueryResponse) Descriptor() ([]byte, []int)

func (*BatchQueryResponse) GetAliases 

func (m *BatchQueryResponse) GetAliases() []*ServiceAlias

func (*BatchQueryResponse) GetAmount 

func (m *BatchQueryResponse) GetAmount() *wrappers.UInt32Value

func (*BatchQueryResponse) GetAuthStrategies 

func (m *BatchQueryResponse) GetAuthStrategies() []*AuthStrategy

func (*BatchQueryResponse) GetClients 

func (m *BatchQueryResponse) GetClients() []*Client

func (*BatchQueryResponse) GetCode 

func (m *BatchQueryResponse) GetCode() *wrappers.UInt32Value

func (*BatchQueryResponse) GetConfigWithServices 

func (m *BatchQueryResponse) GetConfigWithServices() []*ConfigWithService

func (*BatchQueryResponse) GetInfo 

func (m *BatchQueryResponse) GetInfo() *wrappers.StringValue

func (*BatchQueryResponse) GetInstances 

func (m *BatchQueryResponse) GetInstances() []*Instance

func (*BatchQueryResponse) GetNamespaces 

func (m *BatchQueryResponse) GetNamespaces() []*Namespace

func (*BatchQueryResponse) GetPlatforms 

func (m *BatchQueryResponse) GetPlatforms() []*Platform

func (*BatchQueryResponse) GetRateLimits 

func (m *BatchQueryResponse) GetRateLimits() []*Rule

func (*BatchQueryResponse) GetRoutings 

func (m *BatchQueryResponse) GetRoutings() []*Routing

func (*BatchQueryResponse) GetServices 

func (m *BatchQueryResponse) GetServices() []*Service

func (*BatchQueryResponse) GetSize 

func (m *BatchQueryResponse) GetSize() *wrappers.UInt32Value

func (*BatchQueryResponse) GetUserGroups 

func (m *BatchQueryResponse) GetUserGroups() []*UserGroup

func (*BatchQueryResponse) GetUsers 

func (m *BatchQueryResponse) GetUsers() []*User

func (*BatchQueryResponse) ProtoMessage 

func (*BatchQueryResponse) ProtoMessage()

func (*BatchQueryResponse) Reset 

func (m *BatchQueryResponse) Reset()

func (*BatchQueryResponse) String 

func (m *BatchQueryResponse) String() string

func (*BatchQueryResponse) XXX_DiscardUnknown 

func (m *BatchQueryResponse) XXX_DiscardUnknown()

func (*BatchQueryResponse) XXX_Marshal 

func (m *BatchQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchQueryResponse) XXX_Merge 

func (dst *BatchQueryResponse) XXX_Merge(src proto.Message)

func (*BatchQueryResponse) XXX_Size 

func (m *BatchQueryResponse) XXX_Size() int

func (*BatchQueryResponse) XXX_Unmarshal 

func (m *BatchQueryResponse) XXX_Unmarshal(b []byte) error

type BatchWriteResponse 

type BatchWriteResponse struct {
	Code                 *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Size                 *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=size,proto3" json:"size,omitempty"`
	Responses            []*Response           `protobuf:"bytes,4,rep,name=responses,proto3" json:"responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func FormatBatchWriteResponse 

func FormatBatchWriteResponse(response *BatchWriteResponse) *BatchWriteResponse

格式化responses batch操作 如果所有子错误码一致，那么使用子错误码 如果包含任意一个5xx，那么返回500

func NewBatchWriteResponse 

func NewBatchWriteResponse(code uint32) *BatchWriteResponse

*

  • @brief 创建批量回复

func NewBatchWriteResponseWithMsg 

func NewBatchWriteResponseWithMsg(code uint32, msg string) *BatchWriteResponse

*

  • @brief 创建带详细信息的批量回复

func (*BatchWriteResponse) Collect 

func (b *BatchWriteResponse) Collect(response *Response)

*

  • @brief BatchWriteResponse添加Response

func (*BatchWriteResponse) CollectBatch 

func (b *BatchWriteResponse) CollectBatch(response []*Response)

*

  • @brief BatchWriteResponse添加Response

func (*BatchWriteResponse) Descriptor 

func (*BatchWriteResponse) Descriptor() ([]byte, []int)

func (*BatchWriteResponse) GetCode 

func (m *BatchWriteResponse) GetCode() *wrappers.UInt32Value

func (*BatchWriteResponse) GetInfo 

func (m *BatchWriteResponse) GetInfo() *wrappers.StringValue

func (*BatchWriteResponse) GetResponses 

func (m *BatchWriteResponse) GetResponses() []*Response

func (*BatchWriteResponse) GetSize 

func (m *BatchWriteResponse) GetSize() *wrappers.UInt32Value

func (*BatchWriteResponse) ProtoMessage 

func (*BatchWriteResponse) ProtoMessage()

func (*BatchWriteResponse) Reset 

func (m *BatchWriteResponse) Reset()

func (*BatchWriteResponse) String 

func (m *BatchWriteResponse) String() string

func (*BatchWriteResponse) XXX_DiscardUnknown 

func (m *BatchWriteResponse) XXX_DiscardUnknown()

func (*BatchWriteResponse) XXX_Marshal 

func (m *BatchWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchWriteResponse) XXX_Merge 

func (dst *BatchWriteResponse) XXX_Merge(src proto.Message)

func (*BatchWriteResponse) XXX_Size 

func (m *BatchWriteResponse) XXX_Size() int

func (*BatchWriteResponse) XXX_Unmarshal 

func (m *BatchWriteResponse) XXX_Unmarshal(b []byte) error

type CbPolicy 

type CbPolicy struct {
	ErrorRate *CbPolicy_ErrRateConfig  `protobuf:"bytes,1,opt,name=errorRate,proto3" json:"errorRate,omitempty"`
	SlowRate  *CbPolicy_SlowRateConfig `protobuf:"bytes,2,opt,name=slowRate,proto3" json:"slowRate,omitempty"`
	// 熔断的决策周期，多久触发一次熔断决策
	JudgeDuration *duration.Duration `protobuf:"bytes,3,opt,name=judgeDuration,proto3" json:"judgeDuration,omitempty"`
	// 最大熔断比例，超过多少比例后不会继续熔断
	MaxEjectionPercent   *wrappers.UInt32Value          `protobuf:"bytes,4,opt,name=maxEjectionPercent,proto3" json:"maxEjectionPercent,omitempty"`
	Consecutive          *CbPolicy_ConsecutiveErrConfig `protobuf:"bytes,5,opt,name=consecutive,proto3" json:"consecutive,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

熔断策略

func (*CbPolicy) Descriptor 

func (*CbPolicy) Descriptor() ([]byte, []int)

func (*CbPolicy) GetConsecutive 

func (m *CbPolicy) GetConsecutive() *CbPolicy_ConsecutiveErrConfig

func (*CbPolicy) GetErrorRate 

func (m *CbPolicy) GetErrorRate() *CbPolicy_ErrRateConfig

func (*CbPolicy) GetJudgeDuration 

func (m *CbPolicy) GetJudgeDuration() *duration.Duration

func (*CbPolicy) GetMaxEjectionPercent 

func (m *CbPolicy) GetMaxEjectionPercent() *wrappers.UInt32Value

func (*CbPolicy) GetSlowRate 

func (m *CbPolicy) GetSlowRate() *CbPolicy_SlowRateConfig

func (*CbPolicy) ProtoMessage 

func (*CbPolicy) ProtoMessage()

func (*CbPolicy) Reset 

func (m *CbPolicy) Reset()

func (*CbPolicy) String 

func (m *CbPolicy) String() string

func (*CbPolicy) XXX_DiscardUnknown 

func (m *CbPolicy) XXX_DiscardUnknown()

func (*CbPolicy) XXX_Marshal 

func (m *CbPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CbPolicy) XXX_Merge 

func (dst *CbPolicy) XXX_Merge(src proto.Message)

func (*CbPolicy) XXX_Size 

func (m *CbPolicy) XXX_Size() int

func (*CbPolicy) XXX_Unmarshal 

func (m *CbPolicy) XXX_Unmarshal(b []byte) error

type CbPolicy_ConsecutiveErrConfig 

type CbPolicy_ConsecutiveErrConfig struct {
	// 是否启用连续错误数配置
	Enable *wrappers.BoolValue `protobuf:"bytes,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// 连续错误数阈值，进入Preserved状态
	ConsecutiveErrorToPreserved *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=consecutiveErrorToPreserved,proto3" json:"consecutiveErrorToPreserved,omitempty"`
	// 连续错误数阈值，进入Open状态
	ConsecutiveErrorToOpen *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=consecutiveErrorToOpen,proto3" json:"consecutiveErrorToOpen,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}              `json:"-"`
	XXX_unrecognized       []byte                `json:"-"`
	XXX_sizecache          int32                 `json:"-"`
}

连续错误数熔断配置

func (*CbPolicy_ConsecutiveErrConfig) Descriptor 

func (*CbPolicy_ConsecutiveErrConfig) Descriptor() ([]byte, []int)

func (*CbPolicy_ConsecutiveErrConfig) GetConsecutiveErrorToOpen 

func (m *CbPolicy_ConsecutiveErrConfig) GetConsecutiveErrorToOpen() *wrappers.UInt32Value

func (*CbPolicy_ConsecutiveErrConfig) GetConsecutiveErrorToPreserved 

func (m *CbPolicy_ConsecutiveErrConfig) GetConsecutiveErrorToPreserved() *wrappers.UInt32Value

func (*CbPolicy_ConsecutiveErrConfig) GetEnable 

func (m *CbPolicy_ConsecutiveErrConfig) GetEnable() *wrappers.BoolValue

func (*CbPolicy_ConsecutiveErrConfig) ProtoMessage 

func (*CbPolicy_ConsecutiveErrConfig) ProtoMessage()

func (*CbPolicy_ConsecutiveErrConfig) Reset 

func (m *CbPolicy_ConsecutiveErrConfig) Reset()

func (*CbPolicy_ConsecutiveErrConfig) String 

func (m *CbPolicy_ConsecutiveErrConfig) String() string

func (*CbPolicy_ConsecutiveErrConfig) XXX_DiscardUnknown 

func (m *CbPolicy_ConsecutiveErrConfig) XXX_DiscardUnknown()

func (*CbPolicy_ConsecutiveErrConfig) XXX_Marshal 

func (m *CbPolicy_ConsecutiveErrConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CbPolicy_ConsecutiveErrConfig) XXX_Merge 

func (dst *CbPolicy_ConsecutiveErrConfig) XXX_Merge(src proto.Message)

func (*CbPolicy_ConsecutiveErrConfig) XXX_Size 

func (m *CbPolicy_ConsecutiveErrConfig) XXX_Size() int

func (*CbPolicy_ConsecutiveErrConfig) XXX_Unmarshal 

func (m *CbPolicy_ConsecutiveErrConfig) XXX_Unmarshal(b []byte) error

type CbPolicy_ErrRateConfig 

type CbPolicy_ErrRateConfig struct {
	// 是否启用错误率配置
	Enable *wrappers.BoolValue `protobuf:"bytes,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// 触发错误率熔断的最低请求阈值
	RequestVolumeThreshold *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=requestVolumeThreshold,proto3" json:"requestVolumeThreshold,omitempty"`
	// 可选。触发保持状态的错误率阈值，假如不配置，则默认不会进入Preserved状态
	ErrorRateToPreserved *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=errorRateToPreserved,proto3" json:"errorRateToPreserved,omitempty"`
	// 触发熔断的错误率阈值
	ErrorRateToOpen      *wrappers.UInt32Value                   `protobuf:"bytes,4,opt,name=errorRateToOpen,proto3" json:"errorRateToOpen,omitempty"`
	Specials             []*CbPolicy_ErrRateConfig_SpecialConfig `protobuf:"bytes,5,rep,name=specials,proto3" json:"specials,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

错误率熔断配置

func (*CbPolicy_ErrRateConfig) Descriptor 

func (*CbPolicy_ErrRateConfig) Descriptor() ([]byte, []int)

func (*CbPolicy_ErrRateConfig) GetEnable 

func (m *CbPolicy_ErrRateConfig) GetEnable() *wrappers.BoolValue

func (*CbPolicy_ErrRateConfig) GetErrorRateToOpen 

func (m *CbPolicy_ErrRateConfig) GetErrorRateToOpen() *wrappers.UInt32Value

func (*CbPolicy_ErrRateConfig) GetErrorRateToPreserved 

func (m *CbPolicy_ErrRateConfig) GetErrorRateToPreserved() *wrappers.UInt32Value

func (*CbPolicy_ErrRateConfig) GetRequestVolumeThreshold 

func (m *CbPolicy_ErrRateConfig) GetRequestVolumeThreshold() *wrappers.UInt32Value

func (*CbPolicy_ErrRateConfig) GetSpecials 

func (m *CbPolicy_ErrRateConfig) GetSpecials() []*CbPolicy_ErrRateConfig_SpecialConfig

func (*CbPolicy_ErrRateConfig) ProtoMessage 

func (*CbPolicy_ErrRateConfig) ProtoMessage()

func (*CbPolicy_ErrRateConfig) Reset 

func (m *CbPolicy_ErrRateConfig) Reset()

func (*CbPolicy_ErrRateConfig) String 

func (m *CbPolicy_ErrRateConfig) String() string

func (*CbPolicy_ErrRateConfig) XXX_DiscardUnknown 

func (m *CbPolicy_ErrRateConfig) XXX_DiscardUnknown()

func (*CbPolicy_ErrRateConfig) XXX_Marshal 

func (m *CbPolicy_ErrRateConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CbPolicy_ErrRateConfig) XXX_Merge 

func (dst *CbPolicy_ErrRateConfig) XXX_Merge(src proto.Message)

func (*CbPolicy_ErrRateConfig) XXX_Size 

func (m *CbPolicy_ErrRateConfig) XXX_Size() int

func (*CbPolicy_ErrRateConfig) XXX_Unmarshal 

func (m *CbPolicy_ErrRateConfig) XXX_Unmarshal(b []byte) error

type CbPolicy_ErrRateConfig_SpecialConfig 

type CbPolicy_ErrRateConfig_SpecialConfig struct {
	// 熔断关心的错误类型，用户可以自己定义
	Type                 *wrappers.StringValue  `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	ErrorCodes           []*wrappers.Int64Value `protobuf:"bytes,2,rep,name=errorCodes,proto3" json:"errorCodes,omitempty"`
	ErrorRateToPreserved *wrappers.UInt32Value  `protobuf:"bytes,3,opt,name=errorRateToPreserved,proto3" json:"errorRateToPreserved,omitempty"`
	ErrorRateToOpen      *wrappers.UInt32Value  `protobuf:"bytes,4,opt,name=errorRateToOpen,proto3" json:"errorRateToOpen,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

错误码相关特定配置

func (*CbPolicy_ErrRateConfig_SpecialConfig) Descriptor 

func (*CbPolicy_ErrRateConfig_SpecialConfig) Descriptor() ([]byte, []int)

func (*CbPolicy_ErrRateConfig_SpecialConfig) GetErrorCodes 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) GetErrorCodes() []*wrappers.Int64Value

func (*CbPolicy_ErrRateConfig_SpecialConfig) GetErrorRateToOpen 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) GetErrorRateToOpen() *wrappers.UInt32Value

func (*CbPolicy_ErrRateConfig_SpecialConfig) GetErrorRateToPreserved 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) GetErrorRateToPreserved() *wrappers.UInt32Value

func (*CbPolicy_ErrRateConfig_SpecialConfig) GetType 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) GetType() *wrappers.StringValue

func (*CbPolicy_ErrRateConfig_SpecialConfig) ProtoMessage 

func (*CbPolicy_ErrRateConfig_SpecialConfig) ProtoMessage()

func (*CbPolicy_ErrRateConfig_SpecialConfig) Reset 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) Reset()

func (*CbPolicy_ErrRateConfig_SpecialConfig) String 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) String() string

func (*CbPolicy_ErrRateConfig_SpecialConfig) XXX_DiscardUnknown 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) XXX_DiscardUnknown()

func (*CbPolicy_ErrRateConfig_SpecialConfig) XXX_Marshal 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CbPolicy_ErrRateConfig_SpecialConfig) XXX_Merge 

func (dst *CbPolicy_ErrRateConfig_SpecialConfig) XXX_Merge(src proto.Message)

func (*CbPolicy_ErrRateConfig_SpecialConfig) XXX_Size 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) XXX_Size() int

func (*CbPolicy_ErrRateConfig_SpecialConfig) XXX_Unmarshal 

func (m *CbPolicy_ErrRateConfig_SpecialConfig) XXX_Unmarshal(b []byte) error

type CbPolicy_SlowRateConfig 

type CbPolicy_SlowRateConfig struct {
	// 是否启用慢调用率配置
	Enable *wrappers.BoolValue `protobuf:"bytes,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// 最大响应时间，超过该时间属于慢调用请求
	MaxRt *duration.Duration `protobuf:"bytes,2,opt,name=maxRt,proto3" json:"maxRt,omitempty"`
	// 可选。触发保持状态的超时率阈值，假如不配置，则默认不会进入Preserved状态
	SlowRateToPreserved *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=slowRateToPreserved,proto3" json:"slowRateToPreserved,omitempty"`
	// 触发熔断的超时率阈值
	SlowRateToOpen       *wrappers.UInt32Value `protobuf:"bytes,4,opt,name=slowRateToOpen,proto3" json:"slowRateToOpen,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

慢调用率熔断策略配置

func (*CbPolicy_SlowRateConfig) Descriptor 

func (*CbPolicy_SlowRateConfig) Descriptor() ([]byte, []int)

func (*CbPolicy_SlowRateConfig) GetEnable 

func (m *CbPolicy_SlowRateConfig) GetEnable() *wrappers.BoolValue

func (*CbPolicy_SlowRateConfig) GetMaxRt 

func (m *CbPolicy_SlowRateConfig) GetMaxRt() *duration.Duration

func (*CbPolicy_SlowRateConfig) GetSlowRateToOpen 

func (m *CbPolicy_SlowRateConfig) GetSlowRateToOpen() *wrappers.UInt32Value

func (*CbPolicy_SlowRateConfig) GetSlowRateToPreserved 

func (m *CbPolicy_SlowRateConfig) GetSlowRateToPreserved() *wrappers.UInt32Value

func (*CbPolicy_SlowRateConfig) ProtoMessage 

func (*CbPolicy_SlowRateConfig) ProtoMessage()

func (*CbPolicy_SlowRateConfig) Reset 

func (m *CbPolicy_SlowRateConfig) Reset()

func (*CbPolicy_SlowRateConfig) String 

func (m *CbPolicy_SlowRateConfig) String() string

func (*CbPolicy_SlowRateConfig) XXX_DiscardUnknown 

func (m *CbPolicy_SlowRateConfig) XXX_DiscardUnknown()

func (*CbPolicy_SlowRateConfig) XXX_Marshal 

func (m *CbPolicy_SlowRateConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CbPolicy_SlowRateConfig) XXX_Merge 

func (dst *CbPolicy_SlowRateConfig) XXX_Merge(src proto.Message)

func (*CbPolicy_SlowRateConfig) XXX_Size 

func (m *CbPolicy_SlowRateConfig) XXX_Size() int

func (*CbPolicy_SlowRateConfig) XXX_Unmarshal 

func (m *CbPolicy_SlowRateConfig) XXX_Unmarshal(b []byte) error

type CbRule 

type CbRule struct {
	// 如果匹配Source规则，按照Destination进行熔断
	// 多个Source之间的关系为或
	Sources              []*SourceMatcher  `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	Destinations         []*DestinationSet `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

具体熔断规则

func (*CbRule) Descriptor 

func (*CbRule) Descriptor() ([]byte, []int)

func (*CbRule) GetDestinations 

func (m *CbRule) GetDestinations() []*DestinationSet

func (*CbRule) GetSources 

func (m *CbRule) GetSources() []*SourceMatcher

func (*CbRule) ProtoMessage 

func (*CbRule) ProtoMessage()

func (*CbRule) Reset 

func (m *CbRule) Reset()

func (*CbRule) String 

func (m *CbRule) String() string

func (*CbRule) XXX_DiscardUnknown 

func (m *CbRule) XXX_DiscardUnknown()

func (*CbRule) XXX_Marshal 

func (m *CbRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CbRule) XXX_Merge 

func (dst *CbRule) XXX_Merge(src proto.Message)

func (*CbRule) XXX_Size 

func (m *CbRule) XXX_Size() int

func (*CbRule) XXX_Unmarshal 

func (m *CbRule) XXX_Unmarshal(b []byte) error

type CircuitBreaker 

type CircuitBreaker struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 规则版本
	Version *wrappers.StringValue `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// 规则名
	Name *wrappers.StringValue `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// 规则命名空间
	Namespace *wrappers.StringValue `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 规则所属服务
	Service          *wrappers.StringValue `protobuf:"bytes,5,opt,name=service,proto3" json:"service,omitempty"`
	ServiceNamespace *wrappers.StringValue `protobuf:"bytes,6,opt,name=service_namespace,json=serviceNamespace,proto3" json:"service_namespace,omitempty"`
	// 熔断规则可以分为被调规则和主调规则
	// 被调规则针对所有的指定主调生效，假如不指定则对所有的主调生效
	// 主调规则为当前主调方的规则，假如不指定则针对所有被调生效
	Inbounds  []*CbRule             `protobuf:"bytes,7,rep,name=inbounds,proto3" json:"inbounds,omitempty"`
	Outbounds []*CbRule             `protobuf:"bytes,8,rep,name=outbounds,proto3" json:"outbounds,omitempty"`
	Token     *wrappers.StringValue `protobuf:"bytes,9,opt,name=token,proto3" json:"token,omitempty"`
	Owners    *wrappers.StringValue `protobuf:"bytes,10,opt,name=owners,proto3" json:"owners,omitempty"`
	// 业务
	Business *wrappers.StringValue `protobuf:"bytes,11,opt,name=business,proto3" json:"business,omitempty"`
	// 部门
	Department *wrappers.StringValue `protobuf:"bytes,12,opt,name=department,proto3" json:"department,omitempty"`
	// 规则描述
	Comment              *wrappers.StringValue `protobuf:"bytes,13,opt,name=comment,proto3" json:"comment,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,14,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,15,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Revision             *wrappers.StringValue `protobuf:"bytes,16,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

单个熔断规则定义

func (*CircuitBreaker) Descriptor 

func (*CircuitBreaker) Descriptor() ([]byte, []int)

func (*CircuitBreaker) GetBusiness 

func (m *CircuitBreaker) GetBusiness() *wrappers.StringValue

func (*CircuitBreaker) GetComment 

func (m *CircuitBreaker) GetComment() *wrappers.StringValue

func (*CircuitBreaker) GetCtime 

func (m *CircuitBreaker) GetCtime() *wrappers.StringValue

func (*CircuitBreaker) GetDepartment 

func (m *CircuitBreaker) GetDepartment() *wrappers.StringValue

func (*CircuitBreaker) GetId 

func (m *CircuitBreaker) GetId() *wrappers.StringValue

func (*CircuitBreaker) GetInbounds 

func (m *CircuitBreaker) GetInbounds() []*CbRule

func (*CircuitBreaker) GetMtime 

func (m *CircuitBreaker) GetMtime() *wrappers.StringValue

func (*CircuitBreaker) GetName 

func (m *CircuitBreaker) GetName() *wrappers.StringValue

func (*CircuitBreaker) GetNamespace 

func (m *CircuitBreaker) GetNamespace() *wrappers.StringValue

func (*CircuitBreaker) GetOutbounds 

func (m *CircuitBreaker) GetOutbounds() []*CbRule

func (*CircuitBreaker) GetOwners 

func (m *CircuitBreaker) GetOwners() *wrappers.StringValue

func (*CircuitBreaker) GetRevision 

func (m *CircuitBreaker) GetRevision() *wrappers.StringValue

func (*CircuitBreaker) GetService 

func (m *CircuitBreaker) GetService() *wrappers.StringValue

func (*CircuitBreaker) GetServiceNamespace 

func (m *CircuitBreaker) GetServiceNamespace() *wrappers.StringValue

func (*CircuitBreaker) GetToken 

func (m *CircuitBreaker) GetToken() *wrappers.StringValue

func (*CircuitBreaker) GetVersion 

func (m *CircuitBreaker) GetVersion() *wrappers.StringValue

func (*CircuitBreaker) ProtoMessage 

func (*CircuitBreaker) ProtoMessage()

func (*CircuitBreaker) Reset 

func (m *CircuitBreaker) Reset()

func (*CircuitBreaker) String 

func (m *CircuitBreaker) String() string

func (*CircuitBreaker) XXX_DiscardUnknown 

func (m *CircuitBreaker) XXX_DiscardUnknown()

func (*CircuitBreaker) XXX_Marshal 

func (m *CircuitBreaker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CircuitBreaker) XXX_Merge 

func (dst *CircuitBreaker) XXX_Merge(src proto.Message)

func (*CircuitBreaker) XXX_Size 

func (m *CircuitBreaker) XXX_Size() int

func (*CircuitBreaker) XXX_Unmarshal 

func (m *CircuitBreaker) XXX_Unmarshal(b []byte) error

type Client 

type Client struct {
	Host                 *wrappers.StringValue `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Type                 Client_ClientType     `protobuf:"varint,2,opt,name=type,proto3,enum=v1.Client_ClientType" json:"type,omitempty"`
	Version              *wrappers.StringValue `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Location             *Location             `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	Id                   *wrappers.StringValue `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	Stat                 []*StatInfo           `protobuf:"bytes,6,rep,name=stat,proto3" json:"stat,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,7,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,8,opt,name=mtime,proto3" json:"mtime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Client) Descriptor 

func (*Client) Descriptor() ([]byte, []int)

func (*Client) GetCtime 

func (m *Client) GetCtime() *wrappers.StringValue

func (*Client) GetHost 

func (m *Client) GetHost() *wrappers.StringValue

func (*Client) GetId 

func (m *Client) GetId() *wrappers.StringValue

func (*Client) GetLocation 

func (m *Client) GetLocation() *Location

func (*Client) GetMtime 

func (m *Client) GetMtime() *wrappers.StringValue

func (*Client) GetStat 

func (m *Client) GetStat() []*StatInfo

func (*Client) GetType 

func (m *Client) GetType() Client_ClientType

func (*Client) GetVersion 

func (m *Client) GetVersion() *wrappers.StringValue

func (*Client) ProtoMessage 

func (*Client) ProtoMessage()

func (*Client) Reset 

func (m *Client) Reset()

func (*Client) String 

func (m *Client) String() string

func (*Client) XXX_DiscardUnknown 

func (m *Client) XXX_DiscardUnknown()

func (*Client) XXX_Marshal 

func (m *Client) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Client) XXX_Merge 

func (dst *Client) XXX_Merge(src proto.Message)

func (*Client) XXX_Size 

func (m *Client) XXX_Size() int

func (*Client) XXX_Unmarshal 

func (m *Client) XXX_Unmarshal(b []byte) error

type ClientConfigFileInfo 

type ClientConfigFileInfo struct {
	Namespace            *wrappers.StringValue `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Group                *wrappers.StringValue `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	FileName             *wrappers.StringValue `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Content              *wrappers.StringValue `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"`
	Version              *wrappers.UInt64Value `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Md5                  *wrappers.StringValue `protobuf:"bytes,6,opt,name=md5,proto3" json:"md5,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ClientConfigFileInfo) Descriptor 

func (*ClientConfigFileInfo) Descriptor() ([]byte, []int)

func (*ClientConfigFileInfo) GetContent 

func (m *ClientConfigFileInfo) GetContent() *wrappers.StringValue

func (*ClientConfigFileInfo) GetFileName 

func (m *ClientConfigFileInfo) GetFileName() *wrappers.StringValue

func (*ClientConfigFileInfo) GetGroup 

func (m *ClientConfigFileInfo) GetGroup() *wrappers.StringValue

func (*ClientConfigFileInfo) GetMd5 

func (m *ClientConfigFileInfo) GetMd5() *wrappers.StringValue

func (*ClientConfigFileInfo) GetNamespace 

func (m *ClientConfigFileInfo) GetNamespace() *wrappers.StringValue

func (*ClientConfigFileInfo) GetVersion 

func (m *ClientConfigFileInfo) GetVersion() *wrappers.UInt64Value

func (*ClientConfigFileInfo) ProtoMessage 

func (*ClientConfigFileInfo) ProtoMessage()

func (*ClientConfigFileInfo) Reset 

func (m *ClientConfigFileInfo) Reset()

func (*ClientConfigFileInfo) String 

func (m *ClientConfigFileInfo) String() string

func (*ClientConfigFileInfo) XXX_DiscardUnknown 

func (m *ClientConfigFileInfo) XXX_DiscardUnknown()

func (*ClientConfigFileInfo) XXX_Marshal 

func (m *ClientConfigFileInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientConfigFileInfo) XXX_Merge 

func (dst *ClientConfigFileInfo) XXX_Merge(src proto.Message)

func (*ClientConfigFileInfo) XXX_Size 

func (m *ClientConfigFileInfo) XXX_Size() int

func (*ClientConfigFileInfo) XXX_Unmarshal 

func (m *ClientConfigFileInfo) XXX_Unmarshal(b []byte) error

type ClientWatchConfigFileRequest 

type ClientWatchConfigFileRequest struct {
	ClientIp             *wrappers.StringValue   `protobuf:"bytes,1,opt,name=client_ip,json=clientIp,proto3" json:"client_ip,omitempty"`
	ServiceName          *wrappers.StringValue   `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	WatchFiles           []*ClientConfigFileInfo `protobuf:"bytes,3,rep,name=watch_files,json=watchFiles,proto3" json:"watch_files,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ClientWatchConfigFileRequest) Descriptor 

func (*ClientWatchConfigFileRequest) Descriptor() ([]byte, []int)

func (*ClientWatchConfigFileRequest) GetClientIp 

func (m *ClientWatchConfigFileRequest) GetClientIp() *wrappers.StringValue

func (*ClientWatchConfigFileRequest) GetServiceName 

func (m *ClientWatchConfigFileRequest) GetServiceName() *wrappers.StringValue

func (*ClientWatchConfigFileRequest) GetWatchFiles 

func (m *ClientWatchConfigFileRequest) GetWatchFiles() []*ClientConfigFileInfo

func (*ClientWatchConfigFileRequest) ProtoMessage 

func (*ClientWatchConfigFileRequest) ProtoMessage()

func (*ClientWatchConfigFileRequest) Reset 

func (m *ClientWatchConfigFileRequest) Reset()

func (*ClientWatchConfigFileRequest) String 

func (m *ClientWatchConfigFileRequest) String() string

func (*ClientWatchConfigFileRequest) XXX_DiscardUnknown 

func (m *ClientWatchConfigFileRequest) XXX_DiscardUnknown()

func (*ClientWatchConfigFileRequest) XXX_Marshal 

func (m *ClientWatchConfigFileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientWatchConfigFileRequest) XXX_Merge 

func (dst *ClientWatchConfigFileRequest) XXX_Merge(src proto.Message)

func (*ClientWatchConfigFileRequest) XXX_Size 

func (m *ClientWatchConfigFileRequest) XXX_Size() int

func (*ClientWatchConfigFileRequest) XXX_Unmarshal 

func (m *ClientWatchConfigFileRequest) XXX_Unmarshal(b []byte) error

type Client_ClientType 

type Client_ClientType int32
const (
	Client_UNKNOWN Client_ClientType = 0
	Client_SDK     Client_ClientType = 1
	Client_AGENT   Client_ClientType = 2
)

func (Client_ClientType) EnumDescriptor 

func (Client_ClientType) EnumDescriptor() ([]byte, []int)

func (Client_ClientType) String 

func (x Client_ClientType) String() string

type ClimbConfig 

type ClimbConfig struct {
	Enable               *wrappers.BoolValue          `protobuf:"bytes,1,opt,name=enable,proto3" json:"enable,omitempty"`
	Metric               *ClimbConfig_MetricConfig    `protobuf:"bytes,2,opt,name=metric,proto3" json:"metric,omitempty"`
	Policy               *ClimbConfig_TriggerPolicy   `protobuf:"bytes,3,opt,name=policy,proto3" json:"policy,omitempty"`
	Throttling           *ClimbConfig_ClimbThrottling `protobuf:"bytes,4,opt,name=throttling,proto3" json:"throttling,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

限流调整算法Climb相关配置

func (*ClimbConfig) Descriptor 

func (*ClimbConfig) Descriptor() ([]byte, []int)

func (*ClimbConfig) GetEnable 

func (m *ClimbConfig) GetEnable() *wrappers.BoolValue

func (*ClimbConfig) GetMetric 

func (m *ClimbConfig) GetMetric() *ClimbConfig_MetricConfig

func (*ClimbConfig) GetPolicy 

func (m *ClimbConfig) GetPolicy() *ClimbConfig_TriggerPolicy

func (*ClimbConfig) GetThrottling 

func (m *ClimbConfig) GetThrottling() *ClimbConfig_ClimbThrottling

func (*ClimbConfig) ProtoMessage 

func (*ClimbConfig) ProtoMessage()

func (*ClimbConfig) Reset 

func (m *ClimbConfig) Reset()

func (*ClimbConfig) String 

func (m *ClimbConfig) String() string

func (*ClimbConfig) XXX_DiscardUnknown 

func (m *ClimbConfig) XXX_DiscardUnknown()

func (*ClimbConfig) XXX_Marshal 

func (m *ClimbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClimbConfig) XXX_Merge 

func (dst *ClimbConfig) XXX_Merge(src proto.Message)

func (*ClimbConfig) XXX_Size 

func (m *ClimbConfig) XXX_Size() int

func (*ClimbConfig) XXX_Unmarshal 

func (m *ClimbConfig) XXX_Unmarshal(b []byte) error

type ClimbConfig_ClimbThrottling 

type ClimbConfig_ClimbThrottling struct {
	ColdBelowTuneDownRate  *wrappers.Int32Value `protobuf:"bytes,1,opt,name=coldBelowTuneDownRate,proto3" json:"coldBelowTuneDownRate,omitempty"`
	ColdBelowTuneUpRate    *wrappers.Int32Value `protobuf:"bytes,2,opt,name=coldBelowTuneUpRate,proto3" json:"coldBelowTuneUpRate,omitempty"`
	ColdAboveTuneDownRate  *wrappers.Int32Value `protobuf:"bytes,3,opt,name=coldAboveTuneDownRate,proto3" json:"coldAboveTuneDownRate,omitempty"`
	ColdAboveTuneUpRate    *wrappers.Int32Value `protobuf:"bytes,4,opt,name=coldAboveTuneUpRate,proto3" json:"coldAboveTuneUpRate,omitempty"`
	LimitThresholdToTuneUp *wrappers.Int32Value `protobuf:"bytes,5,opt,name=limitThresholdToTuneUp,proto3" json:"limitThresholdToTuneUp,omitempty"`
	JudgeDuration          *duration.Duration   `protobuf:"bytes,6,opt,name=judgeDuration,proto3" json:"judgeDuration,omitempty"`
	TuneUpPeriod           *wrappers.Int32Value `protobuf:"bytes,7,opt,name=tuneUpPeriod,proto3" json:"tuneUpPeriod,omitempty"`
	TuneDownPeriod         *wrappers.Int32Value `protobuf:"bytes,8,opt,name=tuneDownPeriod,proto3" json:"tuneDownPeriod,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}             `json:"-"`
	XXX_unrecognized       []byte               `json:"-"`
	XXX_sizecache          int32                `json:"-"`
}

爬坡调整相关参数

func (*ClimbConfig_ClimbThrottling) Descriptor 

func (*ClimbConfig_ClimbThrottling) Descriptor() ([]byte, []int)

func (*ClimbConfig_ClimbThrottling) GetColdAboveTuneDownRate 

func (m *ClimbConfig_ClimbThrottling) GetColdAboveTuneDownRate() *wrappers.Int32Value

func (*ClimbConfig_ClimbThrottling) GetColdAboveTuneUpRate 

func (m *ClimbConfig_ClimbThrottling) GetColdAboveTuneUpRate() *wrappers.Int32Value

func (*ClimbConfig_ClimbThrottling) GetColdBelowTuneDownRate 

func (m *ClimbConfig_ClimbThrottling) GetColdBelowTuneDownRate() *wrappers.Int32Value

func (*ClimbConfig_ClimbThrottling) GetColdBelowTuneUpRate 

func (m *ClimbConfig_ClimbThrottling) GetColdBelowTuneUpRate() *wrappers.Int32Value

func (*ClimbConfig_ClimbThrottling) GetJudgeDuration 

func (m *ClimbConfig_ClimbThrottling) GetJudgeDuration() *duration.Duration

func (*ClimbConfig_ClimbThrottling) GetLimitThresholdToTuneUp 

func (m *ClimbConfig_ClimbThrottling) GetLimitThresholdToTuneUp() *wrappers.Int32Value

func (*ClimbConfig_ClimbThrottling) GetTuneDownPeriod 

func (m *ClimbConfig_ClimbThrottling) GetTuneDownPeriod() *wrappers.Int32Value

func (*ClimbConfig_ClimbThrottling) GetTuneUpPeriod 

func (m *ClimbConfig_ClimbThrottling) GetTuneUpPeriod() *wrappers.Int32Value

func (*ClimbConfig_ClimbThrottling) ProtoMessage 

func (*ClimbConfig_ClimbThrottling) ProtoMessage()

func (*ClimbConfig_ClimbThrottling) Reset 

func (m *ClimbConfig_ClimbThrottling) Reset()

func (*ClimbConfig_ClimbThrottling) String 

func (m *ClimbConfig_ClimbThrottling) String() string

func (*ClimbConfig_ClimbThrottling) XXX_DiscardUnknown 

func (m *ClimbConfig_ClimbThrottling) XXX_DiscardUnknown()

func (*ClimbConfig_ClimbThrottling) XXX_Marshal 

func (m *ClimbConfig_ClimbThrottling) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClimbConfig_ClimbThrottling) XXX_Merge 

func (dst *ClimbConfig_ClimbThrottling) XXX_Merge(src proto.Message)

func (*ClimbConfig_ClimbThrottling) XXX_Size 

func (m *ClimbConfig_ClimbThrottling) XXX_Size() int

func (*ClimbConfig_ClimbThrottling) XXX_Unmarshal 

func (m *ClimbConfig_ClimbThrottling) XXX_Unmarshal(b []byte) error

type ClimbConfig_MetricConfig 

type ClimbConfig_MetricConfig struct {
	// 限流数据度量周期，默认60s
	Window *duration.Duration `protobuf:"bytes,1,opt,name=window,proto3" json:"window,omitempty"`
	// 数据统计精度，决定数据度量的最小周期，度量滑窗的步长=window/precision
	Precision *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=precision,proto3" json:"precision,omitempty"`
	// 上报周期，默认20s
	ReportInterval       *duration.Duration `protobuf:"bytes,3,opt,name=reportInterval,proto3" json:"reportInterval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

限流数据统计配置

func (*ClimbConfig_MetricConfig) Descriptor 

func (*ClimbConfig_MetricConfig) Descriptor() ([]byte, []int)

func (*ClimbConfig_MetricConfig) GetPrecision 

func (m *ClimbConfig_MetricConfig) GetPrecision() *wrappers.UInt32Value

func (*ClimbConfig_MetricConfig) GetReportInterval 

func (m *ClimbConfig_MetricConfig) GetReportInterval() *duration.Duration

func (*ClimbConfig_MetricConfig) GetWindow 

func (m *ClimbConfig_MetricConfig) GetWindow() *duration.Duration

func (*ClimbConfig_MetricConfig) ProtoMessage 

func (*ClimbConfig_MetricConfig) ProtoMessage()

func (*ClimbConfig_MetricConfig) Reset 

func (m *ClimbConfig_MetricConfig) Reset()

func (*ClimbConfig_MetricConfig) String 

func (m *ClimbConfig_MetricConfig) String() string

func (*ClimbConfig_MetricConfig) XXX_DiscardUnknown 

func (m *ClimbConfig_MetricConfig) XXX_DiscardUnknown()

func (*ClimbConfig_MetricConfig) XXX_Marshal 

func (m *ClimbConfig_MetricConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClimbConfig_MetricConfig) XXX_Merge 

func (dst *ClimbConfig_MetricConfig) XXX_Merge(src proto.Message)

func (*ClimbConfig_MetricConfig) XXX_Size 

func (m *ClimbConfig_MetricConfig) XXX_Size() int

func (*ClimbConfig_MetricConfig) XXX_Unmarshal 

func (m *ClimbConfig_MetricConfig) XXX_Unmarshal(b []byte) error

type ClimbConfig_TriggerPolicy 

type ClimbConfig_TriggerPolicy struct {
	ErrorRate            *ClimbConfig_TriggerPolicy_ErrorRate `protobuf:"bytes,1,opt,name=errorRate,proto3" json:"errorRate,omitempty"`
	SlowRate             *ClimbConfig_TriggerPolicy_SlowRate  `protobuf:"bytes,2,opt,name=slowRate,proto3" json:"slowRate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

触发调整的策略

func (*ClimbConfig_TriggerPolicy) Descriptor 

func (*ClimbConfig_TriggerPolicy) Descriptor() ([]byte, []int)

func (*ClimbConfig_TriggerPolicy) GetErrorRate 

func (m *ClimbConfig_TriggerPolicy) GetErrorRate() *ClimbConfig_TriggerPolicy_ErrorRate

func (*ClimbConfig_TriggerPolicy) GetSlowRate 

func (m *ClimbConfig_TriggerPolicy) GetSlowRate() *ClimbConfig_TriggerPolicy_SlowRate

func (*ClimbConfig_TriggerPolicy) ProtoMessage 

func (*ClimbConfig_TriggerPolicy) ProtoMessage()

func (*ClimbConfig_TriggerPolicy) Reset 

func (m *ClimbConfig_TriggerPolicy) Reset()

func (*ClimbConfig_TriggerPolicy) String 

func (m *ClimbConfig_TriggerPolicy) String() string

func (*ClimbConfig_TriggerPolicy) XXX_DiscardUnknown 

func (m *ClimbConfig_TriggerPolicy) XXX_DiscardUnknown()

func (*ClimbConfig_TriggerPolicy) XXX_Marshal 

func (m *ClimbConfig_TriggerPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClimbConfig_TriggerPolicy) XXX_Merge 

func (dst *ClimbConfig_TriggerPolicy) XXX_Merge(src proto.Message)

func (*ClimbConfig_TriggerPolicy) XXX_Size 

func (m *ClimbConfig_TriggerPolicy) XXX_Size() int

func (*ClimbConfig_TriggerPolicy) XXX_Unmarshal 

func (m *ClimbConfig_TriggerPolicy) XXX_Unmarshal(b []byte) error

type ClimbConfig_TriggerPolicy_ErrorRate 

type ClimbConfig_TriggerPolicy_ErrorRate struct {
	Enable                 *wrappers.BoolValue                                  `protobuf:"bytes,1,opt,name=enable,proto3" json:"enable,omitempty"`
	RequestVolumeThreshold *wrappers.UInt32Value                                `protobuf:"bytes,2,opt,name=requestVolumeThreshold,proto3" json:"requestVolumeThreshold,omitempty"`
	ErrorRate              *wrappers.Int32Value                                 `protobuf:"bytes,3,opt,name=errorRate,proto3" json:"errorRate,omitempty"`
	Specials               []*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig `protobuf:"bytes,4,rep,name=specials,proto3" json:"specials,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}                                             `json:"-"`
	XXX_unrecognized       []byte                                               `json:"-"`
	XXX_sizecache          int32                                                `json:"-"`
}

错误率触发调整配置

func (*ClimbConfig_TriggerPolicy_ErrorRate) Descriptor 

func (*ClimbConfig_TriggerPolicy_ErrorRate) Descriptor() ([]byte, []int)

func (*ClimbConfig_TriggerPolicy_ErrorRate) GetEnable 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) GetEnable() *wrappers.BoolValue

func (*ClimbConfig_TriggerPolicy_ErrorRate) GetErrorRate 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) GetErrorRate() *wrappers.Int32Value

func (*ClimbConfig_TriggerPolicy_ErrorRate) GetRequestVolumeThreshold 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) GetRequestVolumeThreshold() *wrappers.UInt32Value

func (*ClimbConfig_TriggerPolicy_ErrorRate) GetSpecials 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) GetSpecials() []*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig

func (*ClimbConfig_TriggerPolicy_ErrorRate) ProtoMessage 

func (*ClimbConfig_TriggerPolicy_ErrorRate) ProtoMessage()

func (*ClimbConfig_TriggerPolicy_ErrorRate) Reset 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) Reset()

func (*ClimbConfig_TriggerPolicy_ErrorRate) String 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) String() string

func (*ClimbConfig_TriggerPolicy_ErrorRate) XXX_DiscardUnknown 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) XXX_DiscardUnknown()

func (*ClimbConfig_TriggerPolicy_ErrorRate) XXX_Marshal 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClimbConfig_TriggerPolicy_ErrorRate) XXX_Merge 

func (dst *ClimbConfig_TriggerPolicy_ErrorRate) XXX_Merge(src proto.Message)

func (*ClimbConfig_TriggerPolicy_ErrorRate) XXX_Size 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) XXX_Size() int

func (*ClimbConfig_TriggerPolicy_ErrorRate) XXX_Unmarshal 

func (m *ClimbConfig_TriggerPolicy_ErrorRate) XXX_Unmarshal(b []byte) error

type ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig 

type ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig struct {
	Type                 *wrappers.StringValue  `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	ErrorCodes           []*wrappers.Int64Value `protobuf:"bytes,2,rep,name=errorCodes,proto3" json:"errorCodes,omitempty"`
	ErrorRate            *wrappers.Int32Value   `protobuf:"bytes,3,opt,name=errorRate,proto3" json:"errorRate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

特殊错误码触发调整配置

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) Descriptor 

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) Descriptor() ([]byte, []int)

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) GetErrorCodes 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) GetErrorCodes() []*wrappers.Int64Value

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) GetErrorRate 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) GetErrorRate() *wrappers.Int32Value

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) GetType 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) GetType() *wrappers.StringValue

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) ProtoMessage 

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) ProtoMessage()

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) Reset 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) Reset()

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) String 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) String() string

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_DiscardUnknown 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_DiscardUnknown()

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Marshal 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Merge 

func (dst *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Merge(src proto.Message)

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Size 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Size() int

func (*ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Unmarshal 

func (m *ClimbConfig_TriggerPolicy_ErrorRate_SpecialConfig) XXX_Unmarshal(b []byte) error

type ClimbConfig_TriggerPolicy_SlowRate 

type ClimbConfig_TriggerPolicy_SlowRate struct {
	Enable               *wrappers.BoolValue  `protobuf:"bytes,1,opt,name=enable,proto3" json:"enable,omitempty"`
	MaxRt                *duration.Duration   `protobuf:"bytes,2,opt,name=maxRt,proto3" json:"maxRt,omitempty"`
	SlowRate             *wrappers.Int32Value `protobuf:"bytes,3,opt,name=slowRate,proto3" json:"slowRate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

慢调用触发调整配置

func (*ClimbConfig_TriggerPolicy_SlowRate) Descriptor 

func (*ClimbConfig_TriggerPolicy_SlowRate) Descriptor() ([]byte, []int)

func (*ClimbConfig_TriggerPolicy_SlowRate) GetEnable 

func (m *ClimbConfig_TriggerPolicy_SlowRate) GetEnable() *wrappers.BoolValue

func (*ClimbConfig_TriggerPolicy_SlowRate) GetMaxRt 

func (m *ClimbConfig_TriggerPolicy_SlowRate) GetMaxRt() *duration.Duration

func (*ClimbConfig_TriggerPolicy_SlowRate) GetSlowRate 

func (m *ClimbConfig_TriggerPolicy_SlowRate) GetSlowRate() *wrappers.Int32Value

func (*ClimbConfig_TriggerPolicy_SlowRate) ProtoMessage 

func (*ClimbConfig_TriggerPolicy_SlowRate) ProtoMessage()

func (*ClimbConfig_TriggerPolicy_SlowRate) Reset 

func (m *ClimbConfig_TriggerPolicy_SlowRate) Reset()

func (*ClimbConfig_TriggerPolicy_SlowRate) String 

func (m *ClimbConfig_TriggerPolicy_SlowRate) String() string

func (*ClimbConfig_TriggerPolicy_SlowRate) XXX_DiscardUnknown 

func (m *ClimbConfig_TriggerPolicy_SlowRate) XXX_DiscardUnknown()

func (*ClimbConfig_TriggerPolicy_SlowRate) XXX_Marshal 

func (m *ClimbConfig_TriggerPolicy_SlowRate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClimbConfig_TriggerPolicy_SlowRate) XXX_Merge 

func (dst *ClimbConfig_TriggerPolicy_SlowRate) XXX_Merge(src proto.Message)

func (*ClimbConfig_TriggerPolicy_SlowRate) XXX_Size 

func (m *ClimbConfig_TriggerPolicy_SlowRate) XXX_Size() int

func (*ClimbConfig_TriggerPolicy_SlowRate) XXX_Unmarshal 

func (m *ClimbConfig_TriggerPolicy_SlowRate) XXX_Unmarshal(b []byte) error

type ConfigBatchQueryResponse 

type ConfigBatchQueryResponse struct {
	Code                       *wrappers.UInt32Value       `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                       *wrappers.StringValue       `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Total                      *wrappers.UInt32Value       `protobuf:"bytes,3,opt,name=total,proto3" json:"total,omitempty"`
	ConfigFileGroups           []*ConfigFileGroup          `protobuf:"bytes,4,rep,name=configFileGroups,proto3" json:"configFileGroups,omitempty"`
	ConfigFiles                []*ConfigFile               `protobuf:"bytes,5,rep,name=configFiles,proto3" json:"configFiles,omitempty"`
	ConfigFileReleases         []*ConfigFileRelease        `protobuf:"bytes,6,rep,name=configFileReleases,proto3" json:"configFileReleases,omitempty"`
	ConfigFileReleaseHistories []*ConfigFileReleaseHistory `protobuf:"bytes,7,rep,name=configFileReleaseHistories,proto3" json:"configFileReleaseHistories,omitempty"`
	ConfigFileTemplates        []*ConfigFileTemplate       `protobuf:"bytes,8,rep,name=configFileTemplates,proto3" json:"configFileTemplates,omitempty"`
	XXX_NoUnkeyedLiteral       struct{}                    `json:"-"`
	XXX_unrecognized           []byte                      `json:"-"`
	XXX_sizecache              int32                       `json:"-"`
}

func NewConfigFileBatchQueryResponse 

func NewConfigFileBatchQueryResponse(code uint32, total uint32, configFiles []*ConfigFile) *ConfigBatchQueryResponse

func NewConfigFileGroupBatchQueryResponse 

func NewConfigFileGroupBatchQueryResponse(code uint32, total uint32,
	configFileGroups []*ConfigFileGroup) *ConfigBatchQueryResponse

func NewConfigFileReleaseHistoryBatchQueryResponse 

func NewConfigFileReleaseHistoryBatchQueryResponse(code uint32, total uint32,
	configFileReleaseHistories []*ConfigFileReleaseHistory) *ConfigBatchQueryResponse

func NewConfigFileTemplateBatchQueryResponse 

func NewConfigFileTemplateBatchQueryResponse(code uint32, total uint32, configFileTemplates []*ConfigFileTemplate) *ConfigBatchQueryResponse

func (*ConfigBatchQueryResponse) Descriptor 

func (*ConfigBatchQueryResponse) Descriptor() ([]byte, []int)

func (*ConfigBatchQueryResponse) GetCode 

func (m *ConfigBatchQueryResponse) GetCode() *wrappers.UInt32Value

func (*ConfigBatchQueryResponse) GetConfigFileGroups 

func (m *ConfigBatchQueryResponse) GetConfigFileGroups() []*ConfigFileGroup

func (*ConfigBatchQueryResponse) GetConfigFileReleaseHistories 

func (m *ConfigBatchQueryResponse) GetConfigFileReleaseHistories() []*ConfigFileReleaseHistory

func (*ConfigBatchQueryResponse) GetConfigFileReleases 

func (m *ConfigBatchQueryResponse) GetConfigFileReleases() []*ConfigFileRelease

func (*ConfigBatchQueryResponse) GetConfigFileTemplates 

func (m *ConfigBatchQueryResponse) GetConfigFileTemplates() []*ConfigFileTemplate

func (*ConfigBatchQueryResponse) GetConfigFiles 

func (m *ConfigBatchQueryResponse) GetConfigFiles() []*ConfigFile

func (*ConfigBatchQueryResponse) GetInfo 

func (m *ConfigBatchQueryResponse) GetInfo() *wrappers.StringValue

func (*ConfigBatchQueryResponse) GetTotal 

func (m *ConfigBatchQueryResponse) GetTotal() *wrappers.UInt32Value

func (*ConfigBatchQueryResponse) ProtoMessage 

func (*ConfigBatchQueryResponse) ProtoMessage()

func (*ConfigBatchQueryResponse) Reset 

func (m *ConfigBatchQueryResponse) Reset()

func (*ConfigBatchQueryResponse) String 

func (m *ConfigBatchQueryResponse) String() string

func (*ConfigBatchQueryResponse) XXX_DiscardUnknown 

func (m *ConfigBatchQueryResponse) XXX_DiscardUnknown()

func (*ConfigBatchQueryResponse) XXX_Marshal 

func (m *ConfigBatchQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigBatchQueryResponse) XXX_Merge 

func (dst *ConfigBatchQueryResponse) XXX_Merge(src proto.Message)

func (*ConfigBatchQueryResponse) XXX_Size 

func (m *ConfigBatchQueryResponse) XXX_Size() int

func (*ConfigBatchQueryResponse) XXX_Unmarshal 

func (m *ConfigBatchQueryResponse) XXX_Unmarshal(b []byte) error

type ConfigBatchWriteResponse 

type ConfigBatchWriteResponse struct {
	Code                 *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Total                *wrappers.UInt32Value `protobuf:"bytes,3,opt,name=total,proto3" json:"total,omitempty"`
	Responses            []*ConfigResponse     `protobuf:"bytes,4,rep,name=responses,proto3" json:"responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigBatchWriteResponse) Descriptor 

func (*ConfigBatchWriteResponse) Descriptor() ([]byte, []int)

func (*ConfigBatchWriteResponse) GetCode 

func (m *ConfigBatchWriteResponse) GetCode() *wrappers.UInt32Value

func (*ConfigBatchWriteResponse) GetInfo 

func (m *ConfigBatchWriteResponse) GetInfo() *wrappers.StringValue

func (*ConfigBatchWriteResponse) GetResponses 

func (m *ConfigBatchWriteResponse) GetResponses() []*ConfigResponse

func (*ConfigBatchWriteResponse) GetTotal 

func (m *ConfigBatchWriteResponse) GetTotal() *wrappers.UInt32Value

func (*ConfigBatchWriteResponse) ProtoMessage 

func (*ConfigBatchWriteResponse) ProtoMessage()

func (*ConfigBatchWriteResponse) Reset 

func (m *ConfigBatchWriteResponse) Reset()

func (*ConfigBatchWriteResponse) String 

func (m *ConfigBatchWriteResponse) String() string

func (*ConfigBatchWriteResponse) XXX_DiscardUnknown 

func (m *ConfigBatchWriteResponse) XXX_DiscardUnknown()

func (*ConfigBatchWriteResponse) XXX_Marshal 

func (m *ConfigBatchWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigBatchWriteResponse) XXX_Merge 

func (dst *ConfigBatchWriteResponse) XXX_Merge(src proto.Message)

func (*ConfigBatchWriteResponse) XXX_Size 

func (m *ConfigBatchWriteResponse) XXX_Size() int

func (*ConfigBatchWriteResponse) XXX_Unmarshal 

func (m *ConfigBatchWriteResponse) XXX_Unmarshal(b []byte) error

type ConfigClientResponse 

type ConfigClientResponse struct {
	Code                 *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	ConfigFile           *ClientConfigFileInfo `protobuf:"bytes,3,opt,name=configFile,proto3" json:"configFile,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func NewConfigClientResponse 

func NewConfigClientResponse(code uint32, configFile *ClientConfigFileInfo) *ConfigClientResponse

func NewConfigClientResponseWithMessage 

func NewConfigClientResponseWithMessage(code uint32, message string) *ConfigClientResponse

func (*ConfigClientResponse) Descriptor 

func (*ConfigClientResponse) Descriptor() ([]byte, []int)

func (*ConfigClientResponse) GetCode 

func (m *ConfigClientResponse) GetCode() *wrappers.UInt32Value

func (*ConfigClientResponse) GetConfigFile 

func (m *ConfigClientResponse) GetConfigFile() *ClientConfigFileInfo

func (*ConfigClientResponse) GetInfo 

func (m *ConfigClientResponse) GetInfo() *wrappers.StringValue

func (*ConfigClientResponse) ProtoMessage 

func (*ConfigClientResponse) ProtoMessage()

func (*ConfigClientResponse) Reset 

func (m *ConfigClientResponse) Reset()

func (*ConfigClientResponse) String 

func (m *ConfigClientResponse) String() string

func (*ConfigClientResponse) XXX_DiscardUnknown 

func (m *ConfigClientResponse) XXX_DiscardUnknown()

func (*ConfigClientResponse) XXX_Marshal 

func (m *ConfigClientResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigClientResponse) XXX_Merge 

func (dst *ConfigClientResponse) XXX_Merge(src proto.Message)

func (*ConfigClientResponse) XXX_Size 

func (m *ConfigClientResponse) XXX_Size() int

func (*ConfigClientResponse) XXX_Unmarshal 

func (m *ConfigClientResponse) XXX_Unmarshal(b []byte) error

type ConfigFile 

type ConfigFile struct {
	Id                   *wrappers.UInt64Value `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            *wrappers.StringValue `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Group                *wrappers.StringValue `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	Content              *wrappers.StringValue `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Format               *wrappers.StringValue `protobuf:"bytes,6,opt,name=format,proto3" json:"format,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,7,opt,name=comment,proto3" json:"comment,omitempty"`
	Status               *wrappers.StringValue `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	Tags                 []*ConfigFileTag      `protobuf:"bytes,9,rep,name=tags,proto3" json:"tags,omitempty"`
	CreateTime           *wrappers.StringValue `protobuf:"bytes,10,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	CreateBy             *wrappers.StringValue `protobuf:"bytes,11,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"`
	ModifyTime           *wrappers.StringValue `protobuf:"bytes,12,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	ModifyBy             *wrappers.StringValue `protobuf:"bytes,13,opt,name=modify_by,json=modifyBy,proto3" json:"modify_by,omitempty"`
	ReleaseTime          *wrappers.StringValue `protobuf:"bytes,14,opt,name=release_time,json=releaseTime,proto3" json:"release_time,omitempty"`
	ReleaseBy            *wrappers.StringValue `protobuf:"bytes,15,opt,name=release_by,json=releaseBy,proto3" json:"release_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigFile) Descriptor 

func (*ConfigFile) Descriptor() ([]byte, []int)

func (*ConfigFile) GetComment 

func (m *ConfigFile) GetComment() *wrappers.StringValue

func (*ConfigFile) GetContent 

func (m *ConfigFile) GetContent() *wrappers.StringValue

func (*ConfigFile) GetCreateBy 

func (m *ConfigFile) GetCreateBy() *wrappers.StringValue

func (*ConfigFile) GetCreateTime 

func (m *ConfigFile) GetCreateTime() *wrappers.StringValue

func (*ConfigFile) GetFormat 

func (m *ConfigFile) GetFormat() *wrappers.StringValue

func (*ConfigFile) GetGroup 

func (m *ConfigFile) GetGroup() *wrappers.StringValue

func (*ConfigFile) GetId 

func (m *ConfigFile) GetId() *wrappers.UInt64Value

func (*ConfigFile) GetModifyBy 

func (m *ConfigFile) GetModifyBy() *wrappers.StringValue

func (*ConfigFile) GetModifyTime 

func (m *ConfigFile) GetModifyTime() *wrappers.StringValue

func (*ConfigFile) GetName 

func (m *ConfigFile) GetName() *wrappers.StringValue

func (*ConfigFile) GetNamespace 

func (m *ConfigFile) GetNamespace() *wrappers.StringValue

func (*ConfigFile) GetReleaseBy 

func (m *ConfigFile) GetReleaseBy() *wrappers.StringValue

func (*ConfigFile) GetReleaseTime 

func (m *ConfigFile) GetReleaseTime() *wrappers.StringValue

func (*ConfigFile) GetStatus 

func (m *ConfigFile) GetStatus() *wrappers.StringValue

func (*ConfigFile) GetTags 

func (m *ConfigFile) GetTags() []*ConfigFileTag

func (*ConfigFile) ProtoMessage 

func (*ConfigFile) ProtoMessage()

func (*ConfigFile) Reset 

func (m *ConfigFile) Reset()

func (*ConfigFile) String 

func (m *ConfigFile) String() string

func (*ConfigFile) XXX_DiscardUnknown 

func (m *ConfigFile) XXX_DiscardUnknown()

func (*ConfigFile) XXX_Marshal 

func (m *ConfigFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigFile) XXX_Merge 

func (dst *ConfigFile) XXX_Merge(src proto.Message)

func (*ConfigFile) XXX_Size 

func (m *ConfigFile) XXX_Size() int

func (*ConfigFile) XXX_Unmarshal 

func (m *ConfigFile) XXX_Unmarshal(b []byte) error

type ConfigFileGroup 

type ConfigFileGroup struct {
	Id                   *wrappers.UInt64Value   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            *wrappers.StringValue   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Comment              *wrappers.StringValue   `protobuf:"bytes,4,opt,name=comment,proto3" json:"comment,omitempty"`
	CreateTime           *wrappers.StringValue   `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	CreateBy             *wrappers.StringValue   `protobuf:"bytes,6,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"`
	ModifyTime           *wrappers.StringValue   `protobuf:"bytes,7,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	ModifyBy             *wrappers.StringValue   `protobuf:"bytes,8,opt,name=modify_by,json=modifyBy,proto3" json:"modify_by,omitempty"`
	FileCount            *wrappers.UInt64Value   `protobuf:"bytes,9,opt,name=fileCount,proto3" json:"fileCount,omitempty"`
	UserIds              []*wrappers.StringValue `protobuf:"bytes,10,rep,name=user_ids,proto3" json:"user_ids,omitempty"`
	GroupIds             []*wrappers.StringValue `protobuf:"bytes,11,rep,name=group_ids,proto3" json:"group_ids,omitempty"`
	RemoveUserIds        []*wrappers.StringValue `protobuf:"bytes,13,rep,name=remove_user_ids,proto3" json:"remove_user_ids,omitempty"`
	RemoveGroupIds       []*wrappers.StringValue `protobuf:"bytes,14,rep,name=remove_group_ids,proto3" json:"remove_group_ids,omitempty"`
	Editable             *wrappers.BoolValue     `protobuf:"bytes,15,opt,name=editable,proto3" json:"editable,omitempty"`
	Owner                *wrappers.StringValue   `protobuf:"bytes,16,opt,name=owner,proto3" json:"owner,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ConfigFileGroup) Descriptor 

func (*ConfigFileGroup) Descriptor() ([]byte, []int)

func (*ConfigFileGroup) GetComment 

func (m *ConfigFileGroup) GetComment() *wrappers.StringValue

func (*ConfigFileGroup) GetCreateBy 

func (m *ConfigFileGroup) GetCreateBy() *wrappers.StringValue

func (*ConfigFileGroup) GetCreateTime 

func (m *ConfigFileGroup) GetCreateTime() *wrappers.StringValue

func (*ConfigFileGroup) GetEditable 

func (m *ConfigFileGroup) GetEditable() *wrappers.BoolValue

func (*ConfigFileGroup) GetFileCount 

func (m *ConfigFileGroup) GetFileCount() *wrappers.UInt64Value

func (*ConfigFileGroup) GetGroupIds 

func (m *ConfigFileGroup) GetGroupIds() []*wrappers.StringValue

func (*ConfigFileGroup) GetId 

func (m *ConfigFileGroup) GetId() *wrappers.UInt64Value

func (*ConfigFileGroup) GetModifyBy 

func (m *ConfigFileGroup) GetModifyBy() *wrappers.StringValue

func (*ConfigFileGroup) GetModifyTime 

func (m *ConfigFileGroup) GetModifyTime() *wrappers.StringValue

func (*ConfigFileGroup) GetName 

func (m *ConfigFileGroup) GetName() *wrappers.StringValue

func (*ConfigFileGroup) GetNamespace 

func (m *ConfigFileGroup) GetNamespace() *wrappers.StringValue

func (*ConfigFileGroup) GetOwner 

func (m *ConfigFileGroup) GetOwner() *wrappers.StringValue

func (*ConfigFileGroup) GetRemoveGroupIds 

func (m *ConfigFileGroup) GetRemoveGroupIds() []*wrappers.StringValue

func (*ConfigFileGroup) GetRemoveUserIds 

func (m *ConfigFileGroup) GetRemoveUserIds() []*wrappers.StringValue

func (*ConfigFileGroup) GetUserIds 

func (m *ConfigFileGroup) GetUserIds() []*wrappers.StringValue

func (*ConfigFileGroup) ProtoMessage 

func (*ConfigFileGroup) ProtoMessage()

func (*ConfigFileGroup) Reset 

func (m *ConfigFileGroup) Reset()

func (*ConfigFileGroup) String 

func (m *ConfigFileGroup) String() string

func (*ConfigFileGroup) XXX_DiscardUnknown 

func (m *ConfigFileGroup) XXX_DiscardUnknown()

func (*ConfigFileGroup) XXX_Marshal 

func (m *ConfigFileGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigFileGroup) XXX_Merge 

func (dst *ConfigFileGroup) XXX_Merge(src proto.Message)

func (*ConfigFileGroup) XXX_Size 

func (m *ConfigFileGroup) XXX_Size() int

func (*ConfigFileGroup) XXX_Unmarshal 

func (m *ConfigFileGroup) XXX_Unmarshal(b []byte) error

type ConfigFileRelease 

type ConfigFileRelease struct {
	Id                   *wrappers.UInt64Value `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            *wrappers.StringValue `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Group                *wrappers.StringValue `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	FileName             *wrappers.StringValue `protobuf:"bytes,5,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Content              *wrappers.StringValue `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,7,opt,name=comment,proto3" json:"comment,omitempty"`
	Md5                  *wrappers.StringValue `protobuf:"bytes,8,opt,name=md5,proto3" json:"md5,omitempty"`
	Version              *wrappers.UInt64Value `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	CreateTime           *wrappers.StringValue `protobuf:"bytes,10,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	CreateBy             *wrappers.StringValue `protobuf:"bytes,11,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"`
	ModifyTime           *wrappers.StringValue `protobuf:"bytes,12,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	ModifyBy             *wrappers.StringValue `protobuf:"bytes,13,opt,name=modify_by,json=modifyBy,proto3" json:"modify_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigFileRelease) Descriptor 

func (*ConfigFileRelease) Descriptor() ([]byte, []int)

func (*ConfigFileRelease) GetComment 

func (m *ConfigFileRelease) GetComment() *wrappers.StringValue

func (*ConfigFileRelease) GetContent 

func (m *ConfigFileRelease) GetContent() *wrappers.StringValue

func (*ConfigFileRelease) GetCreateBy 

func (m *ConfigFileRelease) GetCreateBy() *wrappers.StringValue

func (*ConfigFileRelease) GetCreateTime 

func (m *ConfigFileRelease) GetCreateTime() *wrappers.StringValue

func (*ConfigFileRelease) GetFileName 

func (m *ConfigFileRelease) GetFileName() *wrappers.StringValue

func (*ConfigFileRelease) GetGroup 

func (m *ConfigFileRelease) GetGroup() *wrappers.StringValue

func (*ConfigFileRelease) GetId 

func (m *ConfigFileRelease) GetId() *wrappers.UInt64Value

func (*ConfigFileRelease) GetMd5 

func (m *ConfigFileRelease) GetMd5() *wrappers.StringValue

func (*ConfigFileRelease) GetModifyBy 

func (m *ConfigFileRelease) GetModifyBy() *wrappers.StringValue

func (*ConfigFileRelease) GetModifyTime 

func (m *ConfigFileRelease) GetModifyTime() *wrappers.StringValue

func (*ConfigFileRelease) GetName 

func (m *ConfigFileRelease) GetName() *wrappers.StringValue

func (*ConfigFileRelease) GetNamespace 

func (m *ConfigFileRelease) GetNamespace() *wrappers.StringValue

func (*ConfigFileRelease) GetVersion 

func (m *ConfigFileRelease) GetVersion() *wrappers.UInt64Value

func (*ConfigFileRelease) ProtoMessage 

func (*ConfigFileRelease) ProtoMessage()

func (*ConfigFileRelease) Reset 

func (m *ConfigFileRelease) Reset()

func (*ConfigFileRelease) String 

func (m *ConfigFileRelease) String() string

func (*ConfigFileRelease) XXX_DiscardUnknown 

func (m *ConfigFileRelease) XXX_DiscardUnknown()

func (*ConfigFileRelease) XXX_Marshal 

func (m *ConfigFileRelease) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigFileRelease) XXX_Merge 

func (dst *ConfigFileRelease) XXX_Merge(src proto.Message)

func (*ConfigFileRelease) XXX_Size 

func (m *ConfigFileRelease) XXX_Size() int

func (*ConfigFileRelease) XXX_Unmarshal 

func (m *ConfigFileRelease) XXX_Unmarshal(b []byte) error

type ConfigFileReleaseHistory 

type ConfigFileReleaseHistory struct {
	Id                   *wrappers.UInt64Value `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            *wrappers.StringValue `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Group                *wrappers.StringValue `protobuf:"bytes,4,opt,name=group,proto3" json:"group,omitempty"`
	FileName             *wrappers.StringValue `protobuf:"bytes,5,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Content              *wrappers.StringValue `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	Format               *wrappers.StringValue `protobuf:"bytes,7,opt,name=format,proto3" json:"format,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	Md5                  *wrappers.StringValue `protobuf:"bytes,9,opt,name=md5,proto3" json:"md5,omitempty"`
	Type                 *wrappers.StringValue `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"`
	Status               *wrappers.StringValue `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"`
	Tags                 []*ConfigFileTag      `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"`
	CreateTime           *wrappers.StringValue `protobuf:"bytes,13,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	CreateBy             *wrappers.StringValue `protobuf:"bytes,14,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"`
	ModifyTime           *wrappers.StringValue `protobuf:"bytes,15,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	ModifyBy             *wrappers.StringValue `protobuf:"bytes,16,opt,name=modify_by,json=modifyBy,proto3" json:"modify_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigFileReleaseHistory) Descriptor 

func (*ConfigFileReleaseHistory) Descriptor() ([]byte, []int)

func (*ConfigFileReleaseHistory) GetComment 

func (m *ConfigFileReleaseHistory) GetComment() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetContent 

func (m *ConfigFileReleaseHistory) GetContent() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetCreateBy 

func (m *ConfigFileReleaseHistory) GetCreateBy() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetCreateTime 

func (m *ConfigFileReleaseHistory) GetCreateTime() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetFileName 

func (m *ConfigFileReleaseHistory) GetFileName() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetFormat 

func (m *ConfigFileReleaseHistory) GetFormat() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetGroup 

func (m *ConfigFileReleaseHistory) GetGroup() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetId 

func (m *ConfigFileReleaseHistory) GetId() *wrappers.UInt64Value

func (*ConfigFileReleaseHistory) GetMd5 

func (m *ConfigFileReleaseHistory) GetMd5() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetModifyBy 

func (m *ConfigFileReleaseHistory) GetModifyBy() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetModifyTime 

func (m *ConfigFileReleaseHistory) GetModifyTime() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetName 

func (m *ConfigFileReleaseHistory) GetName() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetNamespace 

func (m *ConfigFileReleaseHistory) GetNamespace() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetStatus 

func (m *ConfigFileReleaseHistory) GetStatus() *wrappers.StringValue

func (*ConfigFileReleaseHistory) GetTags 

func (m *ConfigFileReleaseHistory) GetTags() []*ConfigFileTag

func (*ConfigFileReleaseHistory) GetType 

func (m *ConfigFileReleaseHistory) GetType() *wrappers.StringValue

func (*ConfigFileReleaseHistory) ProtoMessage 

func (*ConfigFileReleaseHistory) ProtoMessage()

func (*ConfigFileReleaseHistory) Reset 

func (m *ConfigFileReleaseHistory) Reset()

func (*ConfigFileReleaseHistory) String 

func (m *ConfigFileReleaseHistory) String() string

func (*ConfigFileReleaseHistory) XXX_DiscardUnknown 

func (m *ConfigFileReleaseHistory) XXX_DiscardUnknown()

func (*ConfigFileReleaseHistory) XXX_Marshal 

func (m *ConfigFileReleaseHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigFileReleaseHistory) XXX_Merge 

func (dst *ConfigFileReleaseHistory) XXX_Merge(src proto.Message)

func (*ConfigFileReleaseHistory) XXX_Size 

func (m *ConfigFileReleaseHistory) XXX_Size() int

func (*ConfigFileReleaseHistory) XXX_Unmarshal 

func (m *ConfigFileReleaseHistory) XXX_Unmarshal(b []byte) error

type ConfigFileTag 

type ConfigFileTag struct {
	Key                  *wrappers.StringValue `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                *wrappers.StringValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigFileTag) Descriptor 

func (*ConfigFileTag) Descriptor() ([]byte, []int)

func (*ConfigFileTag) GetKey 

func (m *ConfigFileTag) GetKey() *wrappers.StringValue

func (*ConfigFileTag) GetValue 

func (m *ConfigFileTag) GetValue() *wrappers.StringValue

func (*ConfigFileTag) ProtoMessage 

func (*ConfigFileTag) ProtoMessage()

func (*ConfigFileTag) Reset 

func (m *ConfigFileTag) Reset()

func (*ConfigFileTag) String 

func (m *ConfigFileTag) String() string

func (*ConfigFileTag) XXX_DiscardUnknown 

func (m *ConfigFileTag) XXX_DiscardUnknown()

func (*ConfigFileTag) XXX_Marshal 

func (m *ConfigFileTag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigFileTag) XXX_Merge 

func (dst *ConfigFileTag) XXX_Merge(src proto.Message)

func (*ConfigFileTag) XXX_Size 

func (m *ConfigFileTag) XXX_Size() int

func (*ConfigFileTag) XXX_Unmarshal 

func (m *ConfigFileTag) XXX_Unmarshal(b []byte) error

type ConfigFileTemplate 

type ConfigFileTemplate struct {
	Id                   *wrappers.UInt64Value `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Content              *wrappers.StringValue `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Format               *wrappers.StringValue `protobuf:"bytes,4,opt,name=format,proto3" json:"format,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,5,opt,name=comment,proto3" json:"comment,omitempty"`
	CreateTime           *wrappers.StringValue `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	CreateBy             *wrappers.StringValue `protobuf:"bytes,7,opt,name=create_by,json=createBy,proto3" json:"create_by,omitempty"`
	ModifyTime           *wrappers.StringValue `protobuf:"bytes,8,opt,name=modify_time,json=modifyTime,proto3" json:"modify_time,omitempty"`
	ModifyBy             *wrappers.StringValue `protobuf:"bytes,9,opt,name=modify_by,json=modifyBy,proto3" json:"modify_by,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigFileTemplate) Descriptor 

func (*ConfigFileTemplate) Descriptor() ([]byte, []int)

func (*ConfigFileTemplate) GetComment 

func (m *ConfigFileTemplate) GetComment() *wrappers.StringValue

func (*ConfigFileTemplate) GetContent 

func (m *ConfigFileTemplate) GetContent() *wrappers.StringValue

func (*ConfigFileTemplate) GetCreateBy 

func (m *ConfigFileTemplate) GetCreateBy() *wrappers.StringValue

func (*ConfigFileTemplate) GetCreateTime 

func (m *ConfigFileTemplate) GetCreateTime() *wrappers.StringValue

func (*ConfigFileTemplate) GetFormat 

func (m *ConfigFileTemplate) GetFormat() *wrappers.StringValue

func (*ConfigFileTemplate) GetId 

func (m *ConfigFileTemplate) GetId() *wrappers.UInt64Value

func (*ConfigFileTemplate) GetModifyBy 

func (m *ConfigFileTemplate) GetModifyBy() *wrappers.StringValue

func (*ConfigFileTemplate) GetModifyTime 

func (m *ConfigFileTemplate) GetModifyTime() *wrappers.StringValue

func (*ConfigFileTemplate) GetName 

func (m *ConfigFileTemplate) GetName() *wrappers.StringValue

func (*ConfigFileTemplate) ProtoMessage 

func (*ConfigFileTemplate) ProtoMessage()

func (*ConfigFileTemplate) Reset 

func (m *ConfigFileTemplate) Reset()

func (*ConfigFileTemplate) String 

func (m *ConfigFileTemplate) String() string

func (*ConfigFileTemplate) XXX_DiscardUnknown 

func (m *ConfigFileTemplate) XXX_DiscardUnknown()

func (*ConfigFileTemplate) XXX_Marshal 

func (m *ConfigFileTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigFileTemplate) XXX_Merge 

func (dst *ConfigFileTemplate) XXX_Merge(src proto.Message)

func (*ConfigFileTemplate) XXX_Size 

func (m *ConfigFileTemplate) XXX_Size() int

func (*ConfigFileTemplate) XXX_Unmarshal 

func (m *ConfigFileTemplate) XXX_Unmarshal(b []byte) error

type ConfigRelease 

type ConfigRelease struct {
	Service              *Service              `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,2,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,3,opt,name=mtime,proto3" json:"mtime,omitempty"`
	CircuitBreaker       *CircuitBreaker       `protobuf:"bytes,4,opt,name=circuitBreaker,proto3" json:"circuitBreaker,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigRelease) Descriptor 

func (*ConfigRelease) Descriptor() ([]byte, []int)

func (*ConfigRelease) GetCircuitBreaker 

func (m *ConfigRelease) GetCircuitBreaker() *CircuitBreaker

func (*ConfigRelease) GetCtime 

func (m *ConfigRelease) GetCtime() *wrappers.StringValue

func (*ConfigRelease) GetMtime 

func (m *ConfigRelease) GetMtime() *wrappers.StringValue

func (*ConfigRelease) GetService 

func (m *ConfigRelease) GetService() *Service

func (*ConfigRelease) ProtoMessage 

func (*ConfigRelease) ProtoMessage()

func (*ConfigRelease) Reset 

func (m *ConfigRelease) Reset()

func (*ConfigRelease) String 

func (m *ConfigRelease) String() string

func (*ConfigRelease) XXX_DiscardUnknown 

func (m *ConfigRelease) XXX_DiscardUnknown()

func (*ConfigRelease) XXX_Marshal 

func (m *ConfigRelease) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigRelease) XXX_Merge 

func (dst *ConfigRelease) XXX_Merge(src proto.Message)

func (*ConfigRelease) XXX_Size 

func (m *ConfigRelease) XXX_Size() int

func (*ConfigRelease) XXX_Unmarshal 

func (m *ConfigRelease) XXX_Unmarshal(b []byte) error

type ConfigResponse 

type ConfigResponse struct {
	Code                     *wrappers.UInt32Value     `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                     *wrappers.StringValue     `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	ConfigFileGroup          *ConfigFileGroup          `protobuf:"bytes,3,opt,name=configFileGroup,proto3" json:"configFileGroup,omitempty"`
	ConfigFile               *ConfigFile               `protobuf:"bytes,4,opt,name=configFile,proto3" json:"configFile,omitempty"`
	ConfigFileRelease        *ConfigFileRelease        `protobuf:"bytes,5,opt,name=configFileRelease,proto3" json:"configFileRelease,omitempty"`
	ConfigFileReleaseHistory *ConfigFileReleaseHistory `protobuf:"bytes,6,opt,name=configFileReleaseHistory,proto3" json:"configFileReleaseHistory,omitempty"`
	ConfigFileTemplate       *ConfigFileTemplate       `protobuf:"bytes,7,opt,name=configFileTemplate,proto3" json:"configFileTemplate,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}                  `json:"-"`
	XXX_unrecognized         []byte                    `json:"-"`
	XXX_sizecache            int32                     `json:"-"`
}

func NewConfigFileGroupResponse 

func NewConfigFileGroupResponse(code uint32, configFileGroup *ConfigFileGroup) *ConfigResponse

func NewConfigFileGroupResponseWithMessage 

func NewConfigFileGroupResponseWithMessage(code uint32, message string) *ConfigResponse

func NewConfigFileReleaseHistoryResponse 

func NewConfigFileReleaseHistoryResponse(code uint32, configFileReleaseHistory *ConfigFileReleaseHistory) *ConfigResponse

func NewConfigFileReleaseResponse 

func NewConfigFileReleaseResponse(code uint32, configFileRelease *ConfigFileRelease) *ConfigResponse

func NewConfigFileReleaseResponseWithMessage 

func NewConfigFileReleaseResponseWithMessage(code uint32, message string) *ConfigResponse

func NewConfigFileResponse 

func NewConfigFileResponse(code uint32, configFile *ConfigFile) *ConfigResponse

func NewConfigFileResponseWithMessage 

func NewConfigFileResponseWithMessage(code uint32, message string) *ConfigResponse

func NewConfigFileTemplateResponse 

func NewConfigFileTemplateResponse(code uint32, template *ConfigFileTemplate) *ConfigResponse

func NewConfigFileTemplateResponseWithMessage 

func NewConfigFileTemplateResponseWithMessage(code uint32, message string) *ConfigResponse

func (*ConfigResponse) Descriptor 

func (*ConfigResponse) Descriptor() ([]byte, []int)

func (*ConfigResponse) GetCode 

func (m *ConfigResponse) GetCode() *wrappers.UInt32Value

func (*ConfigResponse) GetConfigFile 

func (m *ConfigResponse) GetConfigFile() *ConfigFile

func (*ConfigResponse) GetConfigFileGroup 

func (m *ConfigResponse) GetConfigFileGroup() *ConfigFileGroup

func (*ConfigResponse) GetConfigFileRelease 

func (m *ConfigResponse) GetConfigFileRelease() *ConfigFileRelease

func (*ConfigResponse) GetConfigFileReleaseHistory 

func (m *ConfigResponse) GetConfigFileReleaseHistory() *ConfigFileReleaseHistory

func (*ConfigResponse) GetConfigFileTemplate 

func (m *ConfigResponse) GetConfigFileTemplate() *ConfigFileTemplate

func (*ConfigResponse) GetInfo 

func (m *ConfigResponse) GetInfo() *wrappers.StringValue

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) Reset 

func (m *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (m *ConfigResponse) String() string

func (*ConfigResponse) XXX_DiscardUnknown 

func (m *ConfigResponse) XXX_DiscardUnknown()

func (*ConfigResponse) XXX_Marshal 

func (m *ConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigResponse) XXX_Merge 

func (dst *ConfigResponse) XXX_Merge(src proto.Message)

func (*ConfigResponse) XXX_Size 

func (m *ConfigResponse) XXX_Size() int

func (*ConfigResponse) XXX_Unmarshal 

func (m *ConfigResponse) XXX_Unmarshal(b []byte) error

type ConfigSimpleResponse 

type ConfigSimpleResponse struct {
	Code                 *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ConfigSimpleResponse) Descriptor 

func (*ConfigSimpleResponse) Descriptor() ([]byte, []int)

func (*ConfigSimpleResponse) GetCode 

func (m *ConfigSimpleResponse) GetCode() *wrappers.UInt32Value

func (*ConfigSimpleResponse) GetInfo 

func (m *ConfigSimpleResponse) GetInfo() *wrappers.StringValue

func (*ConfigSimpleResponse) ProtoMessage 

func (*ConfigSimpleResponse) ProtoMessage()

func (*ConfigSimpleResponse) Reset 

func (m *ConfigSimpleResponse) Reset()

func (*ConfigSimpleResponse) String 

func (m *ConfigSimpleResponse) String() string

func (*ConfigSimpleResponse) XXX_DiscardUnknown 

func (m *ConfigSimpleResponse) XXX_DiscardUnknown()

func (*ConfigSimpleResponse) XXX_Marshal 

func (m *ConfigSimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigSimpleResponse) XXX_Merge 

func (dst *ConfigSimpleResponse) XXX_Merge(src proto.Message)

func (*ConfigSimpleResponse) XXX_Size 

func (m *ConfigSimpleResponse) XXX_Size() int

func (*ConfigSimpleResponse) XXX_Unmarshal 

func (m *ConfigSimpleResponse) XXX_Unmarshal(b []byte) error

type ConfigWithService 

type ConfigWithService struct {
	Services             []*Service      `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	CircuitBreaker       *CircuitBreaker `protobuf:"bytes,2,opt,name=circuitBreaker,proto3" json:"circuitBreaker,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ConfigWithService) Descriptor 

func (*ConfigWithService) Descriptor() ([]byte, []int)

func (*ConfigWithService) GetCircuitBreaker 

func (m *ConfigWithService) GetCircuitBreaker() *CircuitBreaker

func (*ConfigWithService) GetServices 

func (m *ConfigWithService) GetServices() []*Service

func (*ConfigWithService) ProtoMessage 

func (*ConfigWithService) ProtoMessage()

func (*ConfigWithService) Reset 

func (m *ConfigWithService) Reset()

func (*ConfigWithService) String 

func (m *ConfigWithService) String() string

func (*ConfigWithService) XXX_DiscardUnknown 

func (m *ConfigWithService) XXX_DiscardUnknown()

func (*ConfigWithService) XXX_Marshal 

func (m *ConfigWithService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigWithService) XXX_Merge 

func (dst *ConfigWithService) XXX_Merge(src proto.Message)

func (*ConfigWithService) XXX_Size 

func (m *ConfigWithService) XXX_Size() int

func (*ConfigWithService) XXX_Unmarshal 

func (m *ConfigWithService) XXX_Unmarshal(b []byte) error

type Destination 

type Destination struct {
	// 被调方服务以及命名空间
	Service   *wrappers.StringValue `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Namespace *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 被调方服务实例标签
	// value支持正则匹配
	Metadata map[string]*MatchString `` /* 157-byte string literal not displayed */
	// 根据服务名和服务实例metadata筛选符合条件的服务实例子集
	// 服务实例子集可以设置优先级和权重
	// 优先级：整型，范围[0, 9]，最高优先级为0
	// 权重：整型
	// 先按优先级路由，如果存在高优先级，不会使用低优先级
	// 如果存在优先级相同的子集，再按权重分配
	// 优先级和权重可以都不设置/设置一个/设置两个
	// 如果部分设置优先级，部分没有设置，认为没有设置的优先级最低
	// 如果部分设置权重，部分没有设置，认为没有设置的权重为0
	// 如果全部没有设置权重，认为权重相同
	Priority *wrappers.UInt32Value `protobuf:"bytes,4,opt,name=priority,proto3" json:"priority,omitempty"`
	Weight   *wrappers.UInt32Value `protobuf:"bytes,5,opt,name=weight,proto3" json:"weight,omitempty"`
	// 将请求转发到代理服务
	Transfer *wrappers.StringValue `protobuf:"bytes,6,opt,name=transfer,proto3" json:"transfer,omitempty"`
	// 是否对该set执行隔离，隔离后，不会再分配流量
	Isolate              *wrappers.BoolValue `protobuf:"bytes,7,opt,name=isolate,proto3" json:"isolate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Destination) Descriptor 

func (*Destination) Descriptor() ([]byte, []int)

func (*Destination) GetIsolate 

func (m *Destination) GetIsolate() *wrappers.BoolValue

func (*Destination) GetMetadata 

func (m *Destination) GetMetadata() map[string]*MatchString

func (*Destination) GetNamespace 

func (m *Destination) GetNamespace() *wrappers.StringValue

func (*Destination) GetPriority 

func (m *Destination) GetPriority() *wrappers.UInt32Value

func (*Destination) GetService 

func (m *Destination) GetService() *wrappers.StringValue

func (*Destination) GetTransfer 

func (m *Destination) GetTransfer() *wrappers.StringValue

func (*Destination) GetWeight 

func (m *Destination) GetWeight() *wrappers.UInt32Value

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) Reset 

func (m *Destination) Reset()

func (*Destination) String 

func (m *Destination) String() string

func (*Destination) XXX_DiscardUnknown 

func (m *Destination) XXX_DiscardUnknown()

func (*Destination) XXX_Marshal 

func (m *Destination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Destination) XXX_Merge 

func (dst *Destination) XXX_Merge(src proto.Message)

func (*Destination) XXX_Size 

func (m *Destination) XXX_Size() int

func (*Destination) XXX_Unmarshal 

func (m *Destination) XXX_Unmarshal(b []byte) error

type DestinationSet 

type DestinationSet struct {
	// 被调命名空间以及服务名，可以为*，代表全匹配
	Service   *wrappers.StringValue `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Namespace *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 可选，SUBSET标识
	Metadata map[string]*MatchString `` /* 157-byte string literal not displayed */
	Resource DestinationSet_Resource `protobuf:"varint,4,opt,name=resource,proto3,enum=v1.DestinationSet_Resource" json:"resource,omitempty"`
	Type     DestinationSet_Type     `protobuf:"varint,5,opt,name=type,proto3,enum=v1.DestinationSet_Type" json:"type,omitempty"`
	Scope    DestinationSet_Scope    `protobuf:"varint,6,opt,name=scope,proto3,enum=v1.DestinationSet_Scope" json:"scope,omitempty"`
	// 熔断数据度量周期
	// 所有的阈值指标按此周期进行统计
	MetricWindow *duration.Duration `protobuf:"bytes,7,opt,name=metricWindow,proto3" json:"metricWindow,omitempty"`
	// 熔断数据统计精度，决定数据度量的最小周期
	// 度量滑窗的步长=window/precision
	MetricPrecision *wrappers.UInt32Value `protobuf:"bytes,8,opt,name=metricPrecision,proto3" json:"metricPrecision,omitempty"`
	// 熔断数据上报周期，对分布式熔断有效
	UpdateInterval *duration.Duration `protobuf:"bytes,9,opt,name=updateInterval,proto3" json:"updateInterval,omitempty"`
	// 触发熔断后恢复配置
	Recover *RecoverConfig `protobuf:"bytes,10,opt,name=recover,proto3" json:"recover,omitempty"`
	// 熔断策略
	Policy *CbPolicy `protobuf:"bytes,11,opt,name=policy,proto3" json:"policy,omitempty"`
	// 被调的接口信息，指定哪些接口会使用该规则
	Method *MatchString `protobuf:"bytes,12,opt,name=method,proto3" json:"method,omitempty"`
	// 返回码，指定哪些返回码会使用该规则
	ErrorCodes           []*wrappers.Int64Value `protobuf:"bytes,13,rep,name=errorCodes,proto3" json:"errorCodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

目标set的规则

func (*DestinationSet) Descriptor 

func (*DestinationSet) Descriptor() ([]byte, []int)

func (*DestinationSet) GetErrorCodes 

func (m *DestinationSet) GetErrorCodes() []*wrappers.Int64Value

func (*DestinationSet) GetMetadata 

func (m *DestinationSet) GetMetadata() map[string]*MatchString

func (*DestinationSet) GetMethod 

func (m *DestinationSet) GetMethod() *MatchString

func (*DestinationSet) GetMetricPrecision 

func (m *DestinationSet) GetMetricPrecision() *wrappers.UInt32Value

func (*DestinationSet) GetMetricWindow 

func (m *DestinationSet) GetMetricWindow() *duration.Duration

func (*DestinationSet) GetNamespace 

func (m *DestinationSet) GetNamespace() *wrappers.StringValue

func (*DestinationSet) GetPolicy 

func (m *DestinationSet) GetPolicy() *CbPolicy

func (*DestinationSet) GetRecover 

func (m *DestinationSet) GetRecover() *RecoverConfig

func (*DestinationSet) GetResource 

func (m *DestinationSet) GetResource() DestinationSet_Resource

func (*DestinationSet) GetScope 

func (m *DestinationSet) GetScope() DestinationSet_Scope

func (*DestinationSet) GetService 

func (m *DestinationSet) GetService() *wrappers.StringValue

func (*DestinationSet) GetType 

func (m *DestinationSet) GetType() DestinationSet_Type

func (*DestinationSet) GetUpdateInterval 

func (m *DestinationSet) GetUpdateInterval() *duration.Duration

func (*DestinationSet) ProtoMessage 

func (*DestinationSet) ProtoMessage()

func (*DestinationSet) Reset 

func (m *DestinationSet) Reset()

func (*DestinationSet) String 

func (m *DestinationSet) String() string

func (*DestinationSet) XXX_DiscardUnknown 

func (m *DestinationSet) XXX_DiscardUnknown()

func (*DestinationSet) XXX_Marshal 

func (m *DestinationSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DestinationSet) XXX_Merge 

func (dst *DestinationSet) XXX_Merge(src proto.Message)

func (*DestinationSet) XXX_Size 

func (m *DestinationSet) XXX_Size() int

func (*DestinationSet) XXX_Unmarshal 

func (m *DestinationSet) XXX_Unmarshal(b []byte) error

type DestinationSet_Resource 

type DestinationSet_Resource int32

需要进行熔断的资源 支持SUBSET（子集群），以及INSTANCE（单个实例），默认为SUBSET 

const (
	// 针对实例分组进行熔断
	DestinationSet_SUBSET DestinationSet_Resource = 0
	// 针对实例进行熔断
	DestinationSet_INSTANCE DestinationSet_Resource = 1
)

func (DestinationSet_Resource) EnumDescriptor 

func (DestinationSet_Resource) EnumDescriptor() ([]byte, []int)

func (DestinationSet_Resource) String 

func (x DestinationSet_Resource) String() string

type DestinationSet_Scope 

type DestinationSet_Scope int32

熔断范围，是否扩散针对相同服务下所有接口进行熔断 

const (
	// 触发熔断条件，扩散熔断所有接口
	DestinationSet_ALL DestinationSet_Scope = 0
	// 触发熔断条件，只熔断当前接口
	DestinationSet_CURRENT DestinationSet_Scope = 1
)

func (DestinationSet_Scope) EnumDescriptor 

func (DestinationSet_Scope) EnumDescriptor() ([]byte, []int)

func (DestinationSet_Scope) String 

func (x DestinationSet_Scope) String() string

type DestinationSet_Type 

type DestinationSet_Type int32

熔断决策类型，支持GLOBAL（分布式决策）以及LOCAL(本地决策），默认GLOBAL 当指定为GLOBAL时，则会定期上报统计数据并根据汇总数据进行熔断决策 

const (
	DestinationSet_GLOBAL DestinationSet_Type = 0
	DestinationSet_LOCAL  DestinationSet_Type = 1
)

func (DestinationSet_Type) EnumDescriptor 

func (DestinationSet_Type) EnumDescriptor() ([]byte, []int)

func (DestinationSet_Type) String 

func (x DestinationSet_Type) String() string

type DiscoverRequest 

type DiscoverRequest struct {
	Type                 DiscoverRequest_DiscoverRequestType `protobuf:"varint,1,opt,name=type,proto3,enum=v1.DiscoverRequest_DiscoverRequestType" json:"type,omitempty"`
	Service              *Service                            `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*DiscoverRequest) Descriptor 

func (*DiscoverRequest) Descriptor() ([]byte, []int)

func (*DiscoverRequest) GetService 

func (m *DiscoverRequest) GetService() *Service

func (*DiscoverRequest) GetType 

func (m *DiscoverRequest) GetType() DiscoverRequest_DiscoverRequestType

func (*DiscoverRequest) ProtoMessage 

func (*DiscoverRequest) ProtoMessage()

func (*DiscoverRequest) Reset 

func (m *DiscoverRequest) Reset()

func (*DiscoverRequest) String 

func (m *DiscoverRequest) String() string

func (*DiscoverRequest) XXX_DiscardUnknown 

func (m *DiscoverRequest) XXX_DiscardUnknown()

func (*DiscoverRequest) XXX_Marshal 

func (m *DiscoverRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverRequest) XXX_Merge 

func (dst *DiscoverRequest) XXX_Merge(src proto.Message)

func (*DiscoverRequest) XXX_Size 

func (m *DiscoverRequest) XXX_Size() int

func (*DiscoverRequest) XXX_Unmarshal 

func (m *DiscoverRequest) XXX_Unmarshal(b []byte) error

type DiscoverRequest_DiscoverRequestType 

type DiscoverRequest_DiscoverRequestType int32
const (
	DiscoverRequest_UNKNOWN         DiscoverRequest_DiscoverRequestType = 0
	DiscoverRequest_INSTANCE        DiscoverRequest_DiscoverRequestType = 1
	DiscoverRequest_CLUSTER         DiscoverRequest_DiscoverRequestType = 2
	DiscoverRequest_ROUTING         DiscoverRequest_DiscoverRequestType = 3
	DiscoverRequest_RATE_LIMIT      DiscoverRequest_DiscoverRequestType = 4
	DiscoverRequest_CIRCUIT_BREAKER DiscoverRequest_DiscoverRequestType = 5
	DiscoverRequest_SERVICES        DiscoverRequest_DiscoverRequestType = 6
	DiscoverRequest_NAMESPACES      DiscoverRequest_DiscoverRequestType = 12
)

func (DiscoverRequest_DiscoverRequestType) EnumDescriptor 

func (DiscoverRequest_DiscoverRequestType) EnumDescriptor() ([]byte, []int)

func (DiscoverRequest_DiscoverRequestType) String 

func (x DiscoverRequest_DiscoverRequestType) String() string

type DiscoverResponse 

type DiscoverResponse struct {
	Code                 *wrappers.UInt32Value                 `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue                 `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Type                 DiscoverResponse_DiscoverResponseType `protobuf:"varint,3,opt,name=type,proto3,enum=v1.DiscoverResponse_DiscoverResponseType" json:"type,omitempty"`
	Service              *Service                              `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	Instances            []*Instance                           `protobuf:"bytes,5,rep,name=instances,proto3" json:"instances,omitempty"`
	Routing              *Routing                              `protobuf:"bytes,6,opt,name=routing,proto3" json:"routing,omitempty"`
	RateLimit            *RateLimit                            `protobuf:"bytes,7,opt,name=rateLimit,proto3" json:"rateLimit,omitempty"`
	CircuitBreaker       *CircuitBreaker                       `protobuf:"bytes,8,opt,name=circuitBreaker,proto3" json:"circuitBreaker,omitempty"`
	Services             []*Service                            `protobuf:"bytes,9,rep,name=services,proto3" json:"services,omitempty"`
	Namespaces           []*Namespace                          `protobuf:"bytes,10,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func NewDiscoverCircuitBreakerResponse 

func NewDiscoverCircuitBreakerResponse(code uint32, service *Service) *DiscoverResponse

*

  • @brief 创建查询熔断规则回复

func NewDiscoverInstanceResponse 

func NewDiscoverInstanceResponse(code uint32, service *Service) *DiscoverResponse

*

  • @brief 创建查询服务实例回复

func NewDiscoverRateLimitResponse 

func NewDiscoverRateLimitResponse(code uint32, service *Service) *DiscoverResponse

*

  • @brief 创建查询限流规则回复

func NewDiscoverResponse 

func NewDiscoverResponse(code uint32) *DiscoverResponse

创建一个空白的discoverResponse

func NewDiscoverRoutingResponse 

func NewDiscoverRoutingResponse(code uint32, service *Service) *DiscoverResponse

*

  • @brief 创建查询服务路由回复

func NewDiscoverServiceResponse 

func NewDiscoverServiceResponse(code uint32, service *Service) *DiscoverResponse

*

  • @brief 创建查询服务回复

func (*DiscoverResponse) Descriptor 

func (*DiscoverResponse) Descriptor() ([]byte, []int)

func (*DiscoverResponse) GetCircuitBreaker 

func (m *DiscoverResponse) GetCircuitBreaker() *CircuitBreaker

func (*DiscoverResponse) GetCode 

func (m *DiscoverResponse) GetCode() *wrappers.UInt32Value

func (*DiscoverResponse) GetInfo 

func (m *DiscoverResponse) GetInfo() *wrappers.StringValue

func (*DiscoverResponse) GetInstances 

func (m *DiscoverResponse) GetInstances() []*Instance

func (*DiscoverResponse) GetNamespaces 

func (m *DiscoverResponse) GetNamespaces() []*Namespace

func (*DiscoverResponse) GetRateLimit 

func (m *DiscoverResponse) GetRateLimit() *RateLimit

func (*DiscoverResponse) GetRouting 

func (m *DiscoverResponse) GetRouting() *Routing

func (*DiscoverResponse) GetService 

func (m *DiscoverResponse) GetService() *Service

func (*DiscoverResponse) GetServices 

func (m *DiscoverResponse) GetServices() []*Service

func (*DiscoverResponse) GetType 

func (m *DiscoverResponse) GetType() DiscoverResponse_DiscoverResponseType

func (*DiscoverResponse) ProtoMessage 

func (*DiscoverResponse) ProtoMessage()

func (*DiscoverResponse) Reset 

func (m *DiscoverResponse) Reset()

func (*DiscoverResponse) String 

func (m *DiscoverResponse) String() string

func (*DiscoverResponse) XXX_DiscardUnknown 

func (m *DiscoverResponse) XXX_DiscardUnknown()

func (*DiscoverResponse) XXX_Marshal 

func (m *DiscoverResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverResponse) XXX_Merge 

func (dst *DiscoverResponse) XXX_Merge(src proto.Message)

func (*DiscoverResponse) XXX_Size 

func (m *DiscoverResponse) XXX_Size() int

func (*DiscoverResponse) XXX_Unmarshal 

func (m *DiscoverResponse) XXX_Unmarshal(b []byte) error

type DiscoverResponse_DiscoverResponseType 

type DiscoverResponse_DiscoverResponseType int32
const (
	DiscoverResponse_UNKNOWN         DiscoverResponse_DiscoverResponseType = 0
	DiscoverResponse_INSTANCE        DiscoverResponse_DiscoverResponseType = 1
	DiscoverResponse_CLUSTER         DiscoverResponse_DiscoverResponseType = 2
	DiscoverResponse_ROUTING         DiscoverResponse_DiscoverResponseType = 3
	DiscoverResponse_RATE_LIMIT      DiscoverResponse_DiscoverResponseType = 4
	DiscoverResponse_CIRCUIT_BREAKER DiscoverResponse_DiscoverResponseType = 5
	DiscoverResponse_SERVICES        DiscoverResponse_DiscoverResponseType = 6
	DiscoverResponse_NAMESPACES      DiscoverResponse_DiscoverResponseType = 12
)

func (DiscoverResponse_DiscoverResponseType) EnumDescriptor 

func (DiscoverResponse_DiscoverResponseType) EnumDescriptor() ([]byte, []int)

func (DiscoverResponse_DiscoverResponseType) String 

func (x DiscoverResponse_DiscoverResponseType) String() string

type HealthCheck 

type HealthCheck struct {
	Type                 HealthCheck_HealthCheckType `protobuf:"varint,1,opt,name=type,proto3,enum=v1.HealthCheck_HealthCheckType" json:"type,omitempty"`
	Heartbeat            *HeartbeatHealthCheck       `protobuf:"bytes,2,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*HealthCheck) Descriptor 

func (*HealthCheck) Descriptor() ([]byte, []int)

func (*HealthCheck) GetHeartbeat 

func (m *HealthCheck) GetHeartbeat() *HeartbeatHealthCheck

func (*HealthCheck) GetType 

func (m *HealthCheck) GetType() HealthCheck_HealthCheckType

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) String 

func (m *HealthCheck) String() string

func (*HealthCheck) XXX_DiscardUnknown 

func (m *HealthCheck) XXX_DiscardUnknown()

func (*HealthCheck) XXX_Marshal 

func (m *HealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheck) XXX_Merge 

func (dst *HealthCheck) XXX_Merge(src proto.Message)

func (*HealthCheck) XXX_Size 

func (m *HealthCheck) XXX_Size() int

func (*HealthCheck) XXX_Unmarshal 

func (m *HealthCheck) XXX_Unmarshal(b []byte) error

type HealthCheck_HealthCheckType 

type HealthCheck_HealthCheckType int32
const (
	HealthCheck_UNKNOWN   HealthCheck_HealthCheckType = 0
	HealthCheck_HEARTBEAT HealthCheck_HealthCheckType = 1
)

func (HealthCheck_HealthCheckType) EnumDescriptor 

func (HealthCheck_HealthCheckType) EnumDescriptor() ([]byte, []int)

func (HealthCheck_HealthCheckType) String 

func (x HealthCheck_HealthCheckType) String() string

type HeartbeatHealthCheck 

type HeartbeatHealthCheck struct {
	Ttl                  *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*HeartbeatHealthCheck) Descriptor 

func (*HeartbeatHealthCheck) Descriptor() ([]byte, []int)

func (*HeartbeatHealthCheck) GetTtl 

func (m *HeartbeatHealthCheck) GetTtl() *wrappers.UInt32Value

func (*HeartbeatHealthCheck) ProtoMessage 

func (*HeartbeatHealthCheck) ProtoMessage()

func (*HeartbeatHealthCheck) Reset 

func (m *HeartbeatHealthCheck) Reset()

func (*HeartbeatHealthCheck) String 

func (m *HeartbeatHealthCheck) String() string

func (*HeartbeatHealthCheck) XXX_DiscardUnknown 

func (m *HeartbeatHealthCheck) XXX_DiscardUnknown()

func (*HeartbeatHealthCheck) XXX_Marshal 

func (m *HeartbeatHealthCheck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartbeatHealthCheck) XXX_Merge 

func (dst *HeartbeatHealthCheck) XXX_Merge(src proto.Message)

func (*HeartbeatHealthCheck) XXX_Size 

func (m *HeartbeatHealthCheck) XXX_Size() int

func (*HeartbeatHealthCheck) XXX_Unmarshal 

func (m *HeartbeatHealthCheck) XXX_Unmarshal(b []byte) error

type Instance 

type Instance struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Service              *wrappers.StringValue `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Namespace            *wrappers.StringValue `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	VpcId                *wrappers.StringValue `protobuf:"bytes,21,opt,name=vpc_id,proto3" json:"vpc_id,omitempty"`
	Host                 *wrappers.StringValue `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"`
	Port                 *wrappers.UInt32Value `protobuf:"bytes,5,opt,name=port,proto3" json:"port,omitempty"`
	Protocol             *wrappers.StringValue `protobuf:"bytes,6,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Version              *wrappers.StringValue `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	Priority             *wrappers.UInt32Value `protobuf:"bytes,8,opt,name=priority,proto3" json:"priority,omitempty"`
	Weight               *wrappers.UInt32Value `protobuf:"bytes,9,opt,name=weight,proto3" json:"weight,omitempty"`
	EnableHealthCheck    *wrappers.BoolValue   `protobuf:"bytes,20,opt,name=enable_health_check,json=enableHealthCheck,proto3" json:"enable_health_check,omitempty"`
	HealthCheck          *HealthCheck          `protobuf:"bytes,10,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"`
	Healthy              *wrappers.BoolValue   `protobuf:"bytes,11,opt,name=healthy,proto3" json:"healthy,omitempty"`
	Isolate              *wrappers.BoolValue   `protobuf:"bytes,12,opt,name=isolate,proto3" json:"isolate,omitempty"`
	Location             *Location             `protobuf:"bytes,13,opt,name=location,proto3" json:"location,omitempty"`
	Metadata             map[string]string     `` /* 158-byte string literal not displayed */
	LogicSet             *wrappers.StringValue `protobuf:"bytes,15,opt,name=logic_set,proto3" json:"logic_set,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,16,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,17,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Revision             *wrappers.StringValue `protobuf:"bytes,18,opt,name=revision,proto3" json:"revision,omitempty"`
	ServiceToken         *wrappers.StringValue `protobuf:"bytes,19,opt,name=service_token,proto3" json:"service_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Instance) Descriptor 

func (*Instance) Descriptor() ([]byte, []int)

func (*Instance) GetCtime 

func (m *Instance) GetCtime() *wrappers.StringValue

func (*Instance) GetEnableHealthCheck 

func (m *Instance) GetEnableHealthCheck() *wrappers.BoolValue

func (*Instance) GetHealthCheck 

func (m *Instance) GetHealthCheck() *HealthCheck

func (*Instance) GetHealthy 

func (m *Instance) GetHealthy() *wrappers.BoolValue

func (*Instance) GetHost 

func (m *Instance) GetHost() *wrappers.StringValue

func (*Instance) GetId 

func (m *Instance) GetId() *wrappers.StringValue

func (*Instance) GetIsolate 

func (m *Instance) GetIsolate() *wrappers.BoolValue

func (*Instance) GetLocation 

func (m *Instance) GetLocation() *Location

func (*Instance) GetLogicSet 

func (m *Instance) GetLogicSet() *wrappers.StringValue

func (*Instance) GetMetadata 

func (m *Instance) GetMetadata() map[string]string

func (*Instance) GetMtime 

func (m *Instance) GetMtime() *wrappers.StringValue

func (*Instance) GetNamespace 

func (m *Instance) GetNamespace() *wrappers.StringValue

func (*Instance) GetPort 

func (m *Instance) GetPort() *wrappers.UInt32Value

func (*Instance) GetPriority 

func (m *Instance) GetPriority() *wrappers.UInt32Value

func (*Instance) GetProtocol 

func (m *Instance) GetProtocol() *wrappers.StringValue

func (*Instance) GetRevision 

func (m *Instance) GetRevision() *wrappers.StringValue

func (*Instance) GetService 

func (m *Instance) GetService() *wrappers.StringValue

func (*Instance) GetServiceToken 

func (m *Instance) GetServiceToken() *wrappers.StringValue

func (*Instance) GetVersion 

func (m *Instance) GetVersion() *wrappers.StringValue

func (*Instance) GetVpcId 

func (m *Instance) GetVpcId() *wrappers.StringValue

func (*Instance) GetWeight 

func (m *Instance) GetWeight() *wrappers.UInt32Value

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) Reset 

func (m *Instance) Reset()

func (*Instance) String 

func (m *Instance) String() string

func (*Instance) XXX_DiscardUnknown 

func (m *Instance) XXX_DiscardUnknown()

func (*Instance) XXX_Marshal 

func (m *Instance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Instance) XXX_Merge 

func (dst *Instance) XXX_Merge(src proto.Message)

func (*Instance) XXX_Size 

func (m *Instance) XXX_Size() int

func (*Instance) XXX_Unmarshal 

func (m *Instance) XXX_Unmarshal(b []byte) error

type InstanceLabels 

type InstanceLabels struct {
	Labels               map[string]*StringList `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*InstanceLabels) Descriptor 

func (*InstanceLabels) Descriptor() ([]byte, []int)

func (*InstanceLabels) GetLabels 

func (m *InstanceLabels) GetLabels() map[string]*StringList

func (*InstanceLabels) ProtoMessage 

func (*InstanceLabels) ProtoMessage()

func (*InstanceLabels) Reset 

func (m *InstanceLabels) Reset()

func (*InstanceLabels) String 

func (m *InstanceLabels) String() string

func (*InstanceLabels) XXX_DiscardUnknown 

func (m *InstanceLabels) XXX_DiscardUnknown()

func (*InstanceLabels) XXX_Marshal 

func (m *InstanceLabels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceLabels) XXX_Merge 

func (dst *InstanceLabels) XXX_Merge(src proto.Message)

func (*InstanceLabels) XXX_Size 

func (m *InstanceLabels) XXX_Size() int

func (*InstanceLabels) XXX_Unmarshal 

func (m *InstanceLabels) XXX_Unmarshal(b []byte) error

type Location 

type Location struct {
	Region               *wrappers.StringValue `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	Zone                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	Campus               *wrappers.StringValue `protobuf:"bytes,3,opt,name=campus,proto3" json:"campus,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Location) Descriptor 

func (*Location) Descriptor() ([]byte, []int)

func (*Location) GetCampus 

func (m *Location) GetCampus() *wrappers.StringValue

func (*Location) GetRegion 

func (m *Location) GetRegion() *wrappers.StringValue

func (*Location) GetZone 

func (m *Location) GetZone() *wrappers.StringValue

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge 

func (dst *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

func (m *Location) XXX_Unmarshal(b []byte) error

type LoginRequest 

type LoginRequest struct {
	Owner                *wrappers.StringValue `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Password             *wrappers.StringValue `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*LoginRequest) Descriptor 

func (*LoginRequest) Descriptor() ([]byte, []int)

func (*LoginRequest) GetName 

func (m *LoginRequest) GetName() *wrappers.StringValue

func (*LoginRequest) GetOwner 

func (m *LoginRequest) GetOwner() *wrappers.StringValue

func (*LoginRequest) GetPassword 

func (m *LoginRequest) GetPassword() *wrappers.StringValue

func (*LoginRequest) ProtoMessage 

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) Reset 

func (m *LoginRequest) Reset()

func (*LoginRequest) String 

func (m *LoginRequest) String() string

func (*LoginRequest) XXX_DiscardUnknown 

func (m *LoginRequest) XXX_DiscardUnknown()

func (*LoginRequest) XXX_Marshal 

func (m *LoginRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoginRequest) XXX_Merge 

func (dst *LoginRequest) XXX_Merge(src proto.Message)

func (*LoginRequest) XXX_Size 

func (m *LoginRequest) XXX_Size() int

func (*LoginRequest) XXX_Unmarshal 

func (m *LoginRequest) XXX_Unmarshal(b []byte) error

type LoginResponse 

type LoginResponse struct {
	UserId               *wrappers.StringValue `protobuf:"bytes,1,opt,name=user_id,proto3" json:"user_id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Role                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	OwnerId              *wrappers.StringValue `protobuf:"bytes,4,opt,name=owner_id,proto3" json:"owner_id,omitempty"`
	Token                *wrappers.StringValue `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*LoginResponse) Descriptor 

func (*LoginResponse) Descriptor() ([]byte, []int)

func (*LoginResponse) GetName 

func (m *LoginResponse) GetName() *wrappers.StringValue

func (*LoginResponse) GetOwnerId 

func (m *LoginResponse) GetOwnerId() *wrappers.StringValue

func (*LoginResponse) GetRole 

func (m *LoginResponse) GetRole() *wrappers.StringValue

func (*LoginResponse) GetToken 

func (m *LoginResponse) GetToken() *wrappers.StringValue

func (*LoginResponse) GetUserId 

func (m *LoginResponse) GetUserId() *wrappers.StringValue

func (*LoginResponse) ProtoMessage 

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) Reset 

func (m *LoginResponse) Reset()

func (*LoginResponse) String 

func (m *LoginResponse) String() string

func (*LoginResponse) XXX_DiscardUnknown 

func (m *LoginResponse) XXX_DiscardUnknown()

func (*LoginResponse) XXX_Marshal 

func (m *LoginResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoginResponse) XXX_Merge 

func (dst *LoginResponse) XXX_Merge(src proto.Message)

func (*LoginResponse) XXX_Size 

func (m *LoginResponse) XXX_Size() int

func (*LoginResponse) XXX_Unmarshal 

func (m *LoginResponse) XXX_Unmarshal(b []byte) error

type MatchArgument 

type MatchArgument struct {
	Type MatchArgument_Type `protobuf:"varint,1,opt,name=type,proto3,enum=v1.MatchArgument_Type" json:"type,omitempty"`
	// header key or query key
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// header value or query value
	Value                *MatchString `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*MatchArgument) Descriptor 

func (*MatchArgument) Descriptor() ([]byte, []int)

func (*MatchArgument) GetKey 

func (m *MatchArgument) GetKey() string

func (*MatchArgument) GetType 

func (m *MatchArgument) GetType() MatchArgument_Type

func (*MatchArgument) GetValue 

func (m *MatchArgument) GetValue() *MatchString

func (*MatchArgument) ProtoMessage 

func (*MatchArgument) ProtoMessage()

func (*MatchArgument) Reset 

func (m *MatchArgument) Reset()

func (*MatchArgument) String 

func (m *MatchArgument) String() string

func (*MatchArgument) XXX_DiscardUnknown 

func (m *MatchArgument) XXX_DiscardUnknown()

func (*MatchArgument) XXX_Marshal 

func (m *MatchArgument) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MatchArgument) XXX_Merge 

func (dst *MatchArgument) XXX_Merge(src proto.Message)

func (*MatchArgument) XXX_Size 

func (m *MatchArgument) XXX_Size() int

func (*MatchArgument) XXX_Unmarshal 

func (m *MatchArgument) XXX_Unmarshal(b []byte) error

type MatchArgument_Type 

type MatchArgument_Type int32

label type for gateway request 

const (
	// custom arguments
	MatchArgument_CUSTOM MatchArgument_Type = 0
	// method, match the http post/get/put/delete or grpc method
	MatchArgument_METHOD MatchArgument_Type = 1
	// header, match the http header, dubbo attachment, grpc header
	MatchArgument_HEADER MatchArgument_Type = 2
	// query, match the http query, dubbo argument
	MatchArgument_QUERY MatchArgument_Type = 3
	// caller service
	MatchArgument_CALLER_SERVICE MatchArgument_Type = 4
	// caller host ip
	MatchArgument_CALLER_IP MatchArgument_Type = 5
)

func (MatchArgument_Type) EnumDescriptor 

func (MatchArgument_Type) EnumDescriptor() ([]byte, []int)

func (MatchArgument_Type) String 

func (x MatchArgument_Type) String() string

type MatchString 

type MatchString struct {
	Type                 MatchString_MatchStringType `protobuf:"varint,1,opt,name=type,proto3,enum=v1.MatchString_MatchStringType" json:"type,omitempty"`
	Value                *wrappers.StringValue       `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	ValueType            MatchString_ValueType       `protobuf:"varint,3,opt,name=value_type,json=valueType,proto3,enum=v1.MatchString_ValueType" json:"value_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*MatchString) Descriptor 

func (*MatchString) Descriptor() ([]byte, []int)

func (*MatchString) GetType 

func (m *MatchString) GetType() MatchString_MatchStringType

func (*MatchString) GetValue 

func (m *MatchString) GetValue() *wrappers.StringValue

func (*MatchString) GetValueType 

func (m *MatchString) GetValueType() MatchString_ValueType

func (*MatchString) ProtoMessage 

func (*MatchString) ProtoMessage()

func (*MatchString) Reset 

func (m *MatchString) Reset()

func (*MatchString) String 

func (m *MatchString) String() string

func (*MatchString) XXX_DiscardUnknown 

func (m *MatchString) XXX_DiscardUnknown()

func (*MatchString) XXX_Marshal 

func (m *MatchString) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MatchString) XXX_Merge 

func (dst *MatchString) XXX_Merge(src proto.Message)

func (*MatchString) XXX_Size 

func (m *MatchString) XXX_Size() int

func (*MatchString) XXX_Unmarshal 

func (m *MatchString) XXX_Unmarshal(b []byte) error

type MatchString_MatchStringType 

type MatchString_MatchStringType int32
const (
	// Equivalent match
	MatchString_EXACT MatchString_MatchStringType = 0
	// Regular match
	MatchString_REGEX MatchString_MatchStringType = 1
	// Not equals match
	MatchString_NOT_EQUALS MatchString_MatchStringType = 2
	// Include match
	MatchString_IN MatchString_MatchStringType = 3
	// Not include match
	MatchString_NOT_IN MatchString_MatchStringType = 4
)

func (MatchString_MatchStringType) EnumDescriptor 

func (MatchString_MatchStringType) EnumDescriptor() ([]byte, []int)

func (MatchString_MatchStringType) String 

func (x MatchString_MatchStringType) String() string

type MatchString_ValueType 

type MatchString_ValueType int32
const (
	MatchString_TEXT      MatchString_ValueType = 0
	MatchString_PARAMETER MatchString_ValueType = 1
	MatchString_VARIABLE  MatchString_ValueType = 2
)

func (MatchString_ValueType) EnumDescriptor 

func (MatchString_ValueType) EnumDescriptor() ([]byte, []int)

func (MatchString_ValueType) String 

func (x MatchString_ValueType) String() string

type ModifyAuthStrategy 

type ModifyAuthStrategy struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	AddPrincipals        *Principals           `protobuf:"bytes,3,opt,name=add_principals,proto3" json:"add_principals,omitempty"`
	RemovePrincipals     *Principals           `protobuf:"bytes,4,opt,name=remove_principals,proto3" json:"remove_principals,omitempty"`
	AddResources         *StrategyResources    `protobuf:"bytes,5,opt,name=add_resources,proto3" json:"add_resources,omitempty"`
	RemoveResources      *StrategyResources    `protobuf:"bytes,6,opt,name=remove_resources,proto3" json:"remove_resources,omitempty"`
	Action               AuthAction            `protobuf:"varint,7,opt,name=action,proto3,enum=v1.AuthAction" json:"action,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	Owner                *wrappers.StringValue `protobuf:"bytes,9,opt,name=owner,proto3" json:"owner,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ModifyAuthStrategy) Descriptor 

func (*ModifyAuthStrategy) Descriptor() ([]byte, []int)

func (*ModifyAuthStrategy) GetAction 

func (m *ModifyAuthStrategy) GetAction() AuthAction

func (*ModifyAuthStrategy) GetAddPrincipals 

func (m *ModifyAuthStrategy) GetAddPrincipals() *Principals

func (*ModifyAuthStrategy) GetAddResources 

func (m *ModifyAuthStrategy) GetAddResources() *StrategyResources

func (*ModifyAuthStrategy) GetComment 

func (m *ModifyAuthStrategy) GetComment() *wrappers.StringValue

func (*ModifyAuthStrategy) GetId 

func (m *ModifyAuthStrategy) GetId() *wrappers.StringValue

func (*ModifyAuthStrategy) GetName 

func (m *ModifyAuthStrategy) GetName() *wrappers.StringValue

func (*ModifyAuthStrategy) GetOwner 

func (m *ModifyAuthStrategy) GetOwner() *wrappers.StringValue

func (*ModifyAuthStrategy) GetRemovePrincipals 

func (m *ModifyAuthStrategy) GetRemovePrincipals() *Principals

func (*ModifyAuthStrategy) GetRemoveResources 

func (m *ModifyAuthStrategy) GetRemoveResources() *StrategyResources

func (*ModifyAuthStrategy) ProtoMessage 

func (*ModifyAuthStrategy) ProtoMessage()

func (*ModifyAuthStrategy) Reset 

func (m *ModifyAuthStrategy) Reset()

func (*ModifyAuthStrategy) String 

func (m *ModifyAuthStrategy) String() string

func (*ModifyAuthStrategy) XXX_DiscardUnknown 

func (m *ModifyAuthStrategy) XXX_DiscardUnknown()

func (*ModifyAuthStrategy) XXX_Marshal 

func (m *ModifyAuthStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyAuthStrategy) XXX_Merge 

func (dst *ModifyAuthStrategy) XXX_Merge(src proto.Message)

func (*ModifyAuthStrategy) XXX_Size 

func (m *ModifyAuthStrategy) XXX_Size() int

func (*ModifyAuthStrategy) XXX_Unmarshal 

func (m *ModifyAuthStrategy) XXX_Unmarshal(b []byte) error

type ModifyUserGroup 

type ModifyUserGroup struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Owner                *wrappers.StringValue `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	AuthToken            *wrappers.StringValue `protobuf:"bytes,4,opt,name=auth_token,proto3" json:"auth_token,omitempty"`
	TokenEnable          *wrappers.BoolValue   `protobuf:"bytes,5,opt,name=token_enable,proto3" json:"token_enable,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,6,opt,name=comment,proto3" json:"comment,omitempty"`
	AddRelations         *UserGroupRelation    `protobuf:"bytes,7,opt,name=add_relations,proto3" json:"add_relations,omitempty"`
	RemoveRelations      *UserGroupRelation    `protobuf:"bytes,8,opt,name=remove_relations,proto3" json:"remove_relations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ModifyUserGroup) Descriptor 

func (*ModifyUserGroup) Descriptor() ([]byte, []int)

func (*ModifyUserGroup) GetAddRelations 

func (m *ModifyUserGroup) GetAddRelations() *UserGroupRelation

func (*ModifyUserGroup) GetAuthToken 

func (m *ModifyUserGroup) GetAuthToken() *wrappers.StringValue

func (*ModifyUserGroup) GetComment 

func (m *ModifyUserGroup) GetComment() *wrappers.StringValue

func (*ModifyUserGroup) GetId 

func (m *ModifyUserGroup) GetId() *wrappers.StringValue

func (*ModifyUserGroup) GetName 

func (m *ModifyUserGroup) GetName() *wrappers.StringValue

func (*ModifyUserGroup) GetOwner 

func (m *ModifyUserGroup) GetOwner() *wrappers.StringValue

func (*ModifyUserGroup) GetRemoveRelations 

func (m *ModifyUserGroup) GetRemoveRelations() *UserGroupRelation

func (*ModifyUserGroup) GetTokenEnable 

func (m *ModifyUserGroup) GetTokenEnable() *wrappers.BoolValue

func (*ModifyUserGroup) ProtoMessage 

func (*ModifyUserGroup) ProtoMessage()

func (*ModifyUserGroup) Reset 

func (m *ModifyUserGroup) Reset()

func (*ModifyUserGroup) String 

func (m *ModifyUserGroup) String() string

func (*ModifyUserGroup) XXX_DiscardUnknown 

func (m *ModifyUserGroup) XXX_DiscardUnknown()

func (*ModifyUserGroup) XXX_Marshal 

func (m *ModifyUserGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyUserGroup) XXX_Merge 

func (dst *ModifyUserGroup) XXX_Merge(src proto.Message)

func (*ModifyUserGroup) XXX_Size 

func (m *ModifyUserGroup) XXX_Size() int

func (*ModifyUserGroup) XXX_Unmarshal 

func (m *ModifyUserGroup) XXX_Unmarshal(b []byte) error

type ModifyUserPassword 

type ModifyUserPassword struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OldPassword          *wrappers.StringValue `protobuf:"bytes,2,opt,name=old_password,proto3" json:"old_password,omitempty"`
	NewPassword          *wrappers.StringValue `protobuf:"bytes,3,opt,name=new_password,proto3" json:"new_password,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ModifyUserPassword) Descriptor 

func (*ModifyUserPassword) Descriptor() ([]byte, []int)

func (*ModifyUserPassword) GetId 

func (m *ModifyUserPassword) GetId() *wrappers.StringValue

func (*ModifyUserPassword) GetNewPassword 

func (m *ModifyUserPassword) GetNewPassword() *wrappers.StringValue

func (*ModifyUserPassword) GetOldPassword 

func (m *ModifyUserPassword) GetOldPassword() *wrappers.StringValue

func (*ModifyUserPassword) ProtoMessage 

func (*ModifyUserPassword) ProtoMessage()

func (*ModifyUserPassword) Reset 

func (m *ModifyUserPassword) Reset()

func (*ModifyUserPassword) String 

func (m *ModifyUserPassword) String() string

func (*ModifyUserPassword) XXX_DiscardUnknown 

func (m *ModifyUserPassword) XXX_DiscardUnknown()

func (*ModifyUserPassword) XXX_Marshal 

func (m *ModifyUserPassword) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModifyUserPassword) XXX_Merge 

func (dst *ModifyUserPassword) XXX_Merge(src proto.Message)

func (*ModifyUserPassword) XXX_Size 

func (m *ModifyUserPassword) XXX_Size() int

func (*ModifyUserPassword) XXX_Unmarshal 

func (m *ModifyUserPassword) XXX_Unmarshal(b []byte) error

type Namespace 

type Namespace struct {
	Name                     *wrappers.StringValue   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Comment                  *wrappers.StringValue   `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	Owners                   *wrappers.StringValue   `protobuf:"bytes,3,opt,name=owners,proto3" json:"owners,omitempty"`
	Token                    *wrappers.StringValue   `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	Ctime                    *wrappers.StringValue   `protobuf:"bytes,5,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                    *wrappers.StringValue   `protobuf:"bytes,6,opt,name=mtime,proto3" json:"mtime,omitempty"`
	TotalServiceCount        *wrappers.UInt32Value   `protobuf:"bytes,7,opt,name=total_service_count,proto3" json:"total_service_count,omitempty"`
	TotalHealthInstanceCount *wrappers.UInt32Value   `protobuf:"bytes,8,opt,name=total_health_instance_count,proto3" json:"total_health_instance_count,omitempty"`
	TotalInstanceCount       *wrappers.UInt32Value   `protobuf:"bytes,9,opt,name=total_instance_count,proto3" json:"total_instance_count,omitempty"`
	UserIds                  []*wrappers.StringValue `protobuf:"bytes,10,rep,name=user_ids,proto3" json:"user_ids,omitempty"`
	GroupIds                 []*wrappers.StringValue `protobuf:"bytes,11,rep,name=group_ids,proto3" json:"group_ids,omitempty"`
	RemoveUserIds            []*wrappers.StringValue `protobuf:"bytes,13,rep,name=remove_user_ids,proto3" json:"remove_user_ids,omitempty"`
	RemoveGroupIds           []*wrappers.StringValue `protobuf:"bytes,14,rep,name=remove_group_ids,proto3" json:"remove_group_ids,omitempty"`
	Id                       *wrappers.StringValue   `protobuf:"bytes,12,opt,name=id,proto3" json:"id,omitempty"`
	Editable                 *wrappers.BoolValue     `protobuf:"bytes,15,opt,name=editable,proto3" json:"editable,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}                `json:"-"`
	XXX_unrecognized         []byte                  `json:"-"`
	XXX_sizecache            int32                   `json:"-"`
}

func (*Namespace) Descriptor 

func (*Namespace) Descriptor() ([]byte, []int)

func (*Namespace) GetComment 

func (m *Namespace) GetComment() *wrappers.StringValue

func (*Namespace) GetCtime 

func (m *Namespace) GetCtime() *wrappers.StringValue

func (*Namespace) GetEditable 

func (m *Namespace) GetEditable() *wrappers.BoolValue

func (*Namespace) GetGroupIds 

func (m *Namespace) GetGroupIds() []*wrappers.StringValue

func (*Namespace) GetId 

func (m *Namespace) GetId() *wrappers.StringValue

func (*Namespace) GetMtime 

func (m *Namespace) GetMtime() *wrappers.StringValue

func (*Namespace) GetName 

func (m *Namespace) GetName() *wrappers.StringValue

func (*Namespace) GetOwners 

func (m *Namespace) GetOwners() *wrappers.StringValue

func (*Namespace) GetRemoveGroupIds 

func (m *Namespace) GetRemoveGroupIds() []*wrappers.StringValue

func (*Namespace) GetRemoveUserIds 

func (m *Namespace) GetRemoveUserIds() []*wrappers.StringValue

func (*Namespace) GetToken 

func (m *Namespace) GetToken() *wrappers.StringValue

func (*Namespace) GetTotalHealthInstanceCount 

func (m *Namespace) GetTotalHealthInstanceCount() *wrappers.UInt32Value

func (*Namespace) GetTotalInstanceCount 

func (m *Namespace) GetTotalInstanceCount() *wrappers.UInt32Value

func (*Namespace) GetTotalServiceCount 

func (m *Namespace) GetTotalServiceCount() *wrappers.UInt32Value

func (*Namespace) GetUserIds 

func (m *Namespace) GetUserIds() []*wrappers.StringValue

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) Reset 

func (m *Namespace) Reset()

func (*Namespace) String 

func (m *Namespace) String() string

func (*Namespace) XXX_DiscardUnknown 

func (m *Namespace) XXX_DiscardUnknown()

func (*Namespace) XXX_Marshal 

func (m *Namespace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Namespace) XXX_Merge 

func (dst *Namespace) XXX_Merge(src proto.Message)

func (*Namespace) XXX_Size 

func (m *Namespace) XXX_Size() int

func (*Namespace) XXX_Unmarshal 

func (m *Namespace) XXX_Unmarshal(b []byte) error

type OptionSwitch 

type OptionSwitch struct {
	Options              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*OptionSwitch) Descriptor 

func (*OptionSwitch) Descriptor() ([]byte, []int)

func (*OptionSwitch) GetOptions 

func (m *OptionSwitch) GetOptions() map[string]string

func (*OptionSwitch) ProtoMessage 

func (*OptionSwitch) ProtoMessage()

func (*OptionSwitch) Reset 

func (m *OptionSwitch) Reset()

func (*OptionSwitch) String 

func (m *OptionSwitch) String() string

func (*OptionSwitch) XXX_DiscardUnknown 

func (m *OptionSwitch) XXX_DiscardUnknown()

func (*OptionSwitch) XXX_Marshal 

func (m *OptionSwitch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OptionSwitch) XXX_Merge 

func (dst *OptionSwitch) XXX_Merge(src proto.Message)

func (*OptionSwitch) XXX_Size 

func (m *OptionSwitch) XXX_Size() int

func (*OptionSwitch) XXX_Unmarshal 

func (m *OptionSwitch) XXX_Unmarshal(b []byte) error

type Platform 

type Platform struct {
	// 平台ID，唯一标识
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 平台名称
	Name *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// 平台域名
	Domain *wrappers.StringValue `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// 调用频率
	Qps *wrappers.UInt32Value `protobuf:"bytes,4,opt,name=qps,proto3" json:"qps,omitempty"`
	// 平台token
	Token *wrappers.StringValue `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	// 负责人
	Owner *wrappers.StringValue `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"`
	// 部门
	Department *wrappers.StringValue `protobuf:"bytes,7,opt,name=department,proto3" json:"department,omitempty"`
	// 描述
	Comment *wrappers.StringValue `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	// 申请时间
	Ctime *wrappers.StringValue `protobuf:"bytes,9,opt,name=ctime,proto3" json:"ctime,omitempty"`
	// 修改时间
	Mtime                *wrappers.StringValue `protobuf:"bytes,10,opt,name=mtime,proto3" json:"mtime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Platform) Descriptor 

func (*Platform) Descriptor() ([]byte, []int)

func (*Platform) GetComment 

func (m *Platform) GetComment() *wrappers.StringValue

func (*Platform) GetCtime 

func (m *Platform) GetCtime() *wrappers.StringValue

func (*Platform) GetDepartment 

func (m *Platform) GetDepartment() *wrappers.StringValue

func (*Platform) GetDomain 

func (m *Platform) GetDomain() *wrappers.StringValue

func (*Platform) GetId 

func (m *Platform) GetId() *wrappers.StringValue

func (*Platform) GetMtime 

func (m *Platform) GetMtime() *wrappers.StringValue

func (*Platform) GetName 

func (m *Platform) GetName() *wrappers.StringValue

func (*Platform) GetOwner 

func (m *Platform) GetOwner() *wrappers.StringValue

func (*Platform) GetQps 

func (m *Platform) GetQps() *wrappers.UInt32Value

func (*Platform) GetToken 

func (m *Platform) GetToken() *wrappers.StringValue

func (*Platform) ProtoMessage 

func (*Platform) ProtoMessage()

func (*Platform) Reset 

func (m *Platform) Reset()

func (*Platform) String 

func (m *Platform) String() string

func (*Platform) XXX_DiscardUnknown 

func (m *Platform) XXX_DiscardUnknown()

func (*Platform) XXX_Marshal 

func (m *Platform) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Platform) XXX_Merge 

func (dst *Platform) XXX_Merge(src proto.Message)

func (*Platform) XXX_Size 

func (m *Platform) XXX_Size() int

func (*Platform) XXX_Unmarshal 

func (m *Platform) XXX_Unmarshal(b []byte) error

type PolarisConfigGRPCClient 

type PolarisConfigGRPCClient interface {
	// 拉取配置
	GetConfigFile(ctx context.Context, in *ClientConfigFileInfo, opts ...grpc.CallOption) (*ConfigClientResponse, error)
	// 订阅配置变更
	WatchConfigFiles(ctx context.Context, in *ClientWatchConfigFileRequest, opts ...grpc.CallOption) (*ConfigClientResponse, error)
}

PolarisConfigGRPCClient is the client API for PolarisConfigGRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPolarisConfigGRPCClient 

func NewPolarisConfigGRPCClient(cc *grpc.ClientConn) PolarisConfigGRPCClient

type PolarisConfigGRPCServer 

type PolarisConfigGRPCServer interface {
	// 拉取配置
	GetConfigFile(context.Context, *ClientConfigFileInfo) (*ConfigClientResponse, error)
	// 订阅配置变更
	WatchConfigFiles(context.Context, *ClientWatchConfigFileRequest) (*ConfigClientResponse, error)
}

PolarisConfigGRPCServer is the server API for PolarisConfigGRPC service.

type PolarisGRPCClient 

type PolarisGRPCClient interface {
	// 客户端上报
	ReportClient(ctx context.Context, in *Client, opts ...grpc.CallOption) (*Response, error)
	// 被调方注册服务实例
	RegisterInstance(ctx context.Context, in *Instance, opts ...grpc.CallOption) (*Response, error)
	// 被调方反注册服务实例
	DeregisterInstance(ctx context.Context, in *Instance, opts ...grpc.CallOption) (*Response, error)
	// 统一发现接口
	Discover(ctx context.Context, opts ...grpc.CallOption) (PolarisGRPC_DiscoverClient, error)
	// 被调方上报心跳
	Heartbeat(ctx context.Context, in *Instance, opts ...grpc.CallOption) (*Response, error)
}

PolarisGRPCClient is the client API for PolarisGRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPolarisGRPCClient 

func NewPolarisGRPCClient(cc *grpc.ClientConn) PolarisGRPCClient

type PolarisGRPCServer 

type PolarisGRPCServer interface {
	// 客户端上报
	ReportClient(context.Context, *Client) (*Response, error)
	// 被调方注册服务实例
	RegisterInstance(context.Context, *Instance) (*Response, error)
	// 被调方反注册服务实例
	DeregisterInstance(context.Context, *Instance) (*Response, error)
	// 统一发现接口
	Discover(PolarisGRPC_DiscoverServer) error
	// 被调方上报心跳
	Heartbeat(context.Context, *Instance) (*Response, error)
}

PolarisGRPCServer is the server API for PolarisGRPC service.

type PolarisGRPC_DiscoverClient 

type PolarisGRPC_DiscoverClient interface {
	Send(*DiscoverRequest) error
	Recv() (*DiscoverResponse, error)
	grpc.ClientStream
}

type PolarisGRPC_DiscoverServer 

type PolarisGRPC_DiscoverServer interface {
	Send(*DiscoverResponse) error
	Recv() (*DiscoverRequest, error)
	grpc.ServerStream
}

type Principal 

type Principal struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Principal) Descriptor 

func (*Principal) Descriptor() ([]byte, []int)

func (*Principal) GetId 

func (m *Principal) GetId() *wrappers.StringValue

func (*Principal) GetName 

func (m *Principal) GetName() *wrappers.StringValue

func (*Principal) ProtoMessage 

func (*Principal) ProtoMessage()

func (*Principal) Reset 

func (m *Principal) Reset()

func (*Principal) String 

func (m *Principal) String() string

func (*Principal) XXX_DiscardUnknown 

func (m *Principal) XXX_DiscardUnknown()

func (*Principal) XXX_Marshal 

func (m *Principal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Principal) XXX_Merge 

func (dst *Principal) XXX_Merge(src proto.Message)

func (*Principal) XXX_Size 

func (m *Principal) XXX_Size() int

func (*Principal) XXX_Unmarshal 

func (m *Principal) XXX_Unmarshal(b []byte) error

type Principals 

type Principals struct {
	Users                []*Principal `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	Groups               []*Principal `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Principals) Descriptor 

func (*Principals) Descriptor() ([]byte, []int)

func (*Principals) GetGroups 

func (m *Principals) GetGroups() []*Principal

func (*Principals) GetUsers 

func (m *Principals) GetUsers() []*Principal

func (*Principals) ProtoMessage 

func (*Principals) ProtoMessage()

func (*Principals) Reset 

func (m *Principals) Reset()

func (*Principals) String 

func (m *Principals) String() string

func (*Principals) XXX_DiscardUnknown 

func (m *Principals) XXX_DiscardUnknown()

func (*Principals) XXX_Marshal 

func (m *Principals) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Principals) XXX_Merge 

func (dst *Principals) XXX_Merge(src proto.Message)

func (*Principals) XXX_Size 

func (m *Principals) XXX_Size() int

func (*Principals) XXX_Unmarshal 

func (m *Principals) XXX_Unmarshal(b []byte) error

type RateLimit 

type RateLimit struct {
	// 限流规则集合
	Rules []*Rule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
	// 限流规则汇总的revision信息
	Revision             *wrappers.StringValue `protobuf:"bytes,2,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

同一服务下限流规则集合

func (*RateLimit) Descriptor 

func (*RateLimit) Descriptor() ([]byte, []int)

func (*RateLimit) GetRevision 

func (m *RateLimit) GetRevision() *wrappers.StringValue

func (*RateLimit) GetRules 

func (m *RateLimit) GetRules() []*Rule

func (*RateLimit) ProtoMessage 

func (*RateLimit) ProtoMessage()

func (*RateLimit) Reset 

func (m *RateLimit) Reset()

func (*RateLimit) String 

func (m *RateLimit) String() string

func (*RateLimit) XXX_DiscardUnknown 

func (m *RateLimit) XXX_DiscardUnknown()

func (*RateLimit) XXX_Marshal 

func (m *RateLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RateLimit) XXX_Merge 

func (dst *RateLimit) XXX_Merge(src proto.Message)

func (*RateLimit) XXX_Size 

func (m *RateLimit) XXX_Size() int

func (*RateLimit) XXX_Unmarshal 

func (m *RateLimit) XXX_Unmarshal(b []byte) error

type RateLimitCluster 

type RateLimitCluster struct {
	Service *wrappers.StringValue `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// 限流规则所属命名空间
	Namespace            *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

分布式限流服务集群

func (*RateLimitCluster) Descriptor 

func (*RateLimitCluster) Descriptor() ([]byte, []int)

func (*RateLimitCluster) GetNamespace 

func (m *RateLimitCluster) GetNamespace() *wrappers.StringValue

func (*RateLimitCluster) GetService 

func (m *RateLimitCluster) GetService() *wrappers.StringValue

func (*RateLimitCluster) ProtoMessage 

func (*RateLimitCluster) ProtoMessage()

func (*RateLimitCluster) Reset 

func (m *RateLimitCluster) Reset()

func (*RateLimitCluster) String 

func (m *RateLimitCluster) String() string

func (*RateLimitCluster) XXX_DiscardUnknown 

func (m *RateLimitCluster) XXX_DiscardUnknown()

func (*RateLimitCluster) XXX_Marshal 

func (m *RateLimitCluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RateLimitCluster) XXX_Merge 

func (dst *RateLimitCluster) XXX_Merge(src proto.Message)

func (*RateLimitCluster) XXX_Size 

func (m *RateLimitCluster) XXX_Size() int

func (*RateLimitCluster) XXX_Unmarshal 

func (m *RateLimitCluster) XXX_Unmarshal(b []byte) error

type RecoverConfig 

type RecoverConfig struct {
	// 触发熔断后到半开状态之间的等待间隔
	SleepWindow *duration.Duration `protobuf:"bytes,1,opt,name=sleepWindow,proto3" json:"sleepWindow,omitempty"`
	// 半开后，最多重试多少次恢复
	MaxRetryAfterHalfOpen *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=maxRetryAfterHalfOpen,proto3" json:"maxRetryAfterHalfOpen,omitempty"`
	// 半开后放量的最大百分比
	RequestRateAfterHalfOpen []*wrappers.UInt32Value `protobuf:"bytes,3,rep,name=requestRateAfterHalfOpen,proto3" json:"requestRateAfterHalfOpen,omitempty"`
	// 熔断器半开到关闭所必须的最少成功率，默认100%
	SuccessRateToClose *wrappers.UInt32Value `protobuf:"bytes,4,opt,name=successRateToClose,proto3" json:"successRateToClose,omitempty"`
	// 半开后最大放量数（用户不配置最大百分比时默认使用该配置）
	RequestCountAfterHalfOpen *wrappers.UInt32Value           `protobuf:"bytes,5,opt,name=requestCountAfterHalfOpen,proto3" json:"requestCountAfterHalfOpen,omitempty"`
	OutlierDetectWhen         RecoverConfig_OutlierDetectWhen `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}                        `json:"-"`
	XXX_unrecognized          []byte                          `json:"-"`
	XXX_sizecache             int32                           `json:"-"`
}

熔断恢复配置

func (*RecoverConfig) Descriptor 

func (*RecoverConfig) Descriptor() ([]byte, []int)

func (*RecoverConfig) GetMaxRetryAfterHalfOpen 

func (m *RecoverConfig) GetMaxRetryAfterHalfOpen() *wrappers.UInt32Value

func (*RecoverConfig) GetOutlierDetectWhen 

func (m *RecoverConfig) GetOutlierDetectWhen() RecoverConfig_OutlierDetectWhen

func (*RecoverConfig) GetRequestCountAfterHalfOpen 

func (m *RecoverConfig) GetRequestCountAfterHalfOpen() *wrappers.UInt32Value

func (*RecoverConfig) GetRequestRateAfterHalfOpen 

func (m *RecoverConfig) GetRequestRateAfterHalfOpen() []*wrappers.UInt32Value

func (*RecoverConfig) GetSleepWindow 

func (m *RecoverConfig) GetSleepWindow() *duration.Duration

func (*RecoverConfig) GetSuccessRateToClose 

func (m *RecoverConfig) GetSuccessRateToClose() *wrappers.UInt32Value

func (*RecoverConfig) ProtoMessage 

func (*RecoverConfig) ProtoMessage()

func (*RecoverConfig) Reset 

func (m *RecoverConfig) Reset()

func (*RecoverConfig) String 

func (m *RecoverConfig) String() string

func (*RecoverConfig) XXX_DiscardUnknown 

func (m *RecoverConfig) XXX_DiscardUnknown()

func (*RecoverConfig) XXX_Marshal 

func (m *RecoverConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecoverConfig) XXX_Merge 

func (dst *RecoverConfig) XXX_Merge(src proto.Message)

func (*RecoverConfig) XXX_Size 

func (m *RecoverConfig) XXX_Size() int

func (*RecoverConfig) XXX_Unmarshal 

func (m *RecoverConfig) XXX_Unmarshal(b []byte) error

type RecoverConfig_OutlierDetectWhen 

type RecoverConfig_OutlierDetectWhen int32

主动探测配置 

const (
	// 不开启监控探测
	RecoverConfig_NEVER RecoverConfig_OutlierDetectWhen = 0
	// 只有在熔断恢复时才开启健康探测
	RecoverConfig_ON_RECOVER RecoverConfig_OutlierDetectWhen = 1
	// 一直开启健康探测
	RecoverConfig_ALWAYS RecoverConfig_OutlierDetectWhen = 2
)

func (RecoverConfig_OutlierDetectWhen) EnumDescriptor 

func (RecoverConfig_OutlierDetectWhen) EnumDescriptor() ([]byte, []int)

func (RecoverConfig_OutlierDetectWhen) String 

func (x RecoverConfig_OutlierDetectWhen) String() string

type Report 

type Report struct {
	// 配额固定上报周期，单位毫秒
	Interval *duration.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"`
	// 使用了百分之多少配额后启动一次实时上报，值范围(0,100]
	AmountPercent        *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=amountPercent,proto3" json:"amountPercent,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

限流上报方式

func (*Report) Descriptor 

func (*Report) Descriptor() ([]byte, []int)

func (*Report) GetAmountPercent 

func (m *Report) GetAmountPercent() *wrappers.UInt32Value

func (*Report) GetInterval 

func (m *Report) GetInterval() *duration.Duration

func (*Report) ProtoMessage 

func (*Report) ProtoMessage()

func (*Report) Reset 

func (m *Report) Reset()

func (*Report) String 

func (m *Report) String() string

func (*Report) XXX_DiscardUnknown 

func (m *Report) XXX_DiscardUnknown()

func (*Report) XXX_Marshal 

func (m *Report) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Report) XXX_Merge 

func (dst *Report) XXX_Merge(src proto.Message)

func (*Report) XXX_Size 

func (m *Report) XXX_Size() int

func (*Report) XXX_Unmarshal 

func (m *Report) XXX_Unmarshal(b []byte) error

type ResourceType 

type ResourceType int32
const (
	ResourceType_Namespaces   ResourceType = 0
	ResourceType_Services     ResourceType = 1
	ResourceType_ConfigGroups ResourceType = 2
)

func (ResourceType) EnumDescriptor 

func (ResourceType) EnumDescriptor() ([]byte, []int)

func (ResourceType) String 

func (x ResourceType) String() string

type Response 

type Response struct {
	Code                 *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	Client               *Client               `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Namespace            *Namespace            `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Service              *Service              `protobuf:"bytes,5,opt,name=service,proto3" json:"service,omitempty"`
	Instance             *Instance             `protobuf:"bytes,6,opt,name=instance,proto3" json:"instance,omitempty"`
	Routing              *Routing              `protobuf:"bytes,7,opt,name=routing,proto3" json:"routing,omitempty"`
	Alias                *ServiceAlias         `protobuf:"bytes,8,opt,name=alias,proto3" json:"alias,omitempty"`
	RateLimit            *Rule                 `protobuf:"bytes,9,opt,name=rateLimit,proto3" json:"rateLimit,omitempty"`
	CircuitBreaker       *CircuitBreaker       `protobuf:"bytes,10,opt,name=circuitBreaker,proto3" json:"circuitBreaker,omitempty"`
	ConfigRelease        *ConfigRelease        `protobuf:"bytes,11,opt,name=configRelease,proto3" json:"configRelease,omitempty"`
	Platform             *Platform             `protobuf:"bytes,15,opt,name=platform,proto3" json:"platform,omitempty"`
	User                 *User                 `protobuf:"bytes,19,opt,name=user,proto3" json:"user,omitempty"`
	UserGroup            *UserGroup            `protobuf:"bytes,20,opt,name=userGroup,proto3" json:"userGroup,omitempty"`
	AuthStrategy         *AuthStrategy         `protobuf:"bytes,21,opt,name=authStrategy,proto3" json:"authStrategy,omitempty"`
	Relation             *UserGroupRelation    `protobuf:"bytes,22,opt,name=relation,proto3" json:"relation,omitempty"`
	LoginResponse        *LoginResponse        `protobuf:"bytes,23,opt,name=loginResponse,proto3" json:"loginResponse,omitempty"`
	ModifyAuthStrategy   *ModifyAuthStrategy   `protobuf:"bytes,24,opt,name=modifyAuthStrategy,proto3" json:"modifyAuthStrategy,omitempty"`
	ModifyUserGroup      *ModifyUserGroup      `protobuf:"bytes,25,opt,name=modifyUserGroup,proto3" json:"modifyUserGroup,omitempty"`
	Resources            *StrategyResources    `protobuf:"bytes,26,opt,name=resources,proto3" json:"resources,omitempty"`
	OptionSwitch         *OptionSwitch         `protobuf:"bytes,27,opt,name=optionSwitch,proto3" json:"optionSwitch,omitempty"`
	InstanceLabels       *InstanceLabels       `protobuf:"bytes,28,opt,name=instanceLabels,proto3" json:"instanceLabels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func NewAuthStrategyResponse 

func NewAuthStrategyResponse(code uint32, req *AuthStrategy) *Response

NewAuthStrategyResponse 创建鉴权策略响应体

func NewAuthStrategyResponseWithMsg 

func NewAuthStrategyResponseWithMsg(code uint32, msg string, req *AuthStrategy) *Response

NewAuthStrategyResponseWithMsg 创建鉴权策略响应体并自定义Info

func NewCircuitBreakerResponse 

func NewCircuitBreakerResponse(code uint32, circuitBreaker *CircuitBreaker) *Response

*

  • @brief 创建回复带熔断规则信息

func NewClientResponse 

func NewClientResponse(code uint32, client *Client) *Response

*

  • @brief 创建回复带客户端信息

func NewConfigResponse 

func NewConfigResponse(code uint32, configRelease *ConfigRelease) *Response

*

  • @brief 创建回复带发布信息

func NewGroupRelationResponse 

func NewGroupRelationResponse(code uint32, relation *UserGroupRelation) *Response

NewGroupRelationResponse 创建用户组关联关系的响应体

func NewGroupResponse 

func NewGroupResponse(code uint32, user *UserGroup) *Response

NewGroupResponse 创建回复带用户组信息

func NewInstanceRespWithError 

func NewInstanceRespWithError(code uint32, err error, instance *Instance) *Response

创建带自定义error的服务实例response

func NewInstanceResponse 

func NewInstanceResponse(code uint32, instance *Instance) *Response

*

  • @brief 创建回复带服务实例信息

func NewLoginResponse 

func NewLoginResponse(code uint32, loginResponse *LoginResponse) *Response

NewLoginResponse 创建登录响应体

func NewModifyAuthStrategyResponse 

func NewModifyAuthStrategyResponse(code uint32, req *ModifyAuthStrategy) *Response

NewModifyAuthStrategyResponse 创建修改鉴权策略响应体

func NewModifyGroupResponse 

func NewModifyGroupResponse(code uint32, group *ModifyUserGroup) *Response

NewModifyGroupResponse 创建修改用户组的响应信息

func NewNamespaceResponse 

func NewNamespaceResponse(code uint32, namespace *Namespace) *Response

*

  • @brief 创建回复带命名空间信息

func NewRateLimitResponse 

func NewRateLimitResponse(code uint32, rule *Rule) *Response

*

  • @brief 创建回复带限流规则信息

func NewResponse 

func NewResponse(code uint32) *Response

*

  • @brief 创建回复

func NewResponseWithMsg 

func NewResponseWithMsg(code uint32, msg string) *Response

带上具体的错误信息

func NewRoutingResponse 

func NewRoutingResponse(code uint32, routing *Routing) *Response

*

  • @brief 创建回复带服务路由信息

func NewServiceAliasResponse 

func NewServiceAliasResponse(code uint32, alias *ServiceAlias) *Response

创建带别名信息的答复

func NewServiceResponse 

func NewServiceResponse(code uint32, service *Service) *Response

*

  • @brief 创建回复带服务信息

func NewStrategyResourcesResponse 

func NewStrategyResourcesResponse(code uint32, ret *StrategyResources) *Response

NewStrategyResourcesResponse 创建修改鉴权策略响应体

func NewUserResponse 

func NewUserResponse(code uint32, user *User) *Response

NewUserResponse 创建回复带用户信息

func NewUserResponseWithMsg 

func NewUserResponseWithMsg(code uint32, info string, user *User) *Response

NewUserResponse 创建回复带用户信息

func (*Response) Descriptor 

func (*Response) Descriptor() ([]byte, []int)

func (*Response) GetAlias 

func (m *Response) GetAlias() *ServiceAlias

func (*Response) GetAuthStrategy 

func (m *Response) GetAuthStrategy() *AuthStrategy

func (*Response) GetCircuitBreaker 

func (m *Response) GetCircuitBreaker() *CircuitBreaker

func (*Response) GetClient 

func (m *Response) GetClient() *Client

func (*Response) GetCode 

func (m *Response) GetCode() *wrappers.UInt32Value

func (*Response) GetConfigRelease 

func (m *Response) GetConfigRelease() *ConfigRelease

func (*Response) GetInfo 

func (m *Response) GetInfo() *wrappers.StringValue

func (*Response) GetInstance 

func (m *Response) GetInstance() *Instance

func (*Response) GetInstanceLabels 

func (m *Response) GetInstanceLabels() *InstanceLabels

func (*Response) GetLoginResponse 

func (m *Response) GetLoginResponse() *LoginResponse

func (*Response) GetModifyAuthStrategy 

func (m *Response) GetModifyAuthStrategy() *ModifyAuthStrategy

func (*Response) GetModifyUserGroup 

func (m *Response) GetModifyUserGroup() *ModifyUserGroup

func (*Response) GetNamespace 

func (m *Response) GetNamespace() *Namespace

func (*Response) GetOptionSwitch 

func (m *Response) GetOptionSwitch() *OptionSwitch

func (*Response) GetPlatform 

func (m *Response) GetPlatform() *Platform

func (*Response) GetRateLimit 

func (m *Response) GetRateLimit() *Rule

func (*Response) GetRelation 

func (m *Response) GetRelation() *UserGroupRelation

func (*Response) GetResources 

func (m *Response) GetResources() *StrategyResources

func (*Response) GetRouting 

func (m *Response) GetRouting() *Routing

func (*Response) GetService 

func (m *Response) GetService() *Service

func (*Response) GetUser 

func (m *Response) GetUser() *User

func (*Response) GetUserGroup 

func (m *Response) GetUserGroup() *UserGroup

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (dst *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type ResponseMessage 

type ResponseMessage interface {
	proto.Message
	GetCode() *wrappers.UInt32Value
	GetInfo() *wrappers.StringValue
}

*

  • @brief 回复消息接口

type Route 

type Route struct {
	// 如果匹配Source规则，按照Destination路由
	// 多个Source之间的关系为或
	Sources      []*Source      `protobuf:"bytes,1,rep,name=sources,proto3" json:"sources,omitempty"`
	Destinations []*Destination `protobuf:"bytes,2,rep,name=destinations,proto3" json:"destinations,omitempty"`
	// extendInfo 用于承载一些额外信息
	// case 1: 升级到 v2 版本时，记录对应到 v2 版本的 id 信息
	ExtendInfo           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Route) Descriptor 

func (*Route) Descriptor() ([]byte, []int)

func (*Route) GetDestinations 

func (m *Route) GetDestinations() []*Destination

func (*Route) GetExtendInfo 

func (m *Route) GetExtendInfo() map[string]string

func (*Route) GetSources 

func (m *Route) GetSources() []*Source

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) Reset 

func (m *Route) Reset()

func (*Route) String 

func (m *Route) String() string

func (*Route) XXX_DiscardUnknown 

func (m *Route) XXX_DiscardUnknown()

func (*Route) XXX_Marshal 

func (m *Route) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Route) XXX_Merge 

func (dst *Route) XXX_Merge(src proto.Message)

func (*Route) XXX_Size 

func (m *Route) XXX_Size() int

func (*Route) XXX_Unmarshal 

func (m *Route) XXX_Unmarshal(b []byte) error

type Routing 

type Routing struct {
	// 规则所属服务以及命名空间
	Service   *wrappers.StringValue `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Namespace *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 每个服务可以配置多条入站或者出站规则
	// 对于每个请求，从上到下依次匹配，若命中则终止
	Inbounds             []*Route              `protobuf:"bytes,3,rep,name=inbounds,proto3" json:"inbounds,omitempty"`
	Outbounds            []*Route              `protobuf:"bytes,4,rep,name=outbounds,proto3" json:"outbounds,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,5,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,6,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Revision             *wrappers.StringValue `protobuf:"bytes,7,opt,name=revision,proto3" json:"revision,omitempty"`
	ServiceToken         *wrappers.StringValue `protobuf:"bytes,8,opt,name=service_token,proto3" json:"service_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Routing) Descriptor 

func (*Routing) Descriptor() ([]byte, []int)

func (*Routing) GetCtime 

func (m *Routing) GetCtime() *wrappers.StringValue

func (*Routing) GetInbounds 

func (m *Routing) GetInbounds() []*Route

func (*Routing) GetMtime 

func (m *Routing) GetMtime() *wrappers.StringValue

func (*Routing) GetNamespace 

func (m *Routing) GetNamespace() *wrappers.StringValue

func (*Routing) GetOutbounds 

func (m *Routing) GetOutbounds() []*Route

func (*Routing) GetRevision 

func (m *Routing) GetRevision() *wrappers.StringValue

func (*Routing) GetService 

func (m *Routing) GetService() *wrappers.StringValue

func (*Routing) GetServiceToken 

func (m *Routing) GetServiceToken() *wrappers.StringValue

func (*Routing) ProtoMessage 

func (*Routing) ProtoMessage()

func (*Routing) Reset 

func (m *Routing) Reset()

func (*Routing) String 

func (m *Routing) String() string

func (*Routing) XXX_DiscardUnknown 

func (m *Routing) XXX_DiscardUnknown()

func (*Routing) XXX_Marshal 

func (m *Routing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Routing) XXX_Merge 

func (dst *Routing) XXX_Merge(src proto.Message)

func (*Routing) XXX_Size 

func (m *Routing) XXX_Size() int

func (*Routing) XXX_Unmarshal 

func (m *Routing) XXX_Unmarshal(b []byte) error

type Rule 

type Rule struct {
	// 限流规则唯一标识
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 限流规则所属服务名
	Service *wrappers.StringValue `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// 限流规则所属命名空间
	Namespace *wrappers.StringValue `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 可选，SUBSET标识
	Subset map[string]*MatchString `` /* 153-byte string literal not displayed */
	// 限流规则优先级，0值最高
	Priority *wrappers.UInt32Value `protobuf:"bytes,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Resource Rule_Resource         `protobuf:"varint,6,opt,name=resource,proto3,enum=v1.Rule_Resource" json:"resource,omitempty"`
	Type     Rule_Type             `protobuf:"varint,7,opt,name=type,proto3,enum=v1.Rule_Type" json:"type,omitempty"`
	// 业务标签集合，通过KV进行匹配，全部匹配才使用该规则
	Labels map[string]*MatchString `` /* 153-byte string literal not displayed */
	// 限流阈值
	// 可以有多个粒度的配置（比如同时针对秒级，分钟级，天级），匹配一个则进行限流
	// 全局限流模式下，该值为服务配额总量；单机限流模式下，该值为单个节点能处理的配额量
	Amounts []*Amount `protobuf:"bytes,9,rep,name=amounts,proto3" json:"amounts,omitempty"`
	// 限流动作，对应着客户端的插件名字
	Action *wrappers.StringValue `protobuf:"bytes,10,opt,name=action,proto3" json:"action,omitempty"`
	// 是否停用该限流规则，默认启用
	Disable *wrappers.BoolValue `protobuf:"bytes,11,opt,name=disable,proto3" json:"disable,omitempty"`
	// 限流上报方式，同时支持按固定周期上报，以及达到配额百分比后上报
	Report *Report `protobuf:"bytes,12,opt,name=report,proto3" json:"report,omitempty"`
	// 限流规则创建时间
	Ctime *wrappers.StringValue `protobuf:"bytes,13,opt,name=ctime,proto3" json:"ctime,omitempty"`
	// 限流规则修改时间
	Mtime *wrappers.StringValue `protobuf:"bytes,14,opt,name=mtime,proto3" json:"mtime,omitempty"`
	// 限流规则revision信息
	Revision *wrappers.StringValue `protobuf:"bytes,15,opt,name=revision,proto3" json:"revision,omitempty"`
	// 服务的TOKEN信息，仅用于控制台，discover接口不下发
	ServiceToken *wrappers.StringValue `protobuf:"bytes,16,opt,name=service_token,proto3" json:"service_token,omitempty"`
	// 配额调整算法
	Adjuster *AmountAdjuster `protobuf:"bytes,17,opt,name=adjuster,proto3" json:"adjuster,omitempty"`
	// 通配符是否合并计算，默认分开计数
	RegexCombine *wrappers.BoolValue `protobuf:"bytes,18,opt,name=regex_combine,proto3" json:"regex_combine,omitempty"`
	AmountMode   Rule_AmountMode     `protobuf:"varint,19,opt,name=amount_mode,json=amountMode,proto3,enum=v1.Rule_AmountMode" json:"amount_mode,omitempty"`
	Failover     Rule_FailoverType   `protobuf:"varint,20,opt,name=failover,proto3,enum=v1.Rule_FailoverType" json:"failover,omitempty"`
	// 分布式限流服务集群
	Cluster *RateLimitCluster `protobuf:"bytes,21,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// 被调接口名
	Method *MatchString `protobuf:"bytes,22,opt,name=method,proto3" json:"method,omitempty"`
	// 被调的参数过滤条件，满足过滤条件才进入限流规则
	Arguments []*MatchArgument `protobuf:"bytes,23,rep,name=arguments,proto3" json:"arguments,omitempty"`
	// 限流规则名
	Name *wrappers.StringValue `protobuf:"bytes,24,opt,name=name,proto3" json:"name,omitempty"`
	// 限流规则启用时间
	Etime *wrappers.StringValue `protobuf:"bytes,25,opt,name=etime,proto3" json:"etime,omitempty"`
	// 最大排队时长，单位秒
	MaxQueueDelay        *wrappers.UInt32Value `protobuf:"bytes,26,opt,name=max_queue_delay,proto3" json:"max_queue_delay,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

单个限流规则信息

func (*Rule) Descriptor 

func (*Rule) Descriptor() ([]byte, []int)

func (*Rule) GetAction 

func (m *Rule) GetAction() *wrappers.StringValue

func (*Rule) GetAdjuster 

func (m *Rule) GetAdjuster() *AmountAdjuster

func (*Rule) GetAmountMode 

func (m *Rule) GetAmountMode() Rule_AmountMode

func (*Rule) GetAmounts 

func (m *Rule) GetAmounts() []*Amount

func (*Rule) GetArguments 

func (m *Rule) GetArguments() []*MatchArgument

func (*Rule) GetCluster 

func (m *Rule) GetCluster() *RateLimitCluster

func (*Rule) GetCtime 

func (m *Rule) GetCtime() *wrappers.StringValue

func (*Rule) GetDisable 

func (m *Rule) GetDisable() *wrappers.BoolValue

func (*Rule) GetEtime 

func (m *Rule) GetEtime() *wrappers.StringValue

func (*Rule) GetFailover 

func (m *Rule) GetFailover() Rule_FailoverType

func (*Rule) GetId 

func (m *Rule) GetId() *wrappers.StringValue

func (*Rule) GetLabels 

func (m *Rule) GetLabels() map[string]*MatchString

func (*Rule) GetMaxQueueDelay 

func (m *Rule) GetMaxQueueDelay() *wrappers.UInt32Value

func (*Rule) GetMethod 

func (m *Rule) GetMethod() *MatchString

func (*Rule) GetMtime 

func (m *Rule) GetMtime() *wrappers.StringValue

func (*Rule) GetName 

func (m *Rule) GetName() *wrappers.StringValue

func (*Rule) GetNamespace 

func (m *Rule) GetNamespace() *wrappers.StringValue

func (*Rule) GetPriority 

func (m *Rule) GetPriority() *wrappers.UInt32Value

func (*Rule) GetRegexCombine 

func (m *Rule) GetRegexCombine() *wrappers.BoolValue

func (*Rule) GetReport 

func (m *Rule) GetReport() *Report

func (*Rule) GetResource 

func (m *Rule) GetResource() Rule_Resource

func (*Rule) GetRevision 

func (m *Rule) GetRevision() *wrappers.StringValue

func (*Rule) GetService 

func (m *Rule) GetService() *wrappers.StringValue

func (*Rule) GetServiceToken 

func (m *Rule) GetServiceToken() *wrappers.StringValue

func (*Rule) GetSubset 

func (m *Rule) GetSubset() map[string]*MatchString

func (*Rule) GetType 

func (m *Rule) GetType() Rule_Type

func (*Rule) ProtoMessage 

func (*Rule) ProtoMessage()

func (*Rule) Reset 

func (m *Rule) Reset()

func (*Rule) String 

func (m *Rule) String() string

func (*Rule) XXX_DiscardUnknown 

func (m *Rule) XXX_DiscardUnknown()

func (*Rule) XXX_Marshal 

func (m *Rule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Rule) XXX_Merge 

func (dst *Rule) XXX_Merge(src proto.Message)

func (*Rule) XXX_Size 

func (m *Rule) XXX_Size() int

func (*Rule) XXX_Unmarshal 

func (m *Rule) XXX_Unmarshal(b []byte) error

type Rule_AmountMode 

type Rule_AmountMode int32

限流阈值模 

const (
	Rule_GLOBAL_TOTAL  Rule_AmountMode = 0
	Rule_SHARE_EQUALLY Rule_AmountMode = 1
)

func (Rule_AmountMode) EnumDescriptor 

func (Rule_AmountMode) EnumDescriptor() ([]byte, []int)

func (Rule_AmountMode) String 

func (x Rule_AmountMode) String() string

type Rule_FailoverType 

type Rule_FailoverType int32

与限流集群连接失败时降级模式 

const (
	Rule_FAILOVER_LOCAL Rule_FailoverType = 0
	Rule_FAILOVER_PASS  Rule_FailoverType = 1
)

func (Rule_FailoverType) EnumDescriptor 

func (Rule_FailoverType) EnumDescriptor() ([]byte, []int)

func (Rule_FailoverType) String 

func (x Rule_FailoverType) String() string

type Rule_Resource 

type Rule_Resource int32

限流资源 

const (
	// 针对QPS进行限流
	Rule_QPS Rule_Resource = 0
	// 针对并发数进行限流
	Rule_CONCURRENCY Rule_Resource = 1
)

func (Rule_Resource) EnumDescriptor 

func (Rule_Resource) EnumDescriptor() ([]byte, []int)

func (Rule_Resource) String 

func (x Rule_Resource) String() string

type Rule_Type 

type Rule_Type int32

限流类型 global全局限流(默认)或者local单机限流 

const (
	Rule_GLOBAL Rule_Type = 0
	Rule_LOCAL  Rule_Type = 1
)

func (Rule_Type) EnumDescriptor 

func (Rule_Type) EnumDescriptor() ([]byte, []int)

func (Rule_Type) String 

func (x Rule_Type) String() string

type Service 

type Service struct {
	Name                 *wrappers.StringValue   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            *wrappers.StringValue   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Metadata             map[string]string       `` /* 157-byte string literal not displayed */
	Ports                *wrappers.StringValue   `protobuf:"bytes,4,opt,name=ports,proto3" json:"ports,omitempty"`
	Business             *wrappers.StringValue   `protobuf:"bytes,5,opt,name=business,proto3" json:"business,omitempty"`
	Department           *wrappers.StringValue   `protobuf:"bytes,6,opt,name=department,proto3" json:"department,omitempty"`
	CmdbMod1             *wrappers.StringValue   `protobuf:"bytes,7,opt,name=cmdb_mod1,proto3" json:"cmdb_mod1,omitempty"`
	CmdbMod2             *wrappers.StringValue   `protobuf:"bytes,8,opt,name=cmdb_mod2,proto3" json:"cmdb_mod2,omitempty"`
	CmdbMod3             *wrappers.StringValue   `protobuf:"bytes,9,opt,name=cmdb_mod3,proto3" json:"cmdb_mod3,omitempty"`
	Comment              *wrappers.StringValue   `protobuf:"bytes,10,opt,name=comment,proto3" json:"comment,omitempty"`
	Owners               *wrappers.StringValue   `protobuf:"bytes,11,opt,name=owners,proto3" json:"owners,omitempty"`
	Token                *wrappers.StringValue   `protobuf:"bytes,12,opt,name=token,proto3" json:"token,omitempty"`
	Ctime                *wrappers.StringValue   `protobuf:"bytes,13,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue   `protobuf:"bytes,14,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Revision             *wrappers.StringValue   `protobuf:"bytes,15,opt,name=revision,proto3" json:"revision,omitempty"`
	PlatformId           *wrappers.StringValue   `protobuf:"bytes,16,opt,name=platform_id,proto3" json:"platform_id,omitempty"`
	TotalInstanceCount   *wrappers.UInt32Value   `protobuf:"bytes,17,opt,name=total_instance_count,proto3" json:"total_instance_count,omitempty"`
	HealthyInstanceCount *wrappers.UInt32Value   `protobuf:"bytes,18,opt,name=healthy_instance_count,proto3" json:"healthy_instance_count,omitempty"`
	UserIds              []*wrappers.StringValue `protobuf:"bytes,19,rep,name=user_ids,proto3" json:"user_ids,omitempty"`
	GroupIds             []*wrappers.StringValue `protobuf:"bytes,20,rep,name=group_ids,proto3" json:"group_ids,omitempty"`
	RemoveUserIds        []*wrappers.StringValue `protobuf:"bytes,22,rep,name=remove_user_ids,proto3" json:"remove_user_ids,omitempty"`
	RemoveGroupIds       []*wrappers.StringValue `protobuf:"bytes,23,rep,name=remove_group_ids,proto3" json:"remove_group_ids,omitempty"`
	Id                   *wrappers.StringValue   `protobuf:"bytes,21,opt,name=id,proto3" json:"id,omitempty"`
	Editable             *wrappers.BoolValue     `protobuf:"bytes,24,opt,name=editable,proto3" json:"editable,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*Service) Descriptor 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) GetBusiness 

func (m *Service) GetBusiness() *wrappers.StringValue

func (*Service) GetCmdbMod1 

func (m *Service) GetCmdbMod1() *wrappers.StringValue

func (*Service) GetCmdbMod2 

func (m *Service) GetCmdbMod2() *wrappers.StringValue

func (*Service) GetCmdbMod3 

func (m *Service) GetCmdbMod3() *wrappers.StringValue

func (*Service) GetComment 

func (m *Service) GetComment() *wrappers.StringValue

func (*Service) GetCtime 

func (m *Service) GetCtime() *wrappers.StringValue

func (*Service) GetDepartment 

func (m *Service) GetDepartment() *wrappers.StringValue

func (*Service) GetEditable 

func (m *Service) GetEditable() *wrappers.BoolValue

func (*Service) GetGroupIds 

func (m *Service) GetGroupIds() []*wrappers.StringValue

func (*Service) GetHealthyInstanceCount 

func (m *Service) GetHealthyInstanceCount() *wrappers.UInt32Value

func (*Service) GetId 

func (m *Service) GetId() *wrappers.StringValue

func (*Service) GetMetadata 

func (m *Service) GetMetadata() map[string]string

func (*Service) GetMtime 

func (m *Service) GetMtime() *wrappers.StringValue

func (*Service) GetName 

func (m *Service) GetName() *wrappers.StringValue

func (*Service) GetNamespace 

func (m *Service) GetNamespace() *wrappers.StringValue

func (*Service) GetOwners 

func (m *Service) GetOwners() *wrappers.StringValue

func (*Service) GetPlatformId 

func (m *Service) GetPlatformId() *wrappers.StringValue

func (*Service) GetPorts 

func (m *Service) GetPorts() *wrappers.StringValue

func (*Service) GetRemoveGroupIds 

func (m *Service) GetRemoveGroupIds() []*wrappers.StringValue

func (*Service) GetRemoveUserIds 

func (m *Service) GetRemoveUserIds() []*wrappers.StringValue

func (*Service) GetRevision 

func (m *Service) GetRevision() *wrappers.StringValue

func (*Service) GetToken 

func (m *Service) GetToken() *wrappers.StringValue

func (*Service) GetTotalInstanceCount 

func (m *Service) GetTotalInstanceCount() *wrappers.UInt32Value

func (*Service) GetUserIds 

func (m *Service) GetUserIds() []*wrappers.StringValue

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (dst *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type ServiceAlias 

type ServiceAlias struct {
	Service              *wrappers.StringValue `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Namespace            *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Alias                *wrappers.StringValue `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	AliasNamespace       *wrappers.StringValue `protobuf:"bytes,4,opt,name=alias_namespace,proto3" json:"alias_namespace,omitempty"`
	Type                 AliasType             `protobuf:"varint,5,opt,name=type,proto3,enum=v1.AliasType" json:"type,omitempty"`
	Owners               *wrappers.StringValue `protobuf:"bytes,6,opt,name=owners,proto3" json:"owners,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,7,opt,name=comment,proto3" json:"comment,omitempty"`
	ServiceToken         *wrappers.StringValue `protobuf:"bytes,8,opt,name=service_token,proto3" json:"service_token,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,9,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,10,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Id                   *wrappers.StringValue `protobuf:"bytes,11,opt,name=id,proto3" json:"id,omitempty"`
	Editable             *wrappers.BoolValue   `protobuf:"bytes,12,opt,name=editable,proto3" json:"editable,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ServiceAlias) Descriptor 

func (*ServiceAlias) Descriptor() ([]byte, []int)

func (*ServiceAlias) GetAlias 

func (m *ServiceAlias) GetAlias() *wrappers.StringValue

func (*ServiceAlias) GetAliasNamespace 

func (m *ServiceAlias) GetAliasNamespace() *wrappers.StringValue

func (*ServiceAlias) GetComment 

func (m *ServiceAlias) GetComment() *wrappers.StringValue

func (*ServiceAlias) GetCtime 

func (m *ServiceAlias) GetCtime() *wrappers.StringValue

func (*ServiceAlias) GetEditable 

func (m *ServiceAlias) GetEditable() *wrappers.BoolValue

func (*ServiceAlias) GetId 

func (m *ServiceAlias) GetId() *wrappers.StringValue

func (*ServiceAlias) GetMtime 

func (m *ServiceAlias) GetMtime() *wrappers.StringValue

func (*ServiceAlias) GetNamespace 

func (m *ServiceAlias) GetNamespace() *wrappers.StringValue

func (*ServiceAlias) GetOwners 

func (m *ServiceAlias) GetOwners() *wrappers.StringValue

func (*ServiceAlias) GetService 

func (m *ServiceAlias) GetService() *wrappers.StringValue

func (*ServiceAlias) GetServiceToken 

func (m *ServiceAlias) GetServiceToken() *wrappers.StringValue

func (*ServiceAlias) GetType 

func (m *ServiceAlias) GetType() AliasType

func (*ServiceAlias) ProtoMessage 

func (*ServiceAlias) ProtoMessage()

func (*ServiceAlias) Reset 

func (m *ServiceAlias) Reset()

func (*ServiceAlias) String 

func (m *ServiceAlias) String() string

func (*ServiceAlias) XXX_DiscardUnknown 

func (m *ServiceAlias) XXX_DiscardUnknown()

func (*ServiceAlias) XXX_Marshal 

func (m *ServiceAlias) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceAlias) XXX_Merge 

func (dst *ServiceAlias) XXX_Merge(src proto.Message)

func (*ServiceAlias) XXX_Size 

func (m *ServiceAlias) XXX_Size() int

func (*ServiceAlias) XXX_Unmarshal 

func (m *ServiceAlias) XXX_Unmarshal(b []byte) error

type SimpleResponse 

type SimpleResponse struct {
	Code                 *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Info                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func NewSimpleResponse 

func NewSimpleResponse(code uint32) *SimpleResponse

*

  • @brief 创建简单回复

func (*SimpleResponse) Descriptor 

func (*SimpleResponse) Descriptor() ([]byte, []int)

func (*SimpleResponse) GetCode 

func (m *SimpleResponse) GetCode() *wrappers.UInt32Value

func (*SimpleResponse) GetInfo 

func (m *SimpleResponse) GetInfo() *wrappers.StringValue

func (*SimpleResponse) ProtoMessage 

func (*SimpleResponse) ProtoMessage()

func (*SimpleResponse) Reset 

func (m *SimpleResponse) Reset()

func (*SimpleResponse) String 

func (m *SimpleResponse) String() string

func (*SimpleResponse) XXX_DiscardUnknown 

func (m *SimpleResponse) XXX_DiscardUnknown()

func (*SimpleResponse) XXX_Marshal 

func (m *SimpleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SimpleResponse) XXX_Merge 

func (dst *SimpleResponse) XXX_Merge(src proto.Message)

func (*SimpleResponse) XXX_Size 

func (m *SimpleResponse) XXX_Size() int

func (*SimpleResponse) XXX_Unmarshal 

func (m *SimpleResponse) XXX_Unmarshal(b []byte) error

type Source 

type Source struct {
	// 主调方服务以及命名空间
	Service   *wrappers.StringValue `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Namespace *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 主调方服务实例标签或者请求标签
	// value支持正则匹配
	Metadata             map[string]*MatchString `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*Source) Descriptor 

func (*Source) Descriptor() ([]byte, []int)

func (*Source) GetMetadata 

func (m *Source) GetMetadata() map[string]*MatchString

func (*Source) GetNamespace 

func (m *Source) GetNamespace() *wrappers.StringValue

func (*Source) GetService 

func (m *Source) GetService() *wrappers.StringValue

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) Reset 

func (m *Source) Reset()

func (*Source) String 

func (m *Source) String() string

func (*Source) XXX_DiscardUnknown 

func (m *Source) XXX_DiscardUnknown()

func (*Source) XXX_Marshal 

func (m *Source) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Source) XXX_Merge 

func (dst *Source) XXX_Merge(src proto.Message)

func (*Source) XXX_Size 

func (m *Source) XXX_Size() int

func (*Source) XXX_Unmarshal 

func (m *Source) XXX_Unmarshal(b []byte) error

type SourceMatcher 

type SourceMatcher struct {
	// 主调命名空间以及服务名，可以为*，代表全匹配
	Service   *wrappers.StringValue `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Namespace *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 可选，主调业务标签，用于匹配是否使用该熔断规则，可放置用户的接口信息等
	Labels               map[string]*MatchString `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

主调匹配规则

func (*SourceMatcher) Descriptor 

func (*SourceMatcher) Descriptor() ([]byte, []int)

func (*SourceMatcher) GetLabels 

func (m *SourceMatcher) GetLabels() map[string]*MatchString

func (*SourceMatcher) GetNamespace 

func (m *SourceMatcher) GetNamespace() *wrappers.StringValue

func (*SourceMatcher) GetService 

func (m *SourceMatcher) GetService() *wrappers.StringValue

func (*SourceMatcher) ProtoMessage 

func (*SourceMatcher) ProtoMessage()

func (*SourceMatcher) Reset 

func (m *SourceMatcher) Reset()

func (*SourceMatcher) String 

func (m *SourceMatcher) String() string

func (*SourceMatcher) XXX_DiscardUnknown 

func (m *SourceMatcher) XXX_DiscardUnknown()

func (*SourceMatcher) XXX_Marshal 

func (m *SourceMatcher) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SourceMatcher) XXX_Merge 

func (dst *SourceMatcher) XXX_Merge(src proto.Message)

func (*SourceMatcher) XXX_Size 

func (m *SourceMatcher) XXX_Size() int

func (*SourceMatcher) XXX_Unmarshal 

func (m *SourceMatcher) XXX_Unmarshal(b []byte) error

type StatInfo 

type StatInfo struct {
	Target               *wrappers.StringValue `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Port                 *wrappers.UInt32Value `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	Path                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Protocol             *wrappers.StringValue `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StatInfo) Descriptor 

func (*StatInfo) Descriptor() ([]byte, []int)

func (*StatInfo) GetPath 

func (m *StatInfo) GetPath() *wrappers.StringValue

func (*StatInfo) GetPort 

func (m *StatInfo) GetPort() *wrappers.UInt32Value

func (*StatInfo) GetProtocol 

func (m *StatInfo) GetProtocol() *wrappers.StringValue

func (*StatInfo) GetTarget 

func (m *StatInfo) GetTarget() *wrappers.StringValue

func (*StatInfo) ProtoMessage 

func (*StatInfo) ProtoMessage()

func (*StatInfo) Reset 

func (m *StatInfo) Reset()

func (*StatInfo) String 

func (m *StatInfo) String() string

func (*StatInfo) XXX_DiscardUnknown 

func (m *StatInfo) XXX_DiscardUnknown()

func (*StatInfo) XXX_Marshal 

func (m *StatInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatInfo) XXX_Merge 

func (dst *StatInfo) XXX_Merge(src proto.Message)

func (*StatInfo) XXX_Size 

func (m *StatInfo) XXX_Size() int

func (*StatInfo) XXX_Unmarshal 

func (m *StatInfo) XXX_Unmarshal(b []byte) error

type StrategyResourceEntry 

type StrategyResourceEntry struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Namespace            *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StrategyResourceEntry) Descriptor 

func (*StrategyResourceEntry) Descriptor() ([]byte, []int)

func (*StrategyResourceEntry) GetId 

func (m *StrategyResourceEntry) GetId() *wrappers.StringValue

func (*StrategyResourceEntry) GetName 

func (m *StrategyResourceEntry) GetName() *wrappers.StringValue

func (*StrategyResourceEntry) GetNamespace 

func (m *StrategyResourceEntry) GetNamespace() *wrappers.StringValue

func (*StrategyResourceEntry) ProtoMessage 

func (*StrategyResourceEntry) ProtoMessage()

func (*StrategyResourceEntry) Reset 

func (m *StrategyResourceEntry) Reset()

func (*StrategyResourceEntry) String 

func (m *StrategyResourceEntry) String() string

func (*StrategyResourceEntry) XXX_DiscardUnknown 

func (m *StrategyResourceEntry) XXX_DiscardUnknown()

func (*StrategyResourceEntry) XXX_Marshal 

func (m *StrategyResourceEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StrategyResourceEntry) XXX_Merge 

func (dst *StrategyResourceEntry) XXX_Merge(src proto.Message)

func (*StrategyResourceEntry) XXX_Size 

func (m *StrategyResourceEntry) XXX_Size() int

func (*StrategyResourceEntry) XXX_Unmarshal 

func (m *StrategyResourceEntry) XXX_Unmarshal(b []byte) error

type StrategyResources 

type StrategyResources struct {
	StrategyId           *wrappers.StringValue    `protobuf:"bytes,1,opt,name=strategy_id,proto3" json:"strategy_id,omitempty"`
	Namespaces           []*StrategyResourceEntry `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	Services             []*StrategyResourceEntry `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
	ConfigGroups         []*StrategyResourceEntry `protobuf:"bytes,4,rep,name=config_groups,proto3" json:"config_groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*StrategyResources) Descriptor 

func (*StrategyResources) Descriptor() ([]byte, []int)

func (*StrategyResources) GetConfigGroups 

func (m *StrategyResources) GetConfigGroups() []*StrategyResourceEntry

func (*StrategyResources) GetNamespaces 

func (m *StrategyResources) GetNamespaces() []*StrategyResourceEntry

func (*StrategyResources) GetServices 

func (m *StrategyResources) GetServices() []*StrategyResourceEntry

func (*StrategyResources) GetStrategyId 

func (m *StrategyResources) GetStrategyId() *wrappers.StringValue

func (*StrategyResources) ProtoMessage 

func (*StrategyResources) ProtoMessage()

func (*StrategyResources) Reset 

func (m *StrategyResources) Reset()

func (*StrategyResources) String 

func (m *StrategyResources) String() string

func (*StrategyResources) XXX_DiscardUnknown 

func (m *StrategyResources) XXX_DiscardUnknown()

func (*StrategyResources) XXX_Marshal 

func (m *StrategyResources) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StrategyResources) XXX_Merge 

func (dst *StrategyResources) XXX_Merge(src proto.Message)

func (*StrategyResources) XXX_Size 

func (m *StrategyResources) XXX_Size() int

func (*StrategyResources) XXX_Unmarshal 

func (m *StrategyResources) XXX_Unmarshal(b []byte) error

type StringList 

type StringList struct {
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringList) Descriptor 

func (*StringList) Descriptor() ([]byte, []int)

func (*StringList) GetValues 

func (m *StringList) GetValues() []string

func (*StringList) ProtoMessage 

func (*StringList) ProtoMessage()

func (*StringList) Reset 

func (m *StringList) Reset()

func (*StringList) String 

func (m *StringList) String() string

func (*StringList) XXX_DiscardUnknown 

func (m *StringList) XXX_DiscardUnknown()

func (*StringList) XXX_Marshal 

func (m *StringList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StringList) XXX_Merge 

func (dst *StringList) XXX_Merge(src proto.Message)

func (*StringList) XXX_Size 

func (m *StringList) XXX_Size() int

func (*StringList) XXX_Unmarshal 

func (m *StringList) XXX_Unmarshal(b []byte) error

type User 

type User struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Password             *wrappers.StringValue `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Owner                *wrappers.StringValue `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	Source               *wrappers.StringValue `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	AuthToken            *wrappers.StringValue `protobuf:"bytes,6,opt,name=auth_token,proto3" json:"auth_token,omitempty"`
	TokenEnable          *wrappers.BoolValue   `protobuf:"bytes,7,opt,name=token_enable,proto3" json:"token_enable,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,8,opt,name=comment,proto3" json:"comment,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,9,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,10,opt,name=mtime,proto3" json:"mtime,omitempty"`
	UserType             *wrappers.StringValue `protobuf:"bytes,11,opt,name=user_type,proto3" json:"user_type,omitempty"`
	Mobile               *wrappers.StringValue `protobuf:"bytes,12,opt,name=mobile,proto3" json:"mobile,omitempty"`
	Email                *wrappers.StringValue `protobuf:"bytes,13,opt,name=email,proto3" json:"email,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*User) Descriptor 

func (*User) Descriptor() ([]byte, []int)

func (*User) GetAuthToken 

func (m *User) GetAuthToken() *wrappers.StringValue

func (*User) GetComment 

func (m *User) GetComment() *wrappers.StringValue

func (*User) GetCtime 

func (m *User) GetCtime() *wrappers.StringValue

func (*User) GetEmail 

func (m *User) GetEmail() *wrappers.StringValue

func (*User) GetId 

func (m *User) GetId() *wrappers.StringValue

func (*User) GetMobile 

func (m *User) GetMobile() *wrappers.StringValue

func (*User) GetMtime 

func (m *User) GetMtime() *wrappers.StringValue

func (*User) GetName 

func (m *User) GetName() *wrappers.StringValue

func (*User) GetOwner 

func (m *User) GetOwner() *wrappers.StringValue

func (*User) GetPassword 

func (m *User) GetPassword() *wrappers.StringValue

func (*User) GetSource 

func (m *User) GetSource() *wrappers.StringValue

func (*User) GetTokenEnable 

func (m *User) GetTokenEnable() *wrappers.BoolValue

func (*User) GetUserType 

func (m *User) GetUserType() *wrappers.StringValue

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) Reset 

func (m *User) Reset()

func (*User) String 

func (m *User) String() string

func (*User) XXX_DiscardUnknown 

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal 

func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*User) XXX_Merge 

func (dst *User) XXX_Merge(src proto.Message)

func (*User) XXX_Size 

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal 

func (m *User) XXX_Unmarshal(b []byte) error

type UserGroup 

type UserGroup struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 *wrappers.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Owner                *wrappers.StringValue `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	AuthToken            *wrappers.StringValue `protobuf:"bytes,4,opt,name=auth_token,proto3" json:"auth_token,omitempty"`
	TokenEnable          *wrappers.BoolValue   `protobuf:"bytes,5,opt,name=token_enable,proto3" json:"token_enable,omitempty"`
	Comment              *wrappers.StringValue `protobuf:"bytes,6,opt,name=comment,proto3" json:"comment,omitempty"`
	Ctime                *wrappers.StringValue `protobuf:"bytes,7,opt,name=ctime,proto3" json:"ctime,omitempty"`
	Mtime                *wrappers.StringValue `protobuf:"bytes,8,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Relation             *UserGroupRelation    `protobuf:"bytes,9,opt,name=relation,proto3" json:"relation,omitempty"`
	UserCount            *wrappers.UInt32Value `protobuf:"bytes,10,opt,name=user_count,proto3" json:"user_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UserGroup) Descriptor 

func (*UserGroup) Descriptor() ([]byte, []int)

func (*UserGroup) GetAuthToken 

func (m *UserGroup) GetAuthToken() *wrappers.StringValue

func (*UserGroup) GetComment 

func (m *UserGroup) GetComment() *wrappers.StringValue

func (*UserGroup) GetCtime 

func (m *UserGroup) GetCtime() *wrappers.StringValue

func (*UserGroup) GetId 

func (m *UserGroup) GetId() *wrappers.StringValue

func (*UserGroup) GetMtime 

func (m *UserGroup) GetMtime() *wrappers.StringValue

func (*UserGroup) GetName 

func (m *UserGroup) GetName() *wrappers.StringValue

func (*UserGroup) GetOwner 

func (m *UserGroup) GetOwner() *wrappers.StringValue

func (*UserGroup) GetRelation 

func (m *UserGroup) GetRelation() *UserGroupRelation

func (*UserGroup) GetTokenEnable 

func (m *UserGroup) GetTokenEnable() *wrappers.BoolValue

func (*UserGroup) GetUserCount 

func (m *UserGroup) GetUserCount() *wrappers.UInt32Value

func (*UserGroup) ProtoMessage 

func (*UserGroup) ProtoMessage()

func (*UserGroup) Reset 

func (m *UserGroup) Reset()

func (*UserGroup) String 

func (m *UserGroup) String() string

func (*UserGroup) XXX_DiscardUnknown 

func (m *UserGroup) XXX_DiscardUnknown()

func (*UserGroup) XXX_Marshal 

func (m *UserGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserGroup) XXX_Merge 

func (dst *UserGroup) XXX_Merge(src proto.Message)

func (*UserGroup) XXX_Size 

func (m *UserGroup) XXX_Size() int

func (*UserGroup) XXX_Unmarshal 

func (m *UserGroup) XXX_Unmarshal(b []byte) error

type UserGroupRelation 

type UserGroupRelation struct {
	GroupId              *wrappers.StringValue `protobuf:"bytes,1,opt,name=group_id,proto3" json:"group_id,omitempty"`
	Users                []*User               `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UserGroupRelation) Descriptor 

func (*UserGroupRelation) Descriptor() ([]byte, []int)

func (*UserGroupRelation) GetGroupId 

func (m *UserGroupRelation) GetGroupId() *wrappers.StringValue

func (*UserGroupRelation) GetUsers 

func (m *UserGroupRelation) GetUsers() []*User

func (*UserGroupRelation) ProtoMessage 

func (*UserGroupRelation) ProtoMessage()

func (*UserGroupRelation) Reset 

func (m *UserGroupRelation) Reset()

func (*UserGroupRelation) String 

func (m *UserGroupRelation) String() string

func (*UserGroupRelation) XXX_DiscardUnknown 

func (m *UserGroupRelation) XXX_DiscardUnknown()

func (*UserGroupRelation) XXX_Marshal 

func (m *UserGroupRelation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserGroupRelation) XXX_Merge 

func (dst *UserGroupRelation) XXX_Merge(src proto.Message)

func (*UserGroupRelation) XXX_Size 

func (m *UserGroupRelation) XXX_Size() int

func (*UserGroupRelation) XXX_Unmarshal 

func (m *UserGroupRelation) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.