v1

package
v1.0.2 Latest Latest
Warning

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

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

Documentation

Overview

Package v1 is a generated protocol buffer package.

It is generated from these files: 

polaris_client.proto
polaris_grpcapi.proto
polaris_model.proto
polaris_ratelimitrule.proto
polaris_request.proto
polaris_response.proto
polaris_routing.proto
polaris_service.proto

It has these top-level messages: 

Client
Location
MatchString
RateLimit
Rule
Amount
Report
AmountAdjuster
ClimbConfig
DiscoverRequest
SimpleResponse
Response
BatchWriteResponse
BatchQueryResponse
DiscoverResponse
Routing
Route
Source
Destination
Namespace
Service
ServiceAlias
Instance
HealthCheck
HeartbeatHealthCheck

Index

Constants

View Source 
const (
	ExecuteSuccess              uint32 = 200000
	DataNoChange                       = 200001
	ParseException                     = 400001
	EmptyRequest                       = 400002
	BatchSizeOverLimit                 = 400003
	InvalidDiscoverResource            = 400004
	InvalidRequestID                   = 400100
	InvalidUserName                    = 400101
	InvalidUserToken                   = 400102
	InvalidParameter                   = 400103
	InvalidNamespaceName               = 400110
	InvalidNamespaceOwners             = 400111
	InvalidNamespaceToken              = 400112
	InvalidServiceName                 = 400120
	InvalidServiceOwners               = 400121
	InvalidServiceToken                = 400122
	InvalidInstanceID                  = 400130
	InvalidInstanceHost                = 400131
	InvalidInstancePort                = 400132
	InvalidServiceAlias                = 400133
	InvalidNamespaceWithAlias          = 400134
	HealthCheckNotOpen                 = 400140
	HeartbeatOnDisabledIns             = 400141
	HeartbeatExceedLimit               = 400142
	HeartbeatException                 = 400143
	InvalidMetadata                    = 400150
	NotFoundMeshConfig                 = 400177
	ExistedResource                    = 400201
	NotFoundResource                   = 400202
	NamespaceExistedServices           = 400203
	ServiceExistedInstances            = 400204
	ServiceExistedRoutings             = 400205
	NotFoundService                    = 400301
	NotFoundRouting                    = 400302
	NotFoundInstance                   = 400303
	NotFoundServiceAlias               = 400304
	NotFoundNamespace                  = 400305
	NotFoundSourceService              = 400306
	ClientAPINotOpen                   = 400401
	NotAllowAliasUpdate                = 400501
	NotAllowAliasCreateInstance        = 400502
	NotAllowAliasCreateRouting         = 400503
	NotAllowCreateAliasForAlias        = 400504
	Unauthorized                       = 401000
	IPRateLimit                        = 403001
	APIRateLimit                       = 403002
	CMDBNotFindHost                    = 404001
	ExecuteException                   = 500000
	StoreLayerException                = 500001
	CMDBPluginException                = 500002
	ParseRoutingException              = 500004
)

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 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 DiscoverRequest_DiscoverRequestType_name = map[int32]string{
	0: "UNKNOWN",
	1: "INSTANCE",
	2: "CLUSTER",
	3: "ROUTING",
	4: "RATE_LIMIT",
	6: "SERVICES",
	7: "MESH",
	8: "MESH_CONFIG",
}
View Source 
var DiscoverRequest_DiscoverRequestType_value = map[string]int32{
	"UNKNOWN":     0,
	"INSTANCE":    1,
	"CLUSTER":     2,
	"ROUTING":     3,
	"RATE_LIMIT":  4,
	"SERVICES":    6,
	"MESH":        7,
	"MESH_CONFIG": 8,
}
View Source 
var DiscoverResponse_DiscoverResponseType_name = map[int32]string{
	0: "UNKNOWN",
	1: "INSTANCE",
	2: "CLUSTER",
	3: "ROUTING",
	4: "RATE_LIMIT",
	6: "SERVICES",
	7: "MESH",
	8: "MESH_CONFIG",
}
View Source 
var DiscoverResponse_DiscoverResponseType_value = map[string]int32{
	"UNKNOWN":     0,
	"INSTANCE":    1,
	"CLUSTER":     2,
	"ROUTING":     3,
	"RATE_LIMIT":  4,
	"SERVICES":    6,
	"MESH":        7,
	"MESH_CONFIG": 8,
}
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 MatchString_MatchStringType_name = map[int32]string{
	0: "EXACT",
	1: "REGEX",
}
View Source 
var MatchString_MatchStringType_value = map[string]int32{
	"EXACT": 0,
	"REGEX": 1,
}
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 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 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 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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

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) GetCode 

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

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) 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) 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 (*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 Client 

type Client struct {
	Host     *google_protobuf.StringValue `protobuf:"bytes,1,opt,name=host" json:"host,omitempty"`
	Type     Client_ClientType            `protobuf:"varint,2,opt,name=type,enum=v1.Client_ClientType" json:"type,omitempty"`
	Version  *google_protobuf.StringValue `protobuf:"bytes,3,opt,name=version" json:"version,omitempty"`
	Location *Location                    `protobuf:"bytes,4,opt,name=location" json:"location,omitempty"`
}

func (*Client) Descriptor 

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

func (*Client) GetHost 

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

func (*Client) GetLocation 

func (m *Client) GetLocation() *Location

func (*Client) GetType 

func (m *Client) GetType() Client_ClientType

func (*Client) GetVersion 

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

func (*Client) ProtoMessage 

func (*Client) ProtoMessage()

func (*Client) Reset 

func (m *Client) Reset()

func (*Client) String 

func (m *Client) String() string

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 Destination 

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

func (*Destination) Descriptor 

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

func (*Destination) GetMetadata 

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

func (*Destination) GetNamespace 

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

func (*Destination) GetPriority 

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

func (*Destination) GetService 

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

func (*Destination) GetTransfer 

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

func (*Destination) GetWeight 

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

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) Reset 

