This repository has been archived by the owner on Jun 1, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 11
/
input_gelf_amqp.go
37 lines (33 loc) · 1.58 KB
/
input_gelf_amqp.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
package graylog
const (
// InputTypeGELFAMQP is one of input types.
InputTypeGELFAMQP string = "org.graylog2.inputs.gelf.amqp.GELFAMQPInput"
)
// NewInputGELFAMQPAttrs is the constructor of InputGELFAMQPAttrs.
func NewInputGELFAMQPAttrs() InputAttrs {
return &InputGELFAMQPAttrs{}
}
// InputType is the implementation of the InputAttrs interface.
func (attrs InputGELFAMQPAttrs) InputType() string {
return InputTypeGELFAMQP
}
// InputGELFAMQPAttrs represents GELF AMQP Input's attributes.
type InputGELFAMQPAttrs struct {
ExchangeBind bool `json:"exchange_bind,omitempty"`
ThrottlingAllowed bool `json:"throttling_allowed,omitempty"`
TLS bool `json:"tls,omitempty"`
RequeueInvalidMessages bool `json:"requeue_invalid_messages,omitempty"`
BrokerVHost string `json:"broker_vhost,omitempty"`
BrokerUsername string `json:"broker_username,omitempty"`
Queue string `json:"queue,omitempty"`
RoutingKey string `json:"routing_key,omitempty"`
OverrideSource string `json:"override_source,omitempty"`
BrokerHostname string `json:"broker_hostname,omitempty"`
Exchange string `json:"exchange,omitempty"`
BrokerPassword string `json:"broker_password,omitempty"`
Prefetch int `json:"prefetch,omitempty"`
Heartbeat int `json:"heartbeat,omitempty"`
DecompressSizeLimit int `json:"decompress_size_limit,omitempty"`
BrokerPort int `json:"broker_port,omitempty"`
ParallelQueues int `json:"parallel_queues,omitempty"`
}