event

Documentation

Index

• Constants
• type Component
• type Config
• type Event
• type EventID
• type EventLog
  • func NewEventLog(cfg Config, storage Storage) *EventLog
  • func (e *EventLog) LogEvent(ctx context.Context, event *Event) error
  • func (e *EventLog) LogExecutorError(ctx context.Context, responseError pb.ExecutorError, ...)
• type Level
• type Source
• type Storage

Constants

const (
	// EventID_NodeComponentStarted is triggered when the node starts
	EventID_NodeComponentStarted = "NODE COMPONENT STARTED"
	// EventID_PreexecutionOOC is triggered when an OOC error is detected during the preexecution
	EventID_PreexecutionOOC EventID = "PRE EXECUTION OOC"
	// EventID_PreexecutionOOG is triggered when an OOG error is detected during the preexecution
	EventID_PreexecutionOOG EventID = "PRE EXECUTION OOG"
	// EventID_ExecutorError is triggered when an error is detected during the execution
	EventID_ExecutorError EventID = "EXECUTOR ERROR"
	// EventID_ReprocessFullBatchOOC is triggered when an OOC error is detected during the reprocessing of a full batch
	EventID_ReprocessFullBatchOOC EventID = "REPROCESS FULL BATCH OOC"
	// EventID_ExecutorRLPError is triggered when an RLP error is detected during the execution
	EventID_ExecutorRLPError EventID = "EXECUTOR RLP ERROR"
	// EventID_FinalizerHalt is triggered when the finalizer halts
	EventID_FinalizerHalt EventID = "FINALIZER HALT"

	// Source_Node is the source of the event
	Source_Node Source = "node"

	// Component_RPC is the component that triggered the event
	Component_RPC Component = "rpc"
	// Component_Pool is the component that triggered the event
	Component_Pool Component = "pool"
	// Component_Sequencer is the component that triggered the event
	Component_Sequencer Component = "sequencer"
	// Component_Synchronizer is the component that triggered the event
	Component_Synchronizer Component = "synchronizer"
	// Component_Aggregator is the component that triggered the event
	Component_Aggregator Component = "aggregator"
	// Component_EthTxManager is the component that triggered the event
	Component_EthTxManager Component = "ethtxmanager"
	// Component_GasPricer is the component that triggered the event
	Component_GasPricer Component = "gaspricer"
	// Component_Executor is the component that triggered the event
	Component_Executor Component = "executor"
	// Component_Broadcast is the component that triggered the event
	Component_Broadcast Component = "broadcast"

	// Level_Emergency is the most severe level
	Level_Emergency Level = "emerg"
	// Level_Alert is the second most severe level
	Level_Alert Level = "alert"
	// Level_Critical is the third most severe level
	Level_Critical Level = "crit"
	// Level_Error is the fourth most severe level
	Level_Error Level = "err"
	// Level_Warning is the fifth most severe level
	Level_Warning Level = "warning"
	// Level_Notice is the sixth most severe level
	Level_Notice Level = "notice"
	// Level_Info is the seventh most severe level
	Level_Info Level = "info"
	// Level_Debug is the least severe level
	Level_Debug Level = "debug"
)

Types

type Component

type Component string

Component is the component that triggered the event

type Config

type Config struct {
	// DB is the database configuration
	DB db.Config `mapstructure:"DB"`
}

Config for event

type Event

type Event struct {
	Id          big.Int
	ReceivedAt  time.Time
	IPAddress   string
	Source      Source
	Component   Component
	Level       Level
	EventID     EventID
	Description string
	Data        []byte
	Json        interface{}
}

Event represents a event that may be investigated

type EventID

type EventID string

EventID is the ID of the event

type EventLog

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

EventLog is the main struct for the event log

func NewEventLog

func NewEventLog(cfg Config, storage Storage) *EventLog

NewEventLog creates and initializes an instance of EventLog

func (*EventLog) LogEvent

func (e *EventLog) LogEvent(ctx context.Context, event *Event) error

LogEvent is used to store an event for runtime debugging

func (*EventLog) LogExecutorError

func (e *EventLog) LogExecutorError(ctx context.Context, responseError pb.ExecutorError, processBatchRequest *pb.ProcessBatchRequest)

LogExecutorError is used to store Executor error for runtime debugging

type Level

type Level string

Level is the level of the event

type Source

type Source string

Source is the source of the event

type Storage

type Storage interface {
	// LogEvent logs an event
	LogEvent(ctx context.Context, event *Event) error
}

Storage is the interface for the event storage