(t *testing.T)
| 119 | ) |
| 120 | |
| 121 | func TestMessageEncoding(t *testing.T) { |
| 122 | message := Message{} |
| 123 | testEncodable(t, "empty", &message, emptyMessage) |
| 124 | |
| 125 | message.Value = []byte{} |
| 126 | message.Codec = CompressionGZIP |
| 127 | testEncodable(t, "empty gzip", &message, emptyGzipMessage) |
| 128 | |
| 129 | message.Value = []byte{} |
| 130 | message.Codec = CompressionLZ4 |
| 131 | message.Timestamp = time.Unix(1479847795, 0) |
| 132 | message.Version = 1 |
| 133 | testEncodable(t, "empty lz4", &message, emptyLZ4Message) |
| 134 | |
| 135 | message.Value = []byte{} |
| 136 | message.Codec = CompressionZSTD |
| 137 | message.Timestamp = time.Unix(1479847795, 0) |
| 138 | message.Version = 1 |
| 139 | testEncodable(t, "empty zstd", &message, emptyZSTDMessage) |
| 140 | } |
| 141 | |
| 142 | func TestMessageDecoding(t *testing.T) { |
| 143 | message := Message{} |
nothing calls this directly
no test coverage detected