blob: ac2f6e5339a1cb8d82639f91fe5c5a8e1409f169 (
plain)
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
package amqpjobs
// pipeline rabbitmq info
const (
exchangeKey string = "exchange"
exchangeType string = "exchange_type"
queue string = "queue"
routingKey string = "routing_key"
prefetch string = "prefetch"
exclusive string = "exclusive"
priority string = "priority"
multipleAsk string = "multiple_ask"
requeueOnFail string = "requeue_on_fail"
dlx string = "x-dead-letter-exchange"
dlxRoutingKey string = "x-dead-letter-routing-key"
dlxTTL string = "x-message-ttl"
dlxExpires string = "x-expires"
contentType string = "application/octet-stream"
)
type GlobalCfg struct {
Addr string `mapstructure:"addr"`
}
// Config is used to parse pipeline configuration
type Config struct {
Prefetch int `mapstructure:"prefetch"`
Queue string `mapstructure:"queue"`
Priority int64 `mapstructure:"priority"`
Exchange string `mapstructure:"exchange"`
ExchangeType string `mapstructure:"exchange_type"`
RoutingKey string `mapstructure:"routing_key"`
Exclusive bool `mapstructure:"exclusive"`
MultipleAck bool `mapstructure:"multiple_ask"`
RequeueOnFail bool `mapstructure:"requeue_on_fail"`
}
func (c *Config) InitDefault() {
// all options should be in sync with the pipeline defaults in the FromPipeline method
if c.ExchangeType == "" {
c.ExchangeType = "direct"
}
if c.Exchange == "" {
c.Exchange = "amqp.default"
}
if c.Queue == "" {
c.Queue = "default"
}
if c.Prefetch == 0 {
c.Prefetch = 10
}
if c.Priority == 0 {
c.Priority = 10
}
}
func (c *GlobalCfg) InitDefault() {
if c.Addr == "" {
c.Addr = "amqp://guest:[email protected]:5672/"
}
}
|
