Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add batch.BySize function #735

Merged
merged 8 commits into from
Jun 17, 2024
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
48 changes: 48 additions & 0 deletions lib/batch/batch.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,48 @@
package batch

import "fmt"

// BySize takes a series of elements [in], encodes them using [encode], groups them into batches of bytes that sum to at
// most [maxSizeBytes], and then passes each batch to the [yield] function.
func BySize[T any](in []T, maxSizeBytes int, encode func(T) ([]byte, error), yield func([][]byte) error) error {
var buffer [][]byte
var currentSizeBytes int

for i, item := range in {
bytes, err := encode(item)
if err != nil {
return fmt.Errorf("failed to encode item %d: %w", i, err)
}

if len(bytes) > maxSizeBytes {
return fmt.Errorf("item %d is larger (%d bytes) than maxSizeBytes (%d bytes)", i, len(bytes), maxSizeBytes)
}

currentSizeBytes += len(bytes)

if currentSizeBytes < maxSizeBytes {
buffer = append(buffer, bytes)
} else if currentSizeBytes == maxSizeBytes {
buffer = append(buffer, bytes)
if err := yield(buffer); err != nil {
return err
}
buffer = [][]byte{}
currentSizeBytes = 0
} else {
if err := yield(buffer); err != nil {
return err
}
buffer = [][]byte{bytes}
currentSizeBytes = len(bytes)
}
}

if len(buffer) > 0 {
if err := yield(buffer); err != nil {
return err
}
}

return nil
}
98 changes: 98 additions & 0 deletions lib/batch/batch_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,98 @@
package batch

import (
"fmt"
"testing"

"github.com/stretchr/testify/assert"
)

func TestBySize(t *testing.T) {
goodEncoder := func(value string) ([]byte, error) {
return []byte(value), nil
}

panicEncoder := func(value string) ([]byte, error) {
panic("should not be called")
}

badEncoder := func(value string) ([]byte, error) {
return nil, fmt.Errorf("failed to encode %q", value)
}

testBySize := func(in []string, maxSizeBytes int, encoder func(value string) ([]byte, error)) ([][][]byte, error) {
batches := [][][]byte{}
err := BySize(in, maxSizeBytes, encoder, func(batch [][]byte) error { batches = append(batches, batch); return nil })
return batches, err
}

badYield := func(batch [][]byte) error {
out := make([]string, len(batch))
for i, bytes := range batch {
out[i] = string(bytes)
}
return fmt.Errorf("yield failed for %v", out)
}

{
// Empty slice:
batches, err := testBySize([]string{}, 10, panicEncoder)
assert.NoError(t, err)
assert.Empty(t, batches)
}
{
// Non-empty slice + bad encoder:
_, err := testBySize([]string{"foo", "bar"}, 10, badEncoder)
assert.ErrorContains(t, err, `failed to encode item 0: failed to encode "foo"`)
}
{
// Non-empty slice + two items that are < maxSizeBytes + yield returns error.
err := BySize([]string{"foo", "bar"}, 10, goodEncoder, badYield)
assert.ErrorContains(t, err, "yield failed for [foo bar]")
}
{
// Non-empty slice + two items that are = maxSizeBytes + yield returns error.
err := BySize([]string{"foo", "bar"}, 6, goodEncoder, badYield)
assert.ErrorContains(t, err, "yield failed for [foo bar]")
}
{
// Non-empty slice + two items that are > maxSizeBytes + yield returns error.
err := BySize([]string{"foo", "bar-baz"}, 8, goodEncoder, badYield)
assert.ErrorContains(t, err, "yield failed for [foo]")
}
{
// Non-empty slice + item is larger than maxSizeBytes:
_, err := testBySize([]string{"foo", "i-am-23-characters-long", "bar"}, 20, goodEncoder)
assert.ErrorContains(t, err, "item 1 is larger (23 bytes) than maxSizeBytes (20 bytes)")
}
{
// Non-empty slice + item equal to maxSizeBytes:
batches, err := testBySize([]string{"foo", "i-am-23-characters-long", "bar"}, 23, goodEncoder)
assert.NoError(t, err)
assert.Len(t, batches, 3)
assert.Equal(t, [][]byte{[]byte("foo")}, batches[0])
assert.Equal(t, [][]byte{[]byte("i-am-23-characters-long")}, batches[1])
assert.Equal(t, [][]byte{[]byte("bar")}, batches[2])
}
{
// Non-empty slice + one item:
batches, err := testBySize([]string{"foo"}, 100, goodEncoder)
assert.NoError(t, err)
assert.Len(t, batches, 1)
assert.Equal(t, [][]byte{[]byte("foo")}, batches[0])
}
{
// Non-empty slice + all items exactly fit into one batch:
batches, err := testBySize([]string{"foo", "bar", "baz", "qux"}, 12, goodEncoder)
assert.NoError(t, err)
assert.Len(t, batches, 1)
assert.Equal(t, [][]byte{[]byte("foo"), []byte("bar"), []byte("baz"), []byte("qux")}, batches[0])
}
{
// Non-empty slice + all items exactly fit into just under one batch:
batches, err := testBySize([]string{"foo", "bar", "baz", "qux"}, 13, goodEncoder)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Worth adding a check on how many times goodEncoding was called? Which will test how many times yield was called

Copy link
Contributor Author

@nathan-artie nathan-artie Jun 17, 2024

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

In this case goodEncoder will be called once for each item (4 times) but yield will be called once. The amount of times that yield is called will always equal the length of batches.

assert.NoError(t, err)
assert.Len(t, batches, 1)
assert.Equal(t, [][]byte{[]byte("foo"), []byte("bar"), []byte("baz"), []byte("qux")}, batches[0])
}
}