mempool

Documentation

Index

• type Mempool
  • func NewMempool(cfg config.NetworkConfig, pub Publisher) (*Mempool, error)
  • func (m Mempool) Do(ctx context.Context, method, url, params string, v interface{}) (err error)
  • func (m Mempool) GetMempool() (op []gotez.Operations, err error)
  • func (m *Mempool) MonitorMempool()
• type Publisher

Types

type Mempool

type Mempool struct {
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

func NewMempool

func NewMempool(cfg config.NetworkConfig, pub Publisher) (*Mempool, error)

func (Mempool) Do

func (m Mempool) Do(ctx context.Context, method, url, params string, v interface{}) (err error)

func (Mempool) GetMempool

func (m Mempool) GetMempool() (op []gotez.Operations, err error)

func (*Mempool) MonitorMempool

func (m *Mempool) MonitorMempool()

type Publisher

type Publisher interface {
	Broadcast(msg models.MessageInterface) error
}