instruments

package
v0.0.0-...-b9bd852 Latest Latest
Warning

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

Go to latest
Published: Jul 3, 2017 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrRedirected = errors.New("redirected to leader")

Functions

This section is empty.

Types

type Leader

type Leader struct {
	// contains filtered or unexported fields
}

func NewLeader

func NewLeader(getter getter, etcdAddr string, logger lager.Logger) *Leader

func (*Leader) Emit

func (leader *Leader) Emit() instrumentation.Context

type RaftFollowerStats

type RaftFollowerStats struct {
	Latency struct {
		Current float64 `json:"current"`
		Average float64 `json:"average"`

		StandardDeviation float64 `json:"standardDeviation"`
		Minimum           float64 `json:"minimum"`
		Maximum           float64 `json:"maximum"`
		// contains filtered or unexported fields
	} `json:"latency"`

	Counts struct {
		Fail    uint64 `json:"fail"`
		Success uint64 `json:"success"`
	} `json:"counts"`
}

type RaftFollowersStats

type RaftFollowersStats struct {
	Leader    string                        `json:"leader"`
	Followers map[string]*RaftFollowerStats `json:"followers"`
}

type RaftServerStats

type RaftServerStats struct {
	Name  string `json:"name"`
	State string `json:"state"`

	LeaderInfo struct {
		Name   string `json:"leader"`
		Uptime string `json:"uptime"`
	} `json:"leaderInfo"`

	RecvAppendRequestCnt uint64  `json:"recvAppendRequestCnt,"`
	RecvingPkgRate       float64 `json:"recvPkgRate,omitempty"`
	RecvingBandwidthRate float64 `json:"recvBandwidthRate,omitempty"`

	SendAppendRequestCnt uint64  `json:"sendAppendRequestCnt"`
	SendingPkgRate       float64 `json:"sendPkgRate,omitempty"`
	SendingBandwidthRate float64 `json:"sendBandwidthRate,omitempty"`
}

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(getter getter, etcdAddr string, logger lager.Logger) *Server

func (*Server) Emit

func (server *Server) Emit() instrumentation.Context

type Store

type Store struct {
	// contains filtered or unexported fields
}

func NewStore

func NewStore(getter getter, etcdAddr string, logger lager.Logger) *Store

func (*Store) Emit

func (store *Store) Emit() instrumentation.Context

Jump to

Keyboard shortcuts

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