pb

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2021 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause, + 3 more Imports: 25 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ServerErrorCodeTypeMap = map[uint32]model.ErrCode{
	200: model.ErrCodeSuccess,
	400: model.ErrCodeInvalidRequest,
	401: model.ErrCodeUnauthorized,
	403: model.ErrCodeRequestLimit,
	404: model.ErrCodeCmdbNotFound,
	500: model.ErrCodeServerError,
}

获取server错误码类型的map

Functions

func ConvertDuration 

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

convertDuration converts to golang duration and logs errors

func ConvertServerErrorToRpcError 

func ConvertServerErrorToRpcError(code uint32) model.ErrCode

将server返回码转化为服务调用的返回码

func GenServicesRevision 

func GenServicesRevision(services []*namingpb.Service) string

func GetEventType 

func GetEventType(respType namingpb.DiscoverResponse_DiscoverResponseType) model.EventType

通过应答类型获取事件类型

func GetMaxValidDuration 

func GetMaxValidDuration(rule *namingpb.Rule) (time.Duration, error)

获取最大校验周期

func GetProtoRequestType 

func GetProtoRequestType(event model.EventType) namingpb.DiscoverRequest_DiscoverRequestType

通过事件类型获取请求类型

func NewRoutingRuleInProto 

func NewRoutingRuleInProto(resp *namingpb.DiscoverResponse) model.ServiceRule

兼容接口, trpc-go依赖项

func ProtoDurationToMS 

func ProtoDurationToMS(dur *duration.Duration) int64

pb时间段转毫秒

func ValidateMessage 

func ValidateMessage(eventKey *model.ServiceEventKey, message interface{}) error

校验消息 校验返回码为500或者消息类型不对

Types

type DiscoverError 

type DiscoverError struct {
	Code    int32
	Message string
}

从discover获取到了类似500的错误码

func (*DiscoverError) Error 

func (d *DiscoverError) Error() string

将错误信息转化为string

type InstSlice 

type InstSlice []*namingpb.Instance

instSlice，[]*namingpb.Instance的别名

func (InstSlice) Len 

func (is InstSlice) Len() int

instSlice的长度

func (InstSlice) Less 

func (is InstSlice) Less(i, j int) bool

instSlice元素比较方法

func (InstSlice) Swap 

func (is InstSlice) Swap(i, j int)

instSlice交换元素方法

type InstanceInProto 

type InstanceInProto struct {
	*namingpb.Instance
	// contains filtered or unexported fields
}

通过proto定义来构造实例

func NewInstanceInProto 

func NewInstanceInProto(
	instance *namingpb.Instance, svcKey *model.ServiceKey, localValue local.InstanceLocalValue) *InstanceInProto

InstanceInProto的构造函数

func (*InstanceInProto) GetActiveDetectStatus 

func (i *InstanceInProto) GetActiveDetectStatus() model.ActiveDetectStatus

instance dynamic weight

func (*InstanceInProto) GetCampus 

func (i *InstanceInProto) GetCampus() string

instance campus

func (*InstanceInProto) GetCircuitBreakerStatus 

func (i *InstanceInProto) GetCircuitBreakerStatus() model.CircuitBreakerStatus

instance dynamic weight

func (*InstanceInProto) GetExtendedData 

func (i *InstanceInProto) GetExtendedData(pluginIndex int32) interface{}

获取插件数据

func (*InstanceInProto) GetHost 

func (i *InstanceInProto) GetHost() string

获取实例Host，，因为pb3的GetId返回wrappers.StringValue，所以改写

func (*InstanceInProto) GetIDC 

func (i *InstanceInProto) GetIDC() string

instance idc

func (*InstanceInProto) GetId 

func (i *InstanceInProto) GetId() string

获取实例ID，因为pb3的GetId返回wrappers.StringValue，所以改写

func (*InstanceInProto) GetInstanceKey 

func (i *InstanceInProto) GetInstanceKey() model.InstanceKey

获取实例的四元组标识

func (*InstanceInProto) GetInstanceLocalValue 

func (i *InstanceInProto) GetInstanceLocalValue() local.InstanceLocalValue

获取本地可变状态值

func (*InstanceInProto) GetLogicSet 

func (i *InstanceInProto) GetLogicSet() string

获取逻辑分区

func (*InstanceInProto) GetNamespace 

