rendezvous

type AddrsFactory func(addrs []ma.Multiaddr) []ma.Multiaddr

type PubSub struct {
	// contains filtered or unexported fields
}

type PubSubSubscribers struct {
	// contains filtered or unexported fields
}

type PubSubSubscriptionDetails struct {
	PeerID      string
	ChannelName string
}

type Registration struct {
	Peer peer.AddrInfo
	Ns   string
	Ttl  int
}

type RendezvousClient interface {
	Register(ctx context.Context, ns string, ttl int) (time.Duration, error)
	Unregister(ctx context.Context, ns string) error
	Discover(ctx context.Context, ns string, limit int, cookie []byte) ([]peer.AddrInfo, []byte, error)
	DiscoverAsync(ctx context.Context, ns string) (<-chan peer.AddrInfo, error)
	DiscoverSubscribe(ctx context.Context, ns string) (<-chan peer.AddrInfo, error)
}

type RendezvousError struct {
	Status pb.Message_ResponseStatus
	Text   string
}

type RendezvousPoint interface {
	Register(ctx context.Context, ns string, ttl int) (time.Duration, error)
	Unregister(ctx context.Context, ns string) error
	Discover(ctx context.Context, ns string, limit int, cookie []byte) ([]Registration, []byte, error)
	DiscoverAsync(ctx context.Context, ns string) (<-chan Registration, error)
	DiscoverSubscribe(ctx context.Context, ns string, serviceTypes []RendezvousSyncClient) (<-chan peer.AddrInfo, error)
}

type RendezvousPointOption func(cfg *rendezvousPointConfig)

type RendezvousService struct {
	DB db.DB
	// contains filtered or unexported fields
}

type RendezvousSync interface {
	Register(p peer.ID, ns string, addrs [][]byte, ttl int, counter uint64)
	Unregister(p peer.ID, ns string)
}

type RendezvousSyncClient interface {
	Subscribe(ctx context.Context, syncDetails string) (<-chan *Registration, error)
	GetServiceType() string
}

type RendezvousSyncSubscribable interface {
	Subscribe(ns string) (syncDetails string, err error)
	GetServiceType() string
}