1 Star 0 Fork 0

zhangjungang/beats

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
.github
auditbeat
dev-tools
docs/devguide
filebeat
generator
heartbeat
libbeat
metricbeat
packetbeat
_meta
beater
cmd
config
decoder
docs
flows
include
procs
protocols
protos
amqp
applayer
cassandra
_meta
internal/gocql
README.md
cassandra.go
config.go
parser.go
pub.go
trans.go
dns
http
icmp
memcache
mongodb
mysql
nfs
pgsql
redis
tcp
thrift
udp
protos.go
protos_test.go
registry.go
publish
scripts
sniffer
tests
.gitignore
CONTRIBUTING.md
Makefile
README.md
SUPPORT_PROTOCOL.md
dashboards.yml
main.go
main_test.go
packetbeat.reference.yml
packetbeat.yml
script
testing/environments
vendor
winlogbeat
.appveyor.yml
.editorconfig
.gitattributes
.gitignore
.go-version
.pylintrc
.travis.yml
CHANGELOG.asciidoc
CONTRIBUTING.md
LICENSE.txt
Makefile
NOTICE.txt
README.md
Vagrantfile
codecov.yml
reviewdog.yml
setup.yml
克隆/下载
config.go 1022 Bytes
一键复制 编辑 原始数据 按行查看 历史
package cassandra
import (
"fmt"
"github.com/elastic/beats/packetbeat/config"
"github.com/elastic/beats/packetbeat/protos"
gocql "github.com/elastic/beats/packetbeat/protos/cassandra/internal/gocql"
)
type cassandraConfig struct {
config.ProtocolCommon `config:",inline"`
SendRequestHeader bool `config:"send_request_header"`
SendResponseHeader bool `config:"send_response_header"`
Compressor string `config:"compressor"`
OPsIgnored []gocql.FrameOp `config:"ignored_ops"`
}
var (
defaultConfig = cassandraConfig{
ProtocolCommon: config.ProtocolCommon{
TransactionTimeout: protos.DefaultTransactionExpiration,
SendRequest: true,
SendResponse: true,
},
SendRequestHeader: true,
SendResponseHeader: true,
}
)
func (c *cassandraConfig) Validate() error {
if !(c.Compressor == "" || c.Compressor == "snappy") {
return fmt.Errorf("invalid compressor config: %s, only snappy supported", c.Compressor)
}
return nil
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/zhangjungang/beats.git
git@gitee.com:zhangjungang/beats.git
zhangjungang
beats
beats
v6.0.0-rc2

搜索帮助