polaris

Documentation

Overview

Package polaris

@author: xwc1125

Index

• type Polaris
  • func (p *Polaris) GetClient(args map[string]string) (client *fasthttp.HostClient, err error)
  • func (p *Polaris) Name() string
  • func (p *Polaris) Version() string
• type PolarisConf

Types

type Polaris

type Polaris struct {
	plugins.DefaultPlugin
	// contains filtered or unexported fields
}

func (*Polaris) GetClient

func (p *Polaris) GetClient(args map[string]string) (client *fasthttp.HostClient, err error)

func (*Polaris) Name

func (p *Polaris) Name() string

func (*Polaris) Version

func (p *Polaris) Version() string

type PolarisConf

type PolarisConf struct {
	// 初始化consumer的参数
	ServerAddr string `json:"server_addr" mapstructure:"server_addr" yaml:"server_addr"` // 服务器地址
	LBPolicy   string `json:"lb_policy" mapstructure:"lb_policy" yaml:"lb_policy"`       // lb策略

	// 获取实例的参数
	Namespace      string `json:"namespace" mapstructure:"namespace" yaml:"namespace"`                   // 命名空间
	Service        string `json:"service" mapstructure:"service" yaml:"service"`                         // 服务名
	Token          string `json:"token" mapstructure:"token" yaml:"token"`                               // 可选，token
	Timeout        int64  `json:"timeout" mapstructure:"timeout" yaml:"timeout"`                         // 可选，单次查询超时时间，默认直接获取全局的超时配置
	RetryCount     int    `json:"retry_count" mapstructure:"retry_count" yaml:"retry_count"`             // 可选，重试次数，默认直接获取全局的超时配置
	ReplicateCount int    `json:"replicate_count" mapstructure:"replicate_count" yaml:"replicate_count"` // 可选，备份节点数,对于一致性hash等有状态的负载均衡方式
	// LbPolicy   string `json:"lb_policy" mapstructure:"lb_policy" yaml:"lb_policy"`   // 可选，负载均衡算法
	Canary                    string `json:"canary" mapstructure:"canary" yaml:"canary"`                                                                      // 可选，金丝雀
	EnableFailOverDefaultMeta bool   `json:"enable_fail_over_default_meta" mapstructure:"enable_fail_over_default_meta" yaml:"enable_fail_over_default_meta"` // 是否开启元数据匹配不到时启用自定义匹配规则，仅用于dstMetadata路由插件

}