instruments

Documentation

Index

• Variables
• type Leader
  • func NewLeader(etcdAddr string, logger lager.Logger) *Leader
  • func (leader *Leader) Emit() instrumentation.Context
• type RaftFollowerStats
• type RaftFollowersStats
• type RaftServerStats
• type Server
  • func NewServer(etcdAddr string, logger lager.Logger) *Server
  • func (server *Server) Emit() instrumentation.Context
• type Store
  • func NewStore(etcdAddr string, logger lager.Logger) *Store
  • func (store *Store) Emit() instrumentation.Context

Variables

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

Types

type Leader

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

func NewLeader

func NewLeader(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(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(etcdAddr string, logger lager.Logger) *Store

func (*Store) Emit

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