-
Notifications
You must be signed in to change notification settings - Fork 50
/
settings.go
45 lines (35 loc) · 1.24 KB
/
settings.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package consumer
import (
"time"
"github.com/justtrackio/gosoline/pkg/cfg"
"github.com/justtrackio/gosoline/pkg/kafka"
"github.com/justtrackio/gosoline/pkg/kafka/connection"
)
type Settings struct {
ConnectionName string `cfg:"connection" validate:"required"`
connection *connection.Settings
Topic string `cfg:"topic" validate:"required"`
GroupID string `cfg:"group_id"`
// FQTopic is the fully-qualified topic name (with prefix).
FQTopic string
// FQGroupID is the fully-qualified group id (with prefix).
FQGroupID string
BatchSize int `cfg:"batch_size" default:"1"`
BatchTimeout time.Duration `cfg:"idle_timeout" default:"1s"`
}
func (s *Settings) Connection() *connection.Settings {
return s.connection
}
func (s *Settings) WithConnection(conn *connection.Settings) *Settings {
s.connection = conn
return s
}
func ParseSettings(config cfg.Config, key string) *Settings {
settings := &Settings{}
config.UnmarshalKey(key, settings)
appID := cfg.GetAppIdFromConfig(config)
settings.connection = connection.ParseSettings(config, settings.ConnectionName)
settings.FQGroupID = kafka.FQGroupId(config, appID, settings.GroupID)
settings.FQTopic = kafka.FQTopicName(config, appID, settings.Topic)
return settings
}