func (m *Destination) Reset()

func (*Destination) String 

func (m *Destination) 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"`
	Mesh                 *Mesh                               `protobuf:"bytes,3,opt,name=mesh,proto3" json:"mesh,omitempty"`
	MeshConfig           *MeshConfig                         `protobuf:"bytes,4,opt,name=meshConfig,proto3" json:"meshConfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*DiscoverRequest) Descriptor 

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

func (*DiscoverRequest) GetMesh 

func (m *DiscoverRequest) GetMesh() *Mesh

func (*DiscoverRequest) GetMeshConfig 

func (m *DiscoverRequest) GetMeshConfig() *MeshConfig

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_SERVICES    DiscoverRequest_DiscoverRequestType = 6
	DiscoverRequest_MESH        DiscoverRequest_DiscoverRequestType = 7
	DiscoverRequest_MESH_CONFIG DiscoverRequest_DiscoverRequestType = 8
)

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"`
	Services             []*Service                            `protobuf:"bytes,9,rep,name=services,proto3" json:"services,omitempty"`
	Mesh                 *Mesh                                 `protobuf:"bytes,10,opt,name=mesh,proto3" json:"mesh,omitempty"`
	Meshconfig           *MeshConfig                           `protobuf:"bytes,11,opt,name=meshconfig,proto3" json:"meshconfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*DiscoverResponse) Descriptor 

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

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) GetMesh 

func (m *DiscoverResponse) GetMesh() *Mesh

func (*DiscoverResponse) GetMeshconfig 

func (m *DiscoverResponse) GetMeshconfig() *MeshConfig

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_SERVICES    DiscoverResponse_DiscoverResponseType = 6
	DiscoverResponse_MESH        DiscoverResponse_DiscoverResponseType = 7
	DiscoverResponse_MESH_CONFIG DiscoverResponse_DiscoverResponseType = 8
)

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,enum=v1.HealthCheck_HealthCheckType" json:"type,omitempty"`
	Heartbeat *HeartbeatHealthCheck       `protobuf:"bytes,2,opt,name=heartbeat" json:"heartbeat,omitempty"`
}

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

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 *google_protobuf.UInt32Value `protobuf:"bytes,1,opt,name=ttl" json:"ttl,omitempty"`
}

func (*HeartbeatHealthCheck) Descriptor 

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

func (*HeartbeatHealthCheck) GetTtl 

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

func (*HeartbeatHealthCheck) ProtoMessage 

func (*HeartbeatHealthCheck) ProtoMessage()

func (*HeartbeatHealthCheck) Reset 

func (m *HeartbeatHealthCheck) Reset()

func (*HeartbeatHealthCheck) String 

func (m *HeartbeatHealthCheck) String() string

