Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

telemetry

package

Go to main page

Versions in this module

v0

v0.9.0

Mar 1, 2024

v0.8.0

Dec 11, 2023

Changes in this version

+ type AfgApplyingForcedAuthoritySetChange struct

+ Block string

+ func NewAfgApplyingForcedAuthoritySetChange(block string) *AfgApplyingForcedAuthoritySetChange

+ func (afg AfgApplyingForcedAuthoritySetChange) MarshalJSON() ([]byte, error)

+ type AfgApplyingScheduledAuthoritySetChange struct

+ Block string

+ func NewAfgApplyingScheduledAuthoritySetChange(block string) *AfgApplyingScheduledAuthoritySetChange

+ func (afg AfgApplyingScheduledAuthoritySetChange) MarshalJSON() ([]byte, error)

+ type Logger interface

+ Debugf func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

v0.7.0

Nov 23, 2022

Changes in this version

+ var ErrTimoutMessageSending = errors.New("timeout sending telemetry message")

+ type AfgAuthoritySet struct

+ Authorities string

+ AuthorityID string

+ AuthoritySetID string

+ func NewAfgAuthoritySet(authorityID, authoritySetID, authorities string) *AfgAuthoritySet

+ func (afg AfgAuthoritySet) MarshalJSON() ([]byte, error)

+ type AfgFinalizedBlocksUpTo struct

+ Hash common.Hash

+ Number string

+ func NewAfgFinalizedBlocksUpTo(hash common.Hash, number string) *AfgFinalizedBlocksUpTo

+ func (afg AfgFinalizedBlocksUpTo) MarshalJSON() ([]byte, error)

+ type AfgReceivedCommit struct

+ ContainsPrecommitsSignedBy []string

+ TargetHash common.Hash

+ TargetNumber string

+ func NewAfgReceivedCommit(targetHash common.Hash, targetNumber string, ...) *AfgReceivedCommit

+ func (afg AfgReceivedCommit) MarshalJSON() ([]byte, error)

+ type AfgReceivedPrecommit afgReceived

+ func NewAfgReceivedPrecommit(targetHash common.Hash, targetNumber, voter string) *AfgReceivedPrecommit

+ func (afg AfgReceivedPrecommit) MarshalJSON() ([]byte, error)

+ type AfgReceivedPrevote afgReceived

+ func NewAfgReceivedPrevote(targetHash common.Hash, targetNumber, voter string) *AfgReceivedPrevote

+ func (afg AfgReceivedPrevote) MarshalJSON() ([]byte, error)

+ type BlockImport struct

+ BestHash *common.Hash

+ Height uint

+ Origin string

+ func NewBlockImport(bestHash *common.Hash, height uint, origin string) *BlockImport

+ func (bi BlockImport) MarshalJSON() ([]byte, error)

+ type Client interface

+ SendMessage func(msg Message)

+ type Mailer struct

+ func BootstrapMailer(ctx context.Context, conns []*genesis.TelemetryEndpoint, ...) (mailer *Mailer, err error)

+ func (m *Mailer) SendMessage(msg Message)

+ type Message interface

+ MarshalJSON func() ([]byte, error)

+ type Noop struct

+ func NewNoopMailer() *Noop

+ func (*Noop) SendMessage(_ Message)

+ type NoopClient struct

+ func (NoopClient) SendMessage(_ Message)

+ type NotifyFinalized struct

+ Best common.Hash

+ Height string

+ func NewNotifyFinalized(best common.Hash, height string) *NotifyFinalized

+ func (nf NotifyFinalized) MarshalJSON() ([]byte, error)

+ type PreparedBlockForProposing struct

+ Hash common.Hash

+ Number string

+ func NewPreparedBlockForProposing(hash common.Hash, number string) *PreparedBlockForProposing

+ func (pb PreparedBlockForProposing) MarshalJSON() ([]byte, error)

+ type SystemConnected struct

+ Authority bool

+ Chain string

+ GenesisHash *common.Hash

+ Implementation string

+ Name string

+ NetworkID string

+ StartupTime string

+ Version string

+ func NewSystemConnected(authority bool, chain string, genesisHash *common.Hash, ...) *SystemConnected

+ func (sc SystemConnected) MarshalJSON() ([]byte, error)

+ type SystemInterval struct

+ BandwidthDownload float64

+ BandwidthUpload float64

+ BestHash *common.Hash

+ BestHeight uint

+ FinalisedHash *common.Hash

+ FinalisedHeight uint

+ Peers int

+ TxCount *big.Int

+ UsedStateCacheSize *big.Int

+ func NewBandwidth(bandwidthDownload, bandwidthUpload float64, peers int) *SystemInterval

+ func NewBlockInterval(beshHash *common.Hash, bestHeight uint, finalisedHash *common.Hash, ...) *SystemInterval

+ func (si SystemInterval) MarshalJSON() ([]byte, error)

+ type TxpoolImport struct

+ Future uint

+ Ready uint

+ func NewTxpoolImport(ready, future uint) *TxpoolImport

+ func (tx TxpoolImport) MarshalJSON() ([]byte, error)

v0.6.0

Apr 8, 2021

v0.5.2

Apr 7, 2021

v0.5.1

Apr 7, 2021

v0.5.0

Apr 7, 2021

v0.4.1

Apr 14, 2021

Changes in this version

+ type ConnectionData struct

+ Authority bool

+ Chain string

+ GenesisHash string

+ NetworkID string

+ NodeName string

+ StartTime string

+ SystemName string

+ SystemVersion string

+ type Handler struct

+ func GetInstance() *Handler

+ func (h *Handler) AddConnections(conns []*genesis.TelemetryEndpoint)

+ func (h *Handler) SendBlockImport(bestHash string, height *big.Int)

+ func (h *Handler) SendConnection(data *ConnectionData)

+ type MyJSONFormatter struct

+ func (f *MyJSONFormatter) Format(entry *log.Entry) ([]byte, error)