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)
    }
}