func (i *InstanceInProto) GetNamespace() string

命名空间

func (*InstanceInProto) GetPort 

func (i *InstanceInProto) GetPort() uint32

获取实例端口，因为pb3的GetPort返回wrappers.UInt32Value，所以改写

func (*InstanceInProto) GetPriority 

func (i *InstanceInProto) GetPriority() uint32

获取实例优先级，因为pb3的GetPriority返回wrappers.UInt32Value，所以改写

func (*InstanceInProto) GetProtocol 

func (i *InstanceInProto) GetProtocol() string

获取实例协议，因为pb3的GetProtocol返回wrappers.UInt32Value，所以改写

func (*InstanceInProto) GetRegion 

func (i *InstanceInProto) GetRegion() string

instance region

func (*InstanceInProto) GetRevision 

func (i *InstanceInProto) GetRevision() string

获取实例Revision，，因为pb3的GetRevision返回wrappers.StringValue，所以改写

func (*InstanceInProto) GetService 

func (i *InstanceInProto) GetService() string

服务名

func (*InstanceInProto) GetSliceWindows 

func (i *InstanceInProto) GetSliceWindows(pluginIndex int32) []*metric.SliceWindow

获取统计窗口

func (*InstanceInProto) GetVersion 

func (i *InstanceInProto) GetVersion() string

获取实例版本，因为pb3的GetVersion返回wrappers.StringValue，所以改写

func (*InstanceInProto) GetVpcId 

func (i *InstanceInProto) GetVpcId() string

获取实例的vpcId

func (*InstanceInProto) GetWeight 

func (i *InstanceInProto) GetWeight() int

获取实例权重，，因为pb3的GetWeight返回wrappers.UInt32Value，所以改写

func (*InstanceInProto) GetZone 

func (i *InstanceInProto) GetZone() string

instance zone

func (*InstanceInProto) IsEnableHealthCheck 

func (i *InstanceInProto) IsEnableHealthCheck() bool

whether the health check enabled

func (*InstanceInProto) IsHealthy 

func (i *InstanceInProto) IsHealthy() bool

instance health status

func (*InstanceInProto) IsIsolated 

func (i *InstanceInProto) IsIsolated() bool

instance is isolated

func (*InstanceInProto) SetExtendedData 

func (i *InstanceInProto) SetExtendedData(pluginIndex int32, data interface{})

设置插件数据

func (*InstanceInProto) SingleInstances 

func (i *InstanceInProto) SingleInstances() []model.Instance

获取单个实例数组

type MeshConfigProto 

type MeshConfigProto struct {
	*model.ServiceKey

	CacheLoaded int32
	// contains filtered or unexported fields
}

网格规则

func NewMeshConfigInProto 

func NewMeshConfigInProto(resp *namingpb.DiscoverResponse) *MeshConfigProto

新建网格规则

func (*MeshConfigProto) GetNamespace 

func (s *MeshConfigProto) GetNamespace() string

获取Namespace

func (*MeshConfigProto) GetRevision 

func (s *MeshConfigProto) GetRevision() string

缓存版本号，标识缓存是否更新

func (*MeshConfigProto) GetService 

func (s *MeshConfigProto) GetService() string

获取Service

func (*MeshConfigProto) GetType 

func (s *MeshConfigProto) GetType() model.EventType

获取规则类型

func (*MeshConfigProto) GetValue 

func (s *MeshConfigProto) GetValue() interface{}

获取值

func (*MeshConfigProto) IsInitialized 

func (s *MeshConfigProto) IsInitialized() bool

缓存是否已经初始化

type MeshProto 

type MeshProto struct {
	*model.ServiceKey

	CacheLoaded int32
	// contains filtered or unexported fields
}

网格

func NewMeshInProto 

func NewMeshInProto(resp *namingpb.DiscoverResponse) *MeshProto

新建网格

func (*MeshProto) GetNamespace 

func (s *MeshProto) GetNamespace() string

获取Namespace

func (*MeshProto) GetRevision 

func (s *MeshProto) GetRevision() string

缓存版本号，标识缓存是否更新

func (*MeshProto) GetService 

func (s *MeshProto) GetService() string

获取Service

func (*MeshProto) GetType 

func (s *MeshProto) GetType() model.EventType

获取类型

func (*MeshProto) GetValue 

func (s *MeshProto) GetValue() interface{}

