Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ Run `go run ./cmd/bench` on your hardware for concrete numbers (see [Benchmarkin
## Installation

```
go get github.com/tamirms/streamhash
go get github.com/stellar/streamhash
```

Requires Go 1.26+.
Expand Down
6 changes: 3 additions & 3 deletions algorithm.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@ package streamhash
import (
"fmt"

"github.com/tamirms/streamhash/internal/bijection"
"github.com/tamirms/streamhash/internal/ptrhash"
"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/bijection"
"github.com/stellar/streamhash/internal/ptrhash"
"github.com/stellar/streamhash/internal/sherr"
)

// Algorithm identifies the MPHF algorithm used for block construction.
Expand Down
4 changes: 2 additions & 2 deletions builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@ import (
"sync"
"sync/atomic"

intbits "github.com/tamirms/streamhash/internal/bits"
"github.com/tamirms/streamhash/internal/sherr"
intbits "github.com/stellar/streamhash/internal/bits"
"github.com/stellar/streamhash/internal/sherr"
"golang.org/x/sync/errgroup"
)

Expand Down
2 changes: 1 addition & 1 deletion builder_lifecycle_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import (
"testing"
"time"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// ============================================================================
Expand Down
4 changes: 2 additions & 2 deletions builder_unsorted.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,8 +14,8 @@ import (

"golang.org/x/sys/unix"

intbits "github.com/tamirms/streamhash/internal/bits"
"github.com/tamirms/streamhash/internal/sherr"
intbits "github.com/stellar/streamhash/internal/bits"
"github.com/stellar/streamhash/internal/sherr"
)

// Unsorted Build Architecture
Expand Down
4 changes: 2 additions & 2 deletions builder_unsorted_finish.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@ import (

"golang.org/x/sys/unix"

intbits "github.com/tamirms/streamhash/internal/bits"
"github.com/tamirms/streamhash/internal/sherr"
intbits "github.com/stellar/streamhash/internal/bits"
"github.com/stellar/streamhash/internal/sherr"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion builder_unsorted_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (
"sync/atomic"
"testing"

intbits "github.com/tamirms/streamhash/internal/bits"
intbits "github.com/stellar/streamhash/internal/bits"
)

type testEntry struct {
Expand Down
2 changes: 1 addition & 1 deletion cmd/bench/bench_files.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ import (
"sync/atomic"
"time"

"github.com/tamirms/streamhash"
"github.com/stellar/streamhash"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion cmd/bench/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ import (

"github.com/spaolacci/murmur3"

"github.com/tamirms/streamhash"
"github.com/stellar/streamhash"
)

// getMaxRSS returns the maximum resident set size in bytes.
Expand Down
2 changes: 1 addition & 1 deletion corruption_context_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ import (
"runtime"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// ============================================================================
Expand Down
2 changes: 1 addition & 1 deletion error_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import (
"slices"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// ---------------------------------------------------------------------------
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/tamirms/streamhash
module github.com/stellar/streamhash

go 1.26

Expand Down
2 changes: 1 addition & 1 deletion header.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package streamhash
import (
"encoding/binary"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

const (
Expand Down
4 changes: 2 additions & 2 deletions index.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@ import (

"github.com/cespare/xxhash/v2"
"github.com/edsrzf/mmap-go"
intbits "github.com/tamirms/streamhash/internal/bits"
"github.com/tamirms/streamhash/internal/sherr"
intbits "github.com/stellar/streamhash/internal/bits"
"github.com/stellar/streamhash/internal/sherr"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion integration_unique_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ import (
"sync"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// ============================================================================
Expand Down
6 changes: 3 additions & 3 deletions internal/bijection/builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@ import (
"math"
"unsafe"

intbits "github.com/tamirms/streamhash/internal/bits"
"github.com/tamirms/streamhash/internal/encoding"
intbits "github.com/stellar/streamhash/internal/bits"
"github.com/stellar/streamhash/internal/encoding"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// Block metadata format (separated layout with 128-bucket checkpoint stride):
Expand Down
6 changes: 3 additions & 3 deletions internal/bijection/builder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,9 +5,9 @@ import (
"fmt"
"testing"

intbits "github.com/tamirms/streamhash/internal/bits"
"github.com/tamirms/streamhash/internal/encoding"
"github.com/tamirms/streamhash/internal/sherr"
intbits "github.com/stellar/streamhash/internal/bits"
"github.com/stellar/streamhash/internal/encoding"
"github.com/stellar/streamhash/internal/sherr"
)

// NOTE: TestEstimateMetadataSizeIsUpperBound, TestEmptyBlockMetadataSize,
Expand Down
4 changes: 2 additions & 2 deletions internal/bijection/decode.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@ import (
"math/bits"
"unsafe"

intbits "github.com/tamirms/streamhash/internal/bits"
intbits "github.com/stellar/streamhash/internal/bits"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// Decoder handles query-time slot computation for the bijection algorithm.
Expand Down
2 changes: 1 addition & 1 deletion internal/bijection/decode_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"errors"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// TestReadEFLowBits tests the Elias-Fano low bits reading at buffer boundaries.
Expand Down
2 changes: 1 addition & 1 deletion internal/bijection/mix.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package bijection
import (
"math/bits"

intbits "github.com/tamirms/streamhash/internal/bits"
intbits "github.com/stellar/streamhash/internal/bits"
)

// mixParts holds pre-computed parts of the Mix function that don't depend on the bucket seed.
Expand Down
2 changes: 1 addition & 1 deletion internal/bijection/solver_build.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package bijection

import (
"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

func (bb *Builder) solveBijections() error {
Expand Down
2 changes: 1 addition & 1 deletion internal/bijection/solver_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@ import (
"math/rand/v2"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// Named seeds for deterministic reproduction.
Expand Down
4 changes: 2 additions & 2 deletions internal/ptrhash/builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@ import (
"math"
"unsafe"

"github.com/tamirms/streamhash/internal/encoding"
"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/encoding"
"github.com/stellar/streamhash/internal/sherr"
)

// Builder builds a block using the PTRHash algorithm.
Expand Down
4 changes: 2 additions & 2 deletions internal/ptrhash/builder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@ import (
"fmt"
"testing"

"github.com/tamirms/streamhash/internal/encoding"
"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/encoding"
"github.com/stellar/streamhash/internal/sherr"
)

// NOTE: TestEstimateMetadataSizeIsUpperBound, TestEmptyBlockMetadataSize,
Expand Down
2 changes: 1 addition & 1 deletion internal/ptrhash/decoder.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package ptrhash
import (
"fmt"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// Decoder handles query-time slot computation for PTRHash blocks.
Expand Down
2 changes: 1 addition & 1 deletion internal/ptrhash/decoder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"errors"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// TestNewDecoder tests the NewDecoder constructor.
Expand Down
2 changes: 1 addition & 1 deletion internal/ptrhash/pilot.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"encoding/binary"
"math/bits"

intbits "github.com/tamirms/streamhash/internal/bits"
intbits "github.com/stellar/streamhash/internal/bits"
)

// pilotHashC is the mixing constant used by PTRHash for pilot hashing.
Expand Down
2 changes: 1 addition & 1 deletion internal/ptrhash/solver.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"math/rand/v2"
"slices"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// errEvictionLimitExceeded is returned when the PTRHash solver exceeds the
Expand Down
2 changes: 1 addition & 1 deletion internal/ptrhash/solver_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (
"math/rand/v2"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// Named seeds for deterministic reproduction.
Expand Down
2 changes: 1 addition & 1 deletion open_variants_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (
"slices"
"testing"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// buildTestIndex builds a test MPHF index and returns the file path and sorted keys.
Expand Down
2 changes: 1 addition & 1 deletion parallel_pipeline_fuzz_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ import (
"testing"
"time"

"github.com/tamirms/streamhash/internal/sherr"
"github.com/stellar/streamhash/internal/sherr"
)

// This file is a property/fuzz harness for the parallel build pipeline's
Expand Down
2 changes: 1 addition & 1 deletion sentinels.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package streamhash

import "github.com/tamirms/streamhash/internal/sherr"
import "github.com/stellar/streamhash/internal/sherr"

// Build errors.
var (
Expand Down
4 changes: 2 additions & 2 deletions test_helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@ import (
"slices"
"testing"

intbits "github.com/tamirms/streamhash/internal/bits"
"github.com/tamirms/streamhash/internal/sherr"
intbits "github.com/stellar/streamhash/internal/bits"
"github.com/stellar/streamhash/internal/sherr"
)

// entry represents a key-payload pair for test building helpers.
Expand Down