Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetWeightFromAddr ¶ added in v0.2.6
func GetWeightFromAddr(addr grpcResolver.Address) int
GetWeightFromAddr extracts the weight from a resolver.Address's BalancerAttributes. Returns 1 as default weight if not set.
func NewEtcdRegistry ¶
func NewEtcdRegistry(conf *config.ServerConfig, opts ...RegistryOption) (naming.Registry, error)
NewEtcdRegistry 创建etcd注册中心
Types ¶
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
Builder grpc etcd服务发现 implements grpc resolver.Builder
func NewEtcdBuilder ¶
func NewEtcdBuilder(conf *config.EtcdConfig, opts ...BuilderOption) *Builder
NewEtcdBuilder new etcd Builder
func (*Builder) Build ¶
func (d *Builder) Build(target grpcResolver.Target, cc grpcResolver.ClientConn, opts grpcResolver.BuildOptions) (grpcResolver.Resolver, error)
Build creates a new resolver for the given target.
type BuilderOption ¶
type BuilderOption func(builder *Builder)
BuilderOption builder option
func WithBuilderNamespace ¶
func WithBuilderNamespace(namespace string) BuilderOption
WithBuilderNamespace 设置命名空间
func WithBuilderResolveNowTime ¶
func WithBuilderResolveNowTime(t time.Duration) BuilderOption
WithBuilderResolveNowTime 设置强制 ResolveNow 间隔时长
type RegistryOption ¶
type RegistryOption func(v3 *etcd)
RegistryOption etcd registry option.
func WithRegistryEtcdAuth ¶
func WithRegistryEtcdAuth(username, password string) RegistryOption
WithRegistryEtcdAuth 设置etcd认证信息
func WithRegistryEtcdDialTimeout ¶
func WithRegistryEtcdDialTimeout(t time.Duration) RegistryOption
WithRegistryEtcdDialTimeout 设置etcd连接超时时长
func WithRegistryEtcdTLS ¶
func WithRegistryEtcdTLS(t *tls.Config) RegistryOption
WithRegistryEtcdTLS 设置etcd的tls证书
func WithRegistryLease ¶
func WithRegistryLease(lease int64) RegistryOption
WithRegistryLease 设置etcd服务key租约时长(秒) 默认为5秒
func WithRegistryNamespace ¶
func WithRegistryNamespace(namespace string) RegistryOption
WithRegistryNamespace 设置命名空间
type WeightAddrInfo ¶ added in v0.2.6
type WeightAddrInfo struct {
Weight int
}
WeightAddrInfo holds the weight information for a resolver address.
Source Files
Click to show internal directories.
Click to hide internal directories.