type Instance 

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

func (*Instance) Descriptor 

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

func (*Instance) GetCtime 

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

func (*Instance) GetEnableHealthCheck 

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

func (*Instance) GetHealthCheck 

func (m *Instance) GetHealthCheck() *HealthCheck

func (*Instance) GetHealthy 

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

func (*Instance) GetHost 

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

func (*Instance) GetId 

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

func (*Instance) GetIsolate 

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

func (*Instance) GetLocation 

func (m *Instance) GetLocation() *Location

func (*Instance) GetLogicSet 

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

func (*Instance) GetMetadata 

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

func (*Instance) GetMtime 

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

func (*Instance) GetNamespace 

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

func (*Instance) GetPort 

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

func (*Instance) GetPriority 

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

func (*Instance) GetProtocol 

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

func (*Instance) GetRevision 

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

func (*Instance) GetService 

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

func (*Instance) GetServiceToken 

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

func (*Instance) GetVersion 

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

func (*Instance) GetVpcId 

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

func (*Instance) GetWeight 

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

func (*Instance) ProtoMessage 

func (*Instance) ProtoMessage()

func (*Instance) Reset 

func (m *Instance) Reset()

func (*Instance) String 

func (m *Instance) String() string

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 (m *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 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 (m *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 (
	MatchString_EXACT MatchString_MatchStringType = 0
	MatchString_REGEX MatchString_MatchStringType = 1
)

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 Mesh 

type Mesh 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"`
	// 网格所属业务
	Business *wrappers.StringValue `protobuf:"bytes,3,opt,name=business,proto3" json:"business,omitempty"`
	// 网格所属部门
	Department *wrappers.StringValue `protobuf:"bytes,4,opt,name=department,proto3" json:"department,omitempty"`
	// 网格版本号
	Revision *wrappers.StringValue `protobuf:"bytes,5,opt,name=revision,proto3" json:"revision,omitempty"`
	// 网格token
	Token *wrappers.StringValue `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	// 网格属主
	Owners *wrappers.StringValue `protobuf:"bytes,7,opt,name=owners,proto3" json:"owners,omitempty"`
	// 是否为托管网格
	Managed *wrappers.BoolValue `protobuf:"bytes,8,opt,name=managed,proto3" json:"managed,omitempty"`
	// istio的版本
	IstioVersion *wrappers.StringValue `protobuf:"bytes,9,opt,name=istio_version,proto3" json:"istio_version,omitempty"`
	// 该网格的数据面集群
	DataCluster *wrappers.StringValue `protobuf:"bytes,10,opt,name=data_cluster,proto3" json:"data_cluster,omitempty"`
	// 网格订阅的服务
	Services []*MeshService `protobuf:"bytes,11,rep,name=services,proto3" json:"services,omitempty"`
	// 网格描述
	Comment *wrappers.StringValue `protobuf:"bytes,12,opt,name=comment,proto3" json:"comment,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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Mesh) Descriptor 

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

func (*Mesh) GetBusiness 

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

func (*Mesh) GetComment 

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

func (*Mesh) GetCtime 

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

func (*Mesh) GetDataCluster 

func (m *Mesh) GetDataCluster() *wrappers.StringValue

func (*Mesh) GetDepartment 

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

func (*Mesh) GetId 

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

func (*Mesh) GetIstioVersion 

func (m *Mesh) GetIstioVersion() *wrappers.StringValue

func (*Mesh) GetManaged 

func (m *Mesh) GetManaged() *wrappers.BoolValue

func (*Mesh) GetMtime 

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

func (*Mesh) GetName 

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

func (*Mesh) GetOwners 

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

func (*Mesh) GetRevision 

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

func (*Mesh) GetServices 

func (m *Mesh) GetServices() []*MeshService

func (*Mesh) GetToken 

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

func (*Mesh) ProtoMessage 

func (*Mesh) ProtoMessage()

func (*Mesh) Reset 

func (m *Mesh) Reset()

func (*Mesh) String 

func (m *Mesh) String() string

func (*Mesh) XXX_DiscardUnknown 

func (m *Mesh) XXX_DiscardUnknown()

func (*Mesh) XXX_Marshal 

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

func (*Mesh) XXX_Merge 

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

func (*Mesh) XXX_Size 

func (m *Mesh) XXX_Size() int

func (*Mesh) XXX_Unmarshal 

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

type MeshConfig 

type MeshConfig struct {
	// 所属网格ID
	MeshId *wrappers.StringValue `protobuf:"bytes,1,opt,name=mesh_id,proto3" json:"mesh_id,omitempty"`
	// 所属网格名字
	MeshName *wrappers.StringValue `protobuf:"bytes,2,opt,name=mesh_name,proto3" json:"mesh_name,omitempty"`
	// 请求的配置类型
	TypeUrl *wrappers.StringValue `protobuf:"bytes,3,opt,name=type_url,proto3" json:"type_url,omitempty"`
	// 具体的各个网格规则
	Resources []*MeshResource `protobuf:"bytes,4,rep,name=resources,proto3" json:"resources,omitempty"`
	// 总体的修订版本号
	Revision             *wrappers.StringValue `protobuf:"bytes,5,opt,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*MeshConfig) Descriptor 

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

func (*MeshConfig) GetMeshId 

func (m *MeshConfig) GetMeshId() *wrappers.StringValue

func (*MeshConfig) GetMeshName 

func (m *MeshConfig) GetMeshName() *wrappers.StringValue

func (*MeshConfig) GetResources 

func (m *MeshConfig) GetResources() []*MeshResource

func (*MeshConfig) GetRevision 

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

func (*MeshConfig) GetTypeUrl 

func (m *MeshConfig) GetTypeUrl() *wrappers.StringValue

func (*MeshConfig) ProtoMessage 

func (*MeshConfig) ProtoMessage()

func (*MeshConfig) Reset 

func (m *MeshConfig) Reset()

func (*MeshConfig) String 

func (m *MeshConfig) String() string

func (*MeshConfig) XXX_DiscardUnknown 

func (m *MeshConfig) XXX_DiscardUnknown()

func (*MeshConfig) XXX_Marshal 

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

func (*MeshConfig) XXX_Merge 

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

func (*MeshConfig) XXX_Size 

func (m *MeshConfig) XXX_Size() int

func (*MeshConfig) XXX_Unmarshal 

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

type MeshResource 

type MeshResource struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 所属网格ID
	MeshId *wrappers.StringValue `protobuf:"bytes,2,opt,name=mesh_id,proto3" json:"mesh_id,omitempty"`
	// 所属网格名字
	MeshName *wrappers.StringValue `protobuf:"bytes,3,opt,name=mesh_name,proto3" json:"mesh_name,omitempty"`
	// 所属网格命名空间
	MeshNamespace *wrappers.StringValue `protobuf:"bytes,4,opt,name=mesh_namespace,proto3" json:"mesh_namespace,omitempty"`
	// 网格规则的类型
	TypeUrl *wrappers.StringValue `protobuf:"bytes,5,opt,name=type_url,proto3" json:"type_url,omitempty"`
	// 网格规则名字
	Name *wrappers.StringValue `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// 网格规则修订号
	Revision *wrappers.StringValue `protobuf:"bytes,7,opt,name=revision,proto3" json:"revision,omitempty"`
	// 网格规则的内容
	Body *wrappers.StringValue `protobuf:"bytes,8,opt,name=body,proto3" json:"body,omitempty"`
	// 所属网格的token
	MeshToken *wrappers.StringValue `protobuf:"bytes,9,opt,name=mesh_token,proto3" json:"mesh_token,omitempty"`
	// 规则创建时间
	Ctime *wrappers.StringValue `protobuf:"bytes,10,opt,name=ctime,proto3" json:"ctime,omitempty"`
	// 规则修改时间
	Mtime                *wrappers.StringValue `protobuf:"bytes,11,opt,name=mtime,proto3" json:"mtime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*MeshResource) Descriptor 

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

func (*MeshResource) GetBody 

func (m *MeshResource) GetBody() *wrappers.StringValue

func (*MeshResource) GetCtime 

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

func (*MeshResource) GetId 

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

func (*MeshResource) GetMeshId 

func (m *MeshResource) GetMeshId() *wrappers.StringValue

func (*MeshResource) GetMeshName 

func (m *MeshResource) GetMeshName() *wrappers.StringValue

func (*MeshResource) GetMeshNamespace 

func (m *MeshResource) GetMeshNamespace() *wrappers.StringValue

func (*MeshResource) GetMeshToken 

func (m *MeshResource) GetMeshToken() *wrappers.StringValue

func (*MeshResource) GetMtime 

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

func (*MeshResource) GetName 

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

func (*MeshResource) GetRevision 

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

func (*MeshResource) GetTypeUrl 

func (m *MeshResource) GetTypeUrl() *wrappers.StringValue

func (*MeshResource) ProtoMessage 

func (*MeshResource) ProtoMessage()

func (*MeshResource) Reset 

func (m *MeshResource) Reset()

func (*MeshResource) String 

func (m *MeshResource) String() string

func (*MeshResource) XXX_DiscardUnknown 

func (m *MeshResource) XXX_DiscardUnknown()

func (*MeshResource) XXX_Marshal 

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

func (*MeshResource) XXX_Merge 

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

func (*MeshResource) XXX_Size 

func (m *MeshResource) XXX_Size() int

func (*MeshResource) XXX_Unmarshal 

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

type MeshService 

type MeshService struct {
	Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// 所属网格ID
	MeshId *wrappers.StringValue `protobuf:"bytes,2,opt,name=mesh_id,proto3" json:"mesh_id,omitempty"`
	// 所属网格名字
	MeshName *wrappers.StringValue `protobuf:"bytes,3,opt,name=mesh_name,proto3" json:"mesh_name,omitempty"`
	// 所属网格token
	MeshToken *wrappers.StringValue `protobuf:"bytes,4,opt,name=mesh_token,proto3" json:"mesh_token,omitempty"`
	// 在北极星上面的服务的ID
	ServiceId *wrappers.StringValue `protobuf:"bytes,5,opt,name=service_id,proto3" json:"service_id,omitempty"`
	// 在北极星上面的服务名
	Service *wrappers.StringValue `protobuf:"bytes,6,opt,name=service,proto3" json:"service,omitempty"`
	// 在北极星上面的命名空间
	Namespace *wrappers.StringValue `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// 服务的部门
	Department *wrappers.StringValue `protobuf:"bytes,8,opt,name=department,proto3" json:"department,omitempty"`
	// 服务的业务
	Business *wrappers.StringValue `protobuf:"bytes,9,opt,name=business,proto3" json:"business,omitempty"`
	// 服务负责人
	Owners *wrappers.StringValue `protobuf:"bytes,10,opt,name=owners,proto3" json:"owners,omitempty"`
	// 在服务网格里面的命名空间
	MeshNamespace *wrappers.StringValue `protobuf:"bytes,11,opt,name=mesh_namespace,proto3" json:"mesh_namespace,omitempty"`
	// 在服务网格里面的服务名
	MeshService *wrappers.StringValue `protobuf:"bytes,12,opt,name=mesh_service,proto3" json:"mesh_service,omitempty"`
	// 是网格内部还是外部服务
	Location *wrappers.StringValue `protobuf:"bytes,13,opt,name=location,proto3" json:"location,omitempty"`
	// 可以被网格的哪些命名空间看到
	ExportTo *wrappers.StringValue `protobuf:"bytes,14,opt,name=export_to,proto3" json:"export_to,omitempty"`
	// 网格服务的revision
	Revision *wrappers.StringValue `protobuf:"bytes,15,opt,name=revision,proto3" json:"revision,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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*MeshService) Descriptor 

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

func (*MeshService) GetBusiness 

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

func (*MeshService) GetCtime 

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

func (*MeshService) GetDepartment 

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

func (*MeshService) GetExportTo 

func (m *MeshService) GetExportTo() *wrappers.StringValue

func (*MeshService) GetId 

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

func (*MeshService) GetLocation 

func (m *MeshService) GetLocation() *wrappers.StringValue

func (*MeshService) GetMeshId 

func (m *MeshService) GetMeshId() *wrappers.StringValue

func (*MeshService) GetMeshName 

func (m *MeshService) GetMeshName() *wrappers.StringValue

func (*MeshService) GetMeshNamespace 

func (m *MeshService) GetMeshNamespace() *wrappers.StringValue

func (*MeshService) GetMeshService 

func (m *MeshService) GetMeshService() *wrappers.StringValue

func (*MeshService) GetMeshToken 

func (m *MeshService) GetMeshToken() *wrappers.StringValue

func (*MeshService) GetMtime 

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

func (*MeshService) GetNamespace 

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

func (*MeshService) GetOwners 

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

func (*MeshService) GetRevision 

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

func (*MeshService) GetService 

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

func (*MeshService) GetServiceId 

func (m *MeshService) GetServiceId() *wrappers.StringValue

func (*MeshService) ProtoMessage 

func (*MeshService) ProtoMessage()

func (*MeshService) Reset 

func (m *MeshService) Reset()

func (*MeshService) String 

func (m *MeshService) String() string

func (*MeshService) XXX_DiscardUnknown 

func (m *MeshService) XXX_DiscardUnknown()

func (*MeshService) XXX_Marshal 

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

func (*MeshService) XXX_Merge 

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

func (*MeshService) XXX_Size 

func (m *MeshService) XXX_Size() int

func (*MeshService) XXX_Unmarshal 

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

type Namespace 

type Namespace struct {
	Name    *google_protobuf.StringValue `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Comment *google_protobuf.StringValue `protobuf:"bytes,2,opt,name=comment" json:"comment,omitempty"`
	Owners  *google_protobuf.StringValue `protobuf:"bytes,3,opt,name=owners" json:"owners,omitempty"`
	Token   *google_protobuf.StringValue `protobuf:"bytes,4,opt,name=token" json:"token,omitempty"`
	Ctime   *google_protobuf.StringValue `protobuf:"bytes,5,opt,name=ctime" json:"ctime,omitempty"`
	Mtime   *google_protobuf.StringValue `protobuf:"bytes,6,opt,name=mtime" json:"mtime,omitempty"`
}

func (*Namespace) Descriptor 

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

func (*Namespace) GetComment 

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

func (*Namespace) GetCtime 

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

func (*Namespace) GetMtime 

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

func (*Namespace) GetName 

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

func (*Namespace) GetOwners 

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

func (*Namespace) GetToken 

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

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) Reset 

func (m *Namespace) Reset()

func (*Namespace) String 

func (m *Namespace) String() string

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)
}

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)
}

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 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 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 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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetAlias 

