Skip to content

Commit b9f0e03

Browse files
committed
Add missing command descriptions
Part of #351 Signed-off-by: Gabriele Santomaggio <G.santomaggio@gmail.com>
1 parent ad04b60 commit b9f0e03

File tree

1 file changed

+31
-21
lines changed

1 file changed

+31
-21
lines changed

pkg/stream/constants.go

Lines changed: 31 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -197,27 +197,37 @@ func lookErrorCode(errorCode uint16) error {
197197

198198
func lookUpCommand(command uint16) string {
199199
var constLookup = map[uint16]string{
200-
commandPeerProperties: `commandPeerProperties`,
201-
commandSaslHandshake: `commandSaslHandshake`,
202-
commandSaslAuthenticate: `commandSaslAuthenticate`,
203-
commandTune: `commandTune`,
204-
commandOpen: `commandOpen`,
205-
commandHeartbeat: `commandHeartbeat`,
206-
CommandMetadataUpdate: `CommandMetadataUpdate`,
207-
commandMetadata: `CommandMetadata`,
208-
commandDeleteStream: `CommandDeleteStream`,
209-
commandCreateStream: `CommandCreateStream`,
210-
CommandUnsubscribe: `CommandUnsubscribe`,
211-
CommandQueryOffset: `CommandQueryOffset`,
212-
commandCredit: `CommandCredit`,
213-
commandDeliver: `CommandDeliver`,
214-
commandSubscribe: `CommandSubscribe`,
215-
CommandDeletePublisher: `CommandDeletePublisher`,
216-
commandPublishError: `CommandPublishError`,
217-
commandPublishConfirm: `CommandPublishConfirm`,
218-
commandDeclarePublisher: `CommandDeclarePublisher`,
219-
commandUnitTest: `UnitTest`,
220-
CommandClose: `CommandClose`,
200+
commandPeerProperties: `commandPeerProperties`,
201+
commandSaslHandshake: `commandSaslHandshake`,
202+
commandSaslAuthenticate: `commandSaslAuthenticate`,
203+
commandTune: `commandTune`,
204+
commandOpen: `commandOpen`,
205+
commandHeartbeat: `commandHeartbeat`,
206+
CommandMetadataUpdate: `CommandMetadataUpdate`,
207+
commandMetadata: `CommandMetadata`,
208+
commandDeleteStream: `CommandDeleteStream`,
209+
commandCreateStream: `CommandCreateStream`,
210+
CommandUnsubscribe: `CommandUnsubscribe`,
211+
CommandQueryOffset: `CommandQueryOffset`,
212+
commandCredit: `CommandCredit`,
213+
commandDeliver: `CommandDeliver`,
214+
commandSubscribe: `CommandSubscribe`,
215+
CommandDeletePublisher: `CommandDeletePublisher`,
216+
commandPublishError: `CommandPublishError`,
217+
commandPublishConfirm: `CommandPublishConfirm`,
218+
commandDeclarePublisher: `CommandDeclarePublisher`,
219+
commandPublish: `CommandPublish`,
220+
commandQueryPublisherSequence: `CommandQueryPublisherSequence`,
221+
commandQueryRoute: `CommandQueryRoute`,
222+
commandQueryPartition: `CommandQueryPartition`,
223+
commandExchangeVersion: `CommandExchangeVersion`,
224+
commandStreamStatus: `CommandStreamStatus`,
225+
commandCreateSuperStream: `CommandCreateSuperStream`,
226+
commandDeleteSuperStream: `CommandDeleteSuperStream`,
227+
commandConsumerUpdate: `CommandConsumerUpdate`,
228+
229+
commandUnitTest: `UnitTest`,
230+
CommandClose: `CommandClose`,
221231
}
222232
if constLookup[command] == "" {
223233
return fmt.Sprintf("Command not handled %d", command)

0 commit comments

Comments
 (0)