feat(protocol): add CommandDistributionRecordValue

The CommandDistributionRecordValue contains a bunch of fields contains a single partition id, this is the partition id this specific command is getting distributed to.
Apart from that it contains the command that is being distributed.

Author: remcowesterhoud

protocol/src/main/java/io/camunda/zeebe/protocol/record/ValueTypeMapping.java

@@ -15,6 +15,7 @@
  */
 package io.camunda.zeebe.protocol.record;
 
+import io.camunda.zeebe.protocol.record.intent.CommandDistributionIntent;
 import io.camunda.zeebe.protocol.record.intent.DecisionEvaluationIntent;
 import io.camunda.zeebe.protocol.record.intent.DecisionIntent;
 import io.camunda.zeebe.protocol.record.intent.DecisionRequirementsIntent;
@@ -43,6 +44,7 @@
 import io.camunda.zeebe.protocol.record.intent.VariableDocumentIntent;
 import io.camunda.zeebe.protocol.record.intent.VariableIntent;
 import io.camunda.zeebe.protocol.record.intent.management.CheckpointIntent;
+import io.camunda.zeebe.protocol.record.value.CommandDistributionRecordValue;
 import io.camunda.zeebe.protocol.record.value.DecisionEvaluationRecordValue;
 import io.camunda.zeebe.protocol.record.value.DeploymentDistributionRecordValue;
 import io.camunda.zeebe.protocol.record.value.DeploymentRecordValue;
@@ -189,6 +191,9 @@ public static Set<ValueType> getAcceptedValueTypes() {
     mapping.put(
         ValueType.RESOURCE_DELETION,
         new Mapping<>(ResourceDeletionRecordValue.class, ResourceDeletionIntent.class));
+    mapping.put(
+        ValueType.COMMAND_DISTRIBUTION,
+        new Mapping<>(CommandDistributionRecordValue.class, CommandDistributionIntent.class));
 
     return mapping;
   }

protocol/src/main/java/io/camunda/zeebe/protocol/record/value/CommandDistributionRecordValue.java

@@ -0,0 +1,41 @@
+/*
+ * Copyright © 2017 camunda services GmbH ([email protected])
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.camunda.zeebe.protocol.record.value;
+
+import io.camunda.zeebe.protocol.record.ImmutableProtocol;
+import io.camunda.zeebe.protocol.record.RecordValue;
+import io.camunda.zeebe.protocol.record.ValueType;
+import org.immutables.value.Value;
+
+@Value.Immutable
+@ImmutableProtocol(builder = ImmutableCommandDistributionRecordValue.Builder.class)
+public interface CommandDistributionRecordValue extends RecordValue {
+
+  /**
+   * @return the partition where the record should be distributed to
+   */
+  int getPartitionId();
+
+  /**
+   * @return the wrapped record value type
+   */
+  ValueType getValueType();
+
+  /**
+   * @return the wrapped record value
+   */
+  RecordValue getCommandValue();
+}