Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Cluster ¶
type Cluster struct { Input struct { Kafka KafkaConf `json:",optional"` Nats NatsConf `json:",optional"` Tcp TcpInputConf `json:",optional"` } Filters []Filter `json:",optional"` Output struct { ElasticSearch ElasticSearchConf `json:",optional"` ZincObserve ZincObserveConf `json:",optional"` } }
type ElasticSearchConf ¶
type ElasticSearchConf struct { Hosts []string Index string DocType string `json:",default=doc"` TimeZone string `json:",optional"` MaxChunkBytes int `json:",default=15728640"` // default 15M Compress bool `json:",default=false"` Username string `json:",optional"` Password string `json:",optional"` }
type KafkaConf ¶
type KafkaConf struct { service.ServiceConf Brokers []string Group string Topics []string Offset string `json:",options=first|last,default=last"` Conns int `json:",default=1"` Consumers int `json:",default=8"` Processors int `json:",default=8"` MinBytes int `json:",default=10240"` // 10K MaxBytes int `json:",default=10485760"` // 10M Username string `json:",optional"` Password string `json:",optional"` }
type NatsConf ¶ added in v0.2.0
type NatsConf struct { Urls []string // 连接的名字,推荐使用,默认为 Pstash ConnectionName string `json:",default=Pstash"` // 认证类型: Password/Token/NKey/Credentials AuthType string `json:",default=none,options=none|password|token|nkey|creds"` // 认证内容: // password -> Password like : <USER>@<PASSWORD> admin@$2a$11$qbtrnb0mSG2eV55xoyPqHOZx/lLBlryHRhU3LK2oOPFRwGF/5rtGK // token -> <YOUR TOKEN> // nkey -> <YOUR NKey Seed File Path> // creds -> <YOUR Credentials File Path> // See docs in https://docs.nats.io/using-nats/developer/connecting/userpass , // https://docs.nats.io/running-a-nats-service/configuration/securing_nats/auth_intro/nkey_auth , // https://docs.nats.io/using-nats/developer/connecting/creds AuthContent string `json:",optional"` EnableJetStream bool `json:",default=false,options=true|false"` Subject string `json:",default=log"` QueueSubscribeName string `json:",optional"` NeedAck bool `json:",default=false,options=true|false"` TlsCertPath string `json:",optional"` TlsKeyPath string `json:",optional"` TlsCaPath string `json:",optional"` }
type TcpInputConf ¶
Click to show internal directories.
Click to hide internal directories.