chainobserver

Documentation

Index

• Variables
• type ChainObserver
  • func NewChainObserver(ctx context.Context, rollupAddr common.Address, updateOpinion bool, ...) (*ChainObserver, error)
  • func (chain *ChainObserver) AddListener(ctx context.Context, listener chainlistener.ChainListener)
  • func (chain *ChainObserver) ContractAddress() common.Address
  • func (chain *ChainObserver) CurrentEventId() arbbridge.ChainInfo
  • func (chain *ChainObserver) DebugString(prefix string) string
  • func (chain *ChainObserver) GetChainParams() valprotocol.ChainParams
  • func (chain *ChainObserver) HandleNotification(ctx context.Context, event arbbridge.Event) error
  • func (chain *ChainObserver) IsAtHead() bool
  • func (chain *ChainObserver) NotifyNewBlock(blockId *common.BlockId)
  • func (chain *ChainObserver) NotifyNextEvent(blockId *common.BlockId)
  • func (chain *ChainObserver) NowAtHead()
  • func (chain *ChainObserver) RestartFromLatestValid(ctx context.Context)
  • func (chain *ChainObserver) Start(ctx context.Context)
  • func (chain *ChainObserver) UpdateAssumedValidBlock(ctx context.Context, clnt arbbridge.ChainTimeGetter, assumedValidDepth int64) error
• type ChainObserverBuf
  • func (*ChainObserverBuf) Descriptor() ([]byte, []int)
  • func (x *ChainObserverBuf) GetCalculatedValidNode() *common.HashBuf
  • func (x *ChainObserverBuf) GetContractAddress() *common.AddressBuf
  • func (x *ChainObserverBuf) GetInbox() *structures.InboxBuf
  • func (x *ChainObserverBuf) GetKnownValidNode() *common.HashBuf
  • func (x *ChainObserverBuf) GetStakedNodeGraph() *nodegraph.StakedNodeGraphBuf
  • func (*ChainObserverBuf) ProtoMessage()
  • func (x *ChainObserverBuf) ProtoReflect() protoreflect.Message
  • func (x *ChainObserverBuf) Reset()
  • func (x *ChainObserverBuf) String() string
• type DummyCheckpointer
  • func NewDummyCheckpointer() *DummyCheckpointer
  • func (dcp *DummyCheckpointer) AsyncSaveCheckpoint(_ *common.BlockId, _ []byte, _ *ckptcontext.CheckpointContext) <-chan error
  • func (dcp *DummyCheckpointer) GetInitialMachine(valueCache machine.ValueCache) (machine.Machine, error)
  • func (dcp *DummyCheckpointer) HasCheckpointedState() bool
  • func (dcp *DummyCheckpointer) Initialize(arbitrumCodefilePath string) error
  • func (dcp *DummyCheckpointer) Initialized() bool
  • func (dcp DummyCheckpointer) MaxReorgHeight() *big.Int
  • func (dcp *DummyCheckpointer) RestoreLatestState(context.Context, arbbridge.ChainTimeGetter, ...) error

Variables

var File_chainobserver_proto protoreflect.FileDescriptor

Types

type ChainObserver

type ChainObserver struct {
	sync.RWMutex
	NodeGraph *nodegraph.StakedNodeGraph

	Inbox          *structures.Inbox
	KnownValidNode *structures.Node
	// contains filtered or unexported fields
}

func NewChainObserver

func NewChainObserver(
	ctx context.Context,
	rollupAddr common.Address,
	updateOpinion bool,
	clnt arbbridge.ChainTimeGetter,
	watcher arbbridge.ArbRollupWatcher,
	checkpointer checkpointing.RollupCheckpointer,
	assumedValidDepth int64,
) (*ChainObserver, error)

func (*ChainObserver) AddListener

func (chain *ChainObserver) AddListener(
	ctx context.Context,
	listener chainlistener.ChainListener,
)

func (*ChainObserver) ContractAddress

func (chain *ChainObserver) ContractAddress() common.Address

func (*ChainObserver) CurrentEventId

func (chain *ChainObserver) CurrentEventId() arbbridge.ChainInfo

func (*ChainObserver) DebugString

func (chain *ChainObserver) DebugString(prefix string) string

func (*ChainObserver) GetChainParams

func (chain *ChainObserver) GetChainParams() valprotocol.ChainParams

func (*ChainObserver) HandleNotification

func (chain *ChainObserver) HandleNotification(ctx context.Context, event arbbridge.Event) error

