Skip to content

Commit

Permalink
Merge #2
Browse files Browse the repository at this point in the history
2: New-func: Convert params to ptr for consistency r=Jaskaranbir a=Jaskaranbir



Co-authored-by: Jaskaranbir <jaskaranbir.dhillon@gmail.com>
  • Loading branch information
ninja-bruh and Jaskaranbir committed Nov 13, 2018
2 parents c1aa7dd + 497c128 commit 3feadb1
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions framer/framer_suite_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ var _ = Describe("Framer", func() {
prodCfg := &kafka.ProducerConfig{
KafkaBrokers: brokers,
}
topicCfg := TopicConfig{
topicCfg := &TopicConfig{
CommandTopic: commandTopic,
}
f, err := New(context.Background(), prodCfg, topicCfg)
Expand Down Expand Up @@ -130,7 +130,7 @@ var _ = Describe("Framer", func() {
prodCfg := &kafka.ProducerConfig{
KafkaBrokers: brokers,
}
topicCfg := TopicConfig{
topicCfg := &TopicConfig{
DocumentTopic: documentTopic,
}
f, err := New(context.Background(), prodCfg, topicCfg)
Expand Down Expand Up @@ -175,7 +175,7 @@ var _ = Describe("Framer", func() {
prodCfg := &kafka.ProducerConfig{
KafkaBrokers: brokers,
}
topicCfg := TopicConfig{
topicCfg := &TopicConfig{
EventTopic: eventTopic,
}
f, err := New(context.Background(), prodCfg, topicCfg)
Expand Down
2 changes: 1 addition & 1 deletion framer/new.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ type TopicConfig struct {
func New(
ctx context.Context,
prodConfig *kafka.ProducerConfig,
topicConfig TopicConfig,
topicConfig *TopicConfig,
) (*Framer, error) {
command := make(chan *model.Command, 256)
document := make(chan *model.Document, 256)
Expand Down

0 comments on commit 3feadb1

Please sign in to comment.