kademliaclient

Oct 2, 2019

Changes in this version

type Conn

+ func (conn *Conn) Close() error

+ type Observer interface

+ ConnFailure func(ctx context.Context, node *pb.Node, err error)

+ ConnSuccess func(ctx context.Context, node *pb.Node)

Jul 16, 2019

Changes in this version

+ type Conn struct

+ type Dialer struct

+ func NewDialer(log *zap.Logger, transport transport.Client) *Dialer

+ func (dialer *Dialer) AlertSuccess(ctx context.Context, node *pb.Node)

+ func (dialer *Dialer) Close() error

+ func (dialer *Dialer) FetchInfo(ctx context.Context, target pb.Node) (_ *pb.InfoResponse, err error)

+ func (dialer *Dialer) FetchPeerIdentity(ctx context.Context, target pb.Node) (_ *identity.PeerIdentity, err error)

+ func (dialer *Dialer) FetchPeerIdentityUnverified(ctx context.Context, address string, opts ...grpc.CallOption) (_ *identity.PeerIdentity, err error)

+ func (dialer *Dialer) Lookup(ctx context.Context, self *pb.Node, ask pb.Node, find storj.NodeID, limit int) (_ []*pb.Node, err error)

+ func (dialer *Dialer) PingNode(ctx context.Context, target pb.Node) (_ bool, err error)