-
Notifications
You must be signed in to change notification settings - Fork 0
/
structs.go
33 lines (29 loc) · 802 Bytes
/
structs.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
package pkg
import "github.com/IBM/sarama"
// string of topics contains: topics.name-partition-replicas(brokerId)
type Cluster struct {
Brokers []Topics
NumberOfBrokers int
}
type Topics struct {
Topic map[int]string
Leaders int
}
type Settings struct {
BrokersS *string
Brokers []string
Action *string
User *string
Passwd *string
From *int
ToS *string
To []int
H *bool
Help *bool
TopicS *string
Topics []string
Treads *int
Version *bool
KafkaApiVersion *string
KafkaApiVersionFormated sarama.KafkaVersion
}