func (m *Response) GetAlias() *ServiceAlias

func (*Response) GetClient 

func (m *Response) GetClient() *Client

func (*Response) GetCode 

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

func (*Response) GetInfo 

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

func (*Response) GetInstance 

func (m *Response) GetInstance() *Instance

func (*Response) GetNamespace 

func (m *Response) GetNamespace() *Namespace

func (*Response) GetRateLimit 

func (m *Response) GetRateLimit() *Rule

func (*Response) GetRouting 

func (m *Response) GetRouting() *Routing

func (*Response) GetService 

func (m *Response) GetService() *Service

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 Route 

type Route struct {
	// 如果匹配Source规则，按照Destination路由
	// 多个Source之间的关系为或
	Sources      []*Source      `protobuf:"bytes,1,rep,name=sources" json:"sources,omitempty"`
	Destinations []*Destination `protobuf:"bytes,2,rep,name=destinations" json:"destinations,omitempty"`
}

func (*Route) Descriptor 

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

func (*Route) GetDestinations 

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

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

type Routing 

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

func (*Routing) Descriptor 

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

func (*Routing) GetCtime 

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

func (*Routing) GetInbounds 

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

func (*Routing) GetMtime 

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

func (*Routing) GetNamespace 

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

func (*Routing) GetOutbounds 

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

