mempool

Documentation

Index

• func DisableLog()
• func JSONFormatMempoolData(data *MempoolData) (*bytes.Buffer, error)
• func NewMempoolDataCollector(dcrdChainSvr *dcrrpcclient.Client, params *chaincfg.Params) *mempoolDataCollector
• func NewMempoolMonitor(collector *mempoolDataCollector, savers []MempoolDataSaver, ...) *mempoolMonitor
• func UseLogger(logger btclog.Logger)
• type ByAbsoluteFee
  • func (tix ByAbsoluteFee) Less(i, j int) bool
• type ByFeeRate
  • func (tix ByFeeRate) Less(i, j int) bool
• type MempoolData
  • func (m *MempoolData) GetHeight() uint32
  • func (m *MempoolData) GetNumTickets() uint32
• type MempoolDataCache
  • func (c *MempoolDataCache) GetFeeInfo() (uint32, dcrjson.FeeInfoMempool)
  • func (c *MempoolDataCache) GetFeeInfoExtra() (uint32, *apitypes.MempoolTicketFeeInfo)
  • func (c *MempoolDataCache) GetFeeRates(N int) (uint32, int64, int, []float64)
  • func (c *MempoolDataCache) GetFees(N int) (uint32, int, []float64)
  • func (c *MempoolDataCache) GetHeight() uint32
  • func (c *MempoolDataCache) GetNumTickets() (uint32, uint32)
  • func (c *MempoolDataCache) GetTicketsDetails(N int) (uint32, int64, int, TicketsDetails)
  • func (c *MempoolDataCache) StoreMPData(data *MempoolData, timestamp time.Time) error
• type MempoolDataSaver
• type MempoolDataToJSONFiles
  • func NewMempoolDataToJSONFiles(folder string, fileBase string, m ...*sync.Mutex) *MempoolDataToJSONFiles
  • func (s *MempoolDataToJSONFiles) StoreMPData(data *MempoolData) error
• type MempoolDataToJSONStdOut
  • func NewMempoolDataToJSONStdOut(m ...*sync.Mutex) *MempoolDataToJSONStdOut
  • func (s *MempoolDataToJSONStdOut) StoreMPData(data *MempoolData) error
• type MempoolDataToSummaryStdOut
  • func NewMempoolDataToSummaryStdOut(feeWindowRadius int, m ...*sync.Mutex) *MempoolDataToSummaryStdOut
  • func (s *MempoolDataToSummaryStdOut) StoreMPData(data *MempoolData) error
• type MempoolFeeDumper
  • func NewMempoolFeeDumper(folder string, fileBase string, m ...*sync.Mutex) *MempoolFeeDumper
  • func (s *MempoolFeeDumper) StoreMPData(data *MempoolData, timestamp time.Time) error
• type MempoolInfo
• type MinableFeeInfo
• type Stakelimitfeeinfo
• type TicketsDetails
  • func (tix TicketsDetails) Len() int
  • func (tix TicketsDetails) Swap(i, j int)

Functions

func DisableLog

func DisableLog()

DisableLog disables all library log output. Logging output is disabled by default until either UseLogger or SetLogWriter are called.

func JSONFormatMempoolData

func JSONFormatMempoolData(data *MempoolData) (*bytes.Buffer, error)

JSONFormatMempoolData concatenates block data results into a single JSON object with primary keys for the result type

func NewMempoolDataCollector

func NewMempoolDataCollector(dcrdChainSvr *dcrrpcclient.Client, params *chaincfg.Params) *mempoolDataCollector

NewMempoolDataCollector creates a new mempoolDataCollector.

func NewMempoolMonitor

func NewMempoolMonitor(collector *mempoolDataCollector,
	savers []MempoolDataSaver, newTxChan chan *chainhash.Hash,
	quit chan struct{}, wg *sync.WaitGroup, newTicketLimit int32,
	mini time.Duration, maxi time.Duration, mpi *MempoolInfo) *mempoolMonitor

NewMempoolMonitor creates a new mempoolMonitor

func UseLogger

func UseLogger(logger btclog.Logger)

UseLogger uses a specified Logger to output package logging info. This should be used in preference to SetLogWriter if the caller is also using btclog.

Types

type ByAbsoluteFee

type ByAbsoluteFee struct {
	TicketsDetails
}

func (ByAbsoluteFee) Less

func (tix ByAbsoluteFee) Less(i, j int) bool

type ByFeeRate

type ByFeeRate struct {
	TicketsDetails
}

func (ByFeeRate) Less

func (tix ByFeeRate) Less(i, j int) bool

type MempoolData

type MempoolData struct {
	Height            uint32
	NumTickets        uint32
	NewTickets        uint32
	Ticketfees        *dcrjson.TicketFeeInfoResult
	MinableFees       *MinableFeeInfo
	AllTicketsDetails TicketsDetails
}

