feat(core): add request headers in cluster comm impl

shivanshkc · Jul 2, 2022 · 1c0d1e2 · 1c0d1e2
1 parent 2ef6b65
commit 1c0d1e2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/cluster/comm.go b/src/cluster/comm.go
@@ -59,6 +59,9 @@ func (c *Comm) PostMessageInternal(ctx context.Context, nodeAddr string, input *
 	if err != nil {
 		return nil, fmt.Errorf("error in http.NewRequestWithContext call: %w", err)
 	}
+	// Adding the required headers.
+	request.Header.Set("x-request-id", input.RequestID)
+	request.Header.Set("x-client-id", input.ClientID)
 	// Setting the cluster basic auth params.
 	request.SetBasicAuth(conf.Auth.ClusterUsername, conf.Auth.ClusterPassword)