func (*Routing) GetRevision 

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

func (*Routing) GetService 

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

func (*Routing) GetServiceToken 

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

func (*Routing) ProtoMessage 

func (*Routing) ProtoMessage()

func (*Routing) Reset 

func (m *Routing) Reset()

func (*Routing) String 

func (m *Routing) String() string

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,json=regexCombine,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"`
	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) 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) 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) GetMtime 

func (m *Rule) GetMtime() *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       *google_protobuf.StringValue `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Namespace  *google_protobuf.StringValue `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	Metadata   map[string]string            `` /* 136-byte string literal not displayed */
	Ports      *google_protobuf.StringValue `protobuf:"bytes,4,opt,name=ports" json:"ports,omitempty"`
	Business   *google_protobuf.StringValue `protobuf:"bytes,5,opt,name=business" json:"business,omitempty"`
	Department *google_protobuf.StringValue `protobuf:"bytes,6,opt,name=department" json:"department,omitempty"`
	CmdbMod1   *google_protobuf.StringValue `protobuf:"bytes,7,opt,name=cmdb_mod1" json:"cmdb_mod1,omitempty"`
	CmdbMod2   *google_protobuf.StringValue `protobuf:"bytes,8,opt,name=cmdb_mod2" json:"cmdb_mod2,omitempty"`
	CmdbMod3   *google_protobuf.StringValue `protobuf:"bytes,9,opt,name=cmdb_mod3" json:"cmdb_mod3,omitempty"`
	Comment    *google_protobuf.StringValue `protobuf:"bytes,10,opt,name=comment" json:"comment,omitempty"`
	Owners     *google_protobuf.StringValue `protobuf:"bytes,11,opt,name=owners" json:"owners,omitempty"`
	Token      *google_protobuf.StringValue `protobuf:"bytes,12,opt,name=token" json:"token,omitempty"`
	Ctime      *google_protobuf.StringValue `protobuf:"bytes,13,opt,name=ctime" json:"ctime,omitempty"`
	Mtime      *google_protobuf.StringValue `protobuf:"bytes,14,opt,name=mtime" json:"mtime,omitempty"`
	Revision   *google_protobuf.StringValue `protobuf:"bytes,15,opt,name=revision" json:"revision,omitempty"`
}