func (*MempoolData) GetHeight

func (m *MempoolData) GetHeight() uint32

func (*MempoolData) GetNumTickets

func (m *MempoolData) GetNumTickets() uint32

type MempoolDataCache

type MempoolDataCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*MempoolDataCache) GetFeeInfo

func (c *MempoolDataCache) GetFeeInfo() (uint32, dcrjson.FeeInfoMempool)

func (*MempoolDataCache) GetFeeInfoExtra

func (c *MempoolDataCache) GetFeeInfoExtra() (uint32, *apitypes.MempoolTicketFeeInfo)

func (*MempoolDataCache) GetFeeRates

func (c *MempoolDataCache) GetFeeRates(N int) (uint32, int64, int, []float64)

func (*MempoolDataCache) GetFees

func (c *MempoolDataCache) GetFees(N int) (uint32, int, []float64)

func (*MempoolDataCache) GetHeight

func (c *MempoolDataCache) GetHeight() uint32

func (*MempoolDataCache) GetNumTickets

func (c *MempoolDataCache) GetNumTickets() (uint32, uint32)

func (*MempoolDataCache) GetTicketsDetails

func (c *MempoolDataCache) GetTicketsDetails(N int) (uint32, int64, int, TicketsDetails)

func (*MempoolDataCache) StoreMPData

func (c *MempoolDataCache) StoreMPData(data *MempoolData, timestamp time.Time) error

type MempoolDataSaver

type MempoolDataSaver interface {
	StoreMPData(data *MempoolData, timestamp time.Time) error
}

MempoolDataSaver is an interface for saving/storing MempoolData

type MempoolDataToJSONFiles

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

MempoolDataToJSONFiles implements MempoolDataSaver interface for JSON output to the file system

func NewMempoolDataToJSONFiles

func NewMempoolDataToJSONFiles(folder string, fileBase string,
	m ...*sync.Mutex) *MempoolDataToJSONFiles

NewMempoolDataToJSONFiles creates a new MempoolDataToJSONFiles with optional existing mutex

func (*MempoolDataToJSONFiles) StoreMPData

func (s *MempoolDataToJSONFiles) StoreMPData(data *MempoolData) error

Store writes MempoolData to a file in JSON format The file name is nameBase+height+".json".

type MempoolDataToJSONStdOut

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

MempoolDataToJSONStdOut implements MempoolDataSaver interface for JSON output to stdout

func NewMempoolDataToJSONStdOut

func NewMempoolDataToJSONStdOut(m ...*sync.Mutex) *MempoolDataToJSONStdOut

NewMempoolDataToJSONStdOut creates a new MempoolDataToJSONStdOut with optional existing mutex

func (*MempoolDataToJSONStdOut) StoreMPData

func (s *MempoolDataToJSONStdOut) StoreMPData(data *MempoolData) error

Store writes MempoolData to stdout in JSON format

type MempoolDataToSummaryStdOut

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

MempoolDataToSummaryStdOut implements MempoolDataSaver interface for plain text summary to stdout

func NewMempoolDataToSummaryStdOut

func NewMempoolDataToSummaryStdOut(feeWindowRadius int, m ...*sync.Mutex) *MempoolDataToSummaryStdOut

NewMempoolDataToSummaryStdOut creates a new MempoolDataToSummaryStdOut with optional existing mutex

func (*MempoolDataToSummaryStdOut) StoreMPData

func (s *MempoolDataToSummaryStdOut) StoreMPData(data *MempoolData) error

Store writes MempoolData to stdout as plain text summary

type MempoolFeeDumper

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

MempoolFeeDumper implements MempoolDataSaver interface for a complete file dump of all ticket fees to the file system

func NewMempoolFeeDumper

func NewMempoolFeeDumper(folder string, fileBase string, m ...*sync.Mutex) *MempoolFeeDumper

NewMempoolFeeDumper creates a new MempoolFeeDumper with optional existing mutex

func (*MempoolFeeDumper) StoreMPData

func (s *MempoolFeeDumper) StoreMPData(data *MempoolData, timestamp time.Time) error

Store writes all the ticket fees to a file The file name is nameBase+".json".

type MempoolInfo

type MempoolInfo struct {
	CurrentHeight               uint32
	NumTicketPurchasesInMempool uint32
	NumTicketsSinceStatsReport  int32
	LastCollectTime             time.Time
}

type MinableFeeInfo

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

MinableFeeInfo describes the ticket fees

type Stakelimitfeeinfo

type Stakelimitfeeinfo struct {
	Stakelimitfee float64 `json:"stakelimitfee"`
}

Stakelimitfeeinfo JSON output

type TicketsDetails

type TicketsDetails []*apitypes.TicketDetails

func (TicketsDetails) Len

func (tix TicketsDetails) Len() int

func (TicketsDetails) Swap

func (tix TicketsDetails) Swap(i, j int)