-
Notifications
You must be signed in to change notification settings - Fork 4
feat: implement consumer-group service (not exposed) #560
Conversation
79dfa8f
to
c4b2ce2
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM. the couple of nits i mentioned shouldn't affect execution at all
return nil, s.err(ctx, err) | ||
} | ||
|
||
db, err := s.CommonOpts.getDB(ctx, req.Cluster) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
very tiny nit: CommonOpts
isn't needed here. s.getDB(...)
is just as valid (and avoid gopls complains about this)
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you're right, thanks for pointing it out!
cg := &v1.ConsumerGroup{ | ||
Name: "foo", | ||
} | ||
res := c.GET("/v1/consumer-groups").WithJSON(cg).Expect() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
i know this is a placeholder, but GET typically don't have a body:
res := c.GET("/v1/consumer-groups").WithJSON(cg).Expect() | |
res := c.GET("/v1/consumer-groups").Expect() |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
totally!
c4b2ce2
to
66afa6b
Compare
No description provided.