diff options
Diffstat (limited to 'internal/protocol/protocol.go')
| -rw-r--r-- | internal/protocol/protocol.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/internal/protocol/protocol.go b/internal/protocol/protocol.go index d53d07e..13b7fb9 100644 --- a/internal/protocol/protocol.go +++ b/internal/protocol/protocol.go @@ -7,6 +7,12 @@ const ( MessageDelimiter byte = '¬' // FieldDelimiter delimits messagefields. FieldDelimiter string = "|" + // AggregateMessageID is the leading field of a mapreduce aggregate-data + // message on the wire (AGGREGATE|hostname|serialized-data). It is the + // single source of truth used by the server to tag such messages and by + // the mapr client to recognise them, so protocol acks like "AUTHKEY OK" + // (which merely start with the letter 'A') are not mistaken for data. + AggregateMessageID string = "AGGREGATE" // CSVDelimiter delimits CSV file fields.kj:w CSVDelimiter string = "," // AggregateKVDelimiter delimits key-values of an aggregation message. |