mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
Zach LeslieandGitHub
a9f63d073b
* Update proto for v1 backend * Functioning blocklist with new package * Functioning blocklist with existing package * Generate proto to existing package * Add wrapper around google UUID for proto marshaling * Update blocklist for wrapper type * Test WriteTenantIndex * Implement json for uuid * Almost functional backend tests * Passing backend tests * Improve UUID coverage and utility * TempoDB updates for UUID and struct type changes * Update method style for uuid.New() * Update method style for uuid.MustParse() * Add uuid.From helper * Update modules for UUID and proto struct types * Update poller integration test for UUID * Update tempo-cli for UUID and proto struct type changes * Lint and clean up * Fix serverless * Fix cli * Fix cli * Add fixture tests for roundtrip assurance between versions * Clean up notes from proto definition * Update backend/test * Be more specific about unmarshal UUID * Include event for compacted block * Use better json tag for compacted meta * Implement UnmarshalJson on CompcatedBlockMeta for embedded struct * Test for CompactedMeta marshal/unmarshal * Drop benchmark index * Clean commented code * Extend mocks to capture multiple writes * Update backend/test fixtures * Write both proto and json to the backend for all three files in all backends * Fix lint * Back UUID with google.UUID to avoid struct * Relocate pkg/uuid to tempodb/backend * Re-plumb UUID through tempodb * Re-plumb UUID through cmd * Re-plumb UUID through modules * Re-plumb UUID through integration/ * Drop package spec from tempo.proto * Improve encoding marshal performance * Drop block proto and tenantindex json * Drop additional proto include * Implement zstd tenant index compression * Add note about use of json in the dedicatedcolumns * Fix ingester local block * Spell * Revert mock update * Drop json fallback from tenantindex read * Replace single-tenant test fixtures * Update fixture replacement test * Improve error handling and fix test * Extend test for tenantindex round-trip * Small fixes * Revert "Drop json fallback from tenantindex read" This reverts commit 834ff5b85d8a8a4d7eb560fbb67ba8f3a5a3959a. * Add back mocks to capture multiple backend writes * Add back proto & json writitng/reading for tenantindex * Change TotalObjects type from int32 -> int64 The original change was int -> int32, which on 64bit machines is a downgrade that I overlooked. Raising here to int64 to maintain the size. * Store write buffer at object path in mocks to improve readability in tests * Avoid allocation in interface validation * Update note to include intern * Pluralize metas and compacted_metas fields * Fallback to json only on ErrDoesNotExist * Lint * Drop debug * Revert "Pluralize metas and compacted_metas fields" This reverts commit 46a8c36e37ac33e1ffc104287d898930e02cdd97. * Import original tenantindex and test contents for backwards compatibility * Update changelog
61 lines
1.1 KiB
Go
61 lines
1.1 KiB
Go
package backend
|
|
|
|
import (
|
|
"testing"
|
|
|
|
google_uuid "github.com/google/uuid"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func Test_roundTrip(t *testing.T) {
|
|
u := NewUUID()
|
|
t.Logf("u %x", u)
|
|
|
|
require.Equal(t, 16, u.Size())
|
|
|
|
// Marshalto
|
|
b := make([]byte, 16)
|
|
l, err := u.MarshalTo(b)
|
|
require.NoError(t, err)
|
|
require.Equal(t, 16, l)
|
|
require.Equal(t, 16, len(b))
|
|
|
|
u2 := UUID{}
|
|
err = u2.Unmarshal(b)
|
|
require.NoError(t, err)
|
|
assert.Equal(t, u, u2)
|
|
|
|
// Marshal
|
|
b2, err := u2.Marshal()
|
|
require.NoError(t, err)
|
|
require.Equal(t, 16, len(b2))
|
|
|
|
u3 := UUID{}
|
|
err = u3.Unmarshal(b2)
|
|
require.NoError(t, err)
|
|
assert.Equal(t, u, u2, u3)
|
|
|
|
// MarshalJSON
|
|
b3, err := u3.MarshalJSON()
|
|
require.NoError(t, err)
|
|
|
|
u4 := UUID{}
|
|
err = u4.UnmarshalJSON(b3)
|
|
require.NoError(t, err)
|
|
assert.Equal(t, u, u2, u3, u4)
|
|
}
|
|
|
|
func Test_helpers(t *testing.T) {
|
|
u := google_uuid.New()
|
|
s := MustParse(u.String())
|
|
require.Equal(t, u, (google_uuid.UUID)(s))
|
|
|
|
s2, err := ParseUUID(u.String())
|
|
require.NoError(t, err)
|
|
require.Equal(t, u, (google_uuid.UUID)(s2))
|
|
|
|
_, err = ParseUUID("x")
|
|
require.Error(t, err)
|
|
}
|