prometheus

package
v0.0.0-...-5c72b2d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2021 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Registry = prometheus.NewRegistry()

	RaftStateMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "state",
		Help:      "Node state. 0: Follower, 1:Candidate, 2:Leader, 3:Shutdown",
	}, baseLabelNames.copy())
	RaftTermMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "term",
		Help:      "Term",
	}, baseLabelNames.copy())
	RaftLastLogIndexMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "last_log_index",
		Help:      "Last log index.",
	}, baseLabelNames.copy())

	RaftLastLogTermMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "last_log_term",
		Help:      "Last log term.",
	}, baseLabelNames.copy())

	RaftCommitIndexMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "commit_index",
		Help:      "Commit index.",
	}, baseLabelNames.copy())

	RaftAppliedIndexMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "applied_index",
		Help:      "Applied index.",
	}, baseLabelNames.copy())

	RaftFsmPendingMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "fsm_pending",
		Help:      "FSM pending.",
	}, baseLabelNames.copy())

	RaftLastSnapshotIndexMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "last_snapshot_index",
		Help:      "Last snapshot index.",
	}, baseLabelNames.copy())

	RaftLastSnapshotTermMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "last_snapshot_term",
		Help:      "Last snapshot term.",
	}, baseLabelNames.copy())

	RaftLatestConfigurationIndexMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "latest_configuration_index",
		Help:      "Latest configuration index.",
	}, baseLabelNames.copy())

	RaftNumPeersMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "num_peers",
		Help:      "Number of peers.",
	}, baseLabelNames.copy())

	RaftLastContactMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "last_copntact",
		Help:      "Last contact.",
	}, baseLabelNames.copy())

	RaftNumNodesMetric = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Namespace: namespace,
		Subsystem: raftSubSystem,
		Name:      "num_nodes",
		Help:      "Number of nodes.",
	}, baseLabelNames.copy())
)

Functions

func StreamServerInterceptor

func StreamServerInterceptor() func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func UnaryServerInterceptor

func UnaryServerInterceptor() func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL