Pastry

The Pastry DHT written in Go. Written specifically for Pastry Search.

Status

Under development.

Example

package main

import (
	"context"
	"crypto/ed25519"
	"crypto/rand"
	"io"
	"log"
	
	"github.com/uhthomas/pastry"
	"golang.org/x/sync/errgroup"
)

func main() {
	// Generate key for node
	var seed [ed25519.SeedSize]byte
	if _, err := io.ReadFull(rand.Reader, seed[:]); err != nil {
		log.Fatal(err)
	}
	
	n, err := pastry.New(
		// Pass logger to node
		pastry.DebugLogger,
		// Pass ed25519 seed to node
		pastry.Seed(seed[:]),
		// Use a forwarding func to log forwarded requests or modify next
		pastry.Forward(pastry.ForwarderFunc(func(ctx context.Context, next, key []byte, r io.Reader) error {
			// message <key> with <b> is being forwarded to <next>
			return nil
		})),
		// Handle received messages
		pastry.Deliver(pastry.DelivererFunc(func(ctx context.Context, key []byte, r io.Reader) error {
		        return nil
		})),
	)
	if err != nil {
		log.Fatal(err)
	}
	
	g, ctx := errgroup.WithContext(context.Background())
	
	// Connect to another node -- bootstrap 
	g.Go(func() error { return n.DialAndAccept(ctx, "localhost:1234") })
	
	// Listen for other nodes
	g.Go(func() error { return n.ListenAndServe(ctx, "localhost") })
	
	if err := g.Wait(); err != nil {
		log.Fatal(err)
	}
}