Fix tests

This commit is contained in:
Neil Alexander 2020-12-10 18:39:46 +00:00
parent a390479909
commit d7007aa6b3
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944

View file

@ -12,11 +12,11 @@ func TestNewSyncTokenWithLogs(t *testing.T) {
tests := map[string]*StreamingToken{ tests := map[string]*StreamingToken{
"s4_0_0_0": { "s4_0_0_0": {
PDUPosition: 4, PDUPosition: 4,
logs: make(map[string]*LogPosition), Logs: make(map[string]*LogPosition),
}, },
"s4_0_0_0.dl-0-123": { "s4_0_0_0.dl-0-123": {
PDUPosition: 4, PDUPosition: 4,
logs: map[string]*LogPosition{ Logs: map[string]*LogPosition{
"dl": { "dl": {
Partition: 0, Partition: 0,
Offset: 123, Offset: 123,
@ -25,7 +25,7 @@ func TestNewSyncTokenWithLogs(t *testing.T) {
}, },
"s4_0_0_0.ab-1-14419482332.dl-0-123": { "s4_0_0_0.ab-1-14419482332.dl-0-123": {
PDUPosition: 4, PDUPosition: 4,
logs: map[string]*LogPosition{ Logs: map[string]*LogPosition{
"ab": { "ab": {
Partition: 1, Partition: 1,
Offset: 14419482332, Offset: 14419482332,