etcd

Documentation

Index

• Variables
• func DefaultAllowFunc(query url.Values, attr etcd.NodeMeta, addr *resolver.Address) bool
• func GetMetaAttributes[T any](addr resolver.Address) (T, bool)
• func MustSetupEtcdResolver() wresolver.Resolver
• func NewEtcdResolver[T gRPCAttributeComparable](client *clientv3.Client, af AllowFuncType[T]) wresolver.Resolver
• func NewEtcdTarget(org, ns, service string) resolver.Target
• type AllowFuncType
• type AsyncFinder
  • func MustSetupEtcdAsyncFinder(target resolver.Target, allowFunc AllowFuncType[etcd.NodeMeta]) AsyncFinder
  • func NewAsyncFinder[T gRPCAttributeComparable](client *clientv3.Client, target resolver.Target, allowFunc AllowFuncType[T]) AsyncFinder
• type Finder
  • func MustSetupEtcdFinder() *Finder[etcd.NodeMeta]
  • func NewFinder[T gRPCAttributeComparable](client *clientv3.Client) *Finder[T]
  • func (f *Finder[T]) FindAll(ctx context.Context, prefix string) (address []resolver.Address, config *wresolver.CustomizeServiceConfig, ...)
• type ResolveMeta
  • func DefaultResolveMeta() ResolveMeta
  • func (r ResolveMeta) FullServiceName(srvName string) string
  • func (r ResolveMeta) ProxyMetadata() metadata.MD

Variables

var (
	ETCDResolverScheme = "watermelonetcdv3"
)

Functions

func DefaultAllowFunc

func DefaultAllowFunc(query url.Values, attr etcd.NodeMeta, addr *resolver.Address) bool

func GetMetaAttributes

func GetMetaAttributes[T any](addr resolver.Address) (T, bool)

func MustSetupEtcdResolver

func MustSetupEtcdResolver() wresolver.Resolver

func NewEtcdResolver

func NewEtcdResolver[T gRPCAttributeComparable](client *clientv3.Client, af AllowFuncType[T]) wresolver.Resolver

func NewEtcdTarget

func NewEtcdTarget(org, ns, service string) resolver.Target

Types

type AllowFuncType

type AllowFuncType[T gRPCAttributeComparable] func(query url.Values, attr T, addr *resolver.Address) bool

type AsyncFinder

type AsyncFinder interface {
	GetCurrentResults() []resolver.Address
	ResolveNow(_ resolver.ResolveNowOptions)
	Close()
}

func MustSetupEtcdAsyncFinder

func MustSetupEtcdAsyncFinder(target resolver.Target, allowFunc AllowFuncType[etcd.NodeMeta]) AsyncFinder

func NewAsyncFinder

func NewAsyncFinder[T gRPCAttributeComparable](client *clientv3.Client, target resolver.Target, allowFunc AllowFuncType[T]) AsyncFinder

type Finder

type Finder[T gRPCAttributeComparable] struct {
	// contains filtered or unexported fields
}

func MustSetupEtcdFinder

func MustSetupEtcdFinder() *Finder[etcd.NodeMeta]

func NewFinder

func NewFinder[T gRPCAttributeComparable](client *clientv3.Client) *Finder[T]

func (*Finder[T]) FindAll

func (f *Finder[T]) FindAll(ctx context.Context, prefix string) (address []resolver.Address, config *wresolver.CustomizeServiceConfig, err error)

type ResolveMeta

type ResolveMeta struct {
	OrgID     string
	Region    string
	Namespace string
}

func DefaultResolveMeta

func DefaultResolveMeta() ResolveMeta

func (ResolveMeta) FullServiceName

func (r ResolveMeta) FullServiceName(srvName string) string

func (ResolveMeta) ProxyMetadata

func (r ResolveMeta) ProxyMetadata() metadata.MD