performance

Documentation

Overview

Copyright © 2019 Annchain Authors <EMAIL ADDRESS>

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2019 Annchain Authors <EMAIL ADDRESS>

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type PerformanceMonitor
  • func (p *PerformanceMonitor) CollectData() map[string]interface{}
  • func (PerformanceMonitor) Name() string
  • func (p *PerformanceMonitor) Register(holder PerformanceReporter)
  • func (p *PerformanceMonitor) Start()
  • func (p *PerformanceMonitor) Stop()
• type PerformanceReporter
• type TxCounter
  • func NewTxCounter() *TxCounter
  • func (t *TxCounter) GetBenchmarks() map[string]interface{}
  • func (*TxCounter) Name() string
  • func (t *TxCounter) Start()
  • func (t *TxCounter) Stop()

Types

type PerformanceMonitor

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

func (*PerformanceMonitor) CollectData

func (p *PerformanceMonitor) CollectData() map[string]interface{}

func (PerformanceMonitor) Name

func (PerformanceMonitor) Name() string

func (*PerformanceMonitor) Register

func (p *PerformanceMonitor) Register(holder PerformanceReporter)

func (*PerformanceMonitor) Start

func (p *PerformanceMonitor) Start()

func (*PerformanceMonitor) Stop

func (p *PerformanceMonitor) Stop()

type PerformanceReporter

type PerformanceReporter interface {
	Name() string
	GetBenchmarks() map[string]interface{}
}

type TxCounter

type TxCounter struct {
	TxGenerated        atomic.Uint64 `json:"txGenerated"`        // tx generated by me
	TxReceived         atomic.Uint64 `json:"txReceived"`         // tx generated by me and others
	TxConfirmed        atomic.Uint64 `json:"txConfirmed"`        // tx confirmed
	SequencerGenerated atomic.Uint64 `json:"sequencerGenerated"` // sequencer generated by me
	SequencerReceived  atomic.Uint64 `json:"sequencerReceived"`  // sequencer generated by me and others
	SequencerConfirmed atomic.Uint64 `json:"sequencerConfirmed"` // sequencer confirmed
	StartupTime        time.Time     `json:"startupTime"`        // timestamp of the program started.

	// listeners
	NewTxReceivedChan  chan types.Txi                 `json:"-"`
	NewTxGeneratedChan chan types.Txi                 `json:"-"`
	BatchConfirmedChan chan map[common.Hash]types.Txi `json:"-"`
	// contains filtered or unexported fields
}

func NewTxCounter

func NewTxCounter() *TxCounter

func (*TxCounter) GetBenchmarks

func (t *TxCounter) GetBenchmarks() map[string]interface{}

func (*TxCounter) Name

func (*TxCounter) Name() string

func (*TxCounter) Start

func (t *TxCounter) Start()

func (*TxCounter) Stop

func (t *TxCounter) Stop()