Skip to content

Commit

Permalink
Fix linting issues
Browse files Browse the repository at this point in the history
Signed-off-by: Dom Del Nano <[email protected]>
  • Loading branch information
ddelnano committed Jan 16, 2024
1 parent f4f68f9 commit 8a4b0db
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -125,7 +125,7 @@ def gen_json_builder(self):
The field name is used as json key to be close to the key used in spec
"""
if self.field_type == FieldType.table:
return f"// TODO: support KV for {self.field_name} field table type"
return f"// TODO(vsrivatsa): support KV for {self.field_name} field table type"
return f'builder->WriteKV("{self.c_field_name}", {self.c_field_name});'

def gen_buffer_extract(self):
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ std::string ToString(T obj) {
obj.ToJSON(&json_object_builder);
return json_object_builder.GetString();
}
// TODO combine with kafka ToString function
// TODO(vsrivatsa) combine with kafka ToString function
Status ProcessPayload(Frame* req, BinaryDecoder* decoder);


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ struct AMQPConnectionStart {
void ToJSON(utils::JSONObjectBuilder* builder) const {
builder->WriteKV("version_major", version_major);
builder->WriteKV("version_minor", version_minor);
// TODO: support KV for server-properties field table type
// TODO(vsrivatsa): support KV for server-properties field table type
builder->WriteKV("mechanisms", mechanisms);
builder->WriteKV("locales", locales);
}
Expand All @@ -55,7 +55,7 @@ struct AMQPConnectionStartOk {
bool synchronous = 1;

void ToJSON(utils::JSONObjectBuilder* builder) const {
// TODO: support KV for client-properties field table type
// TODO(vsrivatsa): support KV for client-properties field table type
builder->WriteKV("mechanism", mechanism);
builder->WriteKV("response", response);
builder->WriteKV("locale", locale);
Expand Down Expand Up @@ -241,7 +241,7 @@ struct AMQPExchangeDeclare {
builder->WriteKV("reserved_2", reserved_2);
builder->WriteKV("reserved_3", reserved_3);
builder->WriteKV("no_wait", no_wait);
// TODO: support KV for arguments field table type
// TODO(vsrivatsa): support KV for arguments field table type
}
};

Expand Down Expand Up @@ -302,7 +302,7 @@ struct AMQPQueueDeclare {
builder->WriteKV("exclusive", exclusive);
builder->WriteKV("auto_delete", auto_delete);
builder->WriteKV("no_wait", no_wait);
// TODO: support KV for arguments field table type
// TODO(vsrivatsa): support KV for arguments field table type
}
};

Expand Down Expand Up @@ -334,7 +334,7 @@ struct AMQPQueueBind {
builder->WriteKV("exchange", exchange);
builder->WriteKV("routing_key", routing_key);
builder->WriteKV("no_wait", no_wait);
// TODO: support KV for arguments field table type
// TODO(vsrivatsa): support KV for arguments field table type
}
};

Expand All @@ -357,7 +357,7 @@ struct AMQPQueueUnbind {
builder->WriteKV("queue", queue);
builder->WriteKV("exchange", exchange);
builder->WriteKV("routing_key", routing_key);
// TODO: support KV for arguments field table type
// TODO(vsrivatsa): support KV for arguments field table type
}
};

Expand Down Expand Up @@ -464,7 +464,7 @@ struct AMQPBasicConsume {
builder->WriteKV("no_ack", no_ack);
builder->WriteKV("exclusive", exclusive);
builder->WriteKV("no_wait", no_wait);
// TODO: support KV for arguments field table type
// TODO(vsrivatsa): support KV for arguments field table type
}
};

Expand Down Expand Up @@ -651,7 +651,7 @@ struct AMQPBasicContentHeader {
builder->WriteKV("property_flags", property_flags);
builder->WriteKV("content_type", content_type);
builder->WriteKV("content_encoding", content_encoding);
// TODO: support KV for headers field table type
// TODO(vsrivatsa): support KV for headers field table type
builder->WriteKV("delivery_mode", delivery_mode);
builder->WriteKV("priority", priority);
builder->WriteKV("correlation_id", correlation_id);
Expand Down Expand Up @@ -719,7 +719,7 @@ std::string ToString(T obj) {
obj.ToJSON(&json_object_builder);
return json_object_builder.GetString();
}
// TODO combine with kafka ToString function
// TODO(vsrivatsa) combine with kafka ToString function
Status ProcessPayload(Frame* req, BinaryDecoder* decoder);

} // namespace amqp
Expand Down

0 comments on commit 8a4b0db

Please sign in to comment.