func (*Service) Descriptor 

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

func (*Service) GetBusiness 

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

func (*Service) GetCmdbMod1 

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

func (*Service) GetCmdbMod2 

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

func (*Service) GetCmdbMod3 

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

func (*Service) GetComment 

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

func (*Service) GetCtime 

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

func (*Service) GetDepartment 

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

func (*Service) GetMetadata 

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

func (*Service) GetMtime 

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

func (*Service) GetName 

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

func (*Service) GetNamespace 

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

func (*Service) GetOwners 

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

func (*Service) GetPorts 

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

func (*Service) GetRevision 

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

func (*Service) GetToken 

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

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

type ServiceAlias 

type ServiceAlias struct {
	Service      *google_protobuf.StringValue `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
	Namespace    *google_protobuf.StringValue `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	Alias        *google_protobuf.StringValue `protobuf:"bytes,3,opt,name=alias" json:"alias,omitempty"`
	Type         AliasType                    `protobuf:"varint,4,opt,name=type,enum=v1.AliasType" json:"type,omitempty"`
	Owners       *google_protobuf.StringValue `protobuf:"bytes,8,opt,name=owners" json:"owners,omitempty"`
	ServiceToken *google_protobuf.StringValue `protobuf:"bytes,5,opt,name=service_token" json:"service_token,omitempty"`
	Ctime        *google_protobuf.StringValue `protobuf:"bytes,6,opt,name=ctime" json:"ctime,omitempty"`
	Mtime        *google_protobuf.StringValue `protobuf:"bytes,7,opt,name=mtime" json:"mtime,omitempty"`
}

