v1

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2022 License: Apache-2.0, Apache-2.0, BSD-2-Clause, + 4 more Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ReceiveSuccess   uint32 = 200000
	IncompleteRecord        = 400001
)

*

  • @brief 错误码

Variables

View Source 
var APIResultType_name = map[int32]string{
	0: "UnknownType",
	1: "Success",
	2: "UserFail",
	3: "PolarisFail",
}
View Source 
var APIResultType_value = map[string]int32{
	"UnknownType": 0,
	"Success":     1,
	"UserFail":    2,
	"PolarisFail": 3,
}
View Source 
var LimitMode_name = map[int32]string{
	0: "UnknownMode",
	1: "GlobalMode",
	2: "LocalMode",
	3: "DegradeMode",
}
View Source 
var LimitMode_value = map[string]int32{
	"UnknownMode": 0,
	"GlobalMode":  1,
	"LocalMode":   2,
	"DegradeMode": 3,
}
View Source 
var PluginAPIResultType_name = map[int32]string{
	0: "UnknownResult",
	1: "APISuccess",
	2: "APIFail",
}
View Source 
var PluginAPIResultType_value = map[string]int32{
	"UnknownResult": 0,
	"APISuccess":    1,
	"APIFail":       2,
}
View Source 
var RecoverAllStatus_name = map[int32]string{
	0: "Invalid",
	1: "Start",
	2: "End",
}
View Source 
var RecoverAllStatus_value = map[string]int32{
	"Invalid": 0,
	"Start":   1,
	"End":     2,
}
View Source 
var RouteRecord_RuleType_name = map[int32]string{
	0: "Unknown",
	1: "DestRule",
	2: "SrcRule",
}
View Source 
var RouteRecord_RuleType_value = map[string]int32{
	"Unknown":  0,
	"DestRule": 1,
	"SrcRule":  2,
}
View Source 
var StatusChange_name = map[int32]string{
	0: "Unknown",
	1: "CloseToOpen",
	2: "OpenToHalfOpen",
	3: "HalfOpenToOpen",
	4: "HalfOpenToClose",
}
View Source 
var StatusChange_value = map[string]int32{
	"Unknown":         0,
	"CloseToOpen":     1,
	"OpenToHalfOpen":  2,
	"HalfOpenToOpen":  3,
	"HalfOpenToClose": 4,
}

Functions

func RegisterGrpcAPIServer 

func RegisterGrpcAPIServer(s *grpc.Server, srv GrpcAPIServer)

Types

type APIResultType 

type APIResultType int32

api接口调用 

const (
	//未知原因，更新pb后的sdk不得上报这种类型，用于兼容旧版本sdk
	APIResultType_UnknownType APIResultType = 0
	//用户调用成功
	APIResultType_Success APIResultType = 1
	//由于用户的原因，如参数错误导致的调用错误
	APIResultType_UserFail APIResultType = 2
	//由于系统原因（sdk或者server）导致用户调用失败
	APIResultType_PolarisFail APIResultType = 3
)

func (APIResultType) EnumDescriptor 

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

func (APIResultType) String 

func (x APIResultType) String() string

type ChangeInstance 