获取值

func (*MeshProto) IsInitialized 

func (s *MeshProto) IsInitialized() bool

缓存是否已经初始化

type RateLimitRuleCache 

type RateLimitRuleCache struct {
	MaxDuration time.Duration
}

规则PB缓存

type RateLimitingAssistant 

type RateLimitingAssistant struct {
}

限流解析助手

func (*RateLimitingAssistant) ParseRuleValue 

func (r *RateLimitingAssistant) ParseRuleValue(resp *namingpb.DiscoverResponse) (proto.Message, string)

解析出具体的规则值

func (*RateLimitingAssistant) SetDefault 

func (r *RateLimitingAssistant) SetDefault(message proto.Message)

设置默认值

func (*RateLimitingAssistant) Validate 

func (r *RateLimitingAssistant) Validate(message proto.Message, ruleCache model.RuleCache) error

规则校验

type RoutingAssistant 

type RoutingAssistant struct {
}

路由规则解析助手

func (*RoutingAssistant) ParseRuleValue 

func (r *RoutingAssistant) ParseRuleValue(resp *namingpb.DiscoverResponse) (proto.Message, string)

解析出具体的规则值

func (*RoutingAssistant) SetDefault 

func (r *RoutingAssistant) SetDefault(message proto.Message)

设置默认值

func (*RoutingAssistant) Validate 

func (r *RoutingAssistant) Validate(message proto.Message, ruleCache model.RuleCache) error

规则校验

type ServiceInstancesInProto 

type ServiceInstancesInProto struct {
	CacheLoaded int32
	// contains filtered or unexported fields
}

通用的应答

func NewServiceInstancesInProto 

func NewServiceInstancesInProto(resp *namingpb.DiscoverResponse, createLocalValue func(string) local.InstanceLocalValue,
	pluginValues *SvcPluginValues, svcLocalValue local.ServiceLocalValue) *ServiceInstancesInProto

ServiceInstancesResponse的构造函数

func (*ServiceInstancesInProto) GetGetTotalWeight 

func (s *ServiceInstancesInProto) GetGetTotalWeight() int

总权重

func (*ServiceInstancesInProto) GetInstance 

func (s *ServiceInstancesInProto) GetInstance(instId string) model.Instance

通过实例ID获取实例

func (*ServiceInstancesInProto) GetInstanceLocalValue 

func (s *ServiceInstancesInProto) GetInstanceLocalValue(instId string) local.InstanceLocalValue

按实例获取本地可变状态值

func (*ServiceInstancesInProto) GetInstances 

func (s *ServiceInstancesInProto) GetInstances() []model.Instance

获取服务实例列表

func (*ServiceInstancesInProto) GetMetadata 

func (s *ServiceInstancesInProto) GetMetadata() map[string]string

获取元数据信息

func (*ServiceInstancesInProto) GetNamespace 

func (s *ServiceInstancesInProto) GetNamespace() string

获取名字空间

func (*ServiceInstancesInProto) GetRevision 

func (s *ServiceInstancesInProto) GetRevision() string

获取服务的修订版本信息

func (*ServiceInstancesInProto) GetService 

func (s *ServiceInstancesInProto) GetService() string

获取服务名

func (*ServiceInstancesInProto) GetServiceClusters 

func (s *ServiceInstancesInProto) GetServiceClusters() model.ServiceClusters

获取缓存索引

func (*ServiceInstancesInProto) GetServiceLoadbalancer 

func (s *ServiceInstancesInProto) GetServiceLoadbalancer() loadbalancer.LoadBalancer

获取服务级的负载均衡

func (*ServiceInstancesInProto) GetServiceLocalValue 

func (s *ServiceInstancesInProto) GetServiceLocalValue() local.ServiceLocalValue

获取服务的localvalue

func (*ServiceInstancesInProto) GetServiceRouterChain 

func (s *ServiceInstancesInProto) GetServiceRouterChain() *servicerouter.RouterChain

获取服务级的路由链

func (*ServiceInstancesInProto) GetSvcIDSet 

func (s *ServiceInstancesInProto) GetSvcIDSet() model.HashSet

返回实例的id集合

func (*ServiceInstancesInProto) GetTotalWeight 

func (s *ServiceInstancesInProto) GetTotalWeight() int

获取所有实例总权重

func (*ServiceInstancesInProto) GetType 

func (s *ServiceInstancesInProto) GetType() model.EventType

获取配置类型

func (*ServiceInstancesInProto) IsCacheLoaded 

func (s *ServiceInstancesInProto) IsCacheLoaded() bool

pb值是否为从缓存文件中加载的

func (*ServiceInstancesInProto) IsInitialized 

func (s *ServiceInstancesInProto) IsInitialized() bool

服务实例列表是否已经加载

func (*ServiceInstancesInProto) ReloadServiceClusters 

func (s *ServiceInstancesInProto) ReloadServiceClusters()

重建缓存索引

func (*ServiceInstancesInProto) SetInitialized 

func (s *ServiceInstancesInProto) SetInitialized(isInitialized bool)

type ServiceRuleAssistant 

type ServiceRuleAssistant interface {
	//解析出具体的规则值
	ParseRuleValue(resp *namingpb.DiscoverResponse) (proto.Message, string)
	//设置默认值
	SetDefault(message proto.Message)
	//规则校验
	Validate(message proto.Message, cache model.RuleCache) error
}

助手接口

type ServiceRuleInProto 

type ServiceRuleInProto struct {
	*model.ServiceKey

	CacheLoaded int32
	// contains filtered or unexported fields
}

路由规则配置对象

func NewServiceRuleInProto 

func NewServiceRuleInProto(resp *namingpb.DiscoverResponse) *ServiceRuleInProto

创建路由规则配置对象

func (*ServiceRuleInProto) GetNamespace 

func (s *ServiceRuleInProto) GetNamespace() string

获取命名空间

func (*ServiceRuleInProto) GetRevision 

func (s *ServiceRuleInProto) GetRevision() string

缓存版本号，标识缓存是否更新

func (*ServiceRuleInProto) GetRuleCache 

func (s *ServiceRuleInProto) GetRuleCache() model.RuleCache

获取规则缓存信息

func (*ServiceRuleInProto) GetService 

func (s *ServiceRuleInProto) GetService() string

获取服务名

func (*ServiceRuleInProto) GetType 

func (s *ServiceRuleInProto) GetType() model.EventType

获取规则类型

func (*ServiceRuleInProto) GetValidateError 

func (s *ServiceRuleInProto) GetValidateError() error

获取规则校验错误

func (*ServiceRuleInProto) GetValue 

func (s *ServiceRuleInProto) GetValue() interface{}

获取通用规则值

func (*ServiceRuleInProto) IsCacheLoaded 

func (s *ServiceRuleInProto) IsCacheLoaded() bool

pb的值是否从缓存文件中加载

func (*ServiceRuleInProto) IsInitialized 

func (s *ServiceRuleInProto) IsInitialized() bool

缓存是否已经初始化

func (*ServiceRuleInProto) ValidateAndBuildCache 

func (s *ServiceRuleInProto) ValidateAndBuildCache() error

校验路由规则，以及构建正则表达式缓存

type ServicesProto 

type ServicesProto struct {
	*model.ServiceKey

	CacheLoaded int32
	// contains filtered or unexported fields
}

批量服务

func NewServicesProto 

func NewServicesProto(resp *namingpb.DiscoverResponse) *ServicesProto

新建服务proto

func (*ServicesProto) GetNamespace 

func (s *ServicesProto) GetNamespace() string

获取Namespace

func (*ServicesProto) GetRevision 

func (s *ServicesProto) GetRevision() string

缓存版本号，标识缓存是否更新

func (*ServicesProto) GetService 

func (s *ServicesProto) GetService() string

获取Service

func (*ServicesProto) GetType 

func (s *ServicesProto) GetType() model.EventType

获取事件类型

func (*ServicesProto) GetValue 

func (s *ServicesProto) GetValue() interface{}

获取值

func (*ServicesProto) IsInitialized 

func (s *ServicesProto) IsInitialized() bool

缓存是否已经初始化

type SvcPluginValues 

type SvcPluginValues struct {
	Routers      *servicerouter.RouterChain
	Loadbalancer loadbalancer.LoadBalancer
}

服务级插件值

Source Files

View all Source files

Directories

Path Synopsis
Package metric is a generated protocol buffer package.
 Package metric is a generated protocol buffer package.
v2
Package v1 is a generated protocol buffer package.
 Package v1 is a generated protocol buffer package.

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.