| 171 | } |
| 172 | |
| 173 | type FragmentReceivedEvent struct { |
| 174 | Kind string `json:"kind"` |
| 175 | Source string `json:"source"` |
| 176 | Identifier string `json:"identifier"` |
| 177 | PartitionID uint64 `json:"partition_id"` |
| 178 | DataStructure string `json:"data_structure"` |
| 179 | Length int `json:"length"` |
| 180 | IsBackup bool `json:"is_backup"` |
| 181 | Timestamp int64 `json:"timestamp"` |
| 182 | } |
| 183 | |
| 184 | func (f *FragmentReceivedEvent) Encode() (string, error) { |
| 185 | fields := []string{ |
nothing calls this directly
no outgoing calls
no test coverage detected