type ChangeInstance struct {
	VpcId                string   `protobuf:"bytes,1,opt,name=vpc_id,json=vpcId,proto3" json:"vpc_id,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port                 uint32   `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Info                 string   `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

一个实例信息

func (*ChangeInstance) Descriptor 

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

func (*ChangeInstance) GetHost 

func (m *ChangeInstance) GetHost() string

func (*ChangeInstance) GetInfo 

func (m *ChangeInstance) GetInfo() string

func (*ChangeInstance) GetPort 

func (m *ChangeInstance) GetPort() uint32

func (*ChangeInstance) GetVpcId 

func (m *ChangeInstance) GetVpcId() string

func (*ChangeInstance) ProtoMessage 

func (*ChangeInstance) ProtoMessage()

func (*ChangeInstance) Reset 

func (m *ChangeInstance) Reset()

func (*ChangeInstance) String 

func (m *ChangeInstance) String() string

func (*ChangeInstance) XXX_DiscardUnknown 

func (m *ChangeInstance) XXX_DiscardUnknown()

func (*ChangeInstance) XXX_Marshal 

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

func (*ChangeInstance) XXX_Merge 

func (m *ChangeInstance) XXX_Merge(src proto.Message)

func (*ChangeInstance) XXX_Size 

func (m *ChangeInstance) XXX_Size() int

func (*ChangeInstance) XXX_Unmarshal 

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

type ChangeMeshService 

type ChangeMeshService struct {
	MeshNamespace        string   `protobuf:"bytes,1,opt,name=mesh_namespace,json=meshNamespace,proto3" json:"mesh_namespace,omitempty"`
	MeshService          string   `protobuf:"bytes,2,opt,name=mesh_service,json=meshService,proto3" json:"mesh_service,omitempty"`
	Info                 string   `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

单个网格服务的变化情况

func (*ChangeMeshService) Descriptor 

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

func (*ChangeMeshService) GetInfo 

func (m *ChangeMeshService) GetInfo() string

func (*ChangeMeshService) GetMeshNamespace 

func (m *ChangeMeshService) GetMeshNamespace() string

func (*ChangeMeshService) GetMeshService 

func (m *ChangeMeshService) GetMeshService() string

func (*ChangeMeshService) ProtoMessage 

func (*ChangeMeshService) ProtoMessage()

func (*ChangeMeshService) Reset 

func (m *ChangeMeshService) Reset()

func (*ChangeMeshService) String 

func (m *ChangeMeshService) String() string

func (*ChangeMeshService) XXX_DiscardUnknown 

func (m *ChangeMeshService) XXX_DiscardUnknown()

func (*ChangeMeshService) XXX_Marshal 

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

func (*ChangeMeshService) XXX_Merge 

func (m *ChangeMeshService) XXX_Merge(src proto.Message)

func (*ChangeMeshService) XXX_Size 

func (m *ChangeMeshService) XXX_Size() int

func (*ChangeMeshService) XXX_Unmarshal 

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

type CircuitbreakChange 

type CircuitbreakChange struct {
	//变更时间
	Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	//变更的次序
	ChangeSeq uint32 `protobuf:"varint,2,opt,name=change_seq,json=changeSeq,proto3" json:"change_seq,omitempty"`
	//状态变更类型
	Change StatusChange `protobuf:"varint,3,opt,name=change,proto3,enum=v1.StatusChange" json:"change,omitempty"`
	//状态变更原因
	Reason               string   `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

实例的一次熔断状态改变

func (*CircuitbreakChange) Descriptor 

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

func (*CircuitbreakChange) GetChange 

func (m *CircuitbreakChange) GetChange() StatusChange

func (*CircuitbreakChange) GetChangeSeq 

func (m *CircuitbreakChange) GetChangeSeq() uint32

func (*CircuitbreakChange) GetReason 

func (m *CircuitbreakChange) GetReason() string

func (*CircuitbreakChange) GetTime 

func (m *CircuitbreakChange) GetTime() *timestamp.Timestamp

func (*CircuitbreakChange) ProtoMessage 

func (*CircuitbreakChange) ProtoMessage()

func (*CircuitbreakChange) Reset 

func (m *CircuitbreakChange) Reset()

func (*CircuitbreakChange) String 

func (m *CircuitbreakChange) String() string

func (*CircuitbreakChange) XXX_DiscardUnknown 

func (m *CircuitbreakChange) XXX_DiscardUnknown()

func (*CircuitbreakChange) XXX_Marshal 

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

func (*CircuitbreakChange) XXX_Merge 

func (m *CircuitbreakChange) XXX_Merge(src proto.Message)

func (*CircuitbreakChange) XXX_Size 

func (m *CircuitbreakChange) XXX_Size() int

func (*CircuitbreakChange) XXX_Unmarshal 

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

type CircuitbreakHistory 

type CircuitbreakHistory struct {
	Ip                   string                `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 uint32                `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	VpcId                string                `protobuf:"bytes,3,opt,name=vpc_id,json=vpcId,proto3" json:"vpc_id,omitempty"`
	Changes              []*CircuitbreakChange `protobuf:"bytes,4,rep,name=changes,proto3" json:"changes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

实例的周期熔断变更历史

func (*CircuitbreakHistory) Descriptor 

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

func (*CircuitbreakHistory) GetChanges 

func (m *CircuitbreakHistory) GetChanges() []*CircuitbreakChange

func (*CircuitbreakHistory) GetIp 

func (m *CircuitbreakHistory) GetIp() string

func (*CircuitbreakHistory) GetPort 

func (m *CircuitbreakHistory) GetPort() uint32

func (*CircuitbreakHistory) GetVpcId 

func (m *CircuitbreakHistory) GetVpcId() string

func (*CircuitbreakHistory) ProtoMessage 

func (*CircuitbreakHistory) ProtoMessage()

func (*CircuitbreakHistory) Reset 

func (m *CircuitbreakHistory) Reset()

func (*CircuitbreakHistory) String 

func (m *CircuitbreakHistory) String() string

func (*CircuitbreakHistory) XXX_DiscardUnknown 

func (m *CircuitbreakHistory) XXX_DiscardUnknown()

func (*CircuitbreakHistory) XXX_Marshal 

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

func (*CircuitbreakHistory) XXX_Merge 

func (m *CircuitbreakHistory) XXX_Merge(src proto.Message)

func (*CircuitbreakHistory) XXX_Size 

func (m *CircuitbreakHistory) XXX_Size() int

func (*CircuitbreakHistory) XXX_Unmarshal 

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

type GrpcAPIClient 

type GrpcAPIClient interface {
	CollectServerStatistics(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectServerStatisticsClient, error)
	CollectSDKAPIStatistics(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectSDKAPIStatisticsClient, error)
	CollectServiceStatistics(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectServiceStatisticsClient, error)
	CollectSDKConfiguration(ctx context.Context, in *SDKConfig, opts ...grpc.CallOption) (*StatResponse, error)
	CollectSDKCache(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectSDKCacheClient, error)
	CollectCircuitBreak(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectCircuitBreakClient, error)
	CollectPluginStatistics(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectPluginStatisticsClient, error)
	CollectLoadBalanceInfo(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectLoadBalanceInfoClient, error)
	CollectRateLimitRecord(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectRateLimitRecordClient, error)
	CollectRouteRecord(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectRouteRecordClient, error)
	CollectMeshResource(ctx context.Context, opts ...grpc.CallOption) (GrpcAPI_CollectMeshResourceClient, error)
}

GrpcAPIClient is the client API for GrpcAPI service.

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

func NewGrpcAPIClient 

func NewGrpcAPIClient(cc *grpc.ClientConn) GrpcAPIClient

type GrpcAPIServer 

type GrpcAPIServer interface {
	CollectServerStatistics(GrpcAPI_CollectServerStatisticsServer) error
	CollectSDKAPIStatistics(GrpcAPI_CollectSDKAPIStatisticsServer) error
	CollectServiceStatistics(GrpcAPI_CollectServiceStatisticsServer) error
	CollectSDKConfiguration(context.Context, *SDKConfig) (*StatResponse, error)
	CollectSDKCache(GrpcAPI_CollectSDKCacheServer) error
	CollectCircuitBreak(GrpcAPI_CollectCircuitBreakServer) error
	CollectPluginStatistics(GrpcAPI_CollectPluginStatisticsServer) error
	CollectLoadBalanceInfo(GrpcAPI_CollectLoadBalanceInfoServer) error
	CollectRateLimitRecord(GrpcAPI_CollectRateLimitRecordServer) error
	CollectRouteRecord(GrpcAPI_CollectRouteRecordServer) error
	CollectMeshResource(GrpcAPI_CollectMeshResourceServer) error
}

GrpcAPIServer is the server API for GrpcAPI service.

type GrpcAPI_CollectCircuitBreakClient 

type GrpcAPI_CollectCircuitBreakClient interface {
	Send(*ServiceCircuitbreak) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectCircuitBreakServer 

type GrpcAPI_CollectCircuitBreakServer interface {
	Send(*StatResponse) error
	Recv() (*ServiceCircuitbreak, error)
	grpc.ServerStream
}

type GrpcAPI_CollectLoadBalanceInfoClient 

type GrpcAPI_CollectLoadBalanceInfoClient interface {
	Send(*ServiceLoadBalanceInfo) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectLoadBalanceInfoServer 

type GrpcAPI_CollectLoadBalanceInfoServer interface {
	Send(*StatResponse) error
	Recv() (*ServiceLoadBalanceInfo, error)
	grpc.ServerStream
}

type GrpcAPI_CollectMeshResourceClient 

type GrpcAPI_CollectMeshResourceClient interface {
	Send(*MeshResourceInfo) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectMeshResourceServer 

type GrpcAPI_CollectMeshResourceServer interface {
	Send(*StatResponse) error
	Recv() (*MeshResourceInfo, error)
	grpc.ServerStream
}

type GrpcAPI_CollectPluginStatisticsClient 

type GrpcAPI_CollectPluginStatisticsClient interface {
	Send(*PluginAPIStatistics) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectPluginStatisticsServer 

type GrpcAPI_CollectPluginStatisticsServer interface {
	Send(*StatResponse) error
	Recv() (*PluginAPIStatistics, error)
	grpc.ServerStream
}

type GrpcAPI_CollectRateLimitRecordClient 

type GrpcAPI_CollectRateLimitRecordClient interface {
	Send(*RateLimitRecord) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectRateLimitRecordServer 

type GrpcAPI_CollectRateLimitRecordServer interface {
	Send(*StatResponse) error
	Recv() (*RateLimitRecord, error)
	grpc.ServerStream
}

type GrpcAPI_CollectRouteRecordClient 

type GrpcAPI_CollectRouteRecordClient interface {
	Send(*ServiceRouteRecord) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectRouteRecordServer 

type GrpcAPI_CollectRouteRecordServer interface {
	Send(*StatResponse) error
	Recv() (*ServiceRouteRecord, error)
	grpc.ServerStream
}

type GrpcAPI_CollectSDKAPIStatisticsClient 

type GrpcAPI_CollectSDKAPIStatisticsClient interface {
	Send(*SDKAPIStatistics) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectSDKAPIStatisticsServer 

type GrpcAPI_CollectSDKAPIStatisticsServer interface {
	Send(*StatResponse) error
	Recv() (*SDKAPIStatistics, error)
	grpc.ServerStream
}

type GrpcAPI_CollectSDKCacheClient 

type GrpcAPI_CollectSDKCacheClient interface {
	Send(*ServiceInfo) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectSDKCacheServer 

type GrpcAPI_CollectSDKCacheServer interface {
	Send(*StatResponse) error
	Recv() (*ServiceInfo, error)
	grpc.ServerStream
}

type GrpcAPI_CollectServerStatisticsClient 

type GrpcAPI_CollectServerStatisticsClient interface {
	Send(*ServerStatistics) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectServerStatisticsServer 

type GrpcAPI_CollectServerStatisticsServer interface {
	Send(*StatResponse) error
	Recv() (*ServerStatistics, error)
	grpc.ServerStream
}

type GrpcAPI_CollectServiceStatisticsClient 

type GrpcAPI_CollectServiceStatisticsClient interface {
	Send(*ServiceStatistics) error
	Recv() (*StatResponse, error)
	grpc.ClientStream
}

type GrpcAPI_CollectServiceStatisticsServer 

type GrpcAPI_CollectServiceStatisticsServer interface {
	Send(*StatResponse) error
	Recv() (*ServiceStatistics, error)
	grpc.ServerStream
}

type Indicator 

type Indicator struct {
	TotalRequestPerMinute *wrappers.UInt32Value `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{}              `json:"-"`
	XXX_unrecognized      []byte                `json:"-"`
	XXX_sizecache         int32                 `json:"-"`
}

server和sdk的上报指标

func (*Indicator) Descriptor 

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

func (*Indicator) GetTotalRequestPerMinute 

func (m *Indicator) GetTotalRequestPerMinute() *wrappers.UInt32Value

func (*Indicator) ProtoMessage 

func (*Indicator) ProtoMessage()

func (*Indicator) Reset 

func (m *Indicator) Reset()

func (*Indicator) String 

func (m *Indicator) String() string

func (*Indicator) XXX_DiscardUnknown 

func (m *Indicator) XXX_DiscardUnknown()

func (*Indicator) XXX_Marshal 

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

func (*Indicator) XXX_Merge 

func (m *Indicator) XXX_Merge(src proto.Message)

func (*Indicator) XXX_Size 

func (m *Indicator) XXX_Size() int

func (*Indicator) XXX_Unmarshal 

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

type InstanceLoadBalanceInfo 

type InstanceLoadBalanceInfo struct {
	Ip                   string   `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	VpcId                string   `protobuf:"bytes,3,opt,name=vpc_id,json=vpcId,proto3" json:"vpc_id,omitempty"`
	ChooseNum            uint32   `protobuf:"varint,4,opt,name=choose_num,json=chooseNum,proto3" json:"choose_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InstanceLoadBalanceInfo) Descriptor 

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

func (*InstanceLoadBalanceInfo) GetChooseNum 

func (m *InstanceLoadBalanceInfo) GetChooseNum() uint32

func (*InstanceLoadBalanceInfo) GetIp 

func (m *InstanceLoadBalanceInfo) GetIp() string

func (*InstanceLoadBalanceInfo) GetPort 

func (m *InstanceLoadBalanceInfo) GetPort() uint32

func (*InstanceLoadBalanceInfo) GetVpcId 

func (m *InstanceLoadBalanceInfo) GetVpcId() string

func (*InstanceLoadBalanceInfo) ProtoMessage 

func (*InstanceLoadBalanceInfo) ProtoMessage()

func (*InstanceLoadBalanceInfo) Reset 

func (m *InstanceLoadBalanceInfo) Reset()

func (*InstanceLoadBalanceInfo) String 

func (m *InstanceLoadBalanceInfo) String() string

func (*InstanceLoadBalanceInfo) XXX_DiscardUnknown 

func (m *InstanceLoadBalanceInfo) XXX_DiscardUnknown()

func (*InstanceLoadBalanceInfo) XXX_Marshal 

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

func (*InstanceLoadBalanceInfo) XXX_Merge 

func (m *InstanceLoadBalanceInfo) XXX_Merge(src proto.Message)

func (*InstanceLoadBalanceInfo) XXX_Size 

func (m *InstanceLoadBalanceInfo) XXX_Size() int

func (*InstanceLoadBalanceInfo) XXX_Unmarshal 

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

type InstancesChange 

type InstancesChange struct {
	OldCount             uint32            `protobuf:"varint,1,opt,name=old_count,json=oldCount,proto3" json:"old_count,omitempty"`
	NewCount             uint32            `protobuf:"varint,2,opt,name=new_count,json=newCount,proto3" json:"new_count,omitempty"`
	ModifiedInstances    []*ChangeInstance `protobuf:"bytes,3,rep,name=modified_instances,json=modifiedInstances,proto3" json:"modified_instances,omitempty"`
	AddedInstances       []*ChangeInstance `protobuf:"bytes,4,rep,name=added_instances,json=addedInstances,proto3" json:"added_instances,omitempty"`
	DeletedInstances     []*ChangeInstance `protobuf:"bytes,5,rep,name=deleted_instances,json=deletedInstances,proto3" json:"deleted_instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

实例信息的变化情况

func (*InstancesChange) Descriptor 

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

func (*InstancesChange) GetAddedInstances 

func (m *InstancesChange) GetAddedInstances() []*ChangeInstance

func (*InstancesChange) GetDeletedInstances 

func (m *InstancesChange) GetDeletedInstances() []*ChangeInstance

func (*InstancesChange) GetModifiedInstances 

func (m *InstancesChange) GetModifiedInstances() []*ChangeInstance

func (*InstancesChange) GetNewCount 

func (m *InstancesChange) GetNewCount() uint32

func (*InstancesChange) GetOldCount 

func (m *InstancesChange) GetOldCount() uint32

func (*InstancesChange) ProtoMessage 

func (*InstancesChange) ProtoMessage()

func (*InstancesChange) Reset 

func (m *InstancesChange) Reset()

func (*InstancesChange) String 

func (m *InstancesChange) String() string

func (*InstancesChange) XXX_DiscardUnknown 

func (m *InstancesChange) XXX_DiscardUnknown()

func (*InstancesChange) XXX_Marshal 

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

func (*InstancesChange) XXX_Merge 

func (m *InstancesChange) XXX_Merge(src proto.Message)

func (*InstancesChange) XXX_Size 

func (m *InstancesChange) XXX_Size() int

func (*InstancesChange) XXX_Unmarshal 

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

type InstancesHistory 

type InstancesHistory struct {
	//版本号变更
	Revision             []*RevisionHistory `protobuf:"bytes,1,rep,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

实例变更历史

func (*InstancesHistory) Descriptor 

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

func (*InstancesHistory) GetRevision 

func (m *InstancesHistory) GetRevision() []*RevisionHistory

func (*InstancesHistory) ProtoMessage 

func (*InstancesHistory) ProtoMessage()

func (*InstancesHistory) Reset 

func (m *InstancesHistory) Reset()

func (*InstancesHistory) String 

func (m *InstancesHistory) String() string

func (*InstancesHistory) XXX_DiscardUnknown 

func (m *InstancesHistory) XXX_DiscardUnknown()

func (*InstancesHistory) XXX_Marshal 

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

func (*InstancesHistory) XXX_Merge 

func (m *InstancesHistory) XXX_Merge(src proto.Message)

func (*InstancesHistory) XXX_Size 

func (m *InstancesHistory) XXX_Size() int

func (*InstancesHistory) XXX_Unmarshal 

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

type LimitMode 

type LimitMode int32
const (
	//未知类型，用于兼容前面pb
	LimitMode_UnknownMode LimitMode = 0
	//全局类型，与限流server发生交互
	LimitMode_GlobalMode LimitMode = 1
	//本地类型，使用本地限流算法
	LimitMode_LocalMode LimitMode = 2
	//降级类型，因为无法连接限流server，导致必须使用本地限流算法
	LimitMode_DegradeMode LimitMode = 3
)

func (LimitMode) EnumDescriptor 

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

func (LimitMode) String 

func (x LimitMode) String() string

type LimitRequestsCount 

type LimitRequestsCount struct {
	Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	//总的请求次数
	TotalRequests uint32 `protobuf:"varint,2,opt,name=total_requests,json=totalRequests,proto3" json:"total_requests,omitempty"`
	//通过请求数
	PassRequests uint32 `protobuf:"varint,3,opt,name=pass_requests,json=passRequests,proto3" json:"pass_requests,omitempty"`
	//被拒请求数
	RejectRequests uint32 `protobuf:"varint,4,opt,name=reject_requests,json=rejectRequests,proto3" json:"reject_requests,omitempty"`
	//请求发生在什么模式下面
	Mode                 LimitMode `protobuf:"varint,5,opt,name=mode,proto3,enum=v1.LimitMode" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

一个周期内，限流请求数量的情况

func (*LimitRequestsCount) Descriptor 

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

func (*LimitRequestsCount) GetMode 

func (m *LimitRequestsCount) GetMode() LimitMode

func (*LimitRequestsCount) GetPassRequests 

func (m *LimitRequestsCount) GetPassRequests() uint32

func (*LimitRequestsCount) GetRejectRequests 

func (m *LimitRequestsCount) GetRejectRequests() uint32

func (*LimitRequestsCount) GetTime 

func (m *LimitRequestsCount) GetTime() *timestamp.Timestamp

func (*LimitRequestsCount) GetTotalRequests 

func (m *LimitRequestsCount) GetTotalRequests() uint32

func (*LimitRequestsCount) ProtoMessage 

func (*LimitRequestsCount) ProtoMessage()

func (*LimitRequestsCount) Reset 

func (m *LimitRequestsCount) Reset()

func (*LimitRequestsCount) String 

func (m *LimitRequestsCount) String() string

func (*LimitRequestsCount) XXX_DiscardUnknown 

func (m *LimitRequestsCount) XXX_DiscardUnknown()

func (*LimitRequestsCount) XXX_Marshal 

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

func (*LimitRequestsCount) XXX_Merge 

func (m *LimitRequestsCount) XXX_Merge(src proto.Message)

func (*LimitRequestsCount) XXX_Size 

func (m *LimitRequestsCount) XXX_Size() int

func (*LimitRequestsCount) XXX_Unmarshal 

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

type LimitStat 

type LimitStat struct {
	Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	//限流次数
	PeriodTimes uint32 `protobuf:"varint,2,opt,name=period_times,json=periodTimes,proto3" json:"period_times,omitempty"`
	//限流原因，每种原因一个limitStat
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	//限流发生时处于哪种模式
	Mode LimitMode `protobuf:"varint,4,opt,name=mode,proto3,enum=v1.LimitMode" json:"mode,omitempty"`
	//通过请求数
	Pass uint32 `protobuf:"varint,5,opt,name=pass,proto3" json:"pass,omitempty"`
	//限流周期，单位为s
	LimitDuration        uint32   `protobuf:"varint,6,opt,name=limit_duration,json=limitDuration,proto3" json:"limit_duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

被限流的统计

func (*LimitStat) Descriptor 

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

func (*LimitStat) GetLimitDuration 

func (m *LimitStat) GetLimitDuration() uint32

func (*LimitStat) GetMode 

func (m *LimitStat) GetMode() LimitMode

func (*LimitStat) GetPass 

func (m *LimitStat) GetPass() uint32

func (*LimitStat) GetPeriodTimes 

func (m *LimitStat) GetPeriodTimes() uint32

func (*LimitStat) GetReason 

func (m *LimitStat) GetReason() string

func (*LimitStat) GetTime 

func (m *LimitStat) GetTime() *timestamp.Timestamp

func (*LimitStat) ProtoMessage 

func (*LimitStat) ProtoMessage()

func (*LimitStat) Reset 

func (m *LimitStat) Reset()

func (*LimitStat) String 

func (m *LimitStat) String() string

func (*LimitStat) XXX_DiscardUnknown 

func (m *LimitStat) XXX_DiscardUnknown()

func (*LimitStat) XXX_Marshal 

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

func (*LimitStat) XXX_Merge 

func (m *LimitStat) XXX_Merge(src proto.Message)

func (*LimitStat) XXX_Size 

func (m *LimitStat) XXX_Size() int

func (*LimitStat) XXX_Unmarshal 

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

type MeshInfo 

type MeshInfo struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	//sdk标识
	SdkToken *SDKToken `protobuf:"bytes,2,opt,name=sdk_token,json=sdkToken,proto3" json:"sdk_token,omitempty"`
	MeshId   string    `protobuf:"bytes,3,opt,name=mesh_id,json=meshId,proto3" json:"mesh_id,omitempty"`
	//整个订阅服务集体的版本号变更
	Revision []*RevisionHistory `protobuf:"bytes,4,rep,name=revision,proto3" json:"revision,omitempty"`
	//整个网格是否被删除
	MeshDeleted bool `protobuf:"varint,5,opt,name=mesh_deleted,json=meshDeleted,proto3" json:"mesh_deleted,omitempty"`
	//网格服务的版本变化
	MeshServicesHistory *MeshServicesHistory `protobuf:"bytes,6,opt,name=mesh_services_history,json=meshServicesHistory,proto3" json:"mesh_services_history,omitempty"`
	//各个单个规则的版本变更历史
	SingleMeshServiceHistory []*SingleMeshServiceHistory `` /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral     struct{}                    `json:"-"`
	XXX_unrecognized         []byte                      `json:"-"`
	XXX_sizecache            int32                       `json:"-"`
}

网格服务的版本变更记录

func (*MeshInfo) Descriptor 

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

func (*MeshInfo) GetId 

func (m *MeshInfo) GetId() string

func (*MeshInfo) GetMeshDeleted 

func (m *MeshInfo) GetMeshDeleted() bool

func (*MeshInfo) GetMeshId 

func (m *MeshInfo) GetMeshId() string

func (*MeshInfo) GetMeshServicesHistory 

func (m *MeshInfo) GetMeshServicesHistory() *MeshServicesHistory

func (*MeshInfo) GetRevision 

func (m *MeshInfo) GetRevision() []*RevisionHistory

func (*MeshInfo) GetSdkToken 

func (m *MeshInfo) GetSdkToken() *SDKToken

func (*MeshInfo) GetSingleMeshServiceHistory 

func (m *MeshInfo) GetSingleMeshServiceHistory() []*SingleMeshServiceHistory

func (*MeshInfo) ProtoMessage 

func (*MeshInfo) ProtoMessage()

func (*MeshInfo) Reset 

func (m *MeshInfo) Reset()

func (*MeshInfo) String 

func (m *MeshInfo) String() string

func (*MeshInfo) XXX_DiscardUnknown 

func (m *MeshInfo) XXX_DiscardUnknown()

func (*MeshInfo) XXX_Marshal 

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

func (*MeshInfo) XXX_Merge 

func (m *MeshInfo) XXX_Merge(src proto.Message)

func (*MeshInfo) XXX_Size 

func (m *MeshInfo) XXX_Size() int

func (*MeshInfo) XXX_Unmarshal 

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

type MeshResourceInfo 

type MeshResourceInfo struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	//sdk标识
	SdkToken *SDKToken `protobuf:"bytes,2,opt,name=sdk_token,json=sdkToken,proto3" json:"sdk_token,omitempty"`
	MeshId   string    `protobuf:"bytes,3,opt,name=mesh_id,json=meshId,proto3" json:"mesh_id,omitempty"`
	TypeUrl  string    `protobuf:"bytes,4,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"`
	//整个规则集体的版本号变更
	Revision []*RevisionHistory `protobuf:"bytes,5,rep,name=revision,proto3" json:"revision,omitempty"`
	//整个规则是否被删除
	MeshConfigDeleted bool `protobuf:"varint,6,opt,name=mesh_config_deleted,json=meshConfigDeleted,proto3" json:"mesh_config_deleted,omitempty"`
	//各个单个规则的版本变更历史
	SingleMeshResourceHistory []*SingleMeshResourceRuleHistory `` /* 140-byte string literal not displayed */
	XXX_NoUnkeyedLiteral      struct{}                         `json:"-"`
	XXX_unrecognized          []byte                           `json:"-"`
	XXX_sizecache             int32                            `json:"-"`
}

网格规则的版本变更记录

func (*MeshResourceInfo) Descriptor 

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

func (*MeshResourceInfo) GetId 

func (m *MeshResourceInfo) GetId() string

func (*MeshResourceInfo) GetMeshConfigDeleted 

func (m *MeshResourceInfo) GetMeshConfigDeleted() bool

func (*MeshResourceInfo) GetMeshId 

func (m *MeshResourceInfo) GetMeshId() string

func (*MeshResourceInfo) GetRevision 

func (m *MeshResourceInfo) GetRevision() []*RevisionHistory

func (*MeshResourceInfo) GetSdkToken 

func (m *MeshResourceInfo) GetSdkToken() *SDKToken

func (*MeshResourceInfo) GetSingleMeshResourceHistory 

func (m *MeshResourceInfo) GetSingleMeshResourceHistory() []*SingleMeshResourceRuleHistory

func (*MeshResourceInfo) GetTypeUrl 

func (m *MeshResourceInfo) GetTypeUrl() string

func (*MeshResourceInfo) ProtoMessage 

func (*MeshResourceInfo) ProtoMessage()

func (*MeshResourceInfo) Reset 

func (m *MeshResourceInfo) Reset()

func (*MeshResourceInfo) String 

func (m *MeshResourceInfo) String() string

func (*MeshResourceInfo) XXX_DiscardUnknown 

func (m *MeshResourceInfo) XXX_DiscardUnknown()

func (*MeshResourceInfo) XXX_Marshal 

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

func (*MeshResourceInfo) XXX_Merge 

func (m *MeshResourceInfo) XXX_Merge(src proto.Message)

func (*MeshResourceInfo) XXX_Size 

func (m *MeshResourceInfo) XXX_Size() int

func (*MeshResourceInfo) XXX_Unmarshal 

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

type MeshServicesChange 

type MeshServicesChange struct {
	OldCount             uint32               `protobuf:"varint,1,opt,name=old_count,json=oldCount,proto3" json:"old_count,omitempty"`
	NewCount             uint32               `protobuf:"varint,2,opt,name=new_count,json=newCount,proto3" json:"new_count,omitempty"`
	ModifiedServices     []*ChangeMeshService `protobuf:"bytes,3,rep,name=modified_services,json=modifiedServices,proto3" json:"modified_services,omitempty"`
	AddedServices        []*ChangeMeshService `protobuf:"bytes,4,rep,name=added_services,json=addedServices,proto3" json:"added_services,omitempty"`
	DeletedServices      []*ChangeMeshService `protobuf:"bytes,5,rep,name=deleted_services,json=deletedServices,proto3" json:"deleted_services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

一个网格下面所有服务的变化情况

func (*MeshServicesChange) Descriptor 

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

func (*MeshServicesChange) GetAddedServices 

func (m *MeshServicesChange) GetAddedServices() []*ChangeMeshService

func (*MeshServicesChange) GetDeletedServices 

func (m *MeshServicesChange) GetDeletedServices() []*ChangeMeshService

func (*MeshServicesChange) GetModifiedServices 

func (m *MeshServicesChange) GetModifiedServices() []*ChangeMeshService

func (*MeshServicesChange) GetNewCount 

func (m *MeshServicesChange) GetNewCount() uint32

func (*MeshServicesChange) GetOldCount 

func (m *MeshServicesChange) GetOldCount() uint32

func (*MeshServicesChange) ProtoMessage 

func (*MeshServicesChange) ProtoMessage()

func (*MeshServicesChange) Reset 

func (m *MeshServicesChange) Reset()

func (*MeshServicesChange) String 

func (m *MeshServicesChange) String() string

func (*MeshServicesChange) XXX_DiscardUnknown 

func (m *MeshServicesChange) XXX_DiscardUnknown()

func (*MeshServicesChange) XXX_Marshal 

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

func (*MeshServicesChange) XXX_Merge 

func (m *MeshServicesChange) XXX_Merge(src proto.Message)

func (*MeshServicesChange) XXX_Size 

func (m *MeshServicesChange) XXX_Size() int

func (*MeshServicesChange) XXX_Unmarshal 

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

type MeshServicesHistory 

type MeshServicesHistory struct {
	// 版本号变更
	Revision             []*RevisionHistory `protobuf:"bytes,1,rep,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

一个网格下面所有服务的变化情况

func (*MeshServicesHistory) Descriptor 

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

func (*MeshServicesHistory) GetRevision 

func (m *MeshServicesHistory) GetRevision() []*RevisionHistory

func (*MeshServicesHistory) ProtoMessage 

func (*MeshServicesHistory) ProtoMessage()

func (*MeshServicesHistory) Reset 

func (m *MeshServicesHistory) Reset()

func (*MeshServicesHistory) String 

func (m *MeshServicesHistory) String() string

func (*MeshServicesHistory) XXX_DiscardUnknown 

func (m *MeshServicesHistory) XXX_DiscardUnknown()

func (*MeshServicesHistory) XXX_Marshal 

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

func (*MeshServicesHistory) XXX_Merge 

func (m *MeshServicesHistory) XXX_Merge(src proto.Message)

func (*MeshServicesHistory) XXX_Size 

func (m *MeshServicesHistory) XXX_Size() int

func (*MeshServicesHistory) XXX_Unmarshal 

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

type PluginAPIKey 

type PluginAPIKey struct {
	PluginType           string   `protobuf:"bytes,1,opt,name=plugin_type,json=pluginType,proto3" json:"plugin_type,omitempty"`
	PluginName           string   `protobuf:"bytes,2,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"`
	PluginMethod         string   `protobuf:"bytes,3,opt,name=plugin_method,json=pluginMethod,proto3" json:"plugin_method,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PluginAPIKey) Descriptor 

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

func (*PluginAPIKey) GetPluginMethod 

func (m *PluginAPIKey) GetPluginMethod() string

func (*PluginAPIKey) GetPluginName 

func (m *PluginAPIKey) GetPluginName() string

func (*PluginAPIKey) GetPluginType 

func (m *PluginAPIKey) GetPluginType() string

func (*PluginAPIKey) ProtoMessage 

func (*PluginAPIKey) ProtoMessage()

func (*PluginAPIKey) Reset 

func (m *PluginAPIKey) Reset()

func (*PluginAPIKey) String 

func (m *PluginAPIKey) String() string

func (*PluginAPIKey) XXX_DiscardUnknown 

func (m *PluginAPIKey) XXX_DiscardUnknown()

func (*PluginAPIKey) XXX_Marshal 

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

func (*PluginAPIKey) XXX_Merge 

func (m *PluginAPIKey) XXX_Merge(src proto.Message)

func (*PluginAPIKey) XXX_Size 

func (m *PluginAPIKey) XXX_Size() int

func (*PluginAPIKey) XXX_Unmarshal 

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

type PluginAPIResult 

type PluginAPIResult struct {
	RetCode                string              `protobuf:"bytes,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
	TotalRequestsPerMinute uint32              `` /* 132-byte string literal not displayed */
	Type                   PluginAPIResultType `protobuf:"varint,3,opt,name=type,proto3,enum=v1.PluginAPIResultType" json:"type,omitempty"`
	DelayRange             string              `protobuf:"bytes,4,opt,name=delay_range,json=delayRange,proto3" json:"delay_range,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}            `json:"-"`
	XXX_unrecognized       []byte              `json:"-"`
	XXX_sizecache          int32               `json:"-"`
}

func (*PluginAPIResult) Descriptor 

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

func (*PluginAPIResult) GetDelayRange 

func (m *PluginAPIResult) GetDelayRange() string

func (*PluginAPIResult) GetRetCode 

func (m *PluginAPIResult) GetRetCode() string

func (*PluginAPIResult) GetTotalRequestsPerMinute 

func (m *PluginAPIResult) GetTotalRequestsPerMinute() uint32

func (*PluginAPIResult) GetType 

func (m *PluginAPIResult) GetType() PluginAPIResultType

func (*PluginAPIResult) ProtoMessage 

func (*PluginAPIResult) ProtoMessage()

func (*PluginAPIResult) Reset 

func (m *PluginAPIResult) Reset()

func (*PluginAPIResult) String 

func (m *PluginAPIResult) String() string

func (*PluginAPIResult) XXX_DiscardUnknown 

func (m *PluginAPIResult) XXX_DiscardUnknown()

func (*PluginAPIResult) XXX_Marshal 

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

func (*PluginAPIResult) XXX_Merge 

func (m *PluginAPIResult) XXX_Merge(src proto.Message)

func (*PluginAPIResult) XXX_Size 

func (m *PluginAPIResult) XXX_Size() int

func (*PluginAPIResult) XXX_Unmarshal 

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

type PluginAPIResultType 

type PluginAPIResultType int32
const (
	PluginAPIResultType_UnknownResult PluginAPIResultType = 0
	PluginAPIResultType_APISuccess    PluginAPIResultType = 1
	PluginAPIResultType_APIFail       PluginAPIResultType = 2
)

func (PluginAPIResultType) EnumDescriptor 

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

func (PluginAPIResultType) String 

func (x PluginAPIResultType) String() string

type PluginAPIStatistics 

type PluginAPIStatistics struct {
	Id                   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Token                *SDKToken          `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	PluginApi            *PluginAPIKey      `protobuf:"bytes,3,opt,name=plugin_api,json=pluginApi,proto3" json:"plugin_api,omitempty"`
	Results              []*PluginAPIResult `protobuf:"bytes,4,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*PluginAPIStatistics) Descriptor 

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

func (*PluginAPIStatistics) GetId 

func (m *PluginAPIStatistics) GetId() string

func (*PluginAPIStatistics) GetPluginApi 

func (m *PluginAPIStatistics) GetPluginApi() *PluginAPIKey

func (*PluginAPIStatistics) GetResults 

func (m *PluginAPIStatistics) GetResults() []*PluginAPIResult

func (*PluginAPIStatistics) GetToken 

func (m *PluginAPIStatistics) GetToken() *SDKToken

func (*PluginAPIStatistics) ProtoMessage 

func (*PluginAPIStatistics) ProtoMessage()

func (*PluginAPIStatistics) Reset 

func (m *PluginAPIStatistics) Reset()

func (*PluginAPIStatistics) String 

func (m *PluginAPIStatistics) String() string

func (*PluginAPIStatistics) XXX_DiscardUnknown 

func (m *PluginAPIStatistics) XXX_DiscardUnknown()

func (*PluginAPIStatistics) XXX_Marshal 

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

func (*PluginAPIStatistics) XXX_Merge 

func (m *PluginAPIStatistics) XXX_Merge(src proto.Message)

func (*PluginAPIStatistics) XXX_Size 

func (m *PluginAPIStatistics) XXX_Size() int

func (*PluginAPIStatistics) XXX_Unmarshal 

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

type RateLimitHistory 

type RateLimitHistory struct {
	//版本号变更
	Revision             []*RevisionHistory `protobuf:"bytes,1,rep,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

限流规则（各个单独限流规则的汇总）变更历史

func (*RateLimitHistory) Descriptor 

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

func (*RateLimitHistory) GetRevision 

func (m *RateLimitHistory) GetRevision() []*RevisionHistory

func (*RateLimitHistory) ProtoMessage 

func (*RateLimitHistory) ProtoMessage()

func (*RateLimitHistory) Reset 

func (m *RateLimitHistory) Reset()

func (*RateLimitHistory) String 

func (m *RateLimitHistory) String() string

func (*RateLimitHistory) XXX_DiscardUnknown 

func (m *RateLimitHistory) XXX_DiscardUnknown()

func (*RateLimitHistory) XXX_Marshal 

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

func (*RateLimitHistory) XXX_Merge 

func (m *RateLimitHistory) XXX_Merge(src proto.Message)

func (*RateLimitHistory) XXX_Size 

func (m *RateLimitHistory) XXX_Size() int

func (*RateLimitHistory) XXX_Unmarshal 

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

type RateLimitRecord 

type RateLimitRecord struct {
	//该条记录的唯一id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	//sdk标识
	SdkToken *SDKToken `protobuf:"bytes,2,opt,name=sdk_token,json=sdkToken,proto3" json:"sdk_token,omitempty"`
	//服务命名空间
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	//服务名
	Service string `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	//规则id
	RuleId string `protobuf:"bytes,5,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	//规则生效集群
	Subset string `protobuf:"bytes,6,opt,name=subset,proto3" json:"subset,omitempty"`
	//限流器
	RateLimiter string `protobuf:"bytes,7,opt,name=rate_limiter,json=rateLimiter,proto3" json:"rate_limiter,omitempty"`
	//限流的接口，使用不同lables代表不同接口
	Labels string `protobuf:"bytes,8,opt,name=labels,proto3" json:"labels,omitempty"`
	//周期限流次数
	LimitStats []*LimitStat `protobuf:"bytes,9,rep,name=limit_stats,json=limitStats,proto3" json:"limit_stats,omitempty"`
	//阈值变化事件
	ThresholdChanges []*ThresholdChange `protobuf:"bytes,10,rep,name=threshold_changes,json=thresholdChanges,proto3" json:"threshold_changes,omitempty"`
	//该限流规则的总请求次数和通过请求次数，在这份PB之后，客户端不要继续上报该字段，使用下面的request_counts字段
	RequestsCount *LimitRequestsCount `protobuf:"bytes,11,opt,name=requests_count,json=requestsCount,proto3" json:"requests_count,omitempty"`
	//不同模式下，该限流规则的总请求次数和通过请求次数
	RequestCounts        []*LimitRequestsCount `protobuf:"bytes,12,rep,name=request_counts,json=requestCounts,proto3" json:"request_counts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

限流记录

func (*RateLimitRecord) Descriptor 

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

func (*RateLimitRecord) GetId 

func (m *RateLimitRecord) GetId() string

func (*RateLimitRecord) GetLabels 

func (m *RateLimitRecord) GetLabels() string

func (*RateLimitRecord) GetLimitStats 

func (m *RateLimitRecord) GetLimitStats() []*LimitStat

func (*RateLimitRecord) GetNamespace 

func (m *RateLimitRecord) GetNamespace() string

func (*RateLimitRecord) GetRateLimiter 

func (m *RateLimitRecord) GetRateLimiter() string

func (*RateLimitRecord) GetRequestCounts 

func (m *RateLimitRecord) GetRequestCounts() []*LimitRequestsCount

func (*RateLimitRecord) GetRequestsCount 

func (m *RateLimitRecord) GetRequestsCount() *LimitRequestsCount

func (*RateLimitRecord) GetRuleId 

func (m *RateLimitRecord) GetRuleId() string

func (*RateLimitRecord) GetSdkToken 

func (m *RateLimitRecord) GetSdkToken() *SDKToken

func (*RateLimitRecord) GetService 

func (m *RateLimitRecord) GetService() string

func (*RateLimitRecord) GetSubset 

func (m *RateLimitRecord) GetSubset() string

func (*RateLimitRecord) GetThresholdChanges 

func (m *RateLimitRecord) GetThresholdChanges() []*ThresholdChange

func (*RateLimitRecord) ProtoMessage 

func (*RateLimitRecord) ProtoMessage()

func (*RateLimitRecord) Reset 

func (m *RateLimitRecord) Reset()

func (*RateLimitRecord) String 

func (m *RateLimitRecord) String() string

func (*RateLimitRecord) XXX_DiscardUnknown 

func (m *RateLimitRecord) XXX_DiscardUnknown()

func (*RateLimitRecord) XXX_Marshal 

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

func (*RateLimitRecord) XXX_Merge 

func (m *RateLimitRecord) XXX_Merge(src proto.Message)

func (*RateLimitRecord) XXX_Size 

func (m *RateLimitRecord) XXX_Size() int

func (*RateLimitRecord) XXX_Unmarshal 

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

type RecoverAllChange 

type RecoverAllChange struct {
	//发生全死全活时间
	Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	//发生全死全活的实例集合的信息，如共同metadata、共同位置等
	InstanceInfo string `protobuf:"bytes,2,opt,name=instance_info,json=instanceInfo,proto3" json:"instance_info,omitempty"`
	//全死全活是发生了还是结束了
	Change RecoverAllStatus `protobuf:"varint,3,opt,name=change,proto3,enum=v1.RecoverAllStatus" json:"change,omitempty"`
	//发生全死全活原因是什么
	Reason               string   `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

全死全活状态

func (*RecoverAllChange) Descriptor 

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

func (*RecoverAllChange) GetChange 

func (m *RecoverAllChange) GetChange() RecoverAllStatus

func (*RecoverAllChange) GetInstanceInfo 

func (m *RecoverAllChange) GetInstanceInfo() string

func (*RecoverAllChange) GetReason 

func (m *RecoverAllChange) GetReason() string

func (*RecoverAllChange) GetTime 

func (m *RecoverAllChange) GetTime() *timestamp.Timestamp

func (*RecoverAllChange) ProtoMessage 

func (*RecoverAllChange) ProtoMessage()

func (*RecoverAllChange) Reset 

func (m *RecoverAllChange) Reset()

func (*RecoverAllChange) String 

func (m *RecoverAllChange) String() string

func (*RecoverAllChange) XXX_DiscardUnknown 

func (m *RecoverAllChange) XXX_DiscardUnknown()

func (*RecoverAllChange) XXX_Marshal 

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

func (*RecoverAllChange) XXX_Merge 

func (m *RecoverAllChange) XXX_Merge(src proto.Message)

func (*RecoverAllChange) XXX_Size 

func (m *RecoverAllChange) XXX_Size() int

func (*RecoverAllChange) XXX_Unmarshal 

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

type RecoverAllStatus 

type RecoverAllStatus int32
const (
	RecoverAllStatus_Invalid RecoverAllStatus = 0
	//发生了全死全活
	RecoverAllStatus_Start RecoverAllStatus = 1
	//全死全活结束（由于服务实例状态的改变）
	RecoverAllStatus_End RecoverAllStatus = 2
)

func (RecoverAllStatus) EnumDescriptor 

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

func (RecoverAllStatus) String 

func (x RecoverAllStatus) String() string

type RevisionHistory 

type RevisionHistory struct {
	//变更时间
	Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	//变更的次序
	ChangeSeq uint32 `protobuf:"varint,2,opt,name=change_seq,json=changeSeq,proto3" json:"change_seq,omitempty"`
	//变更后版本号
	Revision string `protobuf:"bytes,3,opt,name=revision,proto3" json:"revision,omitempty"`
	//实例变化情况
	InstanceChange *InstancesChange `protobuf:"bytes,4,opt,name=instance_change,json=instanceChange,proto3" json:"instance_change,omitempty"`
	//网格服务变化情况
	MeshServiceChange    *MeshServicesChange `protobuf:"bytes,5,opt,name=mesh_service_change,json=meshServiceChange,proto3" json:"mesh_service_change,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

一次版本号变更

func (*RevisionHistory) Descriptor 

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

func (*RevisionHistory) GetChangeSeq 

func (m *RevisionHistory) GetChangeSeq() uint32

func (*RevisionHistory) GetInstanceChange 

func (m *RevisionHistory) GetInstanceChange() *InstancesChange

func (*RevisionHistory) GetMeshServiceChange 

func (m *RevisionHistory) GetMeshServiceChange() *MeshServicesChange

func (*RevisionHistory) GetRevision 

func (m *RevisionHistory) GetRevision() string

func (*RevisionHistory) GetTime 

func (m *RevisionHistory) GetTime() *timestamp.Timestamp

func (*RevisionHistory) ProtoMessage 

func (*RevisionHistory) ProtoMessage()

func (*RevisionHistory) Reset 

func (m *RevisionHistory) Reset()

func (*RevisionHistory) String 

func (m *RevisionHistory) String() string

func (*RevisionHistory) XXX_DiscardUnknown 

func (m *RevisionHistory) XXX_DiscardUnknown()

func (*RevisionHistory) XXX_Marshal 

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

func (*RevisionHistory) XXX_Merge 

func (m *RevisionHistory) XXX_Merge(src proto.Message)

func (*RevisionHistory) XXX_Size 

func (m *RevisionHistory) XXX_Size() int

func (*RevisionHistory) XXX_Unmarshal 

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

type RouteRecord 

type RouteRecord struct {
	//使用这个规则的插件名字
	PluginName string `protobuf:"bytes,1,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"`
	//各种不同返回码的结果
	Results []*RouteResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	//主调服务命名空间
	SrcNamespace string `protobuf:"bytes,3,opt,name=src_namespace,json=srcNamespace,proto3" json:"src_namespace,omitempty"`
	//主调服务名
	SrcService           string               `protobuf:"bytes,4,opt,name=src_service,json=srcService,proto3" json:"src_service,omitempty"`
	RuleType             RouteRecord_RuleType `protobuf:"varint,5,opt,name=rule_type,json=ruleType,proto3,enum=v1.RouteRecord_RuleType" json:"rule_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

路由规则调用记录

func (*RouteRecord) Descriptor 

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

func (*RouteRecord) GetPluginName 

func (m *RouteRecord) GetPluginName() string

func (*RouteRecord) GetResults 

func (m *RouteRecord) GetResults() []*RouteResult

func (*RouteRecord) GetRuleType 

func (m *RouteRecord) GetRuleType() RouteRecord_RuleType

func (*RouteRecord) GetSrcNamespace 

func (m *RouteRecord) GetSrcNamespace() string

func (*RouteRecord) GetSrcService 

func (m *RouteRecord) GetSrcService() string

func (*RouteRecord) ProtoMessage 

func (*RouteRecord) ProtoMessage()

func (*RouteRecord) Reset 

func (m *RouteRecord) Reset()

func (*RouteRecord) String 

func (m *RouteRecord) String() string

func (*RouteRecord) XXX_DiscardUnknown 

func (m *RouteRecord) XXX_DiscardUnknown()

func (*RouteRecord) XXX_Marshal 

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

func (*RouteRecord) XXX_Merge 

func (m *RouteRecord) XXX_Merge(src proto.Message)

func (*RouteRecord) XXX_Size 

func (m *RouteRecord) XXX_Size() int

func (*RouteRecord) XXX_Unmarshal 

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

type RouteRecord_RuleType 

type RouteRecord_RuleType int32

规则类型，现在就规则路由要区分主调规则还是被调规则 

const (
	RouteRecord_Unknown  RouteRecord_RuleType = 0
	RouteRecord_DestRule RouteRecord_RuleType = 1
	RouteRecord_SrcRule  RouteRecord_RuleType = 2
)

func (RouteRecord_RuleType) EnumDescriptor 

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

func (RouteRecord_RuleType) String 

func (x RouteRecord_RuleType) String() string

type RouteResult 

type RouteResult struct {
	//返回码
	RetCode string `protobuf:"bytes,1,opt,name=ret_code,json=retCode,proto3" json:"ret_code,omitempty"`
	//一个周期内的这种返回码的调用次数
	PeriodTimes uint32 `protobuf:"varint,2,opt,name=period_times,json=periodTimes,proto3" json:"period_times,omitempty"`
	//路由状态，如是否发生了就近降级，是否是全活状态
	RouteStatus string `protobuf:"bytes,3,opt,name=route_status,json=routeStatus,proto3" json:"route_status,omitempty"`
	//路由返回的cluster结果
	Cluster              string   `protobuf:"bytes,4,opt,name=cluster,proto3" json:"cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

路由调用结果

func (*RouteResult) Descriptor 

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

func (*RouteResult) GetCluster 

func (m *RouteResult) GetCluster() string

func (*RouteResult) GetPeriodTimes 

func (m *RouteResult) GetPeriodTimes() uint32

func (*RouteResult) GetRetCode 

func (m *RouteResult) GetRetCode() string

func (*RouteResult) GetRouteStatus 

func (m *RouteResult) GetRouteStatus() string

func (*RouteResult) ProtoMessage 

func (*RouteResult) ProtoMessage()

func (*RouteResult) Reset 

func (m *RouteResult) Reset()

func (*RouteResult) String 

func (m *RouteResult) String() string

func (*RouteResult) XXX_DiscardUnknown 

func (m *RouteResult) XXX_DiscardUnknown()

func (*RouteResult) XXX_Marshal 

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

func (*RouteResult) XXX_Merge 

func (m *RouteResult) XXX_Merge(src proto.Message)

func (*RouteResult) XXX_Size 

func (m *RouteResult) XXX_Size() int

func (*RouteResult) XXX_Unmarshal 

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

type RoutingHistory 

type RoutingHistory struct {
	//版本号变更
	Revision             []*RevisionHistory `protobuf:"bytes,1,rep,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

路由变更历史

func (*RoutingHistory) Descriptor 

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

func (*RoutingHistory) GetRevision 

func (m *RoutingHistory) GetRevision() []*RevisionHistory

func (*RoutingHistory) ProtoMessage 

func (*RoutingHistory) ProtoMessage()

func (*RoutingHistory) Reset 

func (m *RoutingHistory) Reset()

func (*RoutingHistory) String 

func (m *RoutingHistory) String() string

func (*RoutingHistory) XXX_DiscardUnknown 

func (m *RoutingHistory) XXX_DiscardUnknown()

func (*RoutingHistory) XXX_Marshal 

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

func (*RoutingHistory) XXX_Merge 

func (m *RoutingHistory) XXX_Merge(src proto.Message)

func (*RoutingHistory) XXX_Size 

func (m *RoutingHistory) XXX_Size() int

func (*RoutingHistory) XXX_Unmarshal 

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

type SDKAPIStatistics 

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

SDK上报的API调用统计

func (*SDKAPIStatistics) Descriptor 

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

func (*SDKAPIStatistics) GetId 

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

func (*SDKAPIStatistics) GetKey 

func (m *SDKAPIStatistics) GetKey() *SDKAPIStatisticsKey

func (*SDKAPIStatistics) GetValue 

func (m *SDKAPIStatistics) GetValue() *Indicator

func (*SDKAPIStatistics) ProtoMessage 

func (*SDKAPIStatistics) ProtoMessage()

func (*SDKAPIStatistics) Reset 

func (m *SDKAPIStatistics) Reset()

func (*SDKAPIStatistics) String 

func (m *SDKAPIStatistics) String() string

func (*SDKAPIStatistics) XXX_DiscardUnknown 

func (m *SDKAPIStatistics) XXX_DiscardUnknown()

func (*SDKAPIStatistics) XXX_Marshal 

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

func (*SDKAPIStatistics) XXX_Merge 

func (m *SDKAPIStatistics) XXX_Merge(src proto.Message)

func (*SDKAPIStatistics) XXX_Size 

func (m *SDKAPIStatistics) XXX_Size() int

func (*SDKAPIStatistics) XXX_Unmarshal 

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

type SDKAPIStatisticsKey 

type SDKAPIStatisticsKey struct {
	ClientHost           *wrappers.StringValue `protobuf:"bytes,1,opt,name=client_host,json=clientHost,proto3" json:"client_host,omitempty"`
	SdkApi               *wrappers.StringValue `protobuf:"bytes,2,opt,name=sdk_api,json=sdkApi,proto3" json:"sdk_api,omitempty"`
	ResCode              *wrappers.StringValue `protobuf:"bytes,3,opt,name=res_code,json=resCode,proto3" json:"res_code,omitempty"`
	Success              *wrappers.BoolValue   `protobuf:"bytes,4,opt,name=success,proto3" json:"success,omitempty"`
	DelayRange           *wrappers.StringValue `protobuf:"bytes,5,opt,name=delay_range,json=delayRange,proto3" json:"delay_range,omitempty"`
	ClientVersion        *wrappers.StringValue `protobuf:"bytes,6,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`
	ClientType           *wrappers.StringValue `protobuf:"bytes,7,opt,name=client_type,json=clientType,proto3" json:"client_type,omitempty"`
	Result               APIResultType         `protobuf:"varint,8,opt,name=result,proto3,enum=v1.APIResultType" json:"result,omitempty"`
	Uid                  string                `protobuf:"bytes,9,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*SDKAPIStatisticsKey) Descriptor 

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

func (*SDKAPIStatisticsKey) GetClientHost 

func (m *SDKAPIStatisticsKey) GetClientHost() *wrappers.StringValue

func (*SDKAPIStatisticsKey) GetClientType 

func (m *SDKAPIStatisticsKey) GetClientType() *wrappers.StringValue

func (*SDKAPIStatisticsKey) GetClientVersion 

func (m *SDKAPIStatisticsKey) GetClientVersion() *wrappers.StringValue

func (*SDKAPIStatisticsKey) GetDelayRange 

func (m *SDKAPIStatisticsKey) GetDelayRange() *wrappers.StringValue

func (*SDKAPIStatisticsKey) GetResCode 

func (m *SDKAPIStatisticsKey) GetResCode() *wrappers.StringValue

func (*SDKAPIStatisticsKey) GetResult 

func (m *SDKAPIStatisticsKey) GetResult() APIResultType

func (*SDKAPIStatisticsKey) GetSdkApi 

func (m *SDKAPIStatisticsKey) GetSdkApi() *wrappers.StringValue

func (*SDKAPIStatisticsKey) GetSuccess 

func (m *SDKAPIStatisticsKey) GetSuccess() *wrappers.BoolValue

func (*SDKAPIStatisticsKey) GetUid 

func (m *SDKAPIStatisticsKey) GetUid() string

func (*SDKAPIStatisticsKey) ProtoMessage 

func (*SDKAPIStatisticsKey) ProtoMessage()

func (*SDKAPIStatisticsKey) Reset 

func (m *SDKAPIStatisticsKey) Reset()

func (*SDKAPIStatisticsKey) String 

func (m *SDKAPIStatisticsKey) String() string

func (*SDKAPIStatisticsKey) XXX_DiscardUnknown 

func (m *SDKAPIStatisticsKey) XXX_DiscardUnknown()

func (*SDKAPIStatisticsKey) XXX_Marshal 

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

func (*SDKAPIStatisticsKey) XXX_Merge 

func (m *SDKAPIStatisticsKey) XXX_Merge(src proto.Message)

func (*SDKAPIStatisticsKey) XXX_Size 

func (m *SDKAPIStatisticsKey) XXX_Size() int

func (*SDKAPIStatisticsKey) XXX_Unmarshal 

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

type SDKConfig 

type SDKConfig struct {
	Token                *SDKToken            `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Config               string               `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	TakeEffectTime       *timestamp.Timestamp `protobuf:"bytes,3,opt,name=take_effect_time,json=takeEffectTime,proto3" json:"take_effect_time,omitempty"`
	Location             string               `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"`
	Version              string               `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Client               string               `protobuf:"bytes,6,opt,name=client,proto3" json:"client,omitempty"`
	Plugins              string               `protobuf:"bytes,7,opt,name=plugins,proto3" json:"plugins,omitempty"`
	InitFinishTime       *timestamp.Timestamp `protobuf:"bytes,8,opt,name=init_finish_time,json=initFinishTime,proto3" json:"init_finish_time,omitempty"`
	ReportTime           *timestamp.Timestamp `protobuf:"bytes,9,opt,name=report_time,json=reportTime,proto3" json:"report_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

SDK的配置信息

func (*SDKConfig) Descriptor 

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

func (*SDKConfig) GetClient 

func (m *SDKConfig) GetClient() string

func (*SDKConfig) GetConfig 

func (m *SDKConfig) GetConfig() string

func (*SDKConfig) GetInitFinishTime 

func (m *SDKConfig) GetInitFinishTime() *timestamp.Timestamp

func (*SDKConfig) GetLocation 

func (m *SDKConfig) GetLocation() string

func (*SDKConfig) GetPlugins 

func (m *SDKConfig) GetPlugins() string

func (*SDKConfig) GetReportTime 

func (m *SDKConfig) GetReportTime() *timestamp.Timestamp

func (*SDKConfig) GetTakeEffectTime 

func (m *SDKConfig) GetTakeEffectTime() *timestamp.Timestamp

func (*SDKConfig) GetToken 

func (m *SDKConfig) GetToken() *SDKToken

func (*SDKConfig) GetVersion 

func (m *SDKConfig) GetVersion() string

func (*SDKConfig) ProtoMessage 

func (*SDKConfig) ProtoMessage()

func (*SDKConfig) Reset 

func (m *SDKConfig) Reset()

func (*SDKConfig) String 

func (m *SDKConfig) String() string

func (*SDKConfig) XXX_DiscardUnknown 

func (m *SDKConfig) XXX_DiscardUnknown()

func (*SDKConfig) XXX_Marshal 

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

func (*SDKConfig) XXX_Merge 

func (m *SDKConfig) XXX_Merge(src proto.Message)

func (*SDKConfig) XXX_Size 

func (m *SDKConfig) XXX_Size() int

func (*SDKConfig) XXX_Unmarshal 

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

type SDKToken 

type SDKToken struct {
	Ip      string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Pid     uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	Uid     string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"`
	Client  string `protobuf:"bytes,4,opt,name=client,proto3" json:"client,omitempty"`
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	//该sdkContext所属进程运行的容器pod
	PodName string `protobuf:"bytes,6,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	//该sdkContext所属进程所属容器或者机器的hostname
	HostName             string   `protobuf:"bytes,7,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SDK的唯一标识

func (*SDKToken) Descriptor 

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

func (*SDKToken) GetClient 

func (m *SDKToken) GetClient() string

func (*SDKToken) GetHostName 

func (m *SDKToken) GetHostName() string

func (*SDKToken) GetIp 

func (m *SDKToken) GetIp() string

func (*SDKToken) GetPid 

func (m *SDKToken) GetPid() uint32

func (*SDKToken) GetPodName 

func (m *SDKToken) GetPodName() string

func (*SDKToken) GetUid 

func (m *SDKToken) GetUid() string

func (*SDKToken) GetVersion 

func (m *SDKToken) GetVersion() string

func (*SDKToken) ProtoMessage 

func (*SDKToken) ProtoMessage()

func (*SDKToken) Reset 

func (m *SDKToken) Reset()

func (*SDKToken) String 

func (m *SDKToken) String() string

func (*SDKToken) XXX_DiscardUnknown 

func (m *SDKToken) XXX_DiscardUnknown()

func (*SDKToken) XXX_Marshal 

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

func (*SDKToken) XXX_Merge 

func (m *SDKToken) XXX_Merge(src proto.Message)

func (*SDKToken) XXX_Size 

func (m *SDKToken) XXX_Size() int

func (*SDKToken) XXX_Unmarshal 

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

type ServerStatistics 

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

polaris server上报的统计数据

func (*ServerStatistics) Descriptor 

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

func (*ServerStatistics) GetId 

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

func (*ServerStatistics) GetKey 

func (m *ServerStatistics) GetKey() *ServerStatisticsKey

func (*ServerStatistics) GetValue 

func (m *ServerStatistics) GetValue() *Indicator

func (*ServerStatistics) ProtoMessage 

func (*ServerStatistics) ProtoMessage()

func (*ServerStatistics) Reset 

func (m *ServerStatistics) Reset()

func (*ServerStatistics) String 

func (m *ServerStatistics) String() string

func (*ServerStatistics) XXX_DiscardUnknown 

func (m *ServerStatistics) XXX_DiscardUnknown()

func (*ServerStatistics) XXX_Marshal 

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

func (*ServerStatistics) XXX_Merge 

func (m *ServerStatistics) XXX_Merge(src proto.Message)

func (*ServerStatistics) XXX_Size 

func (m *ServerStatistics) XXX_Size() int

func (*ServerStatistics) XXX_Unmarshal 

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

type ServerStatisticsKey 

type ServerStatisticsKey struct {
	ServerHost           *wrappers.StringValue `protobuf:"bytes,1,opt,name=server_host,json=serverHost,proto3" json:"server_host,omitempty"`
	Resource             *wrappers.StringValue `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	Operation            *wrappers.StringValue `protobuf:"bytes,3,opt,name=operation,proto3" json:"operation,omitempty"`
	Code                 *wrappers.StringValue `protobuf:"bytes,4,opt,name=code,proto3" json:"code,omitempty"`
	Success              *wrappers.BoolValue   `protobuf:"bytes,5,opt,name=success,proto3" json:"success,omitempty"`
	DelayRange           *wrappers.StringValue `protobuf:"bytes,6,opt,name=delay_range,json=delayRange,proto3" json:"delay_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ServerStatisticsKey) Descriptor 

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

func (*ServerStatisticsKey) GetCode 

func (m *ServerStatisticsKey) GetCode() *wrappers.StringValue

func (*ServerStatisticsKey) GetDelayRange 

func (m *ServerStatisticsKey) GetDelayRange() *wrappers.StringValue

func (*ServerStatisticsKey) GetOperation 

func (m *ServerStatisticsKey) GetOperation() *wrappers.StringValue

func (*ServerStatisticsKey) GetResource 

func (m *ServerStatisticsKey) GetResource() *wrappers.StringValue

func (*ServerStatisticsKey) GetServerHost 

func (m *ServerStatisticsKey) GetServerHost() *wrappers.StringValue

func (*ServerStatisticsKey) GetSuccess 

func (m *ServerStatisticsKey) GetSuccess() *wrappers.BoolValue

func (*ServerStatisticsKey) ProtoMessage 

func (*ServerStatisticsKey) ProtoMessage()

func (*ServerStatisticsKey) Reset 

func (m *ServerStatisticsKey) Reset()

func (*ServerStatisticsKey) String 

func (m *ServerStatisticsKey) String() string

func (*ServerStatisticsKey) XXX_DiscardUnknown 

func (m *ServerStatisticsKey) XXX_DiscardUnknown()

func (*ServerStatisticsKey) XXX_Marshal 

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

func (*ServerStatisticsKey) XXX_Merge 

func (m *ServerStatisticsKey) XXX_Merge(src proto.Message)

func (*ServerStatisticsKey) XXX_Size 

func (m *ServerStatisticsKey) XXX_Size() int

func (*ServerStatisticsKey) XXX_Unmarshal 

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

type ServiceCircuitbreak 

type ServiceCircuitbreak struct {
	//该条记录的唯一id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	//sdk标识
	SdkToken  *SDKToken `protobuf:"bytes,2,opt,name=sdk_token,json=sdkToken,proto3" json:"sdk_token,omitempty"`
	Namespace string    `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Service   string    `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	//发生全死全活的情况
	RecoverAll []*RecoverAllChange `protobuf:"bytes,5,rep,name=recover_all,json=recoverAll,proto3" json:"recover_all,omitempty"`
	//实例熔断情况
	InstanceCircuitbreak []*CircuitbreakHistory `protobuf:"bytes,6,rep,name=instance_circuitbreak,json=instanceCircuitbreak,proto3" json:"instance_circuitbreak,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

一个服务一个周期的熔断变化情况

func (*ServiceCircuitbreak) Descriptor 

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

func (*ServiceCircuitbreak) GetId 

func (m *ServiceCircuitbreak) GetId() string

func (*ServiceCircuitbreak) GetInstanceCircuitbreak 

func (m *ServiceCircuitbreak) GetInstanceCircuitbreak() []*CircuitbreakHistory

func (*ServiceCircuitbreak) GetNamespace 

func (m *ServiceCircuitbreak) GetNamespace() string

func (*ServiceCircuitbreak) GetRecoverAll 

func (m *ServiceCircuitbreak) GetRecoverAll() []*RecoverAllChange

func (*ServiceCircuitbreak) GetSdkToken 

func (m *ServiceCircuitbreak) GetSdkToken() *SDKToken

func (*ServiceCircuitbreak) GetService 

func (m *ServiceCircuitbreak) GetService() string

func (*ServiceCircuitbreak) ProtoMessage 

func (*ServiceCircuitbreak) ProtoMessage()

func (*ServiceCircuitbreak) Reset 

func (m *ServiceCircuitbreak) Reset()

func (*ServiceCircuitbreak) String 

func (m *ServiceCircuitbreak) String() string

func (*ServiceCircuitbreak) XXX_DiscardUnknown 

func (m *ServiceCircuitbreak) XXX_DiscardUnknown()

func (*ServiceCircuitbreak) XXX_Marshal 

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

func (*ServiceCircuitbreak) XXX_Merge 

func (m *ServiceCircuitbreak) XXX_Merge(src proto.Message)

func (*ServiceCircuitbreak) XXX_Size 

func (m *ServiceCircuitbreak) XXX_Size() int

func (*ServiceCircuitbreak) XXX_Unmarshal 

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

type ServiceIndicator 

type ServiceIndicator struct {
	TotalRequestPerMinute *wrappers.UInt32Value `` /* 128-byte string literal not displayed */
	TotalDelayPerMinute   *wrappers.UInt64Value `protobuf:"bytes,2,opt,name=total_delay_per_minute,json=totalDelayPerMinute,proto3" json:"total_delay_per_minute,omitempty"`
	XXX_NoUnkeyedLiteral  struct{}              `json:"-"`
	XXX_unrecognized      []byte                `json:"-"`
	XXX_sizecache         int32                 `json:"-"`
}

服务调用的上报指标

func (*ServiceIndicator) Descriptor 

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

func (*ServiceIndicator) GetTotalDelayPerMinute 

func (m *ServiceIndicator) GetTotalDelayPerMinute() *wrappers.UInt64Value

func (*ServiceIndicator) GetTotalRequestPerMinute 

func (m *ServiceIndicator) GetTotalRequestPerMinute() *wrappers.UInt32Value

func (*ServiceIndicator) ProtoMessage 

func (*ServiceIndicator) ProtoMessage()

func (*ServiceIndicator) Reset 

func (m *ServiceIndicator) Reset()

func (*ServiceIndicator) String 

func (m *ServiceIndicator) String() string

func (*ServiceIndicator) XXX_DiscardUnknown 

func (m *ServiceIndicator) XXX_DiscardUnknown()

func (*ServiceIndicator) XXX_Marshal 

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

func (*ServiceIndicator) XXX_Merge 

func (m *ServiceIndicator) XXX_Merge(src proto.Message)

func (*ServiceIndicator) XXX_Size 

func (m *ServiceIndicator) XXX_Size() int

func (*ServiceIndicator) XXX_Unmarshal 

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

type ServiceInfo 

type ServiceInfo struct {
	//该条记录的唯一id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	//sdk标识
	SdkToken  *SDKToken `protobuf:"bytes,2,opt,name=sdk_token,json=sdkToken,proto3" json:"sdk_token,omitempty"`
	Namespace string    `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Service   string    `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	//服务实例的版本变化
	InstancesHistory *InstancesHistory `protobuf:"bytes,5,opt,name=instances_history,json=instancesHistory,proto3" json:"instances_history,omitempty"`
	//服务的实例数据已从sdk中删除（过期淘汰或者server删除了）
	InstanceEliminated bool `protobuf:"varint,6,opt,name=instance_eliminated,json=instanceEliminated,proto3" json:"instance_eliminated,omitempty"`
	//该服务对应的路由变化情况
	RoutingHistory *RoutingHistory `protobuf:"bytes,7,opt,name=routing_history,json=routingHistory,proto3" json:"routing_history,omitempty"`
	//服务的路由数据已从sdk中删除（过期淘汰或者server删除了）
	RoutingEliminated bool `protobuf:"varint,8,opt,name=routing_eliminated,json=routingEliminated,proto3" json:"routing_eliminated,omitempty"`
	//服务对应的限流规则版本
	RateLimitHistory *RateLimitHistory `protobuf:"bytes,9,opt,name=rate_limit_history,json=rateLimitHistory,proto3" json:"rate_limit_history,omitempty"`
	//各个单独限流规则的版本变更历史
	SingleRateLimitHistories []*SingleRateLimitRuleHistory `` /* 138-byte string literal not displayed */
	//服务的限流规则数据已从sdk中删除（过期淘汰或者server删除了）
	RateLimitEliminated  bool     `protobuf:"varint,11,opt,name=rate_limit_eliminated,json=rateLimitEliminated,proto3" json:"rate_limit_eliminated,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

上报的服务信息

func (*ServiceInfo) Descriptor 

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

func (*ServiceInfo) GetId 

func (m *ServiceInfo) GetId() string

func (*ServiceInfo) GetInstanceEliminated 

func (m *ServiceInfo) GetInstanceEliminated() bool

func (*ServiceInfo) GetInstancesHistory 

func (m *ServiceInfo) GetInstancesHistory() *InstancesHistory

func (*ServiceInfo) GetNamespace 

func (m *ServiceInfo) GetNamespace() string

func (*ServiceInfo) GetRateLimitEliminated 

func (m *ServiceInfo) GetRateLimitEliminated() bool

func (*ServiceInfo) GetRateLimitHistory 

func (m *ServiceInfo) GetRateLimitHistory() *RateLimitHistory

func (*ServiceInfo) GetRoutingEliminated 

func (m *ServiceInfo) GetRoutingEliminated() bool

func (*ServiceInfo) GetRoutingHistory 

func (m *ServiceInfo) GetRoutingHistory() *RoutingHistory

func (*ServiceInfo) GetSdkToken 

func (m *ServiceInfo) GetSdkToken() *SDKToken

func (*ServiceInfo) GetService 

func (m *ServiceInfo) GetService() string

func (*ServiceInfo) GetSingleRateLimitHistories 

func (m *ServiceInfo) GetSingleRateLimitHistories() []*SingleRateLimitRuleHistory

func (*ServiceInfo) ProtoMessage 

func (*ServiceInfo) ProtoMessage()

func (*ServiceInfo) Reset 

func (m *ServiceInfo) Reset()

func (*ServiceInfo) String 

func (m *ServiceInfo) String() string

func (*ServiceInfo) XXX_DiscardUnknown 

func (m *ServiceInfo) XXX_DiscardUnknown()

func (*ServiceInfo) XXX_Marshal 

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

func (*ServiceInfo) XXX_Merge 

func (m *ServiceInfo) XXX_Merge(src proto.Message)

func (*ServiceInfo) XXX_Size 

func (m *ServiceInfo) XXX_Size() int

func (*ServiceInfo) XXX_Unmarshal 

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

type ServiceLoadBalanceInfo 

type ServiceLoadBalanceInfo struct {
	Id                   string                     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Token                *SDKToken                  `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Namespace            string                     `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Service              string                     `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	Loadbalancer         string                     `protobuf:"bytes,5,opt,name=loadbalancer,proto3" json:"loadbalancer,omitempty"`
	TotalChooseNum       uint32                     `protobuf:"varint,6,opt,name=total_choose_num,json=totalChooseNum,proto3" json:"total_choose_num,omitempty"`
	InstanceInfo         []*InstanceLoadBalanceInfo `protobuf:"bytes,7,rep,name=instance_info,json=instanceInfo,proto3" json:"instance_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ServiceLoadBalanceInfo) Descriptor 

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

func (*ServiceLoadBalanceInfo) GetId 

func (m *ServiceLoadBalanceInfo) GetId() string

func (*ServiceLoadBalanceInfo) GetInstanceInfo 

func (m *ServiceLoadBalanceInfo) GetInstanceInfo() []*InstanceLoadBalanceInfo

func (*ServiceLoadBalanceInfo) GetLoadbalancer 

func (m *ServiceLoadBalanceInfo) GetLoadbalancer() string

func (*ServiceLoadBalanceInfo) GetNamespace 

func (m *ServiceLoadBalanceInfo) GetNamespace() string

func (*ServiceLoadBalanceInfo) GetService 

func (m *ServiceLoadBalanceInfo) GetService() string

func (*ServiceLoadBalanceInfo) GetToken 

func (m *ServiceLoadBalanceInfo) GetToken() *SDKToken

func (*ServiceLoadBalanceInfo) GetTotalChooseNum 

func (m *ServiceLoadBalanceInfo) GetTotalChooseNum() uint32

func (*ServiceLoadBalanceInfo) ProtoMessage 

func (*ServiceLoadBalanceInfo) ProtoMessage()

func (*ServiceLoadBalanceInfo) Reset 

func (m *ServiceLoadBalanceInfo) Reset()

func (*ServiceLoadBalanceInfo) String 

func (m *ServiceLoadBalanceInfo) String() string

func (*ServiceLoadBalanceInfo) XXX_DiscardUnknown 

func (m *ServiceLoadBalanceInfo) XXX_DiscardUnknown()

func (*ServiceLoadBalanceInfo) XXX_Marshal 

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

func (*ServiceLoadBalanceInfo) XXX_Merge 

func (m *ServiceLoadBalanceInfo) XXX_Merge(src proto.Message)

func (*ServiceLoadBalanceInfo) XXX_Size 

func (m *ServiceLoadBalanceInfo) XXX_Size() int

func (*ServiceLoadBalanceInfo) XXX_Unmarshal 

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

type ServiceRouteRecord 

type ServiceRouteRecord struct {
	//该条记录的唯一id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	//sdk标识
	SdkToken *SDKToken `protobuf:"bytes,2,opt,name=sdk_token,json=sdkToken,proto3" json:"sdk_token,omitempty"`
	//命名空间
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	//服务名
	Service string `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	//上报的时间
	Time *timestamp.Timestamp `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	//路由规则调用记录
	Records              []*RouteRecord `protobuf:"bytes,6,rep,name=records,proto3" json:"records,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

一个服务不同类型路由规则调用记录

func (*ServiceRouteRecord) Descriptor 

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

func (*ServiceRouteRecord) GetId 

func (m *ServiceRouteRecord) GetId() string

func (*ServiceRouteRecord) GetNamespace 

func (m *ServiceRouteRecord) GetNamespace() string

func (*ServiceRouteRecord) GetRecords 

func (m *ServiceRouteRecord) GetRecords() []*RouteRecord

func (*ServiceRouteRecord) GetSdkToken 

func (m *ServiceRouteRecord) GetSdkToken() *SDKToken

func (*ServiceRouteRecord) GetService 

func (m *ServiceRouteRecord) GetService() string

func (*ServiceRouteRecord) GetTime 

func (m *ServiceRouteRecord) GetTime() *timestamp.Timestamp

func (*ServiceRouteRecord) ProtoMessage 

func (*ServiceRouteRecord) ProtoMessage()

func (*ServiceRouteRecord) Reset 

func (m *ServiceRouteRecord) Reset()

func (*ServiceRouteRecord) String 

func (m *ServiceRouteRecord) String() string

func (*ServiceRouteRecord) XXX_DiscardUnknown 

func (m *ServiceRouteRecord) XXX_DiscardUnknown()

func (*ServiceRouteRecord) XXX_Marshal 

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

func (*ServiceRouteRecord) XXX_Merge 

func (m *ServiceRouteRecord) XXX_Merge(src proto.Message)

func (*ServiceRouteRecord) XXX_Size 

func (m *ServiceRouteRecord) XXX_Size() int

func (*ServiceRouteRecord) XXX_Unmarshal 

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

type ServiceStatistics 

type ServiceStatistics struct {
	Id                   *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key                  *ServiceStatisticsKey `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                *ServiceIndicator     `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	SdkToken             *SDKToken             `protobuf:"bytes,4,opt,name=sdk_token,json=sdkToken,proto3" json:"sdk_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

SDK上报的服务调用统计

func (*ServiceStatistics) Descriptor 

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

func (*ServiceStatistics) GetId 

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

func (*ServiceStatistics) GetKey 

func (m *ServiceStatistics) GetKey() *ServiceStatisticsKey

func (*ServiceStatistics) GetSdkToken 

func (m *ServiceStatistics) GetSdkToken() *SDKToken

func (*ServiceStatistics) GetValue 

func (m *ServiceStatistics) GetValue() *ServiceIndicator

func (*ServiceStatistics) ProtoMessage 

func (*ServiceStatistics) ProtoMessage()

func (*ServiceStatistics) Reset 

func (m *ServiceStatistics) Reset()

func (*ServiceStatistics) String 

func (m *ServiceStatistics) String() string

func (*ServiceStatistics) XXX_DiscardUnknown 

func (m *ServiceStatistics) XXX_DiscardUnknown()

func (*ServiceStatistics) XXX_Marshal 

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

func (*ServiceStatistics) XXX_Merge 

func (m *ServiceStatistics) XXX_Merge(src proto.Message)

func (*ServiceStatistics) XXX_Size 

func (m *ServiceStatistics) XXX_Size() int

func (*ServiceStatistics) XXX_Unmarshal 

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

type ServiceStatisticsKey 

type ServiceStatisticsKey struct {
	CallerHost           *wrappers.StringValue `protobuf:"bytes,1,opt,name=caller_host,json=callerHost,proto3" json:"caller_host,omitempty"`
	Namespace            *wrappers.StringValue `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Service              *wrappers.StringValue `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	InstanceHost         *wrappers.StringValue `protobuf:"bytes,4,opt,name=instance_host,json=instanceHost,proto3" json:"instance_host,omitempty"`
	Success              *wrappers.BoolValue   `protobuf:"bytes,5,opt,name=success,proto3" json:"success,omitempty"`
	ResCode              int32                 `protobuf:"varint,6,opt,name=res_code,json=resCode,proto3" json:"res_code,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

服务调用的上报维度

func (*ServiceStatisticsKey) Descriptor 

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

func (*ServiceStatisticsKey) GetCallerHost 

func (m *ServiceStatisticsKey) GetCallerHost() *wrappers.StringValue

func (*ServiceStatisticsKey) GetInstanceHost 

func (m *ServiceStatisticsKey) GetInstanceHost() *wrappers.StringValue

func (*ServiceStatisticsKey) GetNamespace 

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

func (*ServiceStatisticsKey) GetResCode 

func (m *ServiceStatisticsKey) GetResCode() int32

func (*ServiceStatisticsKey) GetService 

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

func (*ServiceStatisticsKey) GetSuccess 

func (m *ServiceStatisticsKey) GetSuccess() *wrappers.BoolValue

func (*ServiceStatisticsKey) ProtoMessage 

func (*ServiceStatisticsKey) ProtoMessage()

func (*ServiceStatisticsKey) Reset 

func (m *ServiceStatisticsKey) Reset()

func (*ServiceStatisticsKey) String 

func (m *ServiceStatisticsKey) String() string

func (*ServiceStatisticsKey) XXX_DiscardUnknown 

func (m *ServiceStatisticsKey) XXX_DiscardUnknown()

func (*ServiceStatisticsKey) XXX_Marshal 

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

func (*ServiceStatisticsKey) XXX_Merge 

func (m *ServiceStatisticsKey) XXX_Merge(src proto.Message)

func (*ServiceStatisticsKey) XXX_Size 

func (m *ServiceStatisticsKey) XXX_Size() int

func (*ServiceStatisticsKey) XXX_Unmarshal 

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

type SingleMeshResourceRuleHistory 

type SingleMeshResourceRuleHistory struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Revision             []*RevisionHistory `protobuf:"bytes,2,rep,name=revision,proto3" json:"revision,omitempty"`
	MeshResourceDeleted  bool               `protobuf:"varint,3,opt,name=mesh_resource_deleted,json=meshResourceDeleted,proto3" json:"mesh_resource_deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

单个网格规则的版本变更记录

func (*SingleMeshResourceRuleHistory) Descriptor 

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

func (*SingleMeshResourceRuleHistory) GetMeshResourceDeleted 

func (m *SingleMeshResourceRuleHistory) GetMeshResourceDeleted() bool

func (*SingleMeshResourceRuleHistory) GetName 

func (m *SingleMeshResourceRuleHistory) GetName() string

func (*SingleMeshResourceRuleHistory) GetRevision 

func (m *SingleMeshResourceRuleHistory) GetRevision() []*RevisionHistory

func (*SingleMeshResourceRuleHistory) ProtoMessage 

func (*SingleMeshResourceRuleHistory) ProtoMessage()

func (*SingleMeshResourceRuleHistory) Reset 

func (m *SingleMeshResourceRuleHistory) Reset()

func (*SingleMeshResourceRuleHistory) String 

func (m *SingleMeshResourceRuleHistory) String() string

func (*SingleMeshResourceRuleHistory) XXX_DiscardUnknown 

func (m *SingleMeshResourceRuleHistory) XXX_DiscardUnknown()

func (*SingleMeshResourceRuleHistory) XXX_Marshal 

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

func (*SingleMeshResourceRuleHistory) XXX_Merge 

func (m *SingleMeshResourceRuleHistory) XXX_Merge(src proto.Message)

func (*SingleMeshResourceRuleHistory) XXX_Size 

func (m *SingleMeshResourceRuleHistory) XXX_Size() int

func (*SingleMeshResourceRuleHistory) XXX_Unmarshal 

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

type SingleMeshServiceHistory 

type SingleMeshServiceHistory struct {
	MeshNamespace        string             `protobuf:"bytes,1,opt,name=mesh_namespace,json=meshNamespace,proto3" json:"mesh_namespace,omitempty"`
	MeshService          string             `protobuf:"bytes,2,opt,name=mesh_service,json=meshService,proto3" json:"mesh_service,omitempty"`
	Revision             []*RevisionHistory `protobuf:"bytes,3,rep,name=revision,proto3" json:"revision,omitempty"`
	MeshServiceDeleted   bool               `protobuf:"varint,4,opt,name=mesh_service_deleted,json=meshServiceDeleted,proto3" json:"mesh_service_deleted,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

一个网格服务的版本变化情况

func (*SingleMeshServiceHistory) Descriptor 

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

func (*SingleMeshServiceHistory) GetMeshNamespace 

func (m *SingleMeshServiceHistory) GetMeshNamespace() string

func (*SingleMeshServiceHistory) GetMeshService 

func (m *SingleMeshServiceHistory) GetMeshService() string

func (*SingleMeshServiceHistory) GetMeshServiceDeleted 

func (m *SingleMeshServiceHistory) GetMeshServiceDeleted() bool

func (*SingleMeshServiceHistory) GetRevision 

func (m *SingleMeshServiceHistory) GetRevision() []*RevisionHistory

func (*SingleMeshServiceHistory) ProtoMessage 

func (*SingleMeshServiceHistory) ProtoMessage()

func (*SingleMeshServiceHistory) Reset 

func (m *SingleMeshServiceHistory) Reset()

func (*SingleMeshServiceHistory) String 

func (m *SingleMeshServiceHistory) String() string

func (*SingleMeshServiceHistory) XXX_DiscardUnknown 

func (m *SingleMeshServiceHistory) XXX_DiscardUnknown()

func (*SingleMeshServiceHistory) XXX_Marshal 

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

func (*SingleMeshServiceHistory) XXX_Merge 

func (m *SingleMeshServiceHistory) XXX_Merge(src proto.Message)

func (*SingleMeshServiceHistory) XXX_Size 

func (m *SingleMeshServiceHistory) XXX_Size() int

func (*SingleMeshServiceHistory) XXX_Unmarshal 

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

type SingleRateLimitRuleHistory 

type SingleRateLimitRuleHistory struct {
	RuleId               string             `protobuf:"bytes,1,opt,name=rule_id,json=ruleId,proto3" json:"rule_id,omitempty"`
	Revision             []*RevisionHistory `protobuf:"bytes,2,rep,name=revision,proto3" json:"revision,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

一个单独限流规则（具备一个ruleId）的变更历史

func (*SingleRateLimitRuleHistory) Descriptor 

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

func (*SingleRateLimitRuleHistory) GetRevision 

func (m *SingleRateLimitRuleHistory) GetRevision() []*RevisionHistory

func (*SingleRateLimitRuleHistory) GetRuleId 

func (m *SingleRateLimitRuleHistory) GetRuleId() string

func (*SingleRateLimitRuleHistory) ProtoMessage 

func (*SingleRateLimitRuleHistory) ProtoMessage()

func (*SingleRateLimitRuleHistory) Reset 

func (m *SingleRateLimitRuleHistory) Reset()

func (*SingleRateLimitRuleHistory) String 

func (m *SingleRateLimitRuleHistory) String() string

func (*SingleRateLimitRuleHistory) XXX_DiscardUnknown 

func (m *SingleRateLimitRuleHistory) XXX_DiscardUnknown()

func (*SingleRateLimitRuleHistory) XXX_Marshal 

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

func (*SingleRateLimitRuleHistory) XXX_Merge 

func (m *SingleRateLimitRuleHistory) XXX_Merge(src proto.Message)

func (*SingleRateLimitRuleHistory) XXX_Size 

func (m *SingleRateLimitRuleHistory) XXX_Size() int

func (*SingleRateLimitRuleHistory) XXX_Unmarshal 

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

type StatResponse 

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

func NewResponse 

func NewResponse(id string, code uint32) *StatResponse

*

  • @brief 创建回复

func (*StatResponse) Descriptor 

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

func (*StatResponse) GetCode 

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

func (*StatResponse) GetId 

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

func (*StatResponse) GetInfo 

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

func (*StatResponse) ProtoMessage 

func (*StatResponse) ProtoMessage()

func (*StatResponse) Reset 

func (m *StatResponse) Reset()

func (*StatResponse) String 

func (m *StatResponse) String() string

func (*StatResponse) XXX_DiscardUnknown 

func (m *StatResponse) XXX_DiscardUnknown()

func (*StatResponse) XXX_Marshal 

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

func (*StatResponse) XXX_Merge 

func (m *StatResponse) XXX_Merge(src proto.Message)

func (*StatResponse) XXX_Size 

func (m *StatResponse) XXX_Size() int

func (*StatResponse) XXX_Unmarshal 

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

type StatusChange 

type StatusChange int32

熔断状态变更类型 

const (
	StatusChange_Unknown         StatusChange = 0
	StatusChange_CloseToOpen     StatusChange = 1
	StatusChange_OpenToHalfOpen  StatusChange = 2
	StatusChange_HalfOpenToOpen  StatusChange = 3
	StatusChange_HalfOpenToClose StatusChange = 4
)

func (StatusChange) EnumDescriptor 

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

func (StatusChange) String 

func (x StatusChange) String() string

type ThresholdChange 

type ThresholdChange struct {
	Time                 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	OldThreshold         string               `protobuf:"bytes,2,opt,name=oldThreshold,proto3" json:"oldThreshold,omitempty"`
	NewThreshold         string               `protobuf:"bytes,3,opt,name=newThreshold,proto3" json:"newThreshold,omitempty"`
	Reason               string               `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ThresholdChange) Descriptor 

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

func (*ThresholdChange) GetNewThreshold 

func (m *ThresholdChange) GetNewThreshold() string

func (*ThresholdChange) GetOldThreshold 

func (m *ThresholdChange) GetOldThreshold() string

func (*ThresholdChange) GetReason 

func (m *ThresholdChange) GetReason() string

func (*ThresholdChange) GetTime 

func (m *ThresholdChange) GetTime() *timestamp.Timestamp

func (*ThresholdChange) ProtoMessage 

func (*ThresholdChange) ProtoMessage()

func (*ThresholdChange) Reset 

func (m *ThresholdChange) Reset()

func (*ThresholdChange) String 

func (m *ThresholdChange) String() string

func (*ThresholdChange) XXX_DiscardUnknown 

func (m *ThresholdChange) XXX_DiscardUnknown()

func (*ThresholdChange) XXX_Marshal 

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

func (*ThresholdChange) XXX_Merge 

func (m *ThresholdChange) XXX_Merge(src proto.Message)

func (*ThresholdChange) XXX_Size 

func (m *ThresholdChange) XXX_Size() int

func (*ThresholdChange) XXX_Unmarshal 

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

type UnimplementedGrpcAPIServer 

type UnimplementedGrpcAPIServer struct {
}

UnimplementedGrpcAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedGrpcAPIServer) CollectCircuitBreak 

func (*UnimplementedGrpcAPIServer) CollectCircuitBreak(srv GrpcAPI_CollectCircuitBreakServer) error

func (*UnimplementedGrpcAPIServer) CollectLoadBalanceInfo 

func (*UnimplementedGrpcAPIServer) CollectLoadBalanceInfo(srv GrpcAPI_CollectLoadBalanceInfoServer) error

func (*UnimplementedGrpcAPIServer) CollectMeshResource 

func (*UnimplementedGrpcAPIServer) CollectMeshResource(srv GrpcAPI_CollectMeshResourceServer) error

func (*UnimplementedGrpcAPIServer) CollectPluginStatistics 

func (*UnimplementedGrpcAPIServer) CollectPluginStatistics(srv GrpcAPI_CollectPluginStatisticsServer) error

func (*UnimplementedGrpcAPIServer) CollectRateLimitRecord 

func (*UnimplementedGrpcAPIServer) CollectRateLimitRecord(srv GrpcAPI_CollectRateLimitRecordServer) error

func (*UnimplementedGrpcAPIServer) CollectRouteRecord 

func (*UnimplementedGrpcAPIServer) CollectRouteRecord(srv GrpcAPI_CollectRouteRecordServer) error

func (*UnimplementedGrpcAPIServer) CollectSDKAPIStatistics 

func (*UnimplementedGrpcAPIServer) CollectSDKAPIStatistics(srv GrpcAPI_CollectSDKAPIStatisticsServer) error

func (*UnimplementedGrpcAPIServer) CollectSDKCache 

func (*UnimplementedGrpcAPIServer) CollectSDKCache(srv GrpcAPI_CollectSDKCacheServer) error

func (*UnimplementedGrpcAPIServer) CollectSDKConfiguration 

func (*UnimplementedGrpcAPIServer) CollectSDKConfiguration(ctx context.Context, req *SDKConfig) (*StatResponse, error)

func (*UnimplementedGrpcAPIServer) CollectServerStatistics 

func (*UnimplementedGrpcAPIServer) CollectServerStatistics(srv GrpcAPI_CollectServerStatisticsServer) error

func (*UnimplementedGrpcAPIServer) CollectServiceStatistics 

func (*UnimplementedGrpcAPIServer) CollectServiceStatistics(srv GrpcAPI_CollectServiceStatisticsServer) 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.