notify

Documentation

Index

• Constants
• type MonitorNotify
  • func NewMonitorNotify(p *NotifyConfig, rpcURL string, blockDelay int64, enableTracer bool, ...) (*MonitorNotify, error)
  • func (n *MonitorNotify) MarshalJSON() ([]byte, error)
  • func (n *MonitorNotify) Run() error
• type Notify
• type NotifyConfig
• type PendingNotify
  • func NewPendingNotify(s, p *NotifyConfig, logger *log.Logger) (*PendingNotify, error)
  • func (n *PendingNotify) MarshalJSON() ([]byte, error)
  • func (n *PendingNotify) Run() error
• type TransaferNotify
  • func NewTransferNotify(s, p *NotifyConfig, rpcURL string, block int64, logger *log.Logger) (*TransaferNotify, error)
  • func (n *TransaferNotify) MarshalJSON() ([]byte, error)
  • func (n *TransaferNotify) Run() error
• type TransferTx
  • func (c *TransferTx) MarshalJSON() ([]byte, error)
  • func (c *TransferTx) UnmarshalJSON(data []byte) error
• type Tx
• type TxAge

Constants

const NewChainNotifyMonitorLatestHeight = ".BlockHeight"

LatestHeight config file

Types

type MonitorNotify

type MonitorNotify struct {
	Notify
	// contains filtered or unexported fields
}

func NewMonitorNotify

func NewMonitorNotify(p *NotifyConfig, rpcURL string, blockDelay int64, enableTracer bool, traceConfig *tracer.TraceConfig, logger *log.Logger) (*MonitorNotify, error)

func (*MonitorNotify) MarshalJSON

func (n *MonitorNotify) MarshalJSON() ([]byte, error)

MarshalJSON encodes to json format.

func (*MonitorNotify) Run

func (n *MonitorNotify) Run() error

type Notify

type Notify struct {
	Logger *log.Logger
	// contains filtered or unexported fields
}

type NotifyConfig

type NotifyConfig struct {
	Server      string
	Username    string
	Password    string
	ClientID    string
	QoS         byte
	Topic       string
	PrefixTopic string // for publish and only for n_address
}

type PendingNotify

type PendingNotify struct {
	Notify
}

func NewPendingNotify

func NewPendingNotify(s, p *NotifyConfig, logger *log.Logger) (*PendingNotify, error)

func (*PendingNotify) MarshalJSON

func (n *PendingNotify) MarshalJSON() ([]byte, error)

MarshalJSON encodes to json format.

func (*PendingNotify) Run

func (n *PendingNotify) Run() error

type TransaferNotify

type TransaferNotify struct {
	Notify
	// contains filtered or unexported fields
}

func NewTransferNotify

func NewTransferNotify(s, p *NotifyConfig, rpcURL string, block int64, logger *log.Logger) (*TransaferNotify, error)

func (*TransaferNotify) MarshalJSON

func (n *TransaferNotify) MarshalJSON() ([]byte, error)

MarshalJSON encodes to json format.

func (*TransaferNotify) Run

func (n *TransaferNotify) Run() error

type TransferTx

type TransferTx struct {
	From        common.Address  `json:"from"`
	To          *common.Address `json:"to"`
	Value       *big.Int        `json:"value"`
	Hash        common.Hash     `json:"hash"`
	Data        []byte          `json:"data"`
	BlockNumber *big.Int        `json:"blockNumber"`
}

func (*TransferTx) MarshalJSON

func (c *TransferTx) MarshalJSON() ([]byte, error)

MarshalJSON encodes to json format.

func (*TransferTx) UnmarshalJSON

func (c *TransferTx) UnmarshalJSON(data []byte) error

UnmarshalJSON decodes from json format to a TransferTx.

type Tx

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

type TxAge

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