MCPcopy
hub / github.com/segmentio/kafka-go / TestMessageFixtures

Function TestMessageFixtures

message_test.go:568–677  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

566}
567
568func TestMessageFixtures(t *testing.T) {
569 type fixtureMessage struct {
570 key string
571 value string
572 }
573 var fixtureMessages = map[string]fixtureMessage{
574 "a": {key: "alpha", value: `{"count":0,"filler":"aaaaaaaaaa"}`},
575 "b": {key: "beta", value: `{"count":0,"filler":"bbbbbbbbbb"}`},
576 "c": {key: "gamma", value: `{"count":0,"filler":"cccccccccc"}`},
577 "d": {key: "delta", value: `{"count":0,"filler":"dddddddddd"}`},
578 "e": {key: "epsilon", value: `{"count":0,"filler":"eeeeeeeeee"}`},
579 "f": {key: "zeta", value: `{"count":0,"filler":"ffffffffff"}`},
580 "g": {key: "eta", value: `{"count":0,"filler":"gggggggggg"}`},
581 "h": {key: "theta", value: `{"count":0,"filler":"hhhhhhhhhh"}`},
582 }
583
584 for _, tc := range []struct {
585 name string
586 file string
587 messages []string
588 }{
589 {
590 name: "v2 followed by v1",
591 file: "fixtures/v2b-v1.hex",
592 messages: []string{"a", "b", "a", "b"},
593 },
594 {
595 name: "v2 compressed followed by v1 compressed",
596 file: "fixtures/v2bc-v1c.hex",
597 messages: []string{"a", "b", "a", "b"},
598 },
599 {
600 name: "v2 compressed followed by v1 uncompressed",
601 file: "fixtures/v2bc-v1.hex",
602 messages: []string{"a", "b", "c", "d"},
603 },
604 {
605 name: "v2 compressed followed by v1 uncompressed then v1 compressed",
606 file: "fixtures/v2bc-v1-v1c.hex",
607 messages: []string{"a", "b", "c", "d", "e", "f"},
608 },
609 {
610 name: "v2 compressed followed by v1 uncompressed then v1 compressed",
611 file: "fixtures/v2bc-v1-v1c.hex",
612 messages: []string{"a", "b", "c", "d", "e", "f"},
613 },
614 {
615 name: "v1 followed by v1",
616 file: "fixtures/v1-v1.hex",
617 messages: []string{"a", "b", "c", "d"},
618 },
619 {
620 name: "v1 compressed followed by v1 compressed",
621 file: "fixtures/v1c-v1c.hex",
622 messages: []string{"a", "b", "c", "d"},
623 },
624 {
625 name: "v1 compressed followed by v1 uncompressed then v1 compressed",

Callers

nothing calls this directly

Calls 5

newReaderHelperFunction · 0.85
NewReaderMethod · 0.65
BytesMethod · 0.65
ReadMethod · 0.45
readMessageMethod · 0.45

Tested by

no test coverage detected