From f94b0b48b32956a91d3672cda4850eacdf186ebe Mon Sep 17 00:00:00 2001 From: vyzo Date: Thu, 19 Apr 2018 20:37:48 +0300 Subject: [PATCH] update client interface It's DiscoverOnce and Discover instead of Discover and DiscoverAsync --- client.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/client.go b/client.go index 2d20bbc..e04745e 100644 --- a/client.go +++ b/client.go @@ -20,8 +20,8 @@ var log = logging.Logger("rendezvous") type Rendezvous interface { Register(ctx context.Context, ns string, ttl int) error Unregister(ctx context.Context, ns string) error - Discover(ctx context.Context, ns string, limit int) ([]pstore.PeerInfo, error) - DiscoverAsync(ctx context.Context, ns string) (<-chan pstore.PeerInfo, error) + DiscoverOnce(ctx context.Context, ns string, limit int) ([]pstore.PeerInfo, error) + Discover(ctx context.Context, ns string) (<-chan pstore.PeerInfo, error) } func NewRendezvousClient(host host.Host, rp peer.ID) Rendezvous { @@ -82,7 +82,7 @@ func (cli *client) Unregister(ctx context.Context, ns string) error { return w.WriteMsg(req) } -func (cli *client) Discover(ctx context.Context, ns string, limit int) ([]pstore.PeerInfo, error) { +func (cli *client) DiscoverOnce(ctx context.Context, ns string, limit int) ([]pstore.PeerInfo, error) { s, err := cli.host.NewStream(ctx, cli.rp, RendezvousProto) if err != nil { return nil, err @@ -122,7 +122,7 @@ func (cli *client) Discover(ctx context.Context, ns string, limit int) ([]pstore return pinfos, nil } -func (cli *client) DiscoverAsync(ctx context.Context, ns string) (<-chan pstore.PeerInfo, error) { +func (cli *client) Discover(ctx context.Context, ns string) (<-chan pstore.PeerInfo, error) { s, err := cli.host.NewStream(ctx, cli.rp, RendezvousProto) if err != nil { return nil, err