func (*ChainObserver) IsAtHead

func (chain *ChainObserver) IsAtHead() bool

func (*ChainObserver) NotifyNewBlock

func (chain *ChainObserver) NotifyNewBlock(blockId *common.BlockId)

func (*ChainObserver) NotifyNextEvent

func (chain *ChainObserver) NotifyNextEvent(blockId *common.BlockId)

func (*ChainObserver) NowAtHead

func (chain *ChainObserver) NowAtHead()

func (*ChainObserver) RestartFromLatestValid

func (chain *ChainObserver) RestartFromLatestValid(ctx context.Context)

func (*ChainObserver) Start

func (chain *ChainObserver) Start(ctx context.Context)

func (*ChainObserver) UpdateAssumedValidBlock

func (chain *ChainObserver) UpdateAssumedValidBlock(ctx context.Context, clnt arbbridge.ChainTimeGetter, assumedValidDepth int64) error

type ChainObserverBuf

type ChainObserverBuf struct {
	StakedNodeGraph     *nodegraph.StakedNodeGraphBuf `protobuf:"bytes,1,opt,name=stakedNodeGraph,proto3" json:"stakedNodeGraph,omitempty"`
	ContractAddress     *common.AddressBuf            `protobuf:"bytes,2,opt,name=contractAddress,proto3" json:"contractAddress,omitempty"`
	Inbox               *structures.InboxBuf          `protobuf:"bytes,3,opt,name=inbox,proto3" json:"inbox,omitempty"`
	KnownValidNode      *common.HashBuf               `protobuf:"bytes,4,opt,name=knownValidNode,proto3" json:"knownValidNode,omitempty"`
	CalculatedValidNode *common.HashBuf               `protobuf:"bytes,5,opt,name=calculatedValidNode,proto3" json:"calculatedValidNode,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainObserverBuf) Descriptor

func (*ChainObserverBuf) Descriptor() ([]byte, []int)

Deprecated: Use ChainObserverBuf.ProtoReflect.Descriptor instead.

func (*ChainObserverBuf) GetCalculatedValidNode

func (x *ChainObserverBuf) GetCalculatedValidNode() *common.HashBuf

func (*ChainObserverBuf) GetContractAddress

func (x *ChainObserverBuf) GetContractAddress() *common.AddressBuf

func (*ChainObserverBuf) GetInbox

func (x *ChainObserverBuf) GetInbox() *structures.InboxBuf

func (*ChainObserverBuf) GetKnownValidNode

func (x *ChainObserverBuf) GetKnownValidNode() *common.HashBuf

func (*ChainObserverBuf) GetStakedNodeGraph

func (x *ChainObserverBuf) GetStakedNodeGraph() *nodegraph.StakedNodeGraphBuf

func (*ChainObserverBuf) ProtoMessage

func (*ChainObserverBuf) ProtoMessage()

func (*ChainObserverBuf) ProtoReflect

func (x *ChainObserverBuf) ProtoReflect() protoreflect.Message

func (*ChainObserverBuf) Reset

func (x *ChainObserverBuf) Reset()

func (*ChainObserverBuf) String

func (x *ChainObserverBuf) String() string

type DummyCheckpointer

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

func NewDummyCheckpointer

func NewDummyCheckpointer() *DummyCheckpointer

func (*DummyCheckpointer) AsyncSaveCheckpoint

func (dcp *DummyCheckpointer) AsyncSaveCheckpoint(_ *common.BlockId, _ []byte, _ *ckptcontext.CheckpointContext) <-chan error

func (*DummyCheckpointer) GetInitialMachine

func (dcp *DummyCheckpointer) GetInitialMachine(valueCache machine.ValueCache) (machine.Machine, error)

func (*DummyCheckpointer) HasCheckpointedState

func (dcp *DummyCheckpointer) HasCheckpointedState() bool

func (*DummyCheckpointer) Initialize

func (dcp *DummyCheckpointer) Initialize(arbitrumCodefilePath string) error

func (*DummyCheckpointer) Initialized

func (dcp *DummyCheckpointer) Initialized() bool

func (DummyCheckpointer) MaxReorgHeight

func (dcp DummyCheckpointer) MaxReorgHeight() *big.Int

func (*DummyCheckpointer) RestoreLatestState

func (dcp *DummyCheckpointer) RestoreLatestState(context.Context, arbbridge.ChainTimeGetter, func([]byte, ckptcontext.RestoreContext, *common.BlockId) error) error