func (*ServiceAlias) Descriptor 

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

func (*ServiceAlias) GetAlias 

func (m *ServiceAlias) GetAlias() *google_protobuf.StringValue

func (*ServiceAlias) GetCtime 

func (m *ServiceAlias) GetCtime() *google_protobuf.StringValue

func (*ServiceAlias) GetMtime 

func (m *ServiceAlias) GetMtime() *google_protobuf.StringValue

func (*ServiceAlias) GetNamespace 

func (m *ServiceAlias) GetNamespace() *google_protobuf.StringValue

func (*ServiceAlias) GetOwners 

func (m *ServiceAlias) GetOwners() *google_protobuf.StringValue

func (*ServiceAlias) GetService 

func (m *ServiceAlias) GetService() *google_protobuf.StringValue

func (*ServiceAlias) GetServiceToken 

func (m *ServiceAlias) GetServiceToken() *google_protobuf.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

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 (*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   *google_protobuf.StringValue `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
	Namespace *google_protobuf.StringValue `protobuf:"bytes,2,opt,name=namespace" json:"namespace,omitempty"`
	// 主调方服务实例标签或者请求标签
	// value支持正则匹配
	Metadata map[string]*MatchString `` /* 136-byte string literal not displayed */
}

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() *google_protobuf.StringValue

func (*Source) GetService 

func (m *Source) GetService() *google_protobuf.StringValue

func (*Source) ProtoMessage 

func (*Source) ProtoMessage()

func (*Source) Reset 

func (m *Source) Reset()

func (*Source) String 

func (m *Source) String() string

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.