p2p

func (*Instance) Address ¶

func (i *Instance) Address() net.Addr

func (*Instance) Tag ¶

func (i *Instance) Tag(key string) (value string, exist bool)

func (*Instance) Weight ¶

func (i *Instance) Weight() int

func (*NetAddr) Network ¶

func (na *NetAddr) Network() string

func (*NetAddr) String ¶

func (na *NetAddr) String() string

func (*P2PResolver) Diff ¶

func (p *P2PResolver) Diff(cacheKey string, prev discovery.Result, next discovery.Result) (discovery.Change, bool)

Diff computes the difference between two results. When `next` is cacheable, the Change should be cacheable, too. And the `Result` field's CacheKey in the return value should be set with the given cacheKey.

func (*P2PResolver) Name ¶

func (p *P2PResolver) Name() string

Name returns the name of the resolver.

func (*P2PResolver) Resolve ¶

func (p *P2PResolver) Resolve(ctx context.Context, desc string) (discovery.Result, error)

func (*P2PResolver) Target ¶

func (p *P2PResolver) Target(ctx context.Context, target rpcinfo.EndpointInfo) (description string)

Target should return a description for the given target that is suitable for being a key for cache.