Golang common.NewCache函数代码示例

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/elastic/libbeat/common.NewCache函数的典型用法代码示例。如果您正苦于以下问题：Golang NewCache函数的具体用法？Golang NewCache怎么用？Golang NewCache使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了NewCache函数的10个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: Init

func (redis *Redis) Init(test_mode bool, results publisher.Client) error {
	redis.InitDefaults()
	if !test_mode {
		redis.setFromConfig(config.ConfigSingleton.Protocols.Redis)
	}

	redis.transactions = common.NewCache(protos.DefaultTransactionExpiration,
		protos.DefaultTransactionHashSize)
	redis.transactions.StartJanitor(protos.DefaultTransactionExpiration)
	redis.results = results

	return nil
}

开发者ID:rhoml，项目名称:packetbeat，代码行数:13，代码来源:redis.go

示例2: Init

func (mongodb *Mongodb) Init(test_mode bool, results publisher.Client) error {
	debugf("Init a MongoDB protocol parser")

	mongodb.InitDefaults()
	if !test_mode {
		err := mongodb.setFromConfig(config.ConfigSingleton.Protocols.Mongodb)
		if err != nil {
			return err
		}
	}

	mongodb.requests = common.NewCache(
		mongodb.transactionTimeout,
		protos.DefaultTransactionHashSize)
	mongodb.requests.StartJanitor(mongodb.transactionTimeout)
	mongodb.responses = common.NewCache(
		mongodb.transactionTimeout,
		protos.DefaultTransactionHashSize)
	mongodb.responses.StartJanitor(mongodb.transactionTimeout)
	mongodb.results = results

	return nil
}

开发者ID:shaunrampersad，项目名称:packetbeat，代码行数:23，代码来源:mongodb.go

示例3: Init

func (dns *Dns) Init(test_mode bool, results chan common.MapStr) error {
	dns.initDefaults()
	if !test_mode {
		dns.setFromConfig(config.ConfigSingleton.Protocols.Dns)
	}

	dns.transactions = common.NewCache(protos.DefaultTransactionExpiration,
		protos.DefaultTransactionHashSize)
	dns.transactions.StartJanitor(protos.DefaultTransactionExpiration)

	dns.results = results

	return nil
}

开发者ID:HorstMumpitz，项目名称:packetbeat，代码行数:14，代码来源:dns.go

示例4: NewTcp

// Creates and returns a new Tcp.
func NewTcp(p protos.Protocols) (*Tcp, error) {
	portMap, err := buildPortsMap(p.GetAllTcp())
	if err != nil {
		return nil, err
	}

	tcp := &Tcp{
		protocols: p,
		portMap:   portMap,
		streams: common.NewCache(protos.DefaultTransactionExpiration,
			protos.DefaultTransactionHashSize),
	}
	tcp.streams.StartJanitor(protos.DefaultTransactionExpiration)
	logp.Debug("tcp", "Port map: %v", portMap)

	return tcp, nil
}

开发者ID:rhoml，项目名称:packetbeat，代码行数:18，代码来源:tcp.go

示例5: Init

func (http *Http) Init(test_mode bool, results publisher.Client) error {
	http.InitDefaults()

	if !test_mode {
		err := http.SetFromConfig(config.ConfigSingleton.Protocols.Http)
		if err != nil {
			return err
		}
	}

	http.transactions = common.NewCache(protos.DefaultTransactionExpiration,
		protos.DefaultTransactionHashSize)
	http.transactions.StartJanitor(protos.DefaultTransactionExpiration)
	http.results = results

	return nil
}

开发者ID:rhoml，项目名称:packetbeat，代码行数:17，代码来源:http.go

示例6: Init

func (mongodb *Mongodb) Init(test_mode bool, results chan common.MapStr) error {
	logp.Debug("mongodb", "Init a MongoDB protocol parser")

	mongodb.InitDefaults()
	if !test_mode {
		err := mongodb.setFromConfig(config.ConfigSingleton.Protocols.Mongodb)
		if err != nil {
			return err
		}
	}

	mongodb.transactions = common.NewCache(protos.DefaultTransactionExpiration,
		protos.DefaultTransactionHashSize)
	mongodb.transactions.StartJanitor(protos.DefaultTransactionExpiration)
	mongodb.results = results

	return nil
}

开发者ID:HorstMumpitz，项目名称:packetbeat，代码行数:18，代码来源:mongodb.go

示例7: Init

func (mysql *Mysql) Init(test_mode bool, results chan common.MapStr) error {

	mysql.InitDefaults()
	if !test_mode {
		err := mysql.setFromConfig(config.ConfigSingleton.Protocols.Mysql)
		if err != nil {
			return err
		}
	}

	mysql.transactions = common.NewCache(protos.DefaultTransactionExpiration,
		protos.DefaultTransactionHashSize)
	mysql.transactions.StartJanitor(protos.DefaultTransactionExpiration)
	mysql.handleMysql = handleMysql
	mysql.results = results

	return nil
}

开发者ID:HorstMumpitz，项目名称:packetbeat，代码行数:18，代码来源:mysql.go

示例8: Init

// Init initializes the HTTP protocol analyser.
func (http *HTTP) Init(testMode bool, results publisher.Client) error {
	http.initDefaults()

	if !testMode {
		err := http.setFromConfig(config.ConfigSingleton.Protocols.Http)
		if err != nil {
			return err
		}
	}

	http.transactions = common.NewCache(
		http.transactionTimeout,
		protos.DefaultTransactionHashSize)
	http.transactions.StartJanitor(http.transactionTimeout)
	http.results = results

	return nil
}

开发者ID:bqk-，项目名称:packetbeat，代码行数:19，代码来源:http.go

示例9: Init

func (mysql *Mysql) Init(test_mode bool, results publisher.Client) error {

	mysql.InitDefaults()
	if !test_mode {
		err := mysql.setFromConfig(config.ConfigSingleton.Protocols.Mysql)
		if err != nil {
			return err
		}
	}

	mysql.transactions = common.NewCache(
		mysql.transactionTimeout,
		protos.DefaultTransactionHashSize)
	mysql.transactions.StartJanitor(mysql.transactionTimeout)
	mysql.handleMysql = handleMysql
	mysql.results = results

	return nil
}

开发者ID:huangciyin，项目名称:packetbeat，代码行数:19，代码来源:mysql.go

示例10: Init

func (thrift *Thrift) Init(test_mode bool, results publisher.Client) error {

	thrift.InitDefaults()

	if !test_mode {
		err := thrift.readConfig(config.ConfigSingleton.Protocols.Thrift)
		if err != nil {
			return err
		}
	}

	thrift.transactions = common.NewCache(protos.DefaultTransactionExpiration,
		protos.DefaultTransactionHashSize)
	thrift.transactions.StartJanitor(protos.DefaultTransactionExpiration)

	if !test_mode {
		thrift.PublishQueue = make(chan *ThriftTransaction, 1000)
		thrift.results = results
		go thrift.publishTransactions()
	}

	return nil
}

开发者ID:rhoml，项目名称:packetbeat，代码行数:23，代码来源:thrift.go

注：本文中的github.com/elastic/libbeat/common.NewCache函数示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。