Golang api.TagSet类代码示例

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

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

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

示例1: RemoveMetricName

func (db *cassandraDatabase) RemoveMetricName(metricKey api.MetricKey, tagSet api.TagSet) error {
	return db.session.Query(
		"DELETE FROM metric_names WHERE metric_key = ? AND tag_set = ?",
		metricKey,
		tagSet.Serialize(),
	).Exec()
}

开发者ID:ratneshdeepak，项目名称:metrics，代码行数:7，代码来源:cassandra.go

示例2: RemoveMetricName

func (db *defaultDatabase) RemoveMetricName(metricKey api.MetricKey, tagSet api.TagSet) error {
	db.allMetricsMutex.Lock()
	// Forget the metric in the cache.
	// (If this delete fails, there will be an extraneous write the next time the metric is consumed).
	db.allMetricsCache[metricKey] = false
	db.allMetricsMutex.Unlock()
	return db.session.Query(
		"DELETE FROM metric_names WHERE metric_key = ? AND tag_set = ?",
		metricKey,
		tagSet.Serialize(),
	).Exec()
}

开发者ID:alokmenghrajani，项目名称:metrics，代码行数:12，代码来源:cassandra.go

示例3: AddMetricName

// AddMetricName inserts to metric to Cassandra.
func (db *defaultDatabase) AddMetricName(metricKey api.MetricKey, tagSet api.TagSet) error {

	if err := db.session.Query("INSERT INTO metric_names (metric_key, tag_set) VALUES (?, ?)", metricKey, tagSet.Serialize()).Exec(); err != nil {
		return err
	}
	db.allMetricsMutex.Lock()
	if db.allMetricsCache[metricKey] {
		db.allMetricsMutex.Unlock()
		// If the key is found in the cache, exit early.
		return nil
	}
	db.allMetricsMutex.Unlock()
	if err := db.session.Query("UPDATE metric_name_set SET metric_names = metric_names + ? WHERE shard = ?", []string{string(metricKey)}, 0).Exec(); err != nil {
		return err
	}
	db.allMetricsMutex.Lock()
	// Remember the cached value so that it won't be written again in the absence of reads.
	db.allMetricsCache[metricKey] = true
	db.allMetricsMutex.Unlock()
	return nil

}

开发者ID:alokmenghrajani，项目名称:metrics，代码行数:23，代码来源:cassandra.go

示例4: AddMetricName

// AddMetricName inserts to metric to Cassandra.
func (db *cassandraDatabase) AddMetricName(metricKey api.MetricKey, tagSet api.TagSet) error {

	if err := db.session.Query("INSERT INTO metric_names (metric_key, tag_set) VALUES (?, ?)", metricKey, tagSet.Serialize()).Exec(); err != nil {
		return err
	}
	if err := db.session.Query("UPDATE metric_name_set SET metric_names = metric_names + ? WHERE shard = ?", []string{string(metricKey)}, 0).Exec(); err != nil {
		return err
	}
	return nil

}

开发者ID:ratneshdeepak，项目名称:metrics，代码行数:12，代码来源:cassandra.go

示例5: matchPrecondition

func matchPrecondition(matcherTag string, tagSet api.TagSet) bool {
	return tagSet.HasKey(matcherTag)
}

开发者ID:ratneshdeepak，项目名称:metrics，代码行数:3，代码来源:predicate.go

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