metrics

Documentation

Index

• Constants
• Variables
• func Push(cfg *MetricConfig)
• type MetricConfig

Constants

const (
	// StatusSucceed failed
	StatusSucceed = "succeed"
	// StatusFailed failed
	StatusFailed = "failed"

	// ActionCreate create new branch transaction
	ActionCreate = "new"
	// ActionReport report the branch transaction status on phase one
	ActionReport = "report"
	// ActionCommit commit the global transaction
	ActionCommit = "commit"
	// ActionRollback rollback the global transaction
	ActionRollback = "rollback"
	// ActionACK report the branch transaction status on phase two
	ActionACK = "ack"

	// PhaseOne phase one
	PhaseOne = "one"
	// PhaseTwo phase two
	PhaseTwo = "two"
)

const (
	// RoleLeader leader fragment
	RoleLeader = "leader"
	// RoleFollower follower fragment
	RoleFollower = "follower"
)

Variables

var (
	// ClientGCounter global count in client
	ClientGCounter = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: "taas",
			Subsystem: "client",
			Name:      "global_total",
			Help:      "Total number of global transcation made in client.",
		}, []string{"status"})

	// ClientGRegisterDurationHistogram global transaction register duration in client
	ClientGRegisterDurationHistogram = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "taas",
			Subsystem: "client",
			Name:      "global_register_duration_seconds",
			Help:      "Bucketed histogram of global register processing duration.",
			Buckets:   prometheus.ExponentialBuckets(0.0005, 2.0, 20),
		})

	// ClientGDurationHistogram global transaction duration from begin to complete in client
	ClientGDurationHistogram = prometheus.NewHistogram(
		prometheus.HistogramOpts{
			Namespace: "taas",
			Subsystem: "client",
			Name:      "global_duration_seconds",
			Help:      "Bucketed histogram of global processing duration.",
			Buckets:   prometheus.ExponentialBuckets(0.0005, 2.0, 20),
		})

	// ClientBCounter branch count in client
	ClientBCounter = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: "taas",
			Subsystem: "client",
			Name:      "branch_total",
			Help:      "Total number of branch transcation made in client.",
		}, []string{"status"})
)

var (
	// ActionGCounter action on global count
	ActionGCounter = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: "taas",
			Subsystem: "seata",
			Name:      "action_global_total",
			Help:      "Total number of global transcation actions made.",
		}, []string{"fragment", "action", "status", "name"})

	// ActiveGGauge active global transaction
	ActiveGGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: "taas",
		Subsystem: "seata",
		Name:      "global_active_total",
		Help:      "Total number of active global transaction.",
	}, []string{"fragment"})

	// GDurationHistogram global transaction duration time
	GDurationHistogram = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: "taas",
			Subsystem: "seata",
			Name:      "global_duration_seconds",
			Help:      "Bucketed histogram of global processing duration.",
			Buckets:   prometheus.ExponentialBuckets(0.0005, 2.0, 20),
		}, []string{"fragment"})

	// ActionBCounter action on branch
	ActionBCounter = prometheus.NewCounterVec(
		prometheus.CounterOpts{
			Namespace: "taas",
			Subsystem: "seata",
			Name:      "action_branch_total",
			Help:      "Total number of action on branch transcation made.",
		}, []string{"fragment", "action", "status", "resource"})

	// BDurationHistogram branch transaction duration time with all phase
	BDurationHistogram = prometheus.NewHistogramVec(
		prometheus.HistogramOpts{
			Namespace: "taas",
			Subsystem: "seata",
			Name:      "branch_duration_seconds",
			Help:      "Bucketed histogram of branch processing duration.",
			Buckets:   prometheus.ExponentialBuckets(0.0005, 2.0, 20),
		}, []string{"fragment", "phase"})
)

var (
	// FragmentGauge fragment count
	FragmentGauge = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: "taas",
			Subsystem: "sharding",
			Name:      "fragment_total",
			Help:      "Total number of Fragment.",
		}, []string{"role"})

	// FragmentPeersGauge fragment peers value
	FragmentPeersGauge = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: "taas",
		Subsystem: "seata",
		Name:      "peers_total",
		Help:      "Total number of peers per Fragment.",
	}, []string{"fragment"})
)

Functions

func Push

func Push(cfg *MetricConfig)

Push metircs in background.

Types

type MetricConfig

type MetricConfig struct {
	PushJob      string        `toml:"job" json:"job"`
	PushAddress  string        `toml:"address" json:"address"`
	PushInterval time.Duration `toml:"interval" json:"interval"`
}

MetricConfig is the metric configuration.