package logger import ( "time" ) type utctime8601 struct{} func (utctime8601) MarshalJSON() ([]byte, error) { // FIX This should be re-formated for proper ISO 8601 return []byte(`"` + time.Now().UTC().Format(time.RFC3339Nano)[:26] + `Z"`), nil } type JsonLog interface { EventName() string } type LogEvent struct { Guid string `json:"guid"` Ts utctime8601 `json:"ts"` // Level string `json:"level"` } type LogStarting struct { ClientString string `json:"version_string"` Coinbase string `json:"coinbase"` ProtocolVersion int `json:"eth_version"` LogEvent } func (l *LogStarting) EventName() string { return "starting" } type P2PConnecting struct { RemoteId string `json:"remote_id"` RemoteEndpoint string `json:"remote_endpoint"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PConnecting) EventName() string { return "p2p.connecting" } type P2PConnected struct { NumConnections int `json:"num_connections"` RemoteId string `json:"remote_id"` LogEvent } func (l *P2PConnected) EventName() string { return "p2p.connected" } type P2PHandshaked struct { RemoteCapabilities []string `json:"remote_capabilities"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PHandshaked) EventName() string { return "p2p.handshaked" } type P2PDisconnected struct { NumConnections int `json:"num_connections"` RemoteId string `json:"remote_id"` LogEvent } func (l *P2PDisconnected) EventName() string { return "p2p.disconnected" } type P2PDisconnecting struct { Reason string `json:"reason"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PDisconnecting) EventName() string { return "p2p.disconnecting" } type P2PDisconnectingBadHandshake struct { Reason string `json:"reason"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PDisconnectingBadHandshake) EventName() string { return "p2p.disconnecting.bad_handshake" } type P2PDisconnectingBadProtocol struct { Reason string `json:"reason"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PDisconnectingBadProtocol) EventName() string { return "p2p.disconnecting.bad_protocol" } type P2PDisconnectingReputation struct { Reason string `json:"reason"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PDisconnectingReputation) EventName() string { return "p2p.disconnecting.reputation" } type P2PDisconnectingDHT struct { Reason string `json:"reason"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PDisconnectingDHT) EventName() string { return "p2p.disconnecting.dht" } type P2PEthDisconnectingBadBlock struct { Reason string `json:"reason"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PEthDisconnectingBadBlock) EventName() string { return "p2p.eth.disconnecting.bad_block" } type P2PEthDisconnectingBadTx struct { Reason string `json:"reason"` RemoteId string `json:"remote_id"` NumConnections int `json:"num_connections"` LogEvent } func (l *P2PEthDisconnectingBadTx) EventName() string { return "p2p.eth.disconnecting.bad_tx" } type EthNewBlockMined struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockHexRlp string `json:"block_hexrlp"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockMined) EventName() string { return "eth.newblock.mined" } type EthNewBlockBroadcasted struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockBroadcasted) EventName() string { return "eth.newblock.broadcasted" } type EthNewBlockReceived struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockReceived) EventName() string { return "eth.newblock.received" } type EthNewBlockIsKnown struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockIsKnown) EventName() string { return "eth.newblock.is_known" } type EthNewBlockIsNew struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockIsNew) EventName() string { return "eth.newblock.is_new" } type EthNewBlockMissingParent struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockMissingParent) EventName() string { return "eth.newblock.missing_parent" } type EthNewBlockIsInvalid struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockIsInvalid) EventName() string { return "eth.newblock.is_invalid" } type EthNewBlockChainIsOlder struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockChainIsOlder) EventName() string { return "eth.newblock.chain.is_older" } type EthNewBlockChainIsCanonical struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockChainIsCanonical) EventName() string { return "eth.newblock.chain.is_cannonical" } type EthNewBlockChainNotCanonical struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockChainNotCanonical) EventName() string { return "eth.newblock.chain.not_cannonical" } type EthNewBlockChainSwitched struct { BlockNumber int `json:"block_number"` HeadHash string `json:"head_hash"` OldHeadHash string `json:"old_head_hash"` BlockHash string `json:"block_hash"` BlockDifficulty int `json:"block_difficulty"` BlockPrevHash string `json:"block_prev_hash"` LogEvent } func (l *EthNewBlockChainSwitched) EventName() string { return "eth.newblock.chain.switched" } type EthTxCreated struct { TxHash string `json:"tx_hash"` TxSender string `json:"tx_sender"` TxAddress string `json:"tx_address"` TxHexRLP string `json:"tx_hexrlp"` TxNonce int `json:"tx_nonce"` LogEvent } func (l *EthTxCreated) EventName() string { return "eth.tx.created" } type EthTxReceived struct { TxHash string `json:"tx_hash"` TxAddress string `json:"tx_address"` TxHexRLP string `json:"tx_hexrlp"` RemoteId string `json:"remote_id"` TxNonce int `json:"tx_nonce"` LogEvent } func (l *EthTxReceived) EventName() string { return "eth.tx.received" } type EthTxBroadcasted struct { TxHash string `json:"tx_hash"` TxSender string `json:"tx_sender"` TxAddress string `json:"tx_address"` TxNonce int `json:"tx_nonce"` LogEvent } func (l *EthTxBroadcasted) EventName() string { return "eth.tx.broadcasted" } type EthTxValidated struct { TxHash string `json:"tx_hash"` TxSender string `json:"tx_sender"` TxAddress string `json:"tx_address"` TxNonce int `json:"tx_nonce"` LogEvent } func (l *EthTxValidated) EventName() string { return "eth.tx.validated" } type EthTxIsInvalid struct { TxHash string `json:"tx_hash"` TxSender string `json:"tx_sender"` TxAddress string `json:"tx_address"` Reason string `json:"reason"` TxNonce int `json:"tx_nonce"` LogEvent } func (l *EthTxIsInvalid) EventName() string { return "eth.tx.is_invalid" }