heimdall

Documentation

Overview

Package heimdall is a generated GoMock package.

Package heimdall is a generated GoMock package.

Package heimdall is a generated GoMock package.

Package heimdall is a generated GoMock package.

Package heimdall is a generated GoMock package.

Index

• Variables
• func Fetch[T any](ctx context.Context, request *Request, logger log.Logger) (*T, error)
• func FetchWithRetry[T any](ctx context.Context, client *Client, url *url.URL, logger log.Logger) (*T, error)
• func FetchWithRetryEx[T any](ctx context.Context, client *Client, url *url.URL, ...) (result *T, err error)
• func IsBlockInLastSprintOfSpan(blockNum uint64, config *borcfg.BorConfig) bool
• func NewBlockReaderStore(reader reader, tx kv.Tx) blockReaderStore
• func SpanEndBlockNum(spanId SpanId) uint64
• type Checkpoint
  • func (c Checkpoint) CmpRange(n uint64) int
  • func (c Checkpoint) EndBlock() *big.Int
  • func (c Checkpoint) Length() uint64
  • func (c *Checkpoint) MarshalJSON() ([]byte, error)
  • func (c Checkpoint) RootHash() libcommon.Hash
  • func (c Checkpoint) StartBlock() *big.Int
  • func (m Checkpoint) String() string
  • func (c Checkpoint) Timestamp() uint64
  • func (c *Checkpoint) UnmarshalJSON(b []byte) error
• type CheckpointCount
• type CheckpointCountResponse
• type CheckpointId
  • func CheckpointIdAt(tx kv.Tx, block uint64) (CheckpointId, error)
• type CheckpointListResponse
• type CheckpointReader
• type CheckpointResponse
• type CheckpointStore
• type CheckpointWriter
• type Checkpoints
  • func (cs Checkpoints) Len() int
  • func (cs Checkpoints) Less(i, j int) bool
  • func (cs Checkpoints) Swap(i, j int)
• type Client
  • func NewHeimdallClient(urlString string, logger log.Logger) *Client
  • func (c *Client) Close()
  • func (c *Client) FetchCheckpoint(ctx context.Context, number int64) (*Checkpoint, error)
  • func (c *Client) FetchCheckpointCount(ctx context.Context) (int64, error)
  • func (c *Client) FetchCheckpoints(ctx context.Context, page uint64, limit uint64) (Checkpoints, error)
  • func (c *Client) FetchLastNoAckMilestone(ctx context.Context) (string, error)
  • func (c *Client) FetchLatestSpan(ctx context.Context) (*Span, error)
  • func (c *Client) FetchMilestone(ctx context.Context, number int64) (*Milestone, error)
  • func (c *Client) FetchMilestoneCount(ctx context.Context) (int64, error)
  • func (c *Client) FetchMilestoneID(ctx context.Context, milestoneID string) error
  • func (c *Client) FetchNoAckMilestone(ctx context.Context, milestoneID string) error
  • func (c *Client) FetchSpan(ctx context.Context, spanID uint64) (*Span, error)
  • func (c *Client) FetchStateSyncEvent(ctx context.Context, id uint64) (*EventRecordWithTime, error)
  • func (c *Client) FetchStateSyncEvents(ctx context.Context, fromID uint64, to time.Time, limit int) ([]*EventRecordWithTime, error)
• type EventRecord
• type EventRecordWithTime
  • func UnpackEventRecordWithTime(stateContract abi.ABI, encodedEvent rlp.RawValue) (*EventRecordWithTime, error)
  • func (e *EventRecordWithTime) BuildEventRecord() *EventRecord
  • func (e *EventRecordWithTime) String() string
• type Heimdall
  • func NewHeimdall(client HeimdallClient, logger log.Logger) Heimdall
• type HeimdallClient
• type HeimdallNoStore
  • func NewHeimdallNoStore(client HeimdallClient, logger log.Logger) HeimdallNoStore
• type HttpClient
• type Milestone
  • func (m Milestone) CmpRange(n uint64) int
  • func (m Milestone) EndBlock() *big.Int
  • func (m Milestone) Length() uint64
  • func (m *Milestone) MarshalJSON() ([]byte, error)
  • func (m Milestone) RootHash() libcommon.Hash
  • func (m Milestone) StartBlock() *big.Int
  • func (m Milestone) String() string
  • func (m Milestone) Timestamp() uint64
  • func (m *Milestone) UnmarshalJSON(b []byte) error
• type MilestoneCount
• type MilestoneCountResponse
• type MilestoneID
• type MilestoneIDResponse
• type MilestoneId
  • func MilestoneIdAt(tx kv.Tx, block uint64) (MilestoneId, error)
• type MilestoneLastNoAck
• type MilestoneLastNoAckResponse
• type MilestoneNoAck
• type MilestoneNoAckResponse
• type MilestoneReader
• type MilestoneResponse
• type MilestoneStore
• type MilestoneWriter
• type MockCheckpointReader
  • func NewMockCheckpointReader(ctrl *gomock.Controller) *MockCheckpointReader
  • func (m *MockCheckpointReader) EXPECT() *MockCheckpointReaderMockRecorder
  • func (m *MockCheckpointReader) GetCheckpoint(ctx context.Context, checkpointId CheckpointId) (*Checkpoint, error)
  • func (m *MockCheckpointReader) LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)
• type MockCheckpointReaderGetCheckpointCall
  • func (c *MockCheckpointReaderGetCheckpointCall) Do(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointReaderGetCheckpointCall
  • func (c *MockCheckpointReaderGetCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointReaderGetCheckpointCall
  • func (c *MockCheckpointReaderGetCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockCheckpointReaderGetCheckpointCall
• type MockCheckpointReaderLastCheckpointIdCall
  • func (c *MockCheckpointReaderLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointReaderLastCheckpointIdCall
  • func (c *MockCheckpointReaderLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointReaderLastCheckpointIdCall
  • func (c *MockCheckpointReaderLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockCheckpointReaderLastCheckpointIdCall
• type MockCheckpointReaderMockRecorder
  • func (mr *MockCheckpointReaderMockRecorder) GetCheckpoint(ctx, checkpointId any) *MockCheckpointReaderGetCheckpointCall
  • func (mr *MockCheckpointReaderMockRecorder) LastCheckpointId(ctx any) *MockCheckpointReaderLastCheckpointIdCall
• type MockCheckpointStore
  • func NewMockCheckpointStore(ctrl *gomock.Controller) *MockCheckpointStore
  • func (m *MockCheckpointStore) EXPECT() *MockCheckpointStoreMockRecorder
  • func (m *MockCheckpointStore) GetCheckpoint(ctx context.Context, checkpointId CheckpointId) (*Checkpoint, error)
  • func (m *MockCheckpointStore) LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)
  • func (m *MockCheckpointStore) PutCheckpoint(ctx context.Context, checkpointId CheckpointId, checkpoint *Checkpoint) error
• type MockCheckpointStoreGetCheckpointCall
  • func (c *MockCheckpointStoreGetCheckpointCall) Do(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointStoreGetCheckpointCall
  • func (c *MockCheckpointStoreGetCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointStoreGetCheckpointCall
  • func (c *MockCheckpointStoreGetCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockCheckpointStoreGetCheckpointCall
• type MockCheckpointStoreLastCheckpointIdCall
  • func (c *MockCheckpointStoreLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointStoreLastCheckpointIdCall
  • func (c *MockCheckpointStoreLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointStoreLastCheckpointIdCall
  • func (c *MockCheckpointStoreLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockCheckpointStoreLastCheckpointIdCall
• type MockCheckpointStoreMockRecorder
  • func (mr *MockCheckpointStoreMockRecorder) GetCheckpoint(ctx, checkpointId any) *MockCheckpointStoreGetCheckpointCall
  • func (mr *MockCheckpointStoreMockRecorder) LastCheckpointId(ctx any) *MockCheckpointStoreLastCheckpointIdCall
  • func (mr *MockCheckpointStoreMockRecorder) PutCheckpoint(ctx, checkpointId, checkpoint any) *MockCheckpointStorePutCheckpointCall
• type MockCheckpointStorePutCheckpointCall
  • func (c *MockCheckpointStorePutCheckpointCall) Do(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointStorePutCheckpointCall
  • func (c *MockCheckpointStorePutCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointStorePutCheckpointCall
  • func (c *MockCheckpointStorePutCheckpointCall) Return(arg0 error) *MockCheckpointStorePutCheckpointCall
• type MockCheckpointWriter
  • func NewMockCheckpointWriter(ctrl *gomock.Controller) *MockCheckpointWriter
  • func (m *MockCheckpointWriter) EXPECT() *MockCheckpointWriterMockRecorder
  • func (m *MockCheckpointWriter) PutCheckpoint(ctx context.Context, checkpointId CheckpointId, checkpoint *Checkpoint) error
• type MockCheckpointWriterMockRecorder
  • func (mr *MockCheckpointWriterMockRecorder) PutCheckpoint(ctx, checkpointId, checkpoint any) *MockCheckpointWriterPutCheckpointCall
• type MockCheckpointWriterPutCheckpointCall
  • func (c *MockCheckpointWriterPutCheckpointCall) Do(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointWriterPutCheckpointCall
  • func (c *MockCheckpointWriterPutCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointWriterPutCheckpointCall
  • func (c *MockCheckpointWriterPutCheckpointCall) Return(arg0 error) *MockCheckpointWriterPutCheckpointCall
• type MockHeimdall
  • func NewMockHeimdall(ctrl *gomock.Controller) *MockHeimdall
  • func (m *MockHeimdall) EXPECT() *MockHeimdallMockRecorder
  • func (m *MockHeimdall) FetchCheckpoints(arg0 context.Context, arg1 CheckpointStore, arg2, arg3 CheckpointId) ([]*Checkpoint, error)
  • func (m *MockHeimdall) FetchCheckpointsFromBlock(arg0 context.Context, arg1 CheckpointStore, arg2 uint64) (Waypoints, error)
  • func (m *MockHeimdall) FetchLatestSpan(arg0 context.Context, arg1 SpanStore) (*Span, error)
  • func (m *MockHeimdall) FetchMilestones(arg0 context.Context, arg1 MilestoneStore, arg2, arg3 MilestoneId) ([]*Milestone, error)
  • func (m *MockHeimdall) FetchMilestonesFromBlock(arg0 context.Context, arg1 MilestoneStore, arg2 uint64) (Waypoints, error)
  • func (m *MockHeimdall) FetchSpans(arg0 context.Context, arg1 SpanStore, arg2, arg3 SpanId) ([]*Span, error)
  • func (m *MockHeimdall) FetchSpansFromBlock(arg0 context.Context, arg1 SpanStore, arg2 uint64) ([]*Span, error)
  • func (m *MockHeimdall) LastCheckpointId(arg0 context.Context, arg1 CheckpointStore) (CheckpointId, bool, error)
  • func (m *MockHeimdall) LastMilestoneId(arg0 context.Context, arg1 MilestoneStore) (MilestoneId, bool, error)
  • func (m *MockHeimdall) LastSpanId(arg0 context.Context, arg1 SpanStore) (SpanId, bool, error)
  • func (m *MockHeimdall) OnCheckpointEvent(arg0 context.Context, arg1 CheckpointStore, arg2 func(*Checkpoint)) error
  • func (m *MockHeimdall) OnMilestoneEvent(arg0 context.Context, arg1 MilestoneStore, arg2 func(*Milestone)) error
  • func (m *MockHeimdall) OnSpanEvent(arg0 context.Context, arg1 SpanStore, arg2 func(*Span)) error
• type MockHeimdallClient
  • func NewMockHeimdallClient(ctrl *gomock.Controller) *MockHeimdallClient
  • func (m *MockHeimdallClient) Close()
  • func (m *MockHeimdallClient) EXPECT() *MockHeimdallClientMockRecorder
  • func (m *MockHeimdallClient) FetchCheckpoint(arg0 context.Context, arg1 int64) (*Checkpoint, error)
  • func (m *MockHeimdallClient) FetchCheckpointCount(arg0 context.Context) (int64, error)
  • func (m *MockHeimdallClient) FetchCheckpoints(arg0 context.Context, arg1, arg2 uint64) (Checkpoints, error)
  • func (m *MockHeimdallClient) FetchLastNoAckMilestone(arg0 context.Context) (string, error)
  • func (m *MockHeimdallClient) FetchLatestSpan(arg0 context.Context) (*Span, error)
  • func (m *MockHeimdallClient) FetchMilestone(arg0 context.Context, arg1 int64) (*Milestone, error)
  • func (m *MockHeimdallClient) FetchMilestoneCount(arg0 context.Context) (int64, error)
  • func (m *MockHeimdallClient) FetchMilestoneID(arg0 context.Context, arg1 string) error
  • func (m *MockHeimdallClient) FetchNoAckMilestone(arg0 context.Context, arg1 string) error
  • func (m *MockHeimdallClient) FetchSpan(arg0 context.Context, arg1 uint64) (*Span, error)
  • func (m *MockHeimdallClient) FetchStateSyncEvent(arg0 context.Context, arg1 uint64) (*EventRecordWithTime, error)
  • func (m *MockHeimdallClient) FetchStateSyncEvents(arg0 context.Context, arg1 uint64, arg2 time.Time, arg3 int) ([]*EventRecordWithTime, error)
• type MockHeimdallClientCloseCall
  • func (c *MockHeimdallClientCloseCall) Do(f func()) *MockHeimdallClientCloseCall
  • func (c *MockHeimdallClientCloseCall) DoAndReturn(f func()) *MockHeimdallClientCloseCall
  • func (c *MockHeimdallClientCloseCall) Return() *MockHeimdallClientCloseCall
• type MockHeimdallClientFetchCheckpointCall
  • func (c *MockHeimdallClientFetchCheckpointCall) Do(f func(context.Context, int64) (*Checkpoint, error)) *MockHeimdallClientFetchCheckpointCall
  • func (c *MockHeimdallClientFetchCheckpointCall) DoAndReturn(f func(context.Context, int64) (*Checkpoint, error)) *MockHeimdallClientFetchCheckpointCall
  • func (c *MockHeimdallClientFetchCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockHeimdallClientFetchCheckpointCall
• type MockHeimdallClientFetchCheckpointCountCall
  • func (c *MockHeimdallClientFetchCheckpointCountCall) Do(f func(context.Context) (int64, error)) *MockHeimdallClientFetchCheckpointCountCall
  • func (c *MockHeimdallClientFetchCheckpointCountCall) DoAndReturn(f func(context.Context) (int64, error)) *MockHeimdallClientFetchCheckpointCountCall
  • func (c *MockHeimdallClientFetchCheckpointCountCall) Return(arg0 int64, arg1 error) *MockHeimdallClientFetchCheckpointCountCall
• type MockHeimdallClientFetchCheckpointsCall
  • func (c *MockHeimdallClientFetchCheckpointsCall) Do(f func(context.Context, uint64, uint64) (Checkpoints, error)) *MockHeimdallClientFetchCheckpointsCall
  • func (c *MockHeimdallClientFetchCheckpointsCall) DoAndReturn(f func(context.Context, uint64, uint64) (Checkpoints, error)) *MockHeimdallClientFetchCheckpointsCall
  • func (c *MockHeimdallClientFetchCheckpointsCall) Return(arg0 Checkpoints, arg1 error) *MockHeimdallClientFetchCheckpointsCall
• type MockHeimdallClientFetchLastNoAckMilestoneCall
  • func (c *MockHeimdallClientFetchLastNoAckMilestoneCall) Do(f func(context.Context) (string, error)) *MockHeimdallClientFetchLastNoAckMilestoneCall
  • func (c *MockHeimdallClientFetchLastNoAckMilestoneCall) DoAndReturn(f func(context.Context) (string, error)) *MockHeimdallClientFetchLastNoAckMilestoneCall
  • func (c *MockHeimdallClientFetchLastNoAckMilestoneCall) Return(arg0 string, arg1 error) *MockHeimdallClientFetchLastNoAckMilestoneCall
• type MockHeimdallClientFetchLatestSpanCall
  • func (c *MockHeimdallClientFetchLatestSpanCall) Do(f func(context.Context) (*Span, error)) *MockHeimdallClientFetchLatestSpanCall
  • func (c *MockHeimdallClientFetchLatestSpanCall) DoAndReturn(f func(context.Context) (*Span, error)) *MockHeimdallClientFetchLatestSpanCall
  • func (c *MockHeimdallClientFetchLatestSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallClientFetchLatestSpanCall
• type MockHeimdallClientFetchMilestoneCall
  • func (c *MockHeimdallClientFetchMilestoneCall) Do(f func(context.Context, int64) (*Milestone, error)) *MockHeimdallClientFetchMilestoneCall
  • func (c *MockHeimdallClientFetchMilestoneCall) DoAndReturn(f func(context.Context, int64) (*Milestone, error)) *MockHeimdallClientFetchMilestoneCall
  • func (c *MockHeimdallClientFetchMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockHeimdallClientFetchMilestoneCall
• type MockHeimdallClientFetchMilestoneCountCall
  • func (c *MockHeimdallClientFetchMilestoneCountCall) Do(f func(context.Context) (int64, error)) *MockHeimdallClientFetchMilestoneCountCall
  • func (c *MockHeimdallClientFetchMilestoneCountCall) DoAndReturn(f func(context.Context) (int64, error)) *MockHeimdallClientFetchMilestoneCountCall
  • func (c *MockHeimdallClientFetchMilestoneCountCall) Return(arg0 int64, arg1 error) *MockHeimdallClientFetchMilestoneCountCall
• type MockHeimdallClientFetchMilestoneIDCall
  • func (c *MockHeimdallClientFetchMilestoneIDCall) Do(f func(context.Context, string) error) *MockHeimdallClientFetchMilestoneIDCall
  • func (c *MockHeimdallClientFetchMilestoneIDCall) DoAndReturn(f func(context.Context, string) error) *MockHeimdallClientFetchMilestoneIDCall
  • func (c *MockHeimdallClientFetchMilestoneIDCall) Return(arg0 error) *MockHeimdallClientFetchMilestoneIDCall
• type MockHeimdallClientFetchNoAckMilestoneCall
  • func (c *MockHeimdallClientFetchNoAckMilestoneCall) Do(f func(context.Context, string) error) *MockHeimdallClientFetchNoAckMilestoneCall
  • func (c *MockHeimdallClientFetchNoAckMilestoneCall) DoAndReturn(f func(context.Context, string) error) *MockHeimdallClientFetchNoAckMilestoneCall
  • func (c *MockHeimdallClientFetchNoAckMilestoneCall) Return(arg0 error) *MockHeimdallClientFetchNoAckMilestoneCall
• type MockHeimdallClientFetchSpanCall
  • func (c *MockHeimdallClientFetchSpanCall) Do(f func(context.Context, uint64) (*Span, error)) *MockHeimdallClientFetchSpanCall
  • func (c *MockHeimdallClientFetchSpanCall) DoAndReturn(f func(context.Context, uint64) (*Span, error)) *MockHeimdallClientFetchSpanCall
  • func (c *MockHeimdallClientFetchSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallClientFetchSpanCall
• type MockHeimdallClientFetchStateSyncEventCall
  • func (c *MockHeimdallClientFetchStateSyncEventCall) Do(f func(context.Context, uint64) (*EventRecordWithTime, error)) *MockHeimdallClientFetchStateSyncEventCall
  • func (c *MockHeimdallClientFetchStateSyncEventCall) DoAndReturn(f func(context.Context, uint64) (*EventRecordWithTime, error)) *MockHeimdallClientFetchStateSyncEventCall
  • func (c *MockHeimdallClientFetchStateSyncEventCall) Return(arg0 *EventRecordWithTime, arg1 error) *MockHeimdallClientFetchStateSyncEventCall
• type MockHeimdallClientFetchStateSyncEventsCall
  • func (c *MockHeimdallClientFetchStateSyncEventsCall) Do(...) *MockHeimdallClientFetchStateSyncEventsCall
  • func (c *MockHeimdallClientFetchStateSyncEventsCall) DoAndReturn(...) *MockHeimdallClientFetchStateSyncEventsCall
  • func (c *MockHeimdallClientFetchStateSyncEventsCall) Return(arg0 []*EventRecordWithTime, arg1 error) *MockHeimdallClientFetchStateSyncEventsCall
• type MockHeimdallClientMockRecorder
  • func (mr *MockHeimdallClientMockRecorder) Close() *MockHeimdallClientCloseCall
  • func (mr *MockHeimdallClientMockRecorder) FetchCheckpoint(arg0, arg1 any) *MockHeimdallClientFetchCheckpointCall
  • func (mr *MockHeimdallClientMockRecorder) FetchCheckpointCount(arg0 any) *MockHeimdallClientFetchCheckpointCountCall
  • func (mr *MockHeimdallClientMockRecorder) FetchCheckpoints(arg0, arg1, arg2 any) *MockHeimdallClientFetchCheckpointsCall
  • func (mr *MockHeimdallClientMockRecorder) FetchLastNoAckMilestone(arg0 any) *MockHeimdallClientFetchLastNoAckMilestoneCall
  • func (mr *MockHeimdallClientMockRecorder) FetchLatestSpan(arg0 any) *MockHeimdallClientFetchLatestSpanCall
  • func (mr *MockHeimdallClientMockRecorder) FetchMilestone(arg0, arg1 any) *MockHeimdallClientFetchMilestoneCall
  • func (mr *MockHeimdallClientMockRecorder) FetchMilestoneCount(arg0 any) *MockHeimdallClientFetchMilestoneCountCall
  • func (mr *MockHeimdallClientMockRecorder) FetchMilestoneID(arg0, arg1 any) *MockHeimdallClientFetchMilestoneIDCall
  • func (mr *MockHeimdallClientMockRecorder) FetchNoAckMilestone(arg0, arg1 any) *MockHeimdallClientFetchNoAckMilestoneCall
  • func (mr *MockHeimdallClientMockRecorder) FetchSpan(arg0, arg1 any) *MockHeimdallClientFetchSpanCall
  • func (mr *MockHeimdallClientMockRecorder) FetchStateSyncEvent(arg0, arg1 any) *MockHeimdallClientFetchStateSyncEventCall
  • func (mr *MockHeimdallClientMockRecorder) FetchStateSyncEvents(arg0, arg1, arg2, arg3 any) *MockHeimdallClientFetchStateSyncEventsCall
• type MockHeimdallFetchCheckpointsCall
  • func (c *MockHeimdallFetchCheckpointsCall) Do(...) *MockHeimdallFetchCheckpointsCall
  • func (c *MockHeimdallFetchCheckpointsCall) DoAndReturn(...) *MockHeimdallFetchCheckpointsCall
  • func (c *MockHeimdallFetchCheckpointsCall) Return(arg0 []*Checkpoint, arg1 error) *MockHeimdallFetchCheckpointsCall
• type MockHeimdallFetchCheckpointsFromBlockCall
  • func (c *MockHeimdallFetchCheckpointsFromBlockCall) Do(f func(context.Context, CheckpointStore, uint64) (Waypoints, error)) *MockHeimdallFetchCheckpointsFromBlockCall
  • func (c *MockHeimdallFetchCheckpointsFromBlockCall) DoAndReturn(f func(context.Context, CheckpointStore, uint64) (Waypoints, error)) *MockHeimdallFetchCheckpointsFromBlockCall
  • func (c *MockHeimdallFetchCheckpointsFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallFetchCheckpointsFromBlockCall
• type MockHeimdallFetchLatestSpanCall
  • func (c *MockHeimdallFetchLatestSpanCall) Do(f func(context.Context, SpanStore) (*Span, error)) *MockHeimdallFetchLatestSpanCall
  • func (c *MockHeimdallFetchLatestSpanCall) DoAndReturn(f func(context.Context, SpanStore) (*Span, error)) *MockHeimdallFetchLatestSpanCall
  • func (c *MockHeimdallFetchLatestSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallFetchLatestSpanCall
• type MockHeimdallFetchMilestonesCall
  • func (c *MockHeimdallFetchMilestonesCall) Do(...) *MockHeimdallFetchMilestonesCall
  • func (c *MockHeimdallFetchMilestonesCall) DoAndReturn(...) *MockHeimdallFetchMilestonesCall
  • func (c *MockHeimdallFetchMilestonesCall) Return(arg0 []*Milestone, arg1 error) *MockHeimdallFetchMilestonesCall
• type MockHeimdallFetchMilestonesFromBlockCall
  • func (c *MockHeimdallFetchMilestonesFromBlockCall) Do(f func(context.Context, MilestoneStore, uint64) (Waypoints, error)) *MockHeimdallFetchMilestonesFromBlockCall
  • func (c *MockHeimdallFetchMilestonesFromBlockCall) DoAndReturn(f func(context.Context, MilestoneStore, uint64) (Waypoints, error)) *MockHeimdallFetchMilestonesFromBlockCall
  • func (c *MockHeimdallFetchMilestonesFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallFetchMilestonesFromBlockCall
• type MockHeimdallFetchSpansCall
  • func (c *MockHeimdallFetchSpansCall) Do(f func(context.Context, SpanStore, SpanId, SpanId) ([]*Span, error)) *MockHeimdallFetchSpansCall
  • func (c *MockHeimdallFetchSpansCall) DoAndReturn(f func(context.Context, SpanStore, SpanId, SpanId) ([]*Span, error)) *MockHeimdallFetchSpansCall
  • func (c *MockHeimdallFetchSpansCall) Return(arg0 []*Span, arg1 error) *MockHeimdallFetchSpansCall
• type MockHeimdallFetchSpansFromBlockCall
  • func (c *MockHeimdallFetchSpansFromBlockCall) Do(f func(context.Context, SpanStore, uint64) ([]*Span, error)) *MockHeimdallFetchSpansFromBlockCall
  • func (c *MockHeimdallFetchSpansFromBlockCall) DoAndReturn(f func(context.Context, SpanStore, uint64) ([]*Span, error)) *MockHeimdallFetchSpansFromBlockCall
  • func (c *MockHeimdallFetchSpansFromBlockCall) Return(arg0 []*Span, arg1 error) *MockHeimdallFetchSpansFromBlockCall
• type MockHeimdallLastCheckpointIdCall
  • func (c *MockHeimdallLastCheckpointIdCall) Do(f func(context.Context, CheckpointStore) (CheckpointId, bool, error)) *MockHeimdallLastCheckpointIdCall
  • func (c *MockHeimdallLastCheckpointIdCall) DoAndReturn(f func(context.Context, CheckpointStore) (CheckpointId, bool, error)) *MockHeimdallLastCheckpointIdCall
  • func (c *MockHeimdallLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockHeimdallLastCheckpointIdCall
• type MockHeimdallLastMilestoneIdCall
  • func (c *MockHeimdallLastMilestoneIdCall) Do(f func(context.Context, MilestoneStore) (MilestoneId, bool, error)) *MockHeimdallLastMilestoneIdCall
  • func (c *MockHeimdallLastMilestoneIdCall) DoAndReturn(f func(context.Context, MilestoneStore) (MilestoneId, bool, error)) *MockHeimdallLastMilestoneIdCall
  • func (c *MockHeimdallLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockHeimdallLastMilestoneIdCall
• type MockHeimdallLastSpanIdCall
  • func (c *MockHeimdallLastSpanIdCall) Do(f func(context.Context, SpanStore) (SpanId, bool, error)) *MockHeimdallLastSpanIdCall
  • func (c *MockHeimdallLastSpanIdCall) DoAndReturn(f func(context.Context, SpanStore) (SpanId, bool, error)) *MockHeimdallLastSpanIdCall
  • func (c *MockHeimdallLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockHeimdallLastSpanIdCall
• type MockHeimdallMockRecorder
  • func (mr *MockHeimdallMockRecorder) FetchCheckpoints(arg0, arg1, arg2, arg3 any) *MockHeimdallFetchCheckpointsCall
  • func (mr *MockHeimdallMockRecorder) FetchCheckpointsFromBlock(arg0, arg1, arg2 any) *MockHeimdallFetchCheckpointsFromBlockCall
  • func (mr *MockHeimdallMockRecorder) FetchLatestSpan(arg0, arg1 any) *MockHeimdallFetchLatestSpanCall
  • func (mr *MockHeimdallMockRecorder) FetchMilestones(arg0, arg1, arg2, arg3 any) *MockHeimdallFetchMilestonesCall
  • func (mr *MockHeimdallMockRecorder) FetchMilestonesFromBlock(arg0, arg1, arg2 any) *MockHeimdallFetchMilestonesFromBlockCall
  • func (mr *MockHeimdallMockRecorder) FetchSpans(arg0, arg1, arg2, arg3 any) *MockHeimdallFetchSpansCall
  • func (mr *MockHeimdallMockRecorder) FetchSpansFromBlock(arg0, arg1, arg2 any) *MockHeimdallFetchSpansFromBlockCall
  • func (mr *MockHeimdallMockRecorder) LastCheckpointId(arg0, arg1 any) *MockHeimdallLastCheckpointIdCall
  • func (mr *MockHeimdallMockRecorder) LastMilestoneId(arg0, arg1 any) *MockHeimdallLastMilestoneIdCall
  • func (mr *MockHeimdallMockRecorder) LastSpanId(arg0, arg1 any) *MockHeimdallLastSpanIdCall
  • func (mr *MockHeimdallMockRecorder) OnCheckpointEvent(arg0, arg1, arg2 any) *MockHeimdallOnCheckpointEventCall
  • func (mr *MockHeimdallMockRecorder) OnMilestoneEvent(arg0, arg1, arg2 any) *MockHeimdallOnMilestoneEventCall
  • func (mr *MockHeimdallMockRecorder) OnSpanEvent(arg0, arg1, arg2 any) *MockHeimdallOnSpanEventCall
• type MockHeimdallNoStore
  • func NewMockHeimdallNoStore(ctrl *gomock.Controller) *MockHeimdallNoStore
  • func (m *MockHeimdallNoStore) EXPECT() *MockHeimdallNoStoreMockRecorder
  • func (m *MockHeimdallNoStore) FetchCheckpoints(arg0 context.Context, arg1, arg2 CheckpointId) ([]*Checkpoint, error)
  • func (m *MockHeimdallNoStore) FetchCheckpointsFromBlock(arg0 context.Context, arg1 uint64) (Waypoints, error)
  • func (m *MockHeimdallNoStore) FetchLatestSpan(arg0 context.Context) (*Span, error)
  • func (m *MockHeimdallNoStore) FetchMilestones(arg0 context.Context, arg1, arg2 MilestoneId) ([]*Milestone, error)
  • func (m *MockHeimdallNoStore) FetchMilestonesFromBlock(arg0 context.Context, arg1 uint64) (Waypoints, error)
  • func (m *MockHeimdallNoStore) FetchSpans(arg0 context.Context, arg1, arg2 SpanId) ([]*Span, error)
  • func (m *MockHeimdallNoStore) FetchSpansFromBlock(arg0 context.Context, arg1 uint64) ([]*Span, error)
  • func (m *MockHeimdallNoStore) LastCheckpointId(arg0 context.Context) (CheckpointId, bool, error)
  • func (m *MockHeimdallNoStore) LastMilestoneId(arg0 context.Context) (MilestoneId, bool, error)
  • func (m *MockHeimdallNoStore) LastSpanId(arg0 context.Context) (SpanId, bool, error)
  • func (m *MockHeimdallNoStore) OnCheckpointEvent(arg0 context.Context, arg1 func(*Checkpoint)) error
  • func (m *MockHeimdallNoStore) OnMilestoneEvent(arg0 context.Context, arg1 func(*Milestone)) error
  • func (m *MockHeimdallNoStore) OnSpanEvent(arg0 context.Context, arg1 func(*Span)) error
• type MockHeimdallNoStoreFetchCheckpointsCall
  • func (c *MockHeimdallNoStoreFetchCheckpointsCall) Do(f func(context.Context, CheckpointId, CheckpointId) ([]*Checkpoint, error)) *MockHeimdallNoStoreFetchCheckpointsCall
  • func (c *MockHeimdallNoStoreFetchCheckpointsCall) DoAndReturn(f func(context.Context, CheckpointId, CheckpointId) ([]*Checkpoint, error)) *MockHeimdallNoStoreFetchCheckpointsCall
  • func (c *MockHeimdallNoStoreFetchCheckpointsCall) Return(arg0 []*Checkpoint, arg1 error) *MockHeimdallNoStoreFetchCheckpointsCall
• type MockHeimdallNoStoreFetchCheckpointsFromBlockCall
  • func (c *MockHeimdallNoStoreFetchCheckpointsFromBlockCall) Do(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall
  • func (c *MockHeimdallNoStoreFetchCheckpointsFromBlockCall) DoAndReturn(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall
  • func (c *MockHeimdallNoStoreFetchCheckpointsFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall
• type MockHeimdallNoStoreFetchLatestSpanCall
  • func (c *MockHeimdallNoStoreFetchLatestSpanCall) Do(f func(context.Context) (*Span, error)) *MockHeimdallNoStoreFetchLatestSpanCall
  • func (c *MockHeimdallNoStoreFetchLatestSpanCall) DoAndReturn(f func(context.Context) (*Span, error)) *MockHeimdallNoStoreFetchLatestSpanCall
  • func (c *MockHeimdallNoStoreFetchLatestSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallNoStoreFetchLatestSpanCall
• type MockHeimdallNoStoreFetchMilestonesCall
  • func (c *MockHeimdallNoStoreFetchMilestonesCall) Do(f func(context.Context, MilestoneId, MilestoneId) ([]*Milestone, error)) *MockHeimdallNoStoreFetchMilestonesCall
  • func (c *MockHeimdallNoStoreFetchMilestonesCall) DoAndReturn(f func(context.Context, MilestoneId, MilestoneId) ([]*Milestone, error)) *MockHeimdallNoStoreFetchMilestonesCall
  • func (c *MockHeimdallNoStoreFetchMilestonesCall) Return(arg0 []*Milestone, arg1 error) *MockHeimdallNoStoreFetchMilestonesCall
• type MockHeimdallNoStoreFetchMilestonesFromBlockCall
  • func (c *MockHeimdallNoStoreFetchMilestonesFromBlockCall) Do(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchMilestonesFromBlockCall
  • func (c *MockHeimdallNoStoreFetchMilestonesFromBlockCall) DoAndReturn(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchMilestonesFromBlockCall
  • func (c *MockHeimdallNoStoreFetchMilestonesFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallNoStoreFetchMilestonesFromBlockCall
• type MockHeimdallNoStoreFetchSpansCall
  • func (c *MockHeimdallNoStoreFetchSpansCall) Do(f func(context.Context, SpanId, SpanId) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansCall
  • func (c *MockHeimdallNoStoreFetchSpansCall) DoAndReturn(f func(context.Context, SpanId, SpanId) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansCall
  • func (c *MockHeimdallNoStoreFetchSpansCall) Return(arg0 []*Span, arg1 error) *MockHeimdallNoStoreFetchSpansCall
• type MockHeimdallNoStoreFetchSpansFromBlockCall
  • func (c *MockHeimdallNoStoreFetchSpansFromBlockCall) Do(f func(context.Context, uint64) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansFromBlockCall
  • func (c *MockHeimdallNoStoreFetchSpansFromBlockCall) DoAndReturn(f func(context.Context, uint64) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansFromBlockCall
  • func (c *MockHeimdallNoStoreFetchSpansFromBlockCall) Return(arg0 []*Span, arg1 error) *MockHeimdallNoStoreFetchSpansFromBlockCall
• type MockHeimdallNoStoreLastCheckpointIdCall
  • func (c *MockHeimdallNoStoreLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockHeimdallNoStoreLastCheckpointIdCall
  • func (c *MockHeimdallNoStoreLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockHeimdallNoStoreLastCheckpointIdCall
  • func (c *MockHeimdallNoStoreLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockHeimdallNoStoreLastCheckpointIdCall
• type MockHeimdallNoStoreLastMilestoneIdCall
  • func (c *MockHeimdallNoStoreLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockHeimdallNoStoreLastMilestoneIdCall
  • func (c *MockHeimdallNoStoreLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockHeimdallNoStoreLastMilestoneIdCall
  • func (c *MockHeimdallNoStoreLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockHeimdallNoStoreLastMilestoneIdCall
• type MockHeimdallNoStoreLastSpanIdCall
  • func (c *MockHeimdallNoStoreLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockHeimdallNoStoreLastSpanIdCall
  • func (c *MockHeimdallNoStoreLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockHeimdallNoStoreLastSpanIdCall
  • func (c *MockHeimdallNoStoreLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockHeimdallNoStoreLastSpanIdCall
• type MockHeimdallNoStoreMockRecorder
  • func (mr *MockHeimdallNoStoreMockRecorder) FetchCheckpoints(arg0, arg1, arg2 any) *MockHeimdallNoStoreFetchCheckpointsCall
  • func (mr *MockHeimdallNoStoreMockRecorder) FetchCheckpointsFromBlock(arg0, arg1 any) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall
  • func (mr *MockHeimdallNoStoreMockRecorder) FetchLatestSpan(arg0 any) *MockHeimdallNoStoreFetchLatestSpanCall
  • func (mr *MockHeimdallNoStoreMockRecorder) FetchMilestones(arg0, arg1, arg2 any) *MockHeimdallNoStoreFetchMilestonesCall
  • func (mr *MockHeimdallNoStoreMockRecorder) FetchMilestonesFromBlock(arg0, arg1 any) *MockHeimdallNoStoreFetchMilestonesFromBlockCall
  • func (mr *MockHeimdallNoStoreMockRecorder) FetchSpans(arg0, arg1, arg2 any) *MockHeimdallNoStoreFetchSpansCall
  • func (mr *MockHeimdallNoStoreMockRecorder) FetchSpansFromBlock(arg0, arg1 any) *MockHeimdallNoStoreFetchSpansFromBlockCall
  • func (mr *MockHeimdallNoStoreMockRecorder) LastCheckpointId(arg0 any) *MockHeimdallNoStoreLastCheckpointIdCall
  • func (mr *MockHeimdallNoStoreMockRecorder) LastMilestoneId(arg0 any) *MockHeimdallNoStoreLastMilestoneIdCall
  • func (mr *MockHeimdallNoStoreMockRecorder) LastSpanId(arg0 any) *MockHeimdallNoStoreLastSpanIdCall
  • func (mr *MockHeimdallNoStoreMockRecorder) OnCheckpointEvent(arg0, arg1 any) *MockHeimdallNoStoreOnCheckpointEventCall
  • func (mr *MockHeimdallNoStoreMockRecorder) OnMilestoneEvent(arg0, arg1 any) *MockHeimdallNoStoreOnMilestoneEventCall
  • func (mr *MockHeimdallNoStoreMockRecorder) OnSpanEvent(arg0, arg1 any) *MockHeimdallNoStoreOnSpanEventCall
• type MockHeimdallNoStoreOnCheckpointEventCall
  • func (c *MockHeimdallNoStoreOnCheckpointEventCall) Do(f func(context.Context, func(*Checkpoint)) error) *MockHeimdallNoStoreOnCheckpointEventCall
  • func (c *MockHeimdallNoStoreOnCheckpointEventCall) DoAndReturn(f func(context.Context, func(*Checkpoint)) error) *MockHeimdallNoStoreOnCheckpointEventCall
  • func (c *MockHeimdallNoStoreOnCheckpointEventCall) Return(arg0 error) *MockHeimdallNoStoreOnCheckpointEventCall
• type MockHeimdallNoStoreOnMilestoneEventCall
  • func (c *MockHeimdallNoStoreOnMilestoneEventCall) Do(f func(context.Context, func(*Milestone)) error) *MockHeimdallNoStoreOnMilestoneEventCall
  • func (c *MockHeimdallNoStoreOnMilestoneEventCall) DoAndReturn(f func(context.Context, func(*Milestone)) error) *MockHeimdallNoStoreOnMilestoneEventCall
  • func (c *MockHeimdallNoStoreOnMilestoneEventCall) Return(arg0 error) *MockHeimdallNoStoreOnMilestoneEventCall
• type MockHeimdallNoStoreOnSpanEventCall
  • func (c *MockHeimdallNoStoreOnSpanEventCall) Do(f func(context.Context, func(*Span)) error) *MockHeimdallNoStoreOnSpanEventCall
  • func (c *MockHeimdallNoStoreOnSpanEventCall) DoAndReturn(f func(context.Context, func(*Span)) error) *MockHeimdallNoStoreOnSpanEventCall
  • func (c *MockHeimdallNoStoreOnSpanEventCall) Return(arg0 error) *MockHeimdallNoStoreOnSpanEventCall
• type MockHeimdallOnCheckpointEventCall
  • func (c *MockHeimdallOnCheckpointEventCall) Do(f func(context.Context, CheckpointStore, func(*Checkpoint)) error) *MockHeimdallOnCheckpointEventCall
  • func (c *MockHeimdallOnCheckpointEventCall) DoAndReturn(f func(context.Context, CheckpointStore, func(*Checkpoint)) error) *MockHeimdallOnCheckpointEventCall
  • func (c *MockHeimdallOnCheckpointEventCall) Return(arg0 error) *MockHeimdallOnCheckpointEventCall
• type MockHeimdallOnMilestoneEventCall
  • func (c *MockHeimdallOnMilestoneEventCall) Do(f func(context.Context, MilestoneStore, func(*Milestone)) error) *MockHeimdallOnMilestoneEventCall
  • func (c *MockHeimdallOnMilestoneEventCall) DoAndReturn(f func(context.Context, MilestoneStore, func(*Milestone)) error) *MockHeimdallOnMilestoneEventCall
  • func (c *MockHeimdallOnMilestoneEventCall) Return(arg0 error) *MockHeimdallOnMilestoneEventCall
• type MockHeimdallOnSpanEventCall
  • func (c *MockHeimdallOnSpanEventCall) Do(f func(context.Context, SpanStore, func(*Span)) error) *MockHeimdallOnSpanEventCall
  • func (c *MockHeimdallOnSpanEventCall) DoAndReturn(f func(context.Context, SpanStore, func(*Span)) error) *MockHeimdallOnSpanEventCall
  • func (c *MockHeimdallOnSpanEventCall) Return(arg0 error) *MockHeimdallOnSpanEventCall
• type MockHttpClient
  • func NewMockHttpClient(ctrl *gomock.Controller) *MockHttpClient
  • func (m *MockHttpClient) CloseIdleConnections()
  • func (m *MockHttpClient) Do(arg0 *http.Request) (*http.Response, error)
  • func (m *MockHttpClient) EXPECT() *MockHttpClientMockRecorder
• type MockHttpClientCloseIdleConnectionsCall
  • func (c *MockHttpClientCloseIdleConnectionsCall) Do(f func()) *MockHttpClientCloseIdleConnectionsCall
  • func (c *MockHttpClientCloseIdleConnectionsCall) DoAndReturn(f func()) *MockHttpClientCloseIdleConnectionsCall
  • func (c *MockHttpClientCloseIdleConnectionsCall) Return() *MockHttpClientCloseIdleConnectionsCall
• type MockHttpClientDoCall
  • func (c *MockHttpClientDoCall) Do(f func(*http.Request) (*http.Response, error)) *MockHttpClientDoCall
  • func (c *MockHttpClientDoCall) DoAndReturn(f func(*http.Request) (*http.Response, error)) *MockHttpClientDoCall
  • func (c *MockHttpClientDoCall) Return(arg0 *http.Response, arg1 error) *MockHttpClientDoCall
• type MockHttpClientMockRecorder
  • func (mr *MockHttpClientMockRecorder) CloseIdleConnections() *MockHttpClientCloseIdleConnectionsCall
  • func (mr *MockHttpClientMockRecorder) Do(arg0 any) *MockHttpClientDoCall
• type MockMilestoneReader
  • func NewMockMilestoneReader(ctrl *gomock.Controller) *MockMilestoneReader
  • func (m *MockMilestoneReader) EXPECT() *MockMilestoneReaderMockRecorder
  • func (m *MockMilestoneReader) GetMilestone(ctx context.Context, milestoneId MilestoneId) (*Milestone, error)
  • func (m *MockMilestoneReader) LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)
• type MockMilestoneReaderGetMilestoneCall
  • func (c *MockMilestoneReaderGetMilestoneCall) Do(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneReaderGetMilestoneCall
  • func (c *MockMilestoneReaderGetMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneReaderGetMilestoneCall
  • func (c *MockMilestoneReaderGetMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockMilestoneReaderGetMilestoneCall
• type MockMilestoneReaderLastMilestoneIdCall
  • func (c *MockMilestoneReaderLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneReaderLastMilestoneIdCall
  • func (c *MockMilestoneReaderLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneReaderLastMilestoneIdCall
  • func (c *MockMilestoneReaderLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockMilestoneReaderLastMilestoneIdCall
• type MockMilestoneReaderMockRecorder
  • func (mr *MockMilestoneReaderMockRecorder) GetMilestone(ctx, milestoneId any) *MockMilestoneReaderGetMilestoneCall
  • func (mr *MockMilestoneReaderMockRecorder) LastMilestoneId(ctx any) *MockMilestoneReaderLastMilestoneIdCall
• type MockMilestoneStore
  • func NewMockMilestoneStore(ctrl *gomock.Controller) *MockMilestoneStore
  • func (m *MockMilestoneStore) EXPECT() *MockMilestoneStoreMockRecorder
  • func (m *MockMilestoneStore) GetMilestone(ctx context.Context, milestoneId MilestoneId) (*Milestone, error)
  • func (m *MockMilestoneStore) LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)
  • func (m *MockMilestoneStore) PutMilestone(ctx context.Context, milestoneId MilestoneId, milestone *Milestone) error
• type MockMilestoneStoreGetMilestoneCall
  • func (c *MockMilestoneStoreGetMilestoneCall) Do(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneStoreGetMilestoneCall
  • func (c *MockMilestoneStoreGetMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneStoreGetMilestoneCall
  • func (c *MockMilestoneStoreGetMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockMilestoneStoreGetMilestoneCall
• type MockMilestoneStoreLastMilestoneIdCall
  • func (c *MockMilestoneStoreLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneStoreLastMilestoneIdCall
  • func (c *MockMilestoneStoreLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneStoreLastMilestoneIdCall
  • func (c *MockMilestoneStoreLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockMilestoneStoreLastMilestoneIdCall
• type MockMilestoneStoreMockRecorder
  • func (mr *MockMilestoneStoreMockRecorder) GetMilestone(ctx, milestoneId any) *MockMilestoneStoreGetMilestoneCall
  • func (mr *MockMilestoneStoreMockRecorder) LastMilestoneId(ctx any) *MockMilestoneStoreLastMilestoneIdCall
  • func (mr *MockMilestoneStoreMockRecorder) PutMilestone(ctx, milestoneId, milestone any) *MockMilestoneStorePutMilestoneCall
• type MockMilestoneStorePutMilestoneCall
  • func (c *MockMilestoneStorePutMilestoneCall) Do(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneStorePutMilestoneCall
  • func (c *MockMilestoneStorePutMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneStorePutMilestoneCall
  • func (c *MockMilestoneStorePutMilestoneCall) Return(arg0 error) *MockMilestoneStorePutMilestoneCall
• type MockMilestoneWriter
  • func NewMockMilestoneWriter(ctrl *gomock.Controller) *MockMilestoneWriter
  • func (m *MockMilestoneWriter) EXPECT() *MockMilestoneWriterMockRecorder
  • func (m *MockMilestoneWriter) PutMilestone(ctx context.Context, milestoneId MilestoneId, milestone *Milestone) error
• type MockMilestoneWriterMockRecorder
  • func (mr *MockMilestoneWriterMockRecorder) PutMilestone(ctx, milestoneId, milestone any) *MockMilestoneWriterPutMilestoneCall
• type MockMilestoneWriterPutMilestoneCall
  • func (c *MockMilestoneWriterPutMilestoneCall) Do(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneWriterPutMilestoneCall
  • func (c *MockMilestoneWriterPutMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneWriterPutMilestoneCall
  • func (c *MockMilestoneWriterPutMilestoneCall) Return(arg0 error) *MockMilestoneWriterPutMilestoneCall
• type MockSpanReader
  • func NewMockSpanReader(ctrl *gomock.Controller) *MockSpanReader
  • func (m *MockSpanReader) EXPECT() *MockSpanReaderMockRecorder
  • func (m *MockSpanReader) GetSpan(ctx context.Context, spanId SpanId) (*Span, error)
  • func (m *MockSpanReader) LastSpanId(ctx context.Context) (SpanId, bool, error)
• type MockSpanReaderGetSpanCall
  • func (c *MockSpanReaderGetSpanCall) Do(f func(context.Context, SpanId) (*Span, error)) *MockSpanReaderGetSpanCall
  • func (c *MockSpanReaderGetSpanCall) DoAndReturn(f func(context.Context, SpanId) (*Span, error)) *MockSpanReaderGetSpanCall
  • func (c *MockSpanReaderGetSpanCall) Return(arg0 *Span, arg1 error) *MockSpanReaderGetSpanCall
• type MockSpanReaderLastSpanIdCall
  • func (c *MockSpanReaderLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockSpanReaderLastSpanIdCall
  • func (c *MockSpanReaderLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockSpanReaderLastSpanIdCall
  • func (c *MockSpanReaderLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockSpanReaderLastSpanIdCall
• type MockSpanReaderMockRecorder
  • func (mr *MockSpanReaderMockRecorder) GetSpan(ctx, spanId any) *MockSpanReaderGetSpanCall
  • func (mr *MockSpanReaderMockRecorder) LastSpanId(ctx any) *MockSpanReaderLastSpanIdCall
• type MockSpanStore
  • func NewMockSpanStore(ctrl *gomock.Controller) *MockSpanStore
  • func (m *MockSpanStore) EXPECT() *MockSpanStoreMockRecorder
  • func (m *MockSpanStore) GetSpan(ctx context.Context, spanId SpanId) (*Span, error)
  • func (m *MockSpanStore) LastSpanId(ctx context.Context) (SpanId, bool, error)
  • func (m *MockSpanStore) PutSpan(ctx context.Context, span *Span) error
• type MockSpanStoreGetSpanCall
  • func (c *MockSpanStoreGetSpanCall) Do(f func(context.Context, SpanId) (*Span, error)) *MockSpanStoreGetSpanCall
  • func (c *MockSpanStoreGetSpanCall) DoAndReturn(f func(context.Context, SpanId) (*Span, error)) *MockSpanStoreGetSpanCall
  • func (c *MockSpanStoreGetSpanCall) Return(arg0 *Span, arg1 error) *MockSpanStoreGetSpanCall
• type MockSpanStoreLastSpanIdCall
  • func (c *MockSpanStoreLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockSpanStoreLastSpanIdCall
  • func (c *MockSpanStoreLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockSpanStoreLastSpanIdCall
  • func (c *MockSpanStoreLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockSpanStoreLastSpanIdCall
• type MockSpanStoreMockRecorder
  • func (mr *MockSpanStoreMockRecorder) GetSpan(ctx, spanId any) *MockSpanStoreGetSpanCall
  • func (mr *MockSpanStoreMockRecorder) LastSpanId(ctx any) *MockSpanStoreLastSpanIdCall
  • func (mr *MockSpanStoreMockRecorder) PutSpan(ctx, span any) *MockSpanStorePutSpanCall
• type MockSpanStorePutSpanCall
  • func (c *MockSpanStorePutSpanCall) Do(f func(context.Context, *Span) error) *MockSpanStorePutSpanCall
  • func (c *MockSpanStorePutSpanCall) DoAndReturn(f func(context.Context, *Span) error) *MockSpanStorePutSpanCall
  • func (c *MockSpanStorePutSpanCall) Return(arg0 error) *MockSpanStorePutSpanCall
• type MockSpanWriter
  • func NewMockSpanWriter(ctrl *gomock.Controller) *MockSpanWriter
  • func (m *MockSpanWriter) EXPECT() *MockSpanWriterMockRecorder
  • func (m *MockSpanWriter) PutSpan(ctx context.Context, span *Span) error
• type MockSpanWriterMockRecorder
  • func (mr *MockSpanWriterMockRecorder) PutSpan(ctx, span any) *MockSpanWriterPutSpanCall
• type MockSpanWriterPutSpanCall
  • func (c *MockSpanWriterPutSpanCall) Do(f func(context.Context, *Span) error) *MockSpanWriterPutSpanCall
  • func (c *MockSpanWriterPutSpanCall) DoAndReturn(f func(context.Context, *Span) error) *MockSpanWriterPutSpanCall
  • func (c *MockSpanWriterPutSpanCall) Return(arg0 error) *MockSpanWriterPutSpanCall
• type MockStore
  • func NewMockStore(ctrl *gomock.Controller) *MockStore
  • func (m *MockStore) EXPECT() *MockStoreMockRecorder
  • func (m *MockStore) GetCheckpoint(ctx context.Context, checkpointId CheckpointId) (*Checkpoint, error)
  • func (m *MockStore) GetMilestone(ctx context.Context, milestoneId MilestoneId) (*Milestone, error)
  • func (m *MockStore) GetSpan(ctx context.Context, spanId SpanId) (*Span, error)
  • func (m *MockStore) LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)
  • func (m *MockStore) LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)
  • func (m *MockStore) LastSpanId(ctx context.Context) (SpanId, bool, error)
  • func (m *MockStore) PutCheckpoint(ctx context.Context, checkpointId CheckpointId, checkpoint *Checkpoint) error
  • func (m *MockStore) PutMilestone(ctx context.Context, milestoneId MilestoneId, milestone *Milestone) error
  • func (m *MockStore) PutSpan(ctx context.Context, span *Span) error
• type MockStoreGetCheckpointCall
  • func (c *MockStoreGetCheckpointCall) Do(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockStoreGetCheckpointCall
  • func (c *MockStoreGetCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockStoreGetCheckpointCall
  • func (c *MockStoreGetCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockStoreGetCheckpointCall
• type MockStoreGetMilestoneCall
  • func (c *MockStoreGetMilestoneCall) Do(f func(context.Context, MilestoneId) (*Milestone, error)) *MockStoreGetMilestoneCall
  • func (c *MockStoreGetMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId) (*Milestone, error)) *MockStoreGetMilestoneCall
  • func (c *MockStoreGetMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockStoreGetMilestoneCall
• type MockStoreGetSpanCall
  • func (c *MockStoreGetSpanCall) Do(f func(context.Context, SpanId) (*Span, error)) *MockStoreGetSpanCall
  • func (c *MockStoreGetSpanCall) DoAndReturn(f func(context.Context, SpanId) (*Span, error)) *MockStoreGetSpanCall
  • func (c *MockStoreGetSpanCall) Return(arg0 *Span, arg1 error) *MockStoreGetSpanCall
• type MockStoreLastCheckpointIdCall
  • func (c *MockStoreLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockStoreLastCheckpointIdCall
  • func (c *MockStoreLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockStoreLastCheckpointIdCall
  • func (c *MockStoreLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockStoreLastCheckpointIdCall
• type MockStoreLastMilestoneIdCall
  • func (c *MockStoreLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockStoreLastMilestoneIdCall
  • func (c *MockStoreLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockStoreLastMilestoneIdCall
  • func (c *MockStoreLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockStoreLastMilestoneIdCall
• type MockStoreLastSpanIdCall
  • func (c *MockStoreLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockStoreLastSpanIdCall
  • func (c *MockStoreLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockStoreLastSpanIdCall
  • func (c *MockStoreLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockStoreLastSpanIdCall
• type MockStoreMockRecorder
  • func (mr *MockStoreMockRecorder) GetCheckpoint(ctx, checkpointId any) *MockStoreGetCheckpointCall
  • func (mr *MockStoreMockRecorder) GetMilestone(ctx, milestoneId any) *MockStoreGetMilestoneCall
  • func (mr *MockStoreMockRecorder) GetSpan(ctx, spanId any) *MockStoreGetSpanCall
  • func (mr *MockStoreMockRecorder) LastCheckpointId(ctx any) *MockStoreLastCheckpointIdCall
  • func (mr *MockStoreMockRecorder) LastMilestoneId(ctx any) *MockStoreLastMilestoneIdCall
  • func (mr *MockStoreMockRecorder) LastSpanId(ctx any) *MockStoreLastSpanIdCall
  • func (mr *MockStoreMockRecorder) PutCheckpoint(ctx, checkpointId, checkpoint any) *MockStorePutCheckpointCall
  • func (mr *MockStoreMockRecorder) PutMilestone(ctx, milestoneId, milestone any) *MockStorePutMilestoneCall
  • func (mr *MockStoreMockRecorder) PutSpan(ctx, span any) *MockStorePutSpanCall
• type MockStorePutCheckpointCall
  • func (c *MockStorePutCheckpointCall) Do(f func(context.Context, CheckpointId, *Checkpoint) error) *MockStorePutCheckpointCall
  • func (c *MockStorePutCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId, *Checkpoint) error) *MockStorePutCheckpointCall
  • func (c *MockStorePutCheckpointCall) Return(arg0 error) *MockStorePutCheckpointCall
• type MockStorePutMilestoneCall
  • func (c *MockStorePutMilestoneCall) Do(f func(context.Context, MilestoneId, *Milestone) error) *MockStorePutMilestoneCall
  • func (c *MockStorePutMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId, *Milestone) error) *MockStorePutMilestoneCall
  • func (c *MockStorePutMilestoneCall) Return(arg0 error) *MockStorePutMilestoneCall
• type MockStorePutSpanCall
  • func (c *MockStorePutSpanCall) Do(f func(context.Context, *Span) error) *MockStorePutSpanCall
  • func (c *MockStorePutSpanCall) DoAndReturn(f func(context.Context, *Span) error) *MockStorePutSpanCall
  • func (c *MockStorePutSpanCall) Return(arg0 error) *MockStorePutSpanCall
• type Mockreader
  • func NewMockreader(ctrl *gomock.Controller) *Mockreader
  • func (m *Mockreader) BorStartEventID(ctx context.Context, tx kv.Tx, hash common.Hash, blockNum uint64) (uint64, error)
  • func (m *Mockreader) Checkpoint(ctx context.Context, tx kv.Getter, checkpointId uint64) ([]byte, error)
  • func (m *Mockreader) EXPECT() *MockreaderMockRecorder
  • func (m *Mockreader) EventLookup(ctx context.Context, tx kv.Getter, txnHash common.Hash) (uint64, bool, error)
  • func (m *Mockreader) EventsByBlock(ctx context.Context, tx kv.Tx, hash common.Hash, blockNum uint64) ([]rlp.RawValue, error)
  • func (m *Mockreader) LastCheckpointId(ctx context.Context, tx kv.Tx) (uint64, bool, error)
  • func (m *Mockreader) LastEventId(ctx context.Context, tx kv.Tx) (uint64, bool, error)
  • func (m *Mockreader) LastFrozenEventId() uint64
  • func (m *Mockreader) LastFrozenSpanId() uint64
  • func (m *Mockreader) LastMilestoneId(ctx context.Context, tx kv.Tx) (uint64, bool, error)
  • func (m *Mockreader) LastSpanId(ctx context.Context, tx kv.Tx) (uint64, bool, error)
  • func (m *Mockreader) Milestone(ctx context.Context, tx kv.Getter, milestoneId uint64) ([]byte, error)
  • func (m *Mockreader) Span(ctx context.Context, tx kv.Getter, spanId uint64) ([]byte, error)
• type MockreaderBorStartEventIDCall
  • func (c *MockreaderBorStartEventIDCall) Do(f func(context.Context, kv.Tx, common.Hash, uint64) (uint64, error)) *MockreaderBorStartEventIDCall
  • func (c *MockreaderBorStartEventIDCall) DoAndReturn(f func(context.Context, kv.Tx, common.Hash, uint64) (uint64, error)) *MockreaderBorStartEventIDCall
  • func (c *MockreaderBorStartEventIDCall) Return(arg0 uint64, arg1 error) *MockreaderBorStartEventIDCall
• type MockreaderCheckpointCall
  • func (c *MockreaderCheckpointCall) Do(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderCheckpointCall
  • func (c *MockreaderCheckpointCall) DoAndReturn(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderCheckpointCall
  • func (c *MockreaderCheckpointCall) Return(arg0 []byte, arg1 error) *MockreaderCheckpointCall
• type MockreaderEventLookupCall
  • func (c *MockreaderEventLookupCall) Do(f func(context.Context, kv.Getter, common.Hash) (uint64, bool, error)) *MockreaderEventLookupCall
  • func (c *MockreaderEventLookupCall) DoAndReturn(f func(context.Context, kv.Getter, common.Hash) (uint64, bool, error)) *MockreaderEventLookupCall
  • func (c *MockreaderEventLookupCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderEventLookupCall
• type MockreaderEventsByBlockCall
  • func (c *MockreaderEventsByBlockCall) Do(f func(context.Context, kv.Tx, common.Hash, uint64) ([]rlp.RawValue, error)) *MockreaderEventsByBlockCall
  • func (c *MockreaderEventsByBlockCall) DoAndReturn(f func(context.Context, kv.Tx, common.Hash, uint64) ([]rlp.RawValue, error)) *MockreaderEventsByBlockCall
  • func (c *MockreaderEventsByBlockCall) Return(arg0 []rlp.RawValue, arg1 error) *MockreaderEventsByBlockCall
• type MockreaderLastCheckpointIdCall
  • func (c *MockreaderLastCheckpointIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastCheckpointIdCall
  • func (c *MockreaderLastCheckpointIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastCheckpointIdCall
  • func (c *MockreaderLastCheckpointIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastCheckpointIdCall
• type MockreaderLastEventIdCall
  • func (c *MockreaderLastEventIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastEventIdCall
  • func (c *MockreaderLastEventIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastEventIdCall
  • func (c *MockreaderLastEventIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastEventIdCall
• type MockreaderLastFrozenEventIdCall
  • func (c *MockreaderLastFrozenEventIdCall) Do(f func() uint64) *MockreaderLastFrozenEventIdCall
  • func (c *MockreaderLastFrozenEventIdCall) DoAndReturn(f func() uint64) *MockreaderLastFrozenEventIdCall
  • func (c *MockreaderLastFrozenEventIdCall) Return(arg0 uint64) *MockreaderLastFrozenEventIdCall
• type MockreaderLastFrozenSpanIdCall
  • func (c *MockreaderLastFrozenSpanIdCall) Do(f func() uint64) *MockreaderLastFrozenSpanIdCall
  • func (c *MockreaderLastFrozenSpanIdCall) DoAndReturn(f func() uint64) *MockreaderLastFrozenSpanIdCall
  • func (c *MockreaderLastFrozenSpanIdCall) Return(arg0 uint64) *MockreaderLastFrozenSpanIdCall
• type MockreaderLastMilestoneIdCall
  • func (c *MockreaderLastMilestoneIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastMilestoneIdCall
  • func (c *MockreaderLastMilestoneIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastMilestoneIdCall
  • func (c *MockreaderLastMilestoneIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastMilestoneIdCall
• type MockreaderLastSpanIdCall
  • func (c *MockreaderLastSpanIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastSpanIdCall
  • func (c *MockreaderLastSpanIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastSpanIdCall
  • func (c *MockreaderLastSpanIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastSpanIdCall
• type MockreaderMilestoneCall
  • func (c *MockreaderMilestoneCall) Do(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderMilestoneCall
  • func (c *MockreaderMilestoneCall) DoAndReturn(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderMilestoneCall
  • func (c *MockreaderMilestoneCall) Return(arg0 []byte, arg1 error) *MockreaderMilestoneCall
• type MockreaderMockRecorder
  • func (mr *MockreaderMockRecorder) BorStartEventID(ctx, tx, hash, blockNum any) *MockreaderBorStartEventIDCall
  • func (mr *MockreaderMockRecorder) Checkpoint(ctx, tx, checkpointId any) *MockreaderCheckpointCall
  • func (mr *MockreaderMockRecorder) EventLookup(ctx, tx, txnHash any) *MockreaderEventLookupCall
  • func (mr *MockreaderMockRecorder) EventsByBlock(ctx, tx, hash, blockNum any) *MockreaderEventsByBlockCall
  • func (mr *MockreaderMockRecorder) LastCheckpointId(ctx, tx any) *MockreaderLastCheckpointIdCall
  • func (mr *MockreaderMockRecorder) LastEventId(ctx, tx any) *MockreaderLastEventIdCall
  • func (mr *MockreaderMockRecorder) LastFrozenEventId() *MockreaderLastFrozenEventIdCall
  • func (mr *MockreaderMockRecorder) LastFrozenSpanId() *MockreaderLastFrozenSpanIdCall
  • func (mr *MockreaderMockRecorder) LastMilestoneId(ctx, tx any) *MockreaderLastMilestoneIdCall
  • func (mr *MockreaderMockRecorder) LastSpanId(ctx, tx any) *MockreaderLastSpanIdCall
  • func (mr *MockreaderMockRecorder) Milestone(ctx, tx, milestoneId any) *MockreaderMilestoneCall
  • func (mr *MockreaderMockRecorder) Span(ctx, tx, spanId any) *MockreaderSpanCall
• type MockreaderSpanCall
  • func (c *MockreaderSpanCall) Do(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderSpanCall
  • func (c *MockreaderSpanCall) DoAndReturn(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderSpanCall
  • func (c *MockreaderSpanCall) Return(arg0 []byte, arg1 error) *MockreaderSpanCall
• type Request
• type Span
  • func (s *Span) CmpRange(n uint64) int
  • func (hs *Span) Less(other btree.Item) bool
• type SpanId
  • func SpanIdAt(blockNum uint64) SpanId
• type SpanReader
• type SpanResponse
• type SpanStore
• type SpanWriter
• type StateSyncEventResponse
• type StateSyncEventsResponse
• type Store
• type Waypoint
• type WaypointFields
  • func (a *WaypointFields) CmpRange(n uint64) int
  • func (a *WaypointFields) Length() uint64
• type Waypoints

Variables

var (
	// ErrShutdownDetected is returned if a shutdown was detected
	ErrShutdownDetected      = errors.New("shutdown detected")
	ErrNoResponse            = errors.New("got a nil response")
	ErrNotSuccessfulResponse = errors.New("error while fetching data from Heimdall")
	ErrNotInRejectedList     = errors.New("milestoneId doesn't exist in rejected list")
	ErrNotInMilestoneList    = errors.New("milestoneId doesn't exist in Heimdall")
	ErrNotInCheckpointList   = errors.New("checkpontId doesn't exist in Heimdall")
	ErrNotInSpanList         = errors.New("milestoneId doesn't exist in Heimdall")
	ErrServiceUnavailable    = errors.New("service unavailable")
)

var ErrCheckpointNotFound = fmt.Errorf("checkpoint not found")

var ErrEventRecordNotFound = fmt.Errorf("event record not found")

var ErrIncompleteCheckpointRange = errors.New("checkpoint range doesn't contain the start block")

var ErrIncompleteMilestoneRange = errors.New("milestone range doesn't contain the start block")

ErrIncompleteMilestoneRange happens when FetchMilestones is called with an old start block because old milestones are evicted

var ErrIncompleteSpanRange = errors.New("span range doesn't contain the start block")

var ErrMilestoneNotFound = fmt.Errorf("milestone not found")

Functions

func Fetch

func Fetch[T any](ctx context.Context, request *Request, logger log.Logger) (*T, error)

Fetch fetches response from heimdall

func FetchWithRetry

func FetchWithRetry[T any](ctx context.Context, client *Client, url *url.URL, logger log.Logger) (*T, error)

FetchWithRetry returns data from heimdall with retry

func FetchWithRetryEx

func FetchWithRetryEx[T any](
	ctx context.Context,
	client *Client,
	url *url.URL,
	isRecoverableError func(error) bool,
	logger log.Logger,
) (result *T, err error)

FetchWithRetryEx returns data from heimdall with retry

func IsBlockInLastSprintOfSpan

func IsBlockInLastSprintOfSpan(blockNum uint64, config *borcfg.BorConfig) bool

IsBlockInLastSprintOfSpan returns true if a block num is within the last sprint of a span and false otherwise.

func NewBlockReaderStore

func NewBlockReaderStore(reader reader, tx kv.Tx) blockReaderStore

func SpanEndBlockNum

func SpanEndBlockNum(spanId SpanId) uint64

SpanEndBlockNum returns the number of the last block in the given span.

Types

type Checkpoint

type Checkpoint struct {
	Id     CheckpointId
	Fields WaypointFields
}

Checkpoint defines a response object type of bor checkpoint

func (Checkpoint) CmpRange

func (c Checkpoint) CmpRange(n uint64) int

func (Checkpoint) EndBlock

func (c Checkpoint) EndBlock() *big.Int

func (Checkpoint) Length

func (c Checkpoint) Length() uint64

func (*Checkpoint) MarshalJSON

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

func (Checkpoint) RootHash

func (c Checkpoint) RootHash() libcommon.Hash

func (Checkpoint) StartBlock

func (c Checkpoint) StartBlock() *big.Int

func (Checkpoint) String

func (m Checkpoint) String() string

func (Checkpoint) Timestamp

func (c Checkpoint) Timestamp() uint64

func (*Checkpoint) UnmarshalJSON

func (c *Checkpoint) UnmarshalJSON(b []byte) error

type CheckpointCount

type CheckpointCount struct {
	Result int64 `json:"result"`
}

type CheckpointCountResponse

type CheckpointCountResponse struct {
	Height string          `json:"height"`
	Result CheckpointCount `json:"result"`
}

type CheckpointId

type CheckpointId uint64

func CheckpointIdAt

func CheckpointIdAt(tx kv.Tx, block uint64) (CheckpointId, error)

type CheckpointListResponse

type CheckpointListResponse struct {
	Height string      `json:"height"`
	Result Checkpoints `json:"result"`
}

type CheckpointReader

type CheckpointReader interface {
	LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)
	GetCheckpoint(ctx context.Context, checkpointId CheckpointId) (*Checkpoint, error)
}

type CheckpointResponse

type CheckpointResponse struct {
	Height string     `json:"height"`
	Result Checkpoint `json:"result"`
}

type CheckpointStore

type CheckpointStore interface {
	CheckpointReader
	CheckpointWriter
}

type CheckpointWriter

type CheckpointWriter interface {
	PutCheckpoint(ctx context.Context, checkpointId CheckpointId, checkpoint *Checkpoint) error
}

type Checkpoints

type Checkpoints []*Checkpoint

func (Checkpoints) Len

func (cs Checkpoints) Len() int

func (Checkpoints) Less

func (cs Checkpoints) Less(i, j int) bool

func (Checkpoints) Swap

func (cs Checkpoints) Swap(i, j int)

type Client

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

func NewHeimdallClient

func NewHeimdallClient(urlString string, logger log.Logger) *Client

func (*Client) Close

func (c *Client) Close()

Close sends a signal to stop the running process

func (*Client) FetchCheckpoint

func (c *Client) FetchCheckpoint(ctx context.Context, number int64) (*Checkpoint, error)

FetchCheckpoint fetches the checkpoint from heimdall

func (*Client) FetchCheckpointCount

func (c *Client) FetchCheckpointCount(ctx context.Context) (int64, error)

FetchCheckpointCount fetches the checkpoint count from heimdall

func (*Client) FetchCheckpoints

func (c *Client) FetchCheckpoints(ctx context.Context, page uint64, limit uint64) (Checkpoints, error)

func (*Client) FetchLastNoAckMilestone

func (c *Client) FetchLastNoAckMilestone(ctx context.Context) (string, error)

FetchLastNoAckMilestone fetches the last no-ack-milestone from heimdall

func (*Client) FetchLatestSpan

func (c *Client) FetchLatestSpan(ctx context.Context) (*Span, error)

func (*Client) FetchMilestone

func (c *Client) FetchMilestone(ctx context.Context, number int64) (*Milestone, error)

FetchMilestone fetches a milestone from heimdall

func (*Client) FetchMilestoneCount

func (c *Client) FetchMilestoneCount(ctx context.Context) (int64, error)

FetchMilestoneCount fetches the milestone count from heimdall

func (*Client) FetchMilestoneID

func (c *Client) FetchMilestoneID(ctx context.Context, milestoneID string) error

FetchMilestoneID fetches the bool result from Heimdall whether the ID corresponding to the given milestone is in process in Heimdall

func (*Client) FetchNoAckMilestone

func (c *Client) FetchNoAckMilestone(ctx context.Context, milestoneID string) error

FetchNoAckMilestone fetches the last no-ack-milestone from heimdall

func (*Client) FetchSpan

func (c *Client) FetchSpan(ctx context.Context, spanID uint64) (*Span, error)

func (*Client) FetchStateSyncEvent

func (c *Client) FetchStateSyncEvent(ctx context.Context, id uint64) (*EventRecordWithTime, error)

func (*Client) FetchStateSyncEvents

func (c *Client) FetchStateSyncEvents(ctx context.Context, fromID uint64, to time.Time, limit int) ([]*EventRecordWithTime, error)

type EventRecord

type EventRecord struct {
	ID       uint64            `json:"id" yaml:"id"`
	Contract libcommon.Address `json:"contract" yaml:"contract"`
	Data     hexutility.Bytes  `json:"data" yaml:"data"`
	TxHash   libcommon.Hash    `json:"tx_hash" yaml:"tx_hash"`
	LogIndex uint64            `json:"log_index" yaml:"log_index"`
	ChainID  string            `json:"bor_chain_id" yaml:"bor_chain_id"`
}

EventRecord represents state record

type EventRecordWithTime

type EventRecordWithTime struct {
	EventRecord
	Time time.Time `json:"record_time" yaml:"record_time"`
}

func UnpackEventRecordWithTime

func UnpackEventRecordWithTime(stateContract abi.ABI, encodedEvent rlp.RawValue) (*EventRecordWithTime, error)

func (*EventRecordWithTime) BuildEventRecord

func (e *EventRecordWithTime) BuildEventRecord() *EventRecord

func (*EventRecordWithTime) String

func (e *EventRecordWithTime) String() string

String returns the string representatin of a state record

type Heimdall

type Heimdall interface {
	LastCheckpointId(ctx context.Context, store CheckpointStore) (CheckpointId, bool, error)
	LastMilestoneId(ctx context.Context, store MilestoneStore) (MilestoneId, bool, error)
	LastSpanId(ctx context.Context, store SpanStore) (SpanId, bool, error)
	FetchLatestSpan(ctx context.Context, store SpanStore) (*Span, error)

	FetchCheckpoints(ctx context.Context, store CheckpointStore, start CheckpointId, end CheckpointId) ([]*Checkpoint, error)
	FetchMilestones(ctx context.Context, store MilestoneStore, start MilestoneId, end MilestoneId) ([]*Milestone, error)
	FetchSpans(ctx context.Context, store SpanStore, start SpanId, end SpanId) ([]*Span, error)

	FetchCheckpointsFromBlock(ctx context.Context, store CheckpointStore, startBlock uint64) (Waypoints, error)
	FetchMilestonesFromBlock(ctx context.Context, store MilestoneStore, startBlock uint64) (Waypoints, error)
	FetchSpansFromBlock(ctx context.Context, store SpanStore, startBlock uint64) ([]*Span, error)

	OnCheckpointEvent(ctx context.Context, store CheckpointStore, callback func(*Checkpoint)) error
	OnMilestoneEvent(ctx context.Context, store MilestoneStore, callback func(*Milestone)) error
	OnSpanEvent(ctx context.Context, store SpanStore, callback func(*Span)) error
}

Heimdall is a wrapper of Heimdall HTTP API

func NewHeimdall

func NewHeimdall(client HeimdallClient, logger log.Logger) Heimdall

type HeimdallClient

type HeimdallClient interface {
	FetchStateSyncEvents(ctx context.Context, fromId uint64, to time.Time, limit int) ([]*EventRecordWithTime, error)
	FetchStateSyncEvent(ctx context.Context, id uint64) (*EventRecordWithTime, error)

	FetchLatestSpan(ctx context.Context) (*Span, error)
	FetchSpan(ctx context.Context, spanID uint64) (*Span, error)

	FetchCheckpoint(ctx context.Context, number int64) (*Checkpoint, error)
	FetchCheckpointCount(ctx context.Context) (int64, error)
	FetchCheckpoints(ctx context.Context, page uint64, limit uint64) (Checkpoints, error)
	FetchMilestone(ctx context.Context, number int64) (*Milestone, error)
	FetchMilestoneCount(ctx context.Context) (int64, error)

	// FetchNoAckMilestone fetches a bool value whether milestone corresponding to the given id failed in the Heimdall
	FetchNoAckMilestone(ctx context.Context, milestoneID string) error

	// FetchLastNoAckMilestone fetches the latest failed milestone id
	FetchLastNoAckMilestone(ctx context.Context) (string, error)

	// FetchMilestoneID fetches a bool value whether milestone corresponding to the given id is in process in Heimdall
	FetchMilestoneID(ctx context.Context, milestoneID string) error

	Close()
}

type HeimdallNoStore

type HeimdallNoStore interface {
	LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)
	LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)
	LastSpanId(ctx context.Context) (SpanId, bool, error)
	FetchLatestSpan(ctx context.Context) (*Span, error)

	FetchCheckpoints(ctx context.Context, start CheckpointId, end CheckpointId) ([]*Checkpoint, error)
	FetchMilestones(ctx context.Context, start MilestoneId, end MilestoneId) ([]*Milestone, error)
	FetchSpans(ctx context.Context, start SpanId, end SpanId) ([]*Span, error)

	FetchCheckpointsFromBlock(ctx context.Context, startBlock uint64) (Waypoints, error)
	FetchMilestonesFromBlock(ctx context.Context, startBlock uint64) (Waypoints, error)
	FetchSpansFromBlock(ctx context.Context, startBlock uint64) ([]*Span, error)

	OnCheckpointEvent(ctx context.Context, callback func(*Checkpoint)) error
	OnMilestoneEvent(ctx context.Context, callback func(*Milestone)) error
	OnSpanEvent(ctx context.Context, callback func(*Span)) error
}

func NewHeimdallNoStore

func NewHeimdallNoStore(client HeimdallClient, logger log.Logger) HeimdallNoStore

type HttpClient

type HttpClient interface {
	Do(req *http.Request) (*http.Response, error)
	CloseIdleConnections()
}

type Milestone

type Milestone struct {
	Id     MilestoneId
	Fields WaypointFields
}

milestone defines a response object type of bor milestone

func (Milestone) CmpRange

func (m Milestone) CmpRange(n uint64) int

func (Milestone) EndBlock

func (m Milestone) EndBlock() *big.Int

func (Milestone) Length

func (m Milestone) Length() uint64

func (*Milestone) MarshalJSON

func (m *Milestone) MarshalJSON() ([]byte, error)

func (Milestone) RootHash

func (m Milestone) RootHash() libcommon.Hash

func (Milestone) StartBlock

func (m Milestone) StartBlock() *big.Int

func (Milestone) String

func (m Milestone) String() string

func (Milestone) Timestamp

func (m Milestone) Timestamp() uint64

func (*Milestone) UnmarshalJSON

func (m *Milestone) UnmarshalJSON(b []byte) error

type MilestoneCount

type MilestoneCount struct {
	Count int64 `json:"count"`
}

type MilestoneCountResponse

type MilestoneCountResponse struct {
	Height string         `json:"height"`
	Result MilestoneCount `json:"result"`
}

type MilestoneID

type MilestoneID struct {
	Result bool `json:"result"`
}

type MilestoneIDResponse

type MilestoneIDResponse struct {
	Height string      `json:"height"`
	Result MilestoneID `json:"result"`
}

type MilestoneId

type MilestoneId uint64

func MilestoneIdAt

func MilestoneIdAt(tx kv.Tx, block uint64) (MilestoneId, error)

type MilestoneLastNoAck

type MilestoneLastNoAck struct {
	Result string `json:"result"`
}

type MilestoneLastNoAckResponse

type MilestoneLastNoAckResponse struct {
	Height string             `json:"height"`
	Result MilestoneLastNoAck `json:"result"`
}

type MilestoneNoAck

type MilestoneNoAck struct {
	Result bool `json:"result"`
}

type MilestoneNoAckResponse

type MilestoneNoAckResponse struct {
	Height string         `json:"height"`
	Result MilestoneNoAck `json:"result"`
}

type MilestoneReader

type MilestoneReader interface {
	LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)
	GetMilestone(ctx context.Context, milestoneId MilestoneId) (*Milestone, error)
}

type MilestoneResponse

type MilestoneResponse struct {
	Height string    `json:"height"`
	Result Milestone `json:"result"`
}

type MilestoneStore

type MilestoneStore interface {
	MilestoneReader
	MilestoneWriter
}

type MilestoneWriter

type MilestoneWriter interface {
	PutMilestone(ctx context.Context, milestoneId MilestoneId, milestone *Milestone) error
}

type MockCheckpointReader

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

MockCheckpointReader is a mock of CheckpointReader interface.

func NewMockCheckpointReader

func NewMockCheckpointReader(ctrl *gomock.Controller) *MockCheckpointReader

NewMockCheckpointReader creates a new mock instance.

func (*MockCheckpointReader) EXPECT

func (m *MockCheckpointReader) EXPECT() *MockCheckpointReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCheckpointReader) GetCheckpoint

func (m *MockCheckpointReader) GetCheckpoint(ctx context.Context, checkpointId CheckpointId) (*Checkpoint, error)

GetCheckpoint mocks base method.

func (*MockCheckpointReader) LastCheckpointId

func (m *MockCheckpointReader) LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)

LastCheckpointId mocks base method.

type MockCheckpointReaderGetCheckpointCall

type MockCheckpointReaderGetCheckpointCall struct {
	*gomock.Call
}

MockCheckpointReaderGetCheckpointCall wrap *gomock.Call

func (*MockCheckpointReaderGetCheckpointCall) Do

func (c *MockCheckpointReaderGetCheckpointCall) Do(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointReaderGetCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockCheckpointReaderGetCheckpointCall) DoAndReturn

func (c *MockCheckpointReaderGetCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointReaderGetCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockCheckpointReaderGetCheckpointCall) Return

func (c *MockCheckpointReaderGetCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockCheckpointReaderGetCheckpointCall

Return rewrite *gomock.Call.Return

type MockCheckpointReaderLastCheckpointIdCall

type MockCheckpointReaderLastCheckpointIdCall struct {
	*gomock.Call
}

MockCheckpointReaderLastCheckpointIdCall wrap *gomock.Call

func (*MockCheckpointReaderLastCheckpointIdCall) Do

func (c *MockCheckpointReaderLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointReaderLastCheckpointIdCall

Do rewrite *gomock.Call.Do

func (*MockCheckpointReaderLastCheckpointIdCall) DoAndReturn

func (c *MockCheckpointReaderLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointReaderLastCheckpointIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockCheckpointReaderLastCheckpointIdCall) Return

func (c *MockCheckpointReaderLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockCheckpointReaderLastCheckpointIdCall

Return rewrite *gomock.Call.Return

type MockCheckpointReaderMockRecorder

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

MockCheckpointReaderMockRecorder is the mock recorder for MockCheckpointReader.

func (*MockCheckpointReaderMockRecorder) GetCheckpoint

func (mr *MockCheckpointReaderMockRecorder) GetCheckpoint(ctx, checkpointId any) *MockCheckpointReaderGetCheckpointCall

GetCheckpoint indicates an expected call of GetCheckpoint.

func (*MockCheckpointReaderMockRecorder) LastCheckpointId

func (mr *MockCheckpointReaderMockRecorder) LastCheckpointId(ctx any) *MockCheckpointReaderLastCheckpointIdCall

LastCheckpointId indicates an expected call of LastCheckpointId.

type MockCheckpointStore

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

MockCheckpointStore is a mock of CheckpointStore interface.

func NewMockCheckpointStore

func NewMockCheckpointStore(ctrl *gomock.Controller) *MockCheckpointStore

NewMockCheckpointStore creates a new mock instance.

func (*MockCheckpointStore) EXPECT

func (m *MockCheckpointStore) EXPECT() *MockCheckpointStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCheckpointStore) GetCheckpoint

func (m *MockCheckpointStore) GetCheckpoint(ctx context.Context, checkpointId CheckpointId) (*Checkpoint, error)

GetCheckpoint mocks base method.

func (*MockCheckpointStore) LastCheckpointId

func (m *MockCheckpointStore) LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)

LastCheckpointId mocks base method.

func (*MockCheckpointStore) PutCheckpoint

func (m *MockCheckpointStore) PutCheckpoint(ctx context.Context, checkpointId CheckpointId, checkpoint *Checkpoint) error

PutCheckpoint mocks base method.

type MockCheckpointStoreGetCheckpointCall

type MockCheckpointStoreGetCheckpointCall struct {
	*gomock.Call
}

MockCheckpointStoreGetCheckpointCall wrap *gomock.Call

func (*MockCheckpointStoreGetCheckpointCall) Do

func (c *MockCheckpointStoreGetCheckpointCall) Do(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointStoreGetCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockCheckpointStoreGetCheckpointCall) DoAndReturn

func (c *MockCheckpointStoreGetCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockCheckpointStoreGetCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockCheckpointStoreGetCheckpointCall) Return

func (c *MockCheckpointStoreGetCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockCheckpointStoreGetCheckpointCall

Return rewrite *gomock.Call.Return

type MockCheckpointStoreLastCheckpointIdCall

type MockCheckpointStoreLastCheckpointIdCall struct {
	*gomock.Call
}

MockCheckpointStoreLastCheckpointIdCall wrap *gomock.Call

func (*MockCheckpointStoreLastCheckpointIdCall) Do

func (c *MockCheckpointStoreLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointStoreLastCheckpointIdCall

Do rewrite *gomock.Call.Do

func (*MockCheckpointStoreLastCheckpointIdCall) DoAndReturn

func (c *MockCheckpointStoreLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockCheckpointStoreLastCheckpointIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockCheckpointStoreLastCheckpointIdCall) Return

func (c *MockCheckpointStoreLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockCheckpointStoreLastCheckpointIdCall

Return rewrite *gomock.Call.Return

type MockCheckpointStoreMockRecorder

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

MockCheckpointStoreMockRecorder is the mock recorder for MockCheckpointStore.

func (*MockCheckpointStoreMockRecorder) GetCheckpoint

func (mr *MockCheckpointStoreMockRecorder) GetCheckpoint(ctx, checkpointId any) *MockCheckpointStoreGetCheckpointCall

GetCheckpoint indicates an expected call of GetCheckpoint.

func (*MockCheckpointStoreMockRecorder) LastCheckpointId

func (mr *MockCheckpointStoreMockRecorder) LastCheckpointId(ctx any) *MockCheckpointStoreLastCheckpointIdCall

LastCheckpointId indicates an expected call of LastCheckpointId.

func (*MockCheckpointStoreMockRecorder) PutCheckpoint

func (mr *MockCheckpointStoreMockRecorder) PutCheckpoint(ctx, checkpointId, checkpoint any) *MockCheckpointStorePutCheckpointCall

PutCheckpoint indicates an expected call of PutCheckpoint.

type MockCheckpointStorePutCheckpointCall

type MockCheckpointStorePutCheckpointCall struct {
	*gomock.Call
}

MockCheckpointStorePutCheckpointCall wrap *gomock.Call

func (*MockCheckpointStorePutCheckpointCall) Do

func (c *MockCheckpointStorePutCheckpointCall) Do(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointStorePutCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockCheckpointStorePutCheckpointCall) DoAndReturn

func (c *MockCheckpointStorePutCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointStorePutCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockCheckpointStorePutCheckpointCall) Return

func (c *MockCheckpointStorePutCheckpointCall) Return(arg0 error) *MockCheckpointStorePutCheckpointCall

Return rewrite *gomock.Call.Return

type MockCheckpointWriter

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

MockCheckpointWriter is a mock of CheckpointWriter interface.

func NewMockCheckpointWriter

func NewMockCheckpointWriter(ctrl *gomock.Controller) *MockCheckpointWriter

NewMockCheckpointWriter creates a new mock instance.

func (*MockCheckpointWriter) EXPECT

func (m *MockCheckpointWriter) EXPECT() *MockCheckpointWriterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCheckpointWriter) PutCheckpoint

func (m *MockCheckpointWriter) PutCheckpoint(ctx context.Context, checkpointId CheckpointId, checkpoint *Checkpoint) error

PutCheckpoint mocks base method.

type MockCheckpointWriterMockRecorder

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

MockCheckpointWriterMockRecorder is the mock recorder for MockCheckpointWriter.

func (*MockCheckpointWriterMockRecorder) PutCheckpoint

func (mr *MockCheckpointWriterMockRecorder) PutCheckpoint(ctx, checkpointId, checkpoint any) *MockCheckpointWriterPutCheckpointCall

PutCheckpoint indicates an expected call of PutCheckpoint.

type MockCheckpointWriterPutCheckpointCall

type MockCheckpointWriterPutCheckpointCall struct {
	*gomock.Call
}

MockCheckpointWriterPutCheckpointCall wrap *gomock.Call

func (*MockCheckpointWriterPutCheckpointCall) Do

func (c *MockCheckpointWriterPutCheckpointCall) Do(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointWriterPutCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockCheckpointWriterPutCheckpointCall) DoAndReturn

func (c *MockCheckpointWriterPutCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId, *Checkpoint) error) *MockCheckpointWriterPutCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockCheckpointWriterPutCheckpointCall) Return

func (c *MockCheckpointWriterPutCheckpointCall) Return(arg0 error) *MockCheckpointWriterPutCheckpointCall

Return rewrite *gomock.Call.Return

type MockHeimdall

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

MockHeimdall is a mock of Heimdall interface.

func NewMockHeimdall

func NewMockHeimdall(ctrl *gomock.Controller) *MockHeimdall

NewMockHeimdall creates a new mock instance.

func (*MockHeimdall) EXPECT

func (m *MockHeimdall) EXPECT() *MockHeimdallMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockHeimdall) FetchCheckpoints

func (m *MockHeimdall) FetchCheckpoints(arg0 context.Context, arg1 CheckpointStore, arg2, arg3 CheckpointId) ([]*Checkpoint, error)

FetchCheckpoints mocks base method.

func (*MockHeimdall) FetchCheckpointsFromBlock

func (m *MockHeimdall) FetchCheckpointsFromBlock(arg0 context.Context, arg1 CheckpointStore, arg2 uint64) (Waypoints, error)

FetchCheckpointsFromBlock mocks base method.

func (*MockHeimdall) FetchLatestSpan

func (m *MockHeimdall) FetchLatestSpan(arg0 context.Context, arg1 SpanStore) (*Span, error)

FetchLatestSpan mocks base method.

func (*MockHeimdall) FetchMilestones

func (m *MockHeimdall) FetchMilestones(arg0 context.Context, arg1 MilestoneStore, arg2, arg3 MilestoneId) ([]*Milestone, error)

FetchMilestones mocks base method.

func (*MockHeimdall) FetchMilestonesFromBlock

func (m *MockHeimdall) FetchMilestonesFromBlock(arg0 context.Context, arg1 MilestoneStore, arg2 uint64) (Waypoints, error)

FetchMilestonesFromBlock mocks base method.

func (*MockHeimdall) FetchSpans

func (m *MockHeimdall) FetchSpans(arg0 context.Context, arg1 SpanStore, arg2, arg3 SpanId) ([]*Span, error)

FetchSpans mocks base method.

func (*MockHeimdall) FetchSpansFromBlock

func (m *MockHeimdall) FetchSpansFromBlock(arg0 context.Context, arg1 SpanStore, arg2 uint64) ([]*Span, error)

FetchSpansFromBlock mocks base method.

func (*MockHeimdall) LastCheckpointId

func (m *MockHeimdall) LastCheckpointId(arg0 context.Context, arg1 CheckpointStore) (CheckpointId, bool, error)

LastCheckpointId mocks base method.

func (*MockHeimdall) LastMilestoneId

func (m *MockHeimdall) LastMilestoneId(arg0 context.Context, arg1 MilestoneStore) (MilestoneId, bool, error)

LastMilestoneId mocks base method.

func (*MockHeimdall) LastSpanId

func (m *MockHeimdall) LastSpanId(arg0 context.Context, arg1 SpanStore) (SpanId, bool, error)

LastSpanId mocks base method.

func (*MockHeimdall) OnCheckpointEvent

func (m *MockHeimdall) OnCheckpointEvent(arg0 context.Context, arg1 CheckpointStore, arg2 func(*Checkpoint)) error

OnCheckpointEvent mocks base method.

func (*MockHeimdall) OnMilestoneEvent

func (m *MockHeimdall) OnMilestoneEvent(arg0 context.Context, arg1 MilestoneStore, arg2 func(*Milestone)) error

OnMilestoneEvent mocks base method.

func (*MockHeimdall) OnSpanEvent

func (m *MockHeimdall) OnSpanEvent(arg0 context.Context, arg1 SpanStore, arg2 func(*Span)) error

OnSpanEvent mocks base method.

type MockHeimdallClient

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

MockHeimdallClient is a mock of HeimdallClient interface.

func NewMockHeimdallClient

func NewMockHeimdallClient(ctrl *gomock.Controller) *MockHeimdallClient

NewMockHeimdallClient creates a new mock instance.

func (*MockHeimdallClient) Close

func (m *MockHeimdallClient) Close()

Close mocks base method.

func (*MockHeimdallClient) EXPECT

func (m *MockHeimdallClient) EXPECT() *MockHeimdallClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockHeimdallClient) FetchCheckpoint

func (m *MockHeimdallClient) FetchCheckpoint(arg0 context.Context, arg1 int64) (*Checkpoint, error)

FetchCheckpoint mocks base method.

func (*MockHeimdallClient) FetchCheckpointCount

func (m *MockHeimdallClient) FetchCheckpointCount(arg0 context.Context) (int64, error)

FetchCheckpointCount mocks base method.

func (*MockHeimdallClient) FetchCheckpoints

func (m *MockHeimdallClient) FetchCheckpoints(arg0 context.Context, arg1, arg2 uint64) (Checkpoints, error)

FetchCheckpoints mocks base method.

func (*MockHeimdallClient) FetchLastNoAckMilestone

func (m *MockHeimdallClient) FetchLastNoAckMilestone(arg0 context.Context) (string, error)

FetchLastNoAckMilestone mocks base method.

func (*MockHeimdallClient) FetchLatestSpan

func (m *MockHeimdallClient) FetchLatestSpan(arg0 context.Context) (*Span, error)

FetchLatestSpan mocks base method.

func (*MockHeimdallClient) FetchMilestone

func (m *MockHeimdallClient) FetchMilestone(arg0 context.Context, arg1 int64) (*Milestone, error)

FetchMilestone mocks base method.

func (*MockHeimdallClient) FetchMilestoneCount

func (m *MockHeimdallClient) FetchMilestoneCount(arg0 context.Context) (int64, error)

FetchMilestoneCount mocks base method.

func (*MockHeimdallClient) FetchMilestoneID

func (m *MockHeimdallClient) FetchMilestoneID(arg0 context.Context, arg1 string) error

FetchMilestoneID mocks base method.

func (*MockHeimdallClient) FetchNoAckMilestone

func (m *MockHeimdallClient) FetchNoAckMilestone(arg0 context.Context, arg1 string) error

FetchNoAckMilestone mocks base method.

func (*MockHeimdallClient) FetchSpan

func (m *MockHeimdallClient) FetchSpan(arg0 context.Context, arg1 uint64) (*Span, error)

FetchSpan mocks base method.

func (*MockHeimdallClient) FetchStateSyncEvent

func (m *MockHeimdallClient) FetchStateSyncEvent(arg0 context.Context, arg1 uint64) (*EventRecordWithTime, error)

FetchStateSyncEvent mocks base method.

func (*MockHeimdallClient) FetchStateSyncEvents

func (m *MockHeimdallClient) FetchStateSyncEvents(arg0 context.Context, arg1 uint64, arg2 time.Time, arg3 int) ([]*EventRecordWithTime, error)

FetchStateSyncEvents mocks base method.

type MockHeimdallClientCloseCall

type MockHeimdallClientCloseCall struct {
	*gomock.Call
}

MockHeimdallClientCloseCall wrap *gomock.Call

func (*MockHeimdallClientCloseCall) Do

func (c *MockHeimdallClientCloseCall) Do(f func()) *MockHeimdallClientCloseCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientCloseCall) DoAndReturn

func (c *MockHeimdallClientCloseCall) DoAndReturn(f func()) *MockHeimdallClientCloseCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientCloseCall) Return

func (c *MockHeimdallClientCloseCall) Return() *MockHeimdallClientCloseCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchCheckpointCall

type MockHeimdallClientFetchCheckpointCall struct {
	*gomock.Call
}

MockHeimdallClientFetchCheckpointCall wrap *gomock.Call

func (*MockHeimdallClientFetchCheckpointCall) Do

func (c *MockHeimdallClientFetchCheckpointCall) Do(f func(context.Context, int64) (*Checkpoint, error)) *MockHeimdallClientFetchCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchCheckpointCall) DoAndReturn

func (c *MockHeimdallClientFetchCheckpointCall) DoAndReturn(f func(context.Context, int64) (*Checkpoint, error)) *MockHeimdallClientFetchCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchCheckpointCall) Return

func (c *MockHeimdallClientFetchCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockHeimdallClientFetchCheckpointCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchCheckpointCountCall

type MockHeimdallClientFetchCheckpointCountCall struct {
	*gomock.Call
}

MockHeimdallClientFetchCheckpointCountCall wrap *gomock.Call

func (*MockHeimdallClientFetchCheckpointCountCall) Do

func (c *MockHeimdallClientFetchCheckpointCountCall) Do(f func(context.Context) (int64, error)) *MockHeimdallClientFetchCheckpointCountCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchCheckpointCountCall) DoAndReturn

func (c *MockHeimdallClientFetchCheckpointCountCall) DoAndReturn(f func(context.Context) (int64, error)) *MockHeimdallClientFetchCheckpointCountCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchCheckpointCountCall) Return

func (c *MockHeimdallClientFetchCheckpointCountCall) Return(arg0 int64, arg1 error) *MockHeimdallClientFetchCheckpointCountCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchCheckpointsCall

type MockHeimdallClientFetchCheckpointsCall struct {
	*gomock.Call
}

MockHeimdallClientFetchCheckpointsCall wrap *gomock.Call

func (*MockHeimdallClientFetchCheckpointsCall) Do

func (c *MockHeimdallClientFetchCheckpointsCall) Do(f func(context.Context, uint64, uint64) (Checkpoints, error)) *MockHeimdallClientFetchCheckpointsCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchCheckpointsCall) DoAndReturn

func (c *MockHeimdallClientFetchCheckpointsCall) DoAndReturn(f func(context.Context, uint64, uint64) (Checkpoints, error)) *MockHeimdallClientFetchCheckpointsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchCheckpointsCall) Return

func (c *MockHeimdallClientFetchCheckpointsCall) Return(arg0 Checkpoints, arg1 error) *MockHeimdallClientFetchCheckpointsCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchLastNoAckMilestoneCall

type MockHeimdallClientFetchLastNoAckMilestoneCall struct {
	*gomock.Call
}

MockHeimdallClientFetchLastNoAckMilestoneCall wrap *gomock.Call

func (*MockHeimdallClientFetchLastNoAckMilestoneCall) Do

func (c *MockHeimdallClientFetchLastNoAckMilestoneCall) Do(f func(context.Context) (string, error)) *MockHeimdallClientFetchLastNoAckMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchLastNoAckMilestoneCall) DoAndReturn

func (c *MockHeimdallClientFetchLastNoAckMilestoneCall) DoAndReturn(f func(context.Context) (string, error)) *MockHeimdallClientFetchLastNoAckMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchLastNoAckMilestoneCall) Return

func (c *MockHeimdallClientFetchLastNoAckMilestoneCall) Return(arg0 string, arg1 error) *MockHeimdallClientFetchLastNoAckMilestoneCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchLatestSpanCall

type MockHeimdallClientFetchLatestSpanCall struct {
	*gomock.Call
}

MockHeimdallClientFetchLatestSpanCall wrap *gomock.Call

func (*MockHeimdallClientFetchLatestSpanCall) Do

func (c *MockHeimdallClientFetchLatestSpanCall) Do(f func(context.Context) (*Span, error)) *MockHeimdallClientFetchLatestSpanCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchLatestSpanCall) DoAndReturn

func (c *MockHeimdallClientFetchLatestSpanCall) DoAndReturn(f func(context.Context) (*Span, error)) *MockHeimdallClientFetchLatestSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchLatestSpanCall) Return

func (c *MockHeimdallClientFetchLatestSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallClientFetchLatestSpanCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchMilestoneCall

type MockHeimdallClientFetchMilestoneCall struct {
	*gomock.Call
}

MockHeimdallClientFetchMilestoneCall wrap *gomock.Call

func (*MockHeimdallClientFetchMilestoneCall) Do

func (c *MockHeimdallClientFetchMilestoneCall) Do(f func(context.Context, int64) (*Milestone, error)) *MockHeimdallClientFetchMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchMilestoneCall) DoAndReturn

func (c *MockHeimdallClientFetchMilestoneCall) DoAndReturn(f func(context.Context, int64) (*Milestone, error)) *MockHeimdallClientFetchMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchMilestoneCall) Return

func (c *MockHeimdallClientFetchMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockHeimdallClientFetchMilestoneCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchMilestoneCountCall

type MockHeimdallClientFetchMilestoneCountCall struct {
	*gomock.Call
}

MockHeimdallClientFetchMilestoneCountCall wrap *gomock.Call

func (*MockHeimdallClientFetchMilestoneCountCall) Do

func (c *MockHeimdallClientFetchMilestoneCountCall) Do(f func(context.Context) (int64, error)) *MockHeimdallClientFetchMilestoneCountCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchMilestoneCountCall) DoAndReturn

func (c *MockHeimdallClientFetchMilestoneCountCall) DoAndReturn(f func(context.Context) (int64, error)) *MockHeimdallClientFetchMilestoneCountCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchMilestoneCountCall) Return

func (c *MockHeimdallClientFetchMilestoneCountCall) Return(arg0 int64, arg1 error) *MockHeimdallClientFetchMilestoneCountCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchMilestoneIDCall

type MockHeimdallClientFetchMilestoneIDCall struct {
	*gomock.Call
}

MockHeimdallClientFetchMilestoneIDCall wrap *gomock.Call

func (*MockHeimdallClientFetchMilestoneIDCall) Do

func (c *MockHeimdallClientFetchMilestoneIDCall) Do(f func(context.Context, string) error) *MockHeimdallClientFetchMilestoneIDCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchMilestoneIDCall) DoAndReturn

func (c *MockHeimdallClientFetchMilestoneIDCall) DoAndReturn(f func(context.Context, string) error) *MockHeimdallClientFetchMilestoneIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchMilestoneIDCall) Return

func (c *MockHeimdallClientFetchMilestoneIDCall) Return(arg0 error) *MockHeimdallClientFetchMilestoneIDCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchNoAckMilestoneCall

type MockHeimdallClientFetchNoAckMilestoneCall struct {
	*gomock.Call
}

MockHeimdallClientFetchNoAckMilestoneCall wrap *gomock.Call

func (*MockHeimdallClientFetchNoAckMilestoneCall) Do

func (c *MockHeimdallClientFetchNoAckMilestoneCall) Do(f func(context.Context, string) error) *MockHeimdallClientFetchNoAckMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchNoAckMilestoneCall) DoAndReturn

func (c *MockHeimdallClientFetchNoAckMilestoneCall) DoAndReturn(f func(context.Context, string) error) *MockHeimdallClientFetchNoAckMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchNoAckMilestoneCall) Return

func (c *MockHeimdallClientFetchNoAckMilestoneCall) Return(arg0 error) *MockHeimdallClientFetchNoAckMilestoneCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchSpanCall

type MockHeimdallClientFetchSpanCall struct {
	*gomock.Call
}

MockHeimdallClientFetchSpanCall wrap *gomock.Call

func (*MockHeimdallClientFetchSpanCall) Do

func (c *MockHeimdallClientFetchSpanCall) Do(f func(context.Context, uint64) (*Span, error)) *MockHeimdallClientFetchSpanCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchSpanCall) DoAndReturn

func (c *MockHeimdallClientFetchSpanCall) DoAndReturn(f func(context.Context, uint64) (*Span, error)) *MockHeimdallClientFetchSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchSpanCall) Return

func (c *MockHeimdallClientFetchSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallClientFetchSpanCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchStateSyncEventCall

type MockHeimdallClientFetchStateSyncEventCall struct {
	*gomock.Call
}

MockHeimdallClientFetchStateSyncEventCall wrap *gomock.Call

func (*MockHeimdallClientFetchStateSyncEventCall) Do

func (c *MockHeimdallClientFetchStateSyncEventCall) Do(f func(context.Context, uint64) (*EventRecordWithTime, error)) *MockHeimdallClientFetchStateSyncEventCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchStateSyncEventCall) DoAndReturn

func (c *MockHeimdallClientFetchStateSyncEventCall) DoAndReturn(f func(context.Context, uint64) (*EventRecordWithTime, error)) *MockHeimdallClientFetchStateSyncEventCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchStateSyncEventCall) Return

func (c *MockHeimdallClientFetchStateSyncEventCall) Return(arg0 *EventRecordWithTime, arg1 error) *MockHeimdallClientFetchStateSyncEventCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientFetchStateSyncEventsCall

type MockHeimdallClientFetchStateSyncEventsCall struct {
	*gomock.Call
}

MockHeimdallClientFetchStateSyncEventsCall wrap *gomock.Call

func (*MockHeimdallClientFetchStateSyncEventsCall) Do

func (c *MockHeimdallClientFetchStateSyncEventsCall) Do(f func(context.Context, uint64, time.Time, int) ([]*EventRecordWithTime, error)) *MockHeimdallClientFetchStateSyncEventsCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallClientFetchStateSyncEventsCall) DoAndReturn

func (c *MockHeimdallClientFetchStateSyncEventsCall) DoAndReturn(f func(context.Context, uint64, time.Time, int) ([]*EventRecordWithTime, error)) *MockHeimdallClientFetchStateSyncEventsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallClientFetchStateSyncEventsCall) Return

func (c *MockHeimdallClientFetchStateSyncEventsCall) Return(arg0 []*EventRecordWithTime, arg1 error) *MockHeimdallClientFetchStateSyncEventsCall

Return rewrite *gomock.Call.Return

type MockHeimdallClientMockRecorder

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

MockHeimdallClientMockRecorder is the mock recorder for MockHeimdallClient.

func (*MockHeimdallClientMockRecorder) Close

func (mr *MockHeimdallClientMockRecorder) Close() *MockHeimdallClientCloseCall

Close indicates an expected call of Close.

func (*MockHeimdallClientMockRecorder) FetchCheckpoint

func (mr *MockHeimdallClientMockRecorder) FetchCheckpoint(arg0, arg1 any) *MockHeimdallClientFetchCheckpointCall

FetchCheckpoint indicates an expected call of FetchCheckpoint.

func (*MockHeimdallClientMockRecorder) FetchCheckpointCount

func (mr *MockHeimdallClientMockRecorder) FetchCheckpointCount(arg0 any) *MockHeimdallClientFetchCheckpointCountCall

FetchCheckpointCount indicates an expected call of FetchCheckpointCount.

func (*MockHeimdallClientMockRecorder) FetchCheckpoints

func (mr *MockHeimdallClientMockRecorder) FetchCheckpoints(arg0, arg1, arg2 any) *MockHeimdallClientFetchCheckpointsCall

FetchCheckpoints indicates an expected call of FetchCheckpoints.

func (*MockHeimdallClientMockRecorder) FetchLastNoAckMilestone

func (mr *MockHeimdallClientMockRecorder) FetchLastNoAckMilestone(arg0 any) *MockHeimdallClientFetchLastNoAckMilestoneCall

FetchLastNoAckMilestone indicates an expected call of FetchLastNoAckMilestone.

func (*MockHeimdallClientMockRecorder) FetchLatestSpan

func (mr *MockHeimdallClientMockRecorder) FetchLatestSpan(arg0 any) *MockHeimdallClientFetchLatestSpanCall

FetchLatestSpan indicates an expected call of FetchLatestSpan.

func (*MockHeimdallClientMockRecorder) FetchMilestone

func (mr *MockHeimdallClientMockRecorder) FetchMilestone(arg0, arg1 any) *MockHeimdallClientFetchMilestoneCall

FetchMilestone indicates an expected call of FetchMilestone.

func (*MockHeimdallClientMockRecorder) FetchMilestoneCount

func (mr *MockHeimdallClientMockRecorder) FetchMilestoneCount(arg0 any) *MockHeimdallClientFetchMilestoneCountCall

FetchMilestoneCount indicates an expected call of FetchMilestoneCount.

func (*MockHeimdallClientMockRecorder) FetchMilestoneID

func (mr *MockHeimdallClientMockRecorder) FetchMilestoneID(arg0, arg1 any) *MockHeimdallClientFetchMilestoneIDCall

FetchMilestoneID indicates an expected call of FetchMilestoneID.

func (*MockHeimdallClientMockRecorder) FetchNoAckMilestone

func (mr *MockHeimdallClientMockRecorder) FetchNoAckMilestone(arg0, arg1 any) *MockHeimdallClientFetchNoAckMilestoneCall

FetchNoAckMilestone indicates an expected call of FetchNoAckMilestone.

func (*MockHeimdallClientMockRecorder) FetchSpan

func (mr *MockHeimdallClientMockRecorder) FetchSpan(arg0, arg1 any) *MockHeimdallClientFetchSpanCall

FetchSpan indicates an expected call of FetchSpan.

func (*MockHeimdallClientMockRecorder) FetchStateSyncEvent

func (mr *MockHeimdallClientMockRecorder) FetchStateSyncEvent(arg0, arg1 any) *MockHeimdallClientFetchStateSyncEventCall

FetchStateSyncEvent indicates an expected call of FetchStateSyncEvent.

func (*MockHeimdallClientMockRecorder) FetchStateSyncEvents

func (mr *MockHeimdallClientMockRecorder) FetchStateSyncEvents(arg0, arg1, arg2, arg3 any) *MockHeimdallClientFetchStateSyncEventsCall

FetchStateSyncEvents indicates an expected call of FetchStateSyncEvents.

type MockHeimdallFetchCheckpointsCall

type MockHeimdallFetchCheckpointsCall struct {
	*gomock.Call
}

MockHeimdallFetchCheckpointsCall wrap *gomock.Call

func (*MockHeimdallFetchCheckpointsCall) Do

func (c *MockHeimdallFetchCheckpointsCall) Do(f func(context.Context, CheckpointStore, CheckpointId, CheckpointId) ([]*Checkpoint, error)) *MockHeimdallFetchCheckpointsCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallFetchCheckpointsCall) DoAndReturn

func (c *MockHeimdallFetchCheckpointsCall) DoAndReturn(f func(context.Context, CheckpointStore, CheckpointId, CheckpointId) ([]*Checkpoint, error)) *MockHeimdallFetchCheckpointsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallFetchCheckpointsCall) Return

func (c *MockHeimdallFetchCheckpointsCall) Return(arg0 []*Checkpoint, arg1 error) *MockHeimdallFetchCheckpointsCall

Return rewrite *gomock.Call.Return

type MockHeimdallFetchCheckpointsFromBlockCall

type MockHeimdallFetchCheckpointsFromBlockCall struct {
	*gomock.Call
}

MockHeimdallFetchCheckpointsFromBlockCall wrap *gomock.Call

func (*MockHeimdallFetchCheckpointsFromBlockCall) Do

func (c *MockHeimdallFetchCheckpointsFromBlockCall) Do(f func(context.Context, CheckpointStore, uint64) (Waypoints, error)) *MockHeimdallFetchCheckpointsFromBlockCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallFetchCheckpointsFromBlockCall) DoAndReturn

func (c *MockHeimdallFetchCheckpointsFromBlockCall) DoAndReturn(f func(context.Context, CheckpointStore, uint64) (Waypoints, error)) *MockHeimdallFetchCheckpointsFromBlockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallFetchCheckpointsFromBlockCall) Return

func (c *MockHeimdallFetchCheckpointsFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallFetchCheckpointsFromBlockCall

Return rewrite *gomock.Call.Return

type MockHeimdallFetchLatestSpanCall

type MockHeimdallFetchLatestSpanCall struct {
	*gomock.Call
}

MockHeimdallFetchLatestSpanCall wrap *gomock.Call

func (*MockHeimdallFetchLatestSpanCall) Do

func (c *MockHeimdallFetchLatestSpanCall) Do(f func(context.Context, SpanStore) (*Span, error)) *MockHeimdallFetchLatestSpanCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallFetchLatestSpanCall) DoAndReturn

func (c *MockHeimdallFetchLatestSpanCall) DoAndReturn(f func(context.Context, SpanStore) (*Span, error)) *MockHeimdallFetchLatestSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallFetchLatestSpanCall) Return

func (c *MockHeimdallFetchLatestSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallFetchLatestSpanCall

Return rewrite *gomock.Call.Return

type MockHeimdallFetchMilestonesCall

type MockHeimdallFetchMilestonesCall struct {
	*gomock.Call
}

MockHeimdallFetchMilestonesCall wrap *gomock.Call

func (*MockHeimdallFetchMilestonesCall) Do

func (c *MockHeimdallFetchMilestonesCall) Do(f func(context.Context, MilestoneStore, MilestoneId, MilestoneId) ([]*Milestone, error)) *MockHeimdallFetchMilestonesCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallFetchMilestonesCall) DoAndReturn

func (c *MockHeimdallFetchMilestonesCall) DoAndReturn(f func(context.Context, MilestoneStore, MilestoneId, MilestoneId) ([]*Milestone, error)) *MockHeimdallFetchMilestonesCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallFetchMilestonesCall) Return

func (c *MockHeimdallFetchMilestonesCall) Return(arg0 []*Milestone, arg1 error) *MockHeimdallFetchMilestonesCall

Return rewrite *gomock.Call.Return

type MockHeimdallFetchMilestonesFromBlockCall

type MockHeimdallFetchMilestonesFromBlockCall struct {
	*gomock.Call
}

MockHeimdallFetchMilestonesFromBlockCall wrap *gomock.Call

func (*MockHeimdallFetchMilestonesFromBlockCall) Do

func (c *MockHeimdallFetchMilestonesFromBlockCall) Do(f func(context.Context, MilestoneStore, uint64) (Waypoints, error)) *MockHeimdallFetchMilestonesFromBlockCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallFetchMilestonesFromBlockCall) DoAndReturn

func (c *MockHeimdallFetchMilestonesFromBlockCall) DoAndReturn(f func(context.Context, MilestoneStore, uint64) (Waypoints, error)) *MockHeimdallFetchMilestonesFromBlockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallFetchMilestonesFromBlockCall) Return

func (c *MockHeimdallFetchMilestonesFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallFetchMilestonesFromBlockCall

Return rewrite *gomock.Call.Return

type MockHeimdallFetchSpansCall

type MockHeimdallFetchSpansCall struct {
	*gomock.Call
}

MockHeimdallFetchSpansCall wrap *gomock.Call

func (*MockHeimdallFetchSpansCall) Do

func (c *MockHeimdallFetchSpansCall) Do(f func(context.Context, SpanStore, SpanId, SpanId) ([]*Span, error)) *MockHeimdallFetchSpansCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallFetchSpansCall) DoAndReturn

func (c *MockHeimdallFetchSpansCall) DoAndReturn(f func(context.Context, SpanStore, SpanId, SpanId) ([]*Span, error)) *MockHeimdallFetchSpansCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallFetchSpansCall) Return

func (c *MockHeimdallFetchSpansCall) Return(arg0 []*Span, arg1 error) *MockHeimdallFetchSpansCall

Return rewrite *gomock.Call.Return

type MockHeimdallFetchSpansFromBlockCall

type MockHeimdallFetchSpansFromBlockCall struct {
	*gomock.Call
}

MockHeimdallFetchSpansFromBlockCall wrap *gomock.Call

func (*MockHeimdallFetchSpansFromBlockCall) Do

func (c *MockHeimdallFetchSpansFromBlockCall) Do(f func(context.Context, SpanStore, uint64) ([]*Span, error)) *MockHeimdallFetchSpansFromBlockCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallFetchSpansFromBlockCall) DoAndReturn

func (c *MockHeimdallFetchSpansFromBlockCall) DoAndReturn(f func(context.Context, SpanStore, uint64) ([]*Span, error)) *MockHeimdallFetchSpansFromBlockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallFetchSpansFromBlockCall) Return

func (c *MockHeimdallFetchSpansFromBlockCall) Return(arg0 []*Span, arg1 error) *MockHeimdallFetchSpansFromBlockCall

Return rewrite *gomock.Call.Return

type MockHeimdallLastCheckpointIdCall

type MockHeimdallLastCheckpointIdCall struct {
	*gomock.Call
}

MockHeimdallLastCheckpointIdCall wrap *gomock.Call

func (*MockHeimdallLastCheckpointIdCall) Do

func (c *MockHeimdallLastCheckpointIdCall) Do(f func(context.Context, CheckpointStore) (CheckpointId, bool, error)) *MockHeimdallLastCheckpointIdCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallLastCheckpointIdCall) DoAndReturn

func (c *MockHeimdallLastCheckpointIdCall) DoAndReturn(f func(context.Context, CheckpointStore) (CheckpointId, bool, error)) *MockHeimdallLastCheckpointIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallLastCheckpointIdCall) Return

func (c *MockHeimdallLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockHeimdallLastCheckpointIdCall

Return rewrite *gomock.Call.Return

type MockHeimdallLastMilestoneIdCall

type MockHeimdallLastMilestoneIdCall struct {
	*gomock.Call
}

MockHeimdallLastMilestoneIdCall wrap *gomock.Call

func (*MockHeimdallLastMilestoneIdCall) Do

func (c *MockHeimdallLastMilestoneIdCall) Do(f func(context.Context, MilestoneStore) (MilestoneId, bool, error)) *MockHeimdallLastMilestoneIdCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallLastMilestoneIdCall) DoAndReturn

func (c *MockHeimdallLastMilestoneIdCall) DoAndReturn(f func(context.Context, MilestoneStore) (MilestoneId, bool, error)) *MockHeimdallLastMilestoneIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallLastMilestoneIdCall) Return

func (c *MockHeimdallLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockHeimdallLastMilestoneIdCall

Return rewrite *gomock.Call.Return

type MockHeimdallLastSpanIdCall

type MockHeimdallLastSpanIdCall struct {
	*gomock.Call
}

MockHeimdallLastSpanIdCall wrap *gomock.Call

func (*MockHeimdallLastSpanIdCall) Do

func (c *MockHeimdallLastSpanIdCall) Do(f func(context.Context, SpanStore) (SpanId, bool, error)) *MockHeimdallLastSpanIdCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallLastSpanIdCall) DoAndReturn

func (c *MockHeimdallLastSpanIdCall) DoAndReturn(f func(context.Context, SpanStore) (SpanId, bool, error)) *MockHeimdallLastSpanIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallLastSpanIdCall) Return

func (c *MockHeimdallLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockHeimdallLastSpanIdCall

Return rewrite *gomock.Call.Return

type MockHeimdallMockRecorder

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

MockHeimdallMockRecorder is the mock recorder for MockHeimdall.

func (*MockHeimdallMockRecorder) FetchCheckpoints

func (mr *MockHeimdallMockRecorder) FetchCheckpoints(arg0, arg1, arg2, arg3 any) *MockHeimdallFetchCheckpointsCall

FetchCheckpoints indicates an expected call of FetchCheckpoints.

func (*MockHeimdallMockRecorder) FetchCheckpointsFromBlock

func (mr *MockHeimdallMockRecorder) FetchCheckpointsFromBlock(arg0, arg1, arg2 any) *MockHeimdallFetchCheckpointsFromBlockCall

FetchCheckpointsFromBlock indicates an expected call of FetchCheckpointsFromBlock.

func (*MockHeimdallMockRecorder) FetchLatestSpan

func (mr *MockHeimdallMockRecorder) FetchLatestSpan(arg0, arg1 any) *MockHeimdallFetchLatestSpanCall

FetchLatestSpan indicates an expected call of FetchLatestSpan.

func (*MockHeimdallMockRecorder) FetchMilestones

func (mr *MockHeimdallMockRecorder) FetchMilestones(arg0, arg1, arg2, arg3 any) *MockHeimdallFetchMilestonesCall

FetchMilestones indicates an expected call of FetchMilestones.

func (*MockHeimdallMockRecorder) FetchMilestonesFromBlock

func (mr *MockHeimdallMockRecorder) FetchMilestonesFromBlock(arg0, arg1, arg2 any) *MockHeimdallFetchMilestonesFromBlockCall

FetchMilestonesFromBlock indicates an expected call of FetchMilestonesFromBlock.

func (*MockHeimdallMockRecorder) FetchSpans

func (mr *MockHeimdallMockRecorder) FetchSpans(arg0, arg1, arg2, arg3 any) *MockHeimdallFetchSpansCall

FetchSpans indicates an expected call of FetchSpans.

func (*MockHeimdallMockRecorder) FetchSpansFromBlock

func (mr *MockHeimdallMockRecorder) FetchSpansFromBlock(arg0, arg1, arg2 any) *MockHeimdallFetchSpansFromBlockCall

FetchSpansFromBlock indicates an expected call of FetchSpansFromBlock.

func (*MockHeimdallMockRecorder) LastCheckpointId

func (mr *MockHeimdallMockRecorder) LastCheckpointId(arg0, arg1 any) *MockHeimdallLastCheckpointIdCall

LastCheckpointId indicates an expected call of LastCheckpointId.

func (*MockHeimdallMockRecorder) LastMilestoneId

func (mr *MockHeimdallMockRecorder) LastMilestoneId(arg0, arg1 any) *MockHeimdallLastMilestoneIdCall

LastMilestoneId indicates an expected call of LastMilestoneId.

func (*MockHeimdallMockRecorder) LastSpanId

func (mr *MockHeimdallMockRecorder) LastSpanId(arg0, arg1 any) *MockHeimdallLastSpanIdCall

LastSpanId indicates an expected call of LastSpanId.

func (*MockHeimdallMockRecorder) OnCheckpointEvent

func (mr *MockHeimdallMockRecorder) OnCheckpointEvent(arg0, arg1, arg2 any) *MockHeimdallOnCheckpointEventCall

OnCheckpointEvent indicates an expected call of OnCheckpointEvent.

func (*MockHeimdallMockRecorder) OnMilestoneEvent

func (mr *MockHeimdallMockRecorder) OnMilestoneEvent(arg0, arg1, arg2 any) *MockHeimdallOnMilestoneEventCall

OnMilestoneEvent indicates an expected call of OnMilestoneEvent.

func (*MockHeimdallMockRecorder) OnSpanEvent

func (mr *MockHeimdallMockRecorder) OnSpanEvent(arg0, arg1, arg2 any) *MockHeimdallOnSpanEventCall

OnSpanEvent indicates an expected call of OnSpanEvent.

type MockHeimdallNoStore

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

MockHeimdallNoStore is a mock of HeimdallNoStore interface.

func NewMockHeimdallNoStore

func NewMockHeimdallNoStore(ctrl *gomock.Controller) *MockHeimdallNoStore

NewMockHeimdallNoStore creates a new mock instance.

func (*MockHeimdallNoStore) EXPECT

func (m *MockHeimdallNoStore) EXPECT() *MockHeimdallNoStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockHeimdallNoStore) FetchCheckpoints

func (m *MockHeimdallNoStore) FetchCheckpoints(arg0 context.Context, arg1, arg2 CheckpointId) ([]*Checkpoint, error)

FetchCheckpoints mocks base method.

func (*MockHeimdallNoStore) FetchCheckpointsFromBlock

func (m *MockHeimdallNoStore) FetchCheckpointsFromBlock(arg0 context.Context, arg1 uint64) (Waypoints, error)

FetchCheckpointsFromBlock mocks base method.

func (*MockHeimdallNoStore) FetchLatestSpan

func (m *MockHeimdallNoStore) FetchLatestSpan(arg0 context.Context) (*Span, error)

FetchLatestSpan mocks base method.

func (*MockHeimdallNoStore) FetchMilestones

func (m *MockHeimdallNoStore) FetchMilestones(arg0 context.Context, arg1, arg2 MilestoneId) ([]*Milestone, error)

FetchMilestones mocks base method.

func (*MockHeimdallNoStore) FetchMilestonesFromBlock

func (m *MockHeimdallNoStore) FetchMilestonesFromBlock(arg0 context.Context, arg1 uint64) (Waypoints, error)

FetchMilestonesFromBlock mocks base method.

func (*MockHeimdallNoStore) FetchSpans

func (m *MockHeimdallNoStore) FetchSpans(arg0 context.Context, arg1, arg2 SpanId) ([]*Span, error)

FetchSpans mocks base method.

func (*MockHeimdallNoStore) FetchSpansFromBlock

func (m *MockHeimdallNoStore) FetchSpansFromBlock(arg0 context.Context, arg1 uint64) ([]*Span, error)

FetchSpansFromBlock mocks base method.

func (*MockHeimdallNoStore) LastCheckpointId

func (m *MockHeimdallNoStore) LastCheckpointId(arg0 context.Context) (CheckpointId, bool, error)

LastCheckpointId mocks base method.

func (*MockHeimdallNoStore) LastMilestoneId

func (m *MockHeimdallNoStore) LastMilestoneId(arg0 context.Context) (MilestoneId, bool, error)

LastMilestoneId mocks base method.

func (*MockHeimdallNoStore) LastSpanId

func (m *MockHeimdallNoStore) LastSpanId(arg0 context.Context) (SpanId, bool, error)

LastSpanId mocks base method.

func (*MockHeimdallNoStore) OnCheckpointEvent

func (m *MockHeimdallNoStore) OnCheckpointEvent(arg0 context.Context, arg1 func(*Checkpoint)) error

OnCheckpointEvent mocks base method.

func (*MockHeimdallNoStore) OnMilestoneEvent

func (m *MockHeimdallNoStore) OnMilestoneEvent(arg0 context.Context, arg1 func(*Milestone)) error

OnMilestoneEvent mocks base method.

func (*MockHeimdallNoStore) OnSpanEvent

func (m *MockHeimdallNoStore) OnSpanEvent(arg0 context.Context, arg1 func(*Span)) error

OnSpanEvent mocks base method.

type MockHeimdallNoStoreFetchCheckpointsCall

type MockHeimdallNoStoreFetchCheckpointsCall struct {
	*gomock.Call
}

MockHeimdallNoStoreFetchCheckpointsCall wrap *gomock.Call

func (*MockHeimdallNoStoreFetchCheckpointsCall) Do

func (c *MockHeimdallNoStoreFetchCheckpointsCall) Do(f func(context.Context, CheckpointId, CheckpointId) ([]*Checkpoint, error)) *MockHeimdallNoStoreFetchCheckpointsCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreFetchCheckpointsCall) DoAndReturn

func (c *MockHeimdallNoStoreFetchCheckpointsCall) DoAndReturn(f func(context.Context, CheckpointId, CheckpointId) ([]*Checkpoint, error)) *MockHeimdallNoStoreFetchCheckpointsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreFetchCheckpointsCall) Return

func (c *MockHeimdallNoStoreFetchCheckpointsCall) Return(arg0 []*Checkpoint, arg1 error) *MockHeimdallNoStoreFetchCheckpointsCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreFetchCheckpointsFromBlockCall

type MockHeimdallNoStoreFetchCheckpointsFromBlockCall struct {
	*gomock.Call
}

MockHeimdallNoStoreFetchCheckpointsFromBlockCall wrap *gomock.Call

func (*MockHeimdallNoStoreFetchCheckpointsFromBlockCall) Do

func (c *MockHeimdallNoStoreFetchCheckpointsFromBlockCall) Do(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreFetchCheckpointsFromBlockCall) DoAndReturn

func (c *MockHeimdallNoStoreFetchCheckpointsFromBlockCall) DoAndReturn(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreFetchCheckpointsFromBlockCall) Return

func (c *MockHeimdallNoStoreFetchCheckpointsFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreFetchLatestSpanCall

type MockHeimdallNoStoreFetchLatestSpanCall struct {
	*gomock.Call
}

MockHeimdallNoStoreFetchLatestSpanCall wrap *gomock.Call

func (*MockHeimdallNoStoreFetchLatestSpanCall) Do

func (c *MockHeimdallNoStoreFetchLatestSpanCall) Do(f func(context.Context) (*Span, error)) *MockHeimdallNoStoreFetchLatestSpanCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreFetchLatestSpanCall) DoAndReturn

func (c *MockHeimdallNoStoreFetchLatestSpanCall) DoAndReturn(f func(context.Context) (*Span, error)) *MockHeimdallNoStoreFetchLatestSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreFetchLatestSpanCall) Return

func (c *MockHeimdallNoStoreFetchLatestSpanCall) Return(arg0 *Span, arg1 error) *MockHeimdallNoStoreFetchLatestSpanCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreFetchMilestonesCall

type MockHeimdallNoStoreFetchMilestonesCall struct {
	*gomock.Call
}

MockHeimdallNoStoreFetchMilestonesCall wrap *gomock.Call

func (*MockHeimdallNoStoreFetchMilestonesCall) Do

func (c *MockHeimdallNoStoreFetchMilestonesCall) Do(f func(context.Context, MilestoneId, MilestoneId) ([]*Milestone, error)) *MockHeimdallNoStoreFetchMilestonesCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreFetchMilestonesCall) DoAndReturn

func (c *MockHeimdallNoStoreFetchMilestonesCall) DoAndReturn(f func(context.Context, MilestoneId, MilestoneId) ([]*Milestone, error)) *MockHeimdallNoStoreFetchMilestonesCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreFetchMilestonesCall) Return

func (c *MockHeimdallNoStoreFetchMilestonesCall) Return(arg0 []*Milestone, arg1 error) *MockHeimdallNoStoreFetchMilestonesCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreFetchMilestonesFromBlockCall

type MockHeimdallNoStoreFetchMilestonesFromBlockCall struct {
	*gomock.Call
}

MockHeimdallNoStoreFetchMilestonesFromBlockCall wrap *gomock.Call

func (*MockHeimdallNoStoreFetchMilestonesFromBlockCall) Do

func (c *MockHeimdallNoStoreFetchMilestonesFromBlockCall) Do(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchMilestonesFromBlockCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreFetchMilestonesFromBlockCall) DoAndReturn

func (c *MockHeimdallNoStoreFetchMilestonesFromBlockCall) DoAndReturn(f func(context.Context, uint64) (Waypoints, error)) *MockHeimdallNoStoreFetchMilestonesFromBlockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreFetchMilestonesFromBlockCall) Return

func (c *MockHeimdallNoStoreFetchMilestonesFromBlockCall) Return(arg0 Waypoints, arg1 error) *MockHeimdallNoStoreFetchMilestonesFromBlockCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreFetchSpansCall

type MockHeimdallNoStoreFetchSpansCall struct {
	*gomock.Call
}

MockHeimdallNoStoreFetchSpansCall wrap *gomock.Call

func (*MockHeimdallNoStoreFetchSpansCall) Do

func (c *MockHeimdallNoStoreFetchSpansCall) Do(f func(context.Context, SpanId, SpanId) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreFetchSpansCall) DoAndReturn

func (c *MockHeimdallNoStoreFetchSpansCall) DoAndReturn(f func(context.Context, SpanId, SpanId) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreFetchSpansCall) Return

func (c *MockHeimdallNoStoreFetchSpansCall) Return(arg0 []*Span, arg1 error) *MockHeimdallNoStoreFetchSpansCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreFetchSpansFromBlockCall

type MockHeimdallNoStoreFetchSpansFromBlockCall struct {
	*gomock.Call
}

MockHeimdallNoStoreFetchSpansFromBlockCall wrap *gomock.Call

func (*MockHeimdallNoStoreFetchSpansFromBlockCall) Do

func (c *MockHeimdallNoStoreFetchSpansFromBlockCall) Do(f func(context.Context, uint64) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansFromBlockCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreFetchSpansFromBlockCall) DoAndReturn

func (c *MockHeimdallNoStoreFetchSpansFromBlockCall) DoAndReturn(f func(context.Context, uint64) ([]*Span, error)) *MockHeimdallNoStoreFetchSpansFromBlockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreFetchSpansFromBlockCall) Return

func (c *MockHeimdallNoStoreFetchSpansFromBlockCall) Return(arg0 []*Span, arg1 error) *MockHeimdallNoStoreFetchSpansFromBlockCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreLastCheckpointIdCall

type MockHeimdallNoStoreLastCheckpointIdCall struct {
	*gomock.Call
}

MockHeimdallNoStoreLastCheckpointIdCall wrap *gomock.Call

func (*MockHeimdallNoStoreLastCheckpointIdCall) Do

func (c *MockHeimdallNoStoreLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockHeimdallNoStoreLastCheckpointIdCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreLastCheckpointIdCall) DoAndReturn

func (c *MockHeimdallNoStoreLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockHeimdallNoStoreLastCheckpointIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreLastCheckpointIdCall) Return

func (c *MockHeimdallNoStoreLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockHeimdallNoStoreLastCheckpointIdCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreLastMilestoneIdCall

type MockHeimdallNoStoreLastMilestoneIdCall struct {
	*gomock.Call
}

MockHeimdallNoStoreLastMilestoneIdCall wrap *gomock.Call

func (*MockHeimdallNoStoreLastMilestoneIdCall) Do

func (c *MockHeimdallNoStoreLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockHeimdallNoStoreLastMilestoneIdCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreLastMilestoneIdCall) DoAndReturn

func (c *MockHeimdallNoStoreLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockHeimdallNoStoreLastMilestoneIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreLastMilestoneIdCall) Return

func (c *MockHeimdallNoStoreLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockHeimdallNoStoreLastMilestoneIdCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreLastSpanIdCall

type MockHeimdallNoStoreLastSpanIdCall struct {
	*gomock.Call
}

MockHeimdallNoStoreLastSpanIdCall wrap *gomock.Call

func (*MockHeimdallNoStoreLastSpanIdCall) Do

func (c *MockHeimdallNoStoreLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockHeimdallNoStoreLastSpanIdCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreLastSpanIdCall) DoAndReturn

func (c *MockHeimdallNoStoreLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockHeimdallNoStoreLastSpanIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreLastSpanIdCall) Return

func (c *MockHeimdallNoStoreLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockHeimdallNoStoreLastSpanIdCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreMockRecorder

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

MockHeimdallNoStoreMockRecorder is the mock recorder for MockHeimdallNoStore.

func (*MockHeimdallNoStoreMockRecorder) FetchCheckpoints

func (mr *MockHeimdallNoStoreMockRecorder) FetchCheckpoints(arg0, arg1, arg2 any) *MockHeimdallNoStoreFetchCheckpointsCall

FetchCheckpoints indicates an expected call of FetchCheckpoints.

func (*MockHeimdallNoStoreMockRecorder) FetchCheckpointsFromBlock

func (mr *MockHeimdallNoStoreMockRecorder) FetchCheckpointsFromBlock(arg0, arg1 any) *MockHeimdallNoStoreFetchCheckpointsFromBlockCall

FetchCheckpointsFromBlock indicates an expected call of FetchCheckpointsFromBlock.

func (*MockHeimdallNoStoreMockRecorder) FetchLatestSpan

func (mr *MockHeimdallNoStoreMockRecorder) FetchLatestSpan(arg0 any) *MockHeimdallNoStoreFetchLatestSpanCall

FetchLatestSpan indicates an expected call of FetchLatestSpan.

func (*MockHeimdallNoStoreMockRecorder) FetchMilestones

func (mr *MockHeimdallNoStoreMockRecorder) FetchMilestones(arg0, arg1, arg2 any) *MockHeimdallNoStoreFetchMilestonesCall

FetchMilestones indicates an expected call of FetchMilestones.

func (*MockHeimdallNoStoreMockRecorder) FetchMilestonesFromBlock

func (mr *MockHeimdallNoStoreMockRecorder) FetchMilestonesFromBlock(arg0, arg1 any) *MockHeimdallNoStoreFetchMilestonesFromBlockCall

FetchMilestonesFromBlock indicates an expected call of FetchMilestonesFromBlock.

func (*MockHeimdallNoStoreMockRecorder) FetchSpans

func (mr *MockHeimdallNoStoreMockRecorder) FetchSpans(arg0, arg1, arg2 any) *MockHeimdallNoStoreFetchSpansCall

FetchSpans indicates an expected call of FetchSpans.

func (*MockHeimdallNoStoreMockRecorder) FetchSpansFromBlock

func (mr *MockHeimdallNoStoreMockRecorder) FetchSpansFromBlock(arg0, arg1 any) *MockHeimdallNoStoreFetchSpansFromBlockCall

FetchSpansFromBlock indicates an expected call of FetchSpansFromBlock.

func (*MockHeimdallNoStoreMockRecorder) LastCheckpointId

func (mr *MockHeimdallNoStoreMockRecorder) LastCheckpointId(arg0 any) *MockHeimdallNoStoreLastCheckpointIdCall

LastCheckpointId indicates an expected call of LastCheckpointId.

func (*MockHeimdallNoStoreMockRecorder) LastMilestoneId

func (mr *MockHeimdallNoStoreMockRecorder) LastMilestoneId(arg0 any) *MockHeimdallNoStoreLastMilestoneIdCall

LastMilestoneId indicates an expected call of LastMilestoneId.

func (*MockHeimdallNoStoreMockRecorder) LastSpanId

func (mr *MockHeimdallNoStoreMockRecorder) LastSpanId(arg0 any) *MockHeimdallNoStoreLastSpanIdCall

LastSpanId indicates an expected call of LastSpanId.

func (*MockHeimdallNoStoreMockRecorder) OnCheckpointEvent

func (mr *MockHeimdallNoStoreMockRecorder) OnCheckpointEvent(arg0, arg1 any) *MockHeimdallNoStoreOnCheckpointEventCall

OnCheckpointEvent indicates an expected call of OnCheckpointEvent.

func (*MockHeimdallNoStoreMockRecorder) OnMilestoneEvent

func (mr *MockHeimdallNoStoreMockRecorder) OnMilestoneEvent(arg0, arg1 any) *MockHeimdallNoStoreOnMilestoneEventCall

OnMilestoneEvent indicates an expected call of OnMilestoneEvent.

func (*MockHeimdallNoStoreMockRecorder) OnSpanEvent

func (mr *MockHeimdallNoStoreMockRecorder) OnSpanEvent(arg0, arg1 any) *MockHeimdallNoStoreOnSpanEventCall

OnSpanEvent indicates an expected call of OnSpanEvent.

type MockHeimdallNoStoreOnCheckpointEventCall

type MockHeimdallNoStoreOnCheckpointEventCall struct {
	*gomock.Call
}

MockHeimdallNoStoreOnCheckpointEventCall wrap *gomock.Call

func (*MockHeimdallNoStoreOnCheckpointEventCall) Do

func (c *MockHeimdallNoStoreOnCheckpointEventCall) Do(f func(context.Context, func(*Checkpoint)) error) *MockHeimdallNoStoreOnCheckpointEventCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreOnCheckpointEventCall) DoAndReturn

func (c *MockHeimdallNoStoreOnCheckpointEventCall) DoAndReturn(f func(context.Context, func(*Checkpoint)) error) *MockHeimdallNoStoreOnCheckpointEventCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreOnCheckpointEventCall) Return

func (c *MockHeimdallNoStoreOnCheckpointEventCall) Return(arg0 error) *MockHeimdallNoStoreOnCheckpointEventCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreOnMilestoneEventCall

type MockHeimdallNoStoreOnMilestoneEventCall struct {
	*gomock.Call
}

MockHeimdallNoStoreOnMilestoneEventCall wrap *gomock.Call

func (*MockHeimdallNoStoreOnMilestoneEventCall) Do

func (c *MockHeimdallNoStoreOnMilestoneEventCall) Do(f func(context.Context, func(*Milestone)) error) *MockHeimdallNoStoreOnMilestoneEventCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreOnMilestoneEventCall) DoAndReturn

func (c *MockHeimdallNoStoreOnMilestoneEventCall) DoAndReturn(f func(context.Context, func(*Milestone)) error) *MockHeimdallNoStoreOnMilestoneEventCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreOnMilestoneEventCall) Return

func (c *MockHeimdallNoStoreOnMilestoneEventCall) Return(arg0 error) *MockHeimdallNoStoreOnMilestoneEventCall

Return rewrite *gomock.Call.Return

type MockHeimdallNoStoreOnSpanEventCall

type MockHeimdallNoStoreOnSpanEventCall struct {
	*gomock.Call
}

MockHeimdallNoStoreOnSpanEventCall wrap *gomock.Call

func (*MockHeimdallNoStoreOnSpanEventCall) Do

func (c *MockHeimdallNoStoreOnSpanEventCall) Do(f func(context.Context, func(*Span)) error) *MockHeimdallNoStoreOnSpanEventCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallNoStoreOnSpanEventCall) DoAndReturn

func (c *MockHeimdallNoStoreOnSpanEventCall) DoAndReturn(f func(context.Context, func(*Span)) error) *MockHeimdallNoStoreOnSpanEventCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallNoStoreOnSpanEventCall) Return

func (c *MockHeimdallNoStoreOnSpanEventCall) Return(arg0 error) *MockHeimdallNoStoreOnSpanEventCall

Return rewrite *gomock.Call.Return

type MockHeimdallOnCheckpointEventCall

type MockHeimdallOnCheckpointEventCall struct {
	*gomock.Call
}

MockHeimdallOnCheckpointEventCall wrap *gomock.Call

func (*MockHeimdallOnCheckpointEventCall) Do

func (c *MockHeimdallOnCheckpointEventCall) Do(f func(context.Context, CheckpointStore, func(*Checkpoint)) error) *MockHeimdallOnCheckpointEventCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallOnCheckpointEventCall) DoAndReturn

func (c *MockHeimdallOnCheckpointEventCall) DoAndReturn(f func(context.Context, CheckpointStore, func(*Checkpoint)) error) *MockHeimdallOnCheckpointEventCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallOnCheckpointEventCall) Return

func (c *MockHeimdallOnCheckpointEventCall) Return(arg0 error) *MockHeimdallOnCheckpointEventCall

Return rewrite *gomock.Call.Return

type MockHeimdallOnMilestoneEventCall

type MockHeimdallOnMilestoneEventCall struct {
	*gomock.Call
}

MockHeimdallOnMilestoneEventCall wrap *gomock.Call

func (*MockHeimdallOnMilestoneEventCall) Do

func (c *MockHeimdallOnMilestoneEventCall) Do(f func(context.Context, MilestoneStore, func(*Milestone)) error) *MockHeimdallOnMilestoneEventCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallOnMilestoneEventCall) DoAndReturn

func (c *MockHeimdallOnMilestoneEventCall) DoAndReturn(f func(context.Context, MilestoneStore, func(*Milestone)) error) *MockHeimdallOnMilestoneEventCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallOnMilestoneEventCall) Return

func (c *MockHeimdallOnMilestoneEventCall) Return(arg0 error) *MockHeimdallOnMilestoneEventCall

Return rewrite *gomock.Call.Return

type MockHeimdallOnSpanEventCall

type MockHeimdallOnSpanEventCall struct {
	*gomock.Call
}

MockHeimdallOnSpanEventCall wrap *gomock.Call

func (*MockHeimdallOnSpanEventCall) Do

func (c *MockHeimdallOnSpanEventCall) Do(f func(context.Context, SpanStore, func(*Span)) error) *MockHeimdallOnSpanEventCall

Do rewrite *gomock.Call.Do

func (*MockHeimdallOnSpanEventCall) DoAndReturn

func (c *MockHeimdallOnSpanEventCall) DoAndReturn(f func(context.Context, SpanStore, func(*Span)) error) *MockHeimdallOnSpanEventCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHeimdallOnSpanEventCall) Return

func (c *MockHeimdallOnSpanEventCall) Return(arg0 error) *MockHeimdallOnSpanEventCall

Return rewrite *gomock.Call.Return

type MockHttpClient

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

MockHttpClient is a mock of HttpClient interface.

func NewMockHttpClient

func NewMockHttpClient(ctrl *gomock.Controller) *MockHttpClient

NewMockHttpClient creates a new mock instance.

func (*MockHttpClient) CloseIdleConnections

func (m *MockHttpClient) CloseIdleConnections()

CloseIdleConnections mocks base method.

func (*MockHttpClient) Do

func (m *MockHttpClient) Do(arg0 *http.Request) (*http.Response, error)

Do mocks base method.

func (*MockHttpClient) EXPECT

func (m *MockHttpClient) EXPECT() *MockHttpClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockHttpClientCloseIdleConnectionsCall

type MockHttpClientCloseIdleConnectionsCall struct {
	*gomock.Call
}

MockHttpClientCloseIdleConnectionsCall wrap *gomock.Call

func (*MockHttpClientCloseIdleConnectionsCall) Do

func (c *MockHttpClientCloseIdleConnectionsCall) Do(f func()) *MockHttpClientCloseIdleConnectionsCall

Do rewrite *gomock.Call.Do

func (*MockHttpClientCloseIdleConnectionsCall) DoAndReturn

func (c *MockHttpClientCloseIdleConnectionsCall) DoAndReturn(f func()) *MockHttpClientCloseIdleConnectionsCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHttpClientCloseIdleConnectionsCall) Return

func (c *MockHttpClientCloseIdleConnectionsCall) Return() *MockHttpClientCloseIdleConnectionsCall

Return rewrite *gomock.Call.Return

type MockHttpClientDoCall

type MockHttpClientDoCall struct {
	*gomock.Call
}

MockHttpClientDoCall wrap *gomock.Call

func (*MockHttpClientDoCall) Do

func (c *MockHttpClientDoCall) Do(f func(*http.Request) (*http.Response, error)) *MockHttpClientDoCall

Do rewrite *gomock.Call.Do

func (*MockHttpClientDoCall) DoAndReturn

func (c *MockHttpClientDoCall) DoAndReturn(f func(*http.Request) (*http.Response, error)) *MockHttpClientDoCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockHttpClientDoCall) Return

func (c *MockHttpClientDoCall) Return(arg0 *http.Response, arg1 error) *MockHttpClientDoCall

Return rewrite *gomock.Call.Return

type MockHttpClientMockRecorder

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

MockHttpClientMockRecorder is the mock recorder for MockHttpClient.

func (*MockHttpClientMockRecorder) CloseIdleConnections

func (mr *MockHttpClientMockRecorder) CloseIdleConnections() *MockHttpClientCloseIdleConnectionsCall

CloseIdleConnections indicates an expected call of CloseIdleConnections.

func (*MockHttpClientMockRecorder) Do

func (mr *MockHttpClientMockRecorder) Do(arg0 any) *MockHttpClientDoCall

Do indicates an expected call of Do.

type MockMilestoneReader

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

MockMilestoneReader is a mock of MilestoneReader interface.

func NewMockMilestoneReader

func NewMockMilestoneReader(ctrl *gomock.Controller) *MockMilestoneReader

NewMockMilestoneReader creates a new mock instance.

func (*MockMilestoneReader) EXPECT

func (m *MockMilestoneReader) EXPECT() *MockMilestoneReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMilestoneReader) GetMilestone

func (m *MockMilestoneReader) GetMilestone(ctx context.Context, milestoneId MilestoneId) (*Milestone, error)

GetMilestone mocks base method.

func (*MockMilestoneReader) LastMilestoneId

func (m *MockMilestoneReader) LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)

LastMilestoneId mocks base method.

type MockMilestoneReaderGetMilestoneCall

type MockMilestoneReaderGetMilestoneCall struct {
	*gomock.Call
}

MockMilestoneReaderGetMilestoneCall wrap *gomock.Call

func (*MockMilestoneReaderGetMilestoneCall) Do

func (c *MockMilestoneReaderGetMilestoneCall) Do(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneReaderGetMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockMilestoneReaderGetMilestoneCall) DoAndReturn

func (c *MockMilestoneReaderGetMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneReaderGetMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockMilestoneReaderGetMilestoneCall) Return

func (c *MockMilestoneReaderGetMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockMilestoneReaderGetMilestoneCall

Return rewrite *gomock.Call.Return

type MockMilestoneReaderLastMilestoneIdCall

type MockMilestoneReaderLastMilestoneIdCall struct {
	*gomock.Call
}

MockMilestoneReaderLastMilestoneIdCall wrap *gomock.Call

func (*MockMilestoneReaderLastMilestoneIdCall) Do

func (c *MockMilestoneReaderLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneReaderLastMilestoneIdCall

Do rewrite *gomock.Call.Do

func (*MockMilestoneReaderLastMilestoneIdCall) DoAndReturn

func (c *MockMilestoneReaderLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneReaderLastMilestoneIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockMilestoneReaderLastMilestoneIdCall) Return

func (c *MockMilestoneReaderLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockMilestoneReaderLastMilestoneIdCall

Return rewrite *gomock.Call.Return

type MockMilestoneReaderMockRecorder

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

MockMilestoneReaderMockRecorder is the mock recorder for MockMilestoneReader.

func (*MockMilestoneReaderMockRecorder) GetMilestone

func (mr *MockMilestoneReaderMockRecorder) GetMilestone(ctx, milestoneId any) *MockMilestoneReaderGetMilestoneCall

GetMilestone indicates an expected call of GetMilestone.

func (*MockMilestoneReaderMockRecorder) LastMilestoneId

func (mr *MockMilestoneReaderMockRecorder) LastMilestoneId(ctx any) *MockMilestoneReaderLastMilestoneIdCall

LastMilestoneId indicates an expected call of LastMilestoneId.

type MockMilestoneStore

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

MockMilestoneStore is a mock of MilestoneStore interface.

func NewMockMilestoneStore

func NewMockMilestoneStore(ctrl *gomock.Controller) *MockMilestoneStore

NewMockMilestoneStore creates a new mock instance.

func (*MockMilestoneStore) EXPECT

func (m *MockMilestoneStore) EXPECT() *MockMilestoneStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMilestoneStore) GetMilestone

func (m *MockMilestoneStore) GetMilestone(ctx context.Context, milestoneId MilestoneId) (*Milestone, error)

GetMilestone mocks base method.

func (*MockMilestoneStore) LastMilestoneId

func (m *MockMilestoneStore) LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)

LastMilestoneId mocks base method.

func (*MockMilestoneStore) PutMilestone

func (m *MockMilestoneStore) PutMilestone(ctx context.Context, milestoneId MilestoneId, milestone *Milestone) error

PutMilestone mocks base method.

type MockMilestoneStoreGetMilestoneCall

type MockMilestoneStoreGetMilestoneCall struct {
	*gomock.Call
}

MockMilestoneStoreGetMilestoneCall wrap *gomock.Call

func (*MockMilestoneStoreGetMilestoneCall) Do

func (c *MockMilestoneStoreGetMilestoneCall) Do(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneStoreGetMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockMilestoneStoreGetMilestoneCall) DoAndReturn

func (c *MockMilestoneStoreGetMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId) (*Milestone, error)) *MockMilestoneStoreGetMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockMilestoneStoreGetMilestoneCall) Return

func (c *MockMilestoneStoreGetMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockMilestoneStoreGetMilestoneCall

Return rewrite *gomock.Call.Return

type MockMilestoneStoreLastMilestoneIdCall

type MockMilestoneStoreLastMilestoneIdCall struct {
	*gomock.Call
}

MockMilestoneStoreLastMilestoneIdCall wrap *gomock.Call

func (*MockMilestoneStoreLastMilestoneIdCall) Do

func (c *MockMilestoneStoreLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneStoreLastMilestoneIdCall

Do rewrite *gomock.Call.Do

func (*MockMilestoneStoreLastMilestoneIdCall) DoAndReturn

func (c *MockMilestoneStoreLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockMilestoneStoreLastMilestoneIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockMilestoneStoreLastMilestoneIdCall) Return

func (c *MockMilestoneStoreLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockMilestoneStoreLastMilestoneIdCall

Return rewrite *gomock.Call.Return

type MockMilestoneStoreMockRecorder

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

MockMilestoneStoreMockRecorder is the mock recorder for MockMilestoneStore.

func (*MockMilestoneStoreMockRecorder) GetMilestone

func (mr *MockMilestoneStoreMockRecorder) GetMilestone(ctx, milestoneId any) *MockMilestoneStoreGetMilestoneCall

GetMilestone indicates an expected call of GetMilestone.

func (*MockMilestoneStoreMockRecorder) LastMilestoneId

func (mr *MockMilestoneStoreMockRecorder) LastMilestoneId(ctx any) *MockMilestoneStoreLastMilestoneIdCall

LastMilestoneId indicates an expected call of LastMilestoneId.

func (*MockMilestoneStoreMockRecorder) PutMilestone

func (mr *MockMilestoneStoreMockRecorder) PutMilestone(ctx, milestoneId, milestone any) *MockMilestoneStorePutMilestoneCall

PutMilestone indicates an expected call of PutMilestone.

type MockMilestoneStorePutMilestoneCall

type MockMilestoneStorePutMilestoneCall struct {
	*gomock.Call
}

MockMilestoneStorePutMilestoneCall wrap *gomock.Call

func (*MockMilestoneStorePutMilestoneCall) Do

func (c *MockMilestoneStorePutMilestoneCall) Do(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneStorePutMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockMilestoneStorePutMilestoneCall) DoAndReturn

func (c *MockMilestoneStorePutMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneStorePutMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockMilestoneStorePutMilestoneCall) Return

func (c *MockMilestoneStorePutMilestoneCall) Return(arg0 error) *MockMilestoneStorePutMilestoneCall

Return rewrite *gomock.Call.Return

type MockMilestoneWriter

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

MockMilestoneWriter is a mock of MilestoneWriter interface.

func NewMockMilestoneWriter

func NewMockMilestoneWriter(ctrl *gomock.Controller) *MockMilestoneWriter

NewMockMilestoneWriter creates a new mock instance.

func (*MockMilestoneWriter) EXPECT

func (m *MockMilestoneWriter) EXPECT() *MockMilestoneWriterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMilestoneWriter) PutMilestone

func (m *MockMilestoneWriter) PutMilestone(ctx context.Context, milestoneId MilestoneId, milestone *Milestone) error

PutMilestone mocks base method.

type MockMilestoneWriterMockRecorder

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

MockMilestoneWriterMockRecorder is the mock recorder for MockMilestoneWriter.

func (*MockMilestoneWriterMockRecorder) PutMilestone

func (mr *MockMilestoneWriterMockRecorder) PutMilestone(ctx, milestoneId, milestone any) *MockMilestoneWriterPutMilestoneCall

PutMilestone indicates an expected call of PutMilestone.

type MockMilestoneWriterPutMilestoneCall

type MockMilestoneWriterPutMilestoneCall struct {
	*gomock.Call
}

MockMilestoneWriterPutMilestoneCall wrap *gomock.Call

func (*MockMilestoneWriterPutMilestoneCall) Do

func (c *MockMilestoneWriterPutMilestoneCall) Do(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneWriterPutMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockMilestoneWriterPutMilestoneCall) DoAndReturn

func (c *MockMilestoneWriterPutMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId, *Milestone) error) *MockMilestoneWriterPutMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockMilestoneWriterPutMilestoneCall) Return

func (c *MockMilestoneWriterPutMilestoneCall) Return(arg0 error) *MockMilestoneWriterPutMilestoneCall

Return rewrite *gomock.Call.Return

type MockSpanReader

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

MockSpanReader is a mock of SpanReader interface.

func NewMockSpanReader

func NewMockSpanReader(ctrl *gomock.Controller) *MockSpanReader

NewMockSpanReader creates a new mock instance.

func (*MockSpanReader) EXPECT

func (m *MockSpanReader) EXPECT() *MockSpanReaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSpanReader) GetSpan

func (m *MockSpanReader) GetSpan(ctx context.Context, spanId SpanId) (*Span, error)

GetSpan mocks base method.

func (*MockSpanReader) LastSpanId

func (m *MockSpanReader) LastSpanId(ctx context.Context) (SpanId, bool, error)

LastSpanId mocks base method.

type MockSpanReaderGetSpanCall

type MockSpanReaderGetSpanCall struct {
	*gomock.Call
}

MockSpanReaderGetSpanCall wrap *gomock.Call

func (*MockSpanReaderGetSpanCall) Do

func (c *MockSpanReaderGetSpanCall) Do(f func(context.Context, SpanId) (*Span, error)) *MockSpanReaderGetSpanCall

Do rewrite *gomock.Call.Do

func (*MockSpanReaderGetSpanCall) DoAndReturn

func (c *MockSpanReaderGetSpanCall) DoAndReturn(f func(context.Context, SpanId) (*Span, error)) *MockSpanReaderGetSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSpanReaderGetSpanCall) Return

func (c *MockSpanReaderGetSpanCall) Return(arg0 *Span, arg1 error) *MockSpanReaderGetSpanCall

Return rewrite *gomock.Call.Return

type MockSpanReaderLastSpanIdCall

type MockSpanReaderLastSpanIdCall struct {
	*gomock.Call
}

MockSpanReaderLastSpanIdCall wrap *gomock.Call

func (*MockSpanReaderLastSpanIdCall) Do

func (c *MockSpanReaderLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockSpanReaderLastSpanIdCall

Do rewrite *gomock.Call.Do

func (*MockSpanReaderLastSpanIdCall) DoAndReturn

func (c *MockSpanReaderLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockSpanReaderLastSpanIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSpanReaderLastSpanIdCall) Return

func (c *MockSpanReaderLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockSpanReaderLastSpanIdCall

Return rewrite *gomock.Call.Return

type MockSpanReaderMockRecorder

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

MockSpanReaderMockRecorder is the mock recorder for MockSpanReader.

func (*MockSpanReaderMockRecorder) GetSpan

func (mr *MockSpanReaderMockRecorder) GetSpan(ctx, spanId any) *MockSpanReaderGetSpanCall

GetSpan indicates an expected call of GetSpan.

func (*MockSpanReaderMockRecorder) LastSpanId

func (mr *MockSpanReaderMockRecorder) LastSpanId(ctx any) *MockSpanReaderLastSpanIdCall

LastSpanId indicates an expected call of LastSpanId.

type MockSpanStore

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

MockSpanStore is a mock of SpanStore interface.

func NewMockSpanStore

func NewMockSpanStore(ctrl *gomock.Controller) *MockSpanStore

NewMockSpanStore creates a new mock instance.

func (*MockSpanStore) EXPECT

func (m *MockSpanStore) EXPECT() *MockSpanStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSpanStore) GetSpan

func (m *MockSpanStore) GetSpan(ctx context.Context, spanId SpanId) (*Span, error)

GetSpan mocks base method.

func (*MockSpanStore) LastSpanId

func (m *MockSpanStore) LastSpanId(ctx context.Context) (SpanId, bool, error)

LastSpanId mocks base method.

func (*MockSpanStore) PutSpan

func (m *MockSpanStore) PutSpan(ctx context.Context, span *Span) error

PutSpan mocks base method.

type MockSpanStoreGetSpanCall

type MockSpanStoreGetSpanCall struct {
	*gomock.Call
}

MockSpanStoreGetSpanCall wrap *gomock.Call

func (*MockSpanStoreGetSpanCall) Do

func (c *MockSpanStoreGetSpanCall) Do(f func(context.Context, SpanId) (*Span, error)) *MockSpanStoreGetSpanCall

Do rewrite *gomock.Call.Do

func (*MockSpanStoreGetSpanCall) DoAndReturn

func (c *MockSpanStoreGetSpanCall) DoAndReturn(f func(context.Context, SpanId) (*Span, error)) *MockSpanStoreGetSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSpanStoreGetSpanCall) Return

func (c *MockSpanStoreGetSpanCall) Return(arg0 *Span, arg1 error) *MockSpanStoreGetSpanCall

Return rewrite *gomock.Call.Return

type MockSpanStoreLastSpanIdCall

type MockSpanStoreLastSpanIdCall struct {
	*gomock.Call
}

MockSpanStoreLastSpanIdCall wrap *gomock.Call

func (*MockSpanStoreLastSpanIdCall) Do

func (c *MockSpanStoreLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockSpanStoreLastSpanIdCall

Do rewrite *gomock.Call.Do

func (*MockSpanStoreLastSpanIdCall) DoAndReturn

func (c *MockSpanStoreLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockSpanStoreLastSpanIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSpanStoreLastSpanIdCall) Return

func (c *MockSpanStoreLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockSpanStoreLastSpanIdCall

Return rewrite *gomock.Call.Return

type MockSpanStoreMockRecorder

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

MockSpanStoreMockRecorder is the mock recorder for MockSpanStore.

func (*MockSpanStoreMockRecorder) GetSpan

func (mr *MockSpanStoreMockRecorder) GetSpan(ctx, spanId any) *MockSpanStoreGetSpanCall

GetSpan indicates an expected call of GetSpan.

func (*MockSpanStoreMockRecorder) LastSpanId

func (mr *MockSpanStoreMockRecorder) LastSpanId(ctx any) *MockSpanStoreLastSpanIdCall

LastSpanId indicates an expected call of LastSpanId.

func (*MockSpanStoreMockRecorder) PutSpan

func (mr *MockSpanStoreMockRecorder) PutSpan(ctx, span any) *MockSpanStorePutSpanCall

PutSpan indicates an expected call of PutSpan.

type MockSpanStorePutSpanCall

type MockSpanStorePutSpanCall struct {
	*gomock.Call
}

MockSpanStorePutSpanCall wrap *gomock.Call

func (*MockSpanStorePutSpanCall) Do

func (c *MockSpanStorePutSpanCall) Do(f func(context.Context, *Span) error) *MockSpanStorePutSpanCall

Do rewrite *gomock.Call.Do

func (*MockSpanStorePutSpanCall) DoAndReturn

func (c *MockSpanStorePutSpanCall) DoAndReturn(f func(context.Context, *Span) error) *MockSpanStorePutSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSpanStorePutSpanCall) Return

func (c *MockSpanStorePutSpanCall) Return(arg0 error) *MockSpanStorePutSpanCall

Return rewrite *gomock.Call.Return

type MockSpanWriter

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

MockSpanWriter is a mock of SpanWriter interface.

func NewMockSpanWriter

func NewMockSpanWriter(ctrl *gomock.Controller) *MockSpanWriter

NewMockSpanWriter creates a new mock instance.

func (*MockSpanWriter) EXPECT

func (m *MockSpanWriter) EXPECT() *MockSpanWriterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSpanWriter) PutSpan

func (m *MockSpanWriter) PutSpan(ctx context.Context, span *Span) error

PutSpan mocks base method.

type MockSpanWriterMockRecorder

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

MockSpanWriterMockRecorder is the mock recorder for MockSpanWriter.

func (*MockSpanWriterMockRecorder) PutSpan

func (mr *MockSpanWriterMockRecorder) PutSpan(ctx, span any) *MockSpanWriterPutSpanCall

PutSpan indicates an expected call of PutSpan.

type MockSpanWriterPutSpanCall

type MockSpanWriterPutSpanCall struct {
	*gomock.Call
}

MockSpanWriterPutSpanCall wrap *gomock.Call

func (*MockSpanWriterPutSpanCall) Do

func (c *MockSpanWriterPutSpanCall) Do(f func(context.Context, *Span) error) *MockSpanWriterPutSpanCall

Do rewrite *gomock.Call.Do

func (*MockSpanWriterPutSpanCall) DoAndReturn

func (c *MockSpanWriterPutSpanCall) DoAndReturn(f func(context.Context, *Span) error) *MockSpanWriterPutSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockSpanWriterPutSpanCall) Return

func (c *MockSpanWriterPutSpanCall) Return(arg0 error) *MockSpanWriterPutSpanCall

Return rewrite *gomock.Call.Return

type MockStore

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

MockStore is a mock of Store interface.

func NewMockStore

func NewMockStore(ctrl *gomock.Controller) *MockStore

NewMockStore creates a new mock instance.

func (*MockStore) EXPECT

func (m *MockStore) EXPECT() *MockStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockStore) GetCheckpoint

func (m *MockStore) GetCheckpoint(ctx context.Context, checkpointId CheckpointId) (*Checkpoint, error)

GetCheckpoint mocks base method.

func (*MockStore) GetMilestone

func (m *MockStore) GetMilestone(ctx context.Context, milestoneId MilestoneId) (*Milestone, error)

GetMilestone mocks base method.

func (*MockStore) GetSpan

func (m *MockStore) GetSpan(ctx context.Context, spanId SpanId) (*Span, error)

GetSpan mocks base method.

func (*MockStore) LastCheckpointId

func (m *MockStore) LastCheckpointId(ctx context.Context) (CheckpointId, bool, error)

LastCheckpointId mocks base method.

func (*MockStore) LastMilestoneId

func (m *MockStore) LastMilestoneId(ctx context.Context) (MilestoneId, bool, error)

LastMilestoneId mocks base method.

func (*MockStore) LastSpanId

func (m *MockStore) LastSpanId(ctx context.Context) (SpanId, bool, error)

LastSpanId mocks base method.

func (*MockStore) PutCheckpoint

func (m *MockStore) PutCheckpoint(ctx context.Context, checkpointId CheckpointId, checkpoint *Checkpoint) error

PutCheckpoint mocks base method.

func (*MockStore) PutMilestone

func (m *MockStore) PutMilestone(ctx context.Context, milestoneId MilestoneId, milestone *Milestone) error

PutMilestone mocks base method.

func (*MockStore) PutSpan

func (m *MockStore) PutSpan(ctx context.Context, span *Span) error

PutSpan mocks base method.

type MockStoreGetCheckpointCall

type MockStoreGetCheckpointCall struct {
	*gomock.Call
}

MockStoreGetCheckpointCall wrap *gomock.Call

func (*MockStoreGetCheckpointCall) Do

func (c *MockStoreGetCheckpointCall) Do(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockStoreGetCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockStoreGetCheckpointCall) DoAndReturn

func (c *MockStoreGetCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId) (*Checkpoint, error)) *MockStoreGetCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStoreGetCheckpointCall) Return

func (c *MockStoreGetCheckpointCall) Return(arg0 *Checkpoint, arg1 error) *MockStoreGetCheckpointCall

Return rewrite *gomock.Call.Return

type MockStoreGetMilestoneCall

type MockStoreGetMilestoneCall struct {
	*gomock.Call
}

MockStoreGetMilestoneCall wrap *gomock.Call

func (*MockStoreGetMilestoneCall) Do

func (c *MockStoreGetMilestoneCall) Do(f func(context.Context, MilestoneId) (*Milestone, error)) *MockStoreGetMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockStoreGetMilestoneCall) DoAndReturn

func (c *MockStoreGetMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId) (*Milestone, error)) *MockStoreGetMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStoreGetMilestoneCall) Return

func (c *MockStoreGetMilestoneCall) Return(arg0 *Milestone, arg1 error) *MockStoreGetMilestoneCall

Return rewrite *gomock.Call.Return

type MockStoreGetSpanCall

type MockStoreGetSpanCall struct {
	*gomock.Call
}

MockStoreGetSpanCall wrap *gomock.Call

func (*MockStoreGetSpanCall) Do

func (c *MockStoreGetSpanCall) Do(f func(context.Context, SpanId) (*Span, error)) *MockStoreGetSpanCall

Do rewrite *gomock.Call.Do

func (*MockStoreGetSpanCall) DoAndReturn

func (c *MockStoreGetSpanCall) DoAndReturn(f func(context.Context, SpanId) (*Span, error)) *MockStoreGetSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStoreGetSpanCall) Return

func (c *MockStoreGetSpanCall) Return(arg0 *Span, arg1 error) *MockStoreGetSpanCall

Return rewrite *gomock.Call.Return

type MockStoreLastCheckpointIdCall

type MockStoreLastCheckpointIdCall struct {
	*gomock.Call
}

MockStoreLastCheckpointIdCall wrap *gomock.Call

func (*MockStoreLastCheckpointIdCall) Do

func (c *MockStoreLastCheckpointIdCall) Do(f func(context.Context) (CheckpointId, bool, error)) *MockStoreLastCheckpointIdCall

Do rewrite *gomock.Call.Do

func (*MockStoreLastCheckpointIdCall) DoAndReturn

func (c *MockStoreLastCheckpointIdCall) DoAndReturn(f func(context.Context) (CheckpointId, bool, error)) *MockStoreLastCheckpointIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStoreLastCheckpointIdCall) Return

func (c *MockStoreLastCheckpointIdCall) Return(arg0 CheckpointId, arg1 bool, arg2 error) *MockStoreLastCheckpointIdCall

Return rewrite *gomock.Call.Return

type MockStoreLastMilestoneIdCall

type MockStoreLastMilestoneIdCall struct {
	*gomock.Call
}

MockStoreLastMilestoneIdCall wrap *gomock.Call

func (*MockStoreLastMilestoneIdCall) Do

func (c *MockStoreLastMilestoneIdCall) Do(f func(context.Context) (MilestoneId, bool, error)) *MockStoreLastMilestoneIdCall

Do rewrite *gomock.Call.Do

func (*MockStoreLastMilestoneIdCall) DoAndReturn

func (c *MockStoreLastMilestoneIdCall) DoAndReturn(f func(context.Context) (MilestoneId, bool, error)) *MockStoreLastMilestoneIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStoreLastMilestoneIdCall) Return

func (c *MockStoreLastMilestoneIdCall) Return(arg0 MilestoneId, arg1 bool, arg2 error) *MockStoreLastMilestoneIdCall

Return rewrite *gomock.Call.Return

type MockStoreLastSpanIdCall

type MockStoreLastSpanIdCall struct {
	*gomock.Call
}

MockStoreLastSpanIdCall wrap *gomock.Call

func (*MockStoreLastSpanIdCall) Do

func (c *MockStoreLastSpanIdCall) Do(f func(context.Context) (SpanId, bool, error)) *MockStoreLastSpanIdCall

Do rewrite *gomock.Call.Do

func (*MockStoreLastSpanIdCall) DoAndReturn

func (c *MockStoreLastSpanIdCall) DoAndReturn(f func(context.Context) (SpanId, bool, error)) *MockStoreLastSpanIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStoreLastSpanIdCall) Return

func (c *MockStoreLastSpanIdCall) Return(arg0 SpanId, arg1 bool, arg2 error) *MockStoreLastSpanIdCall

Return rewrite *gomock.Call.Return

type MockStoreMockRecorder

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

MockStoreMockRecorder is the mock recorder for MockStore.

func (*MockStoreMockRecorder) GetCheckpoint

func (mr *MockStoreMockRecorder) GetCheckpoint(ctx, checkpointId any) *MockStoreGetCheckpointCall

GetCheckpoint indicates an expected call of GetCheckpoint.

func (*MockStoreMockRecorder) GetMilestone

func (mr *MockStoreMockRecorder) GetMilestone(ctx, milestoneId any) *MockStoreGetMilestoneCall

GetMilestone indicates an expected call of GetMilestone.

func (*MockStoreMockRecorder) GetSpan

func (mr *MockStoreMockRecorder) GetSpan(ctx, spanId any) *MockStoreGetSpanCall

GetSpan indicates an expected call of GetSpan.

func (*MockStoreMockRecorder) LastCheckpointId

func (mr *MockStoreMockRecorder) LastCheckpointId(ctx any) *MockStoreLastCheckpointIdCall

LastCheckpointId indicates an expected call of LastCheckpointId.

func (*MockStoreMockRecorder) LastMilestoneId

func (mr *MockStoreMockRecorder) LastMilestoneId(ctx any) *MockStoreLastMilestoneIdCall

LastMilestoneId indicates an expected call of LastMilestoneId.

func (*MockStoreMockRecorder) LastSpanId

func (mr *MockStoreMockRecorder) LastSpanId(ctx any) *MockStoreLastSpanIdCall

LastSpanId indicates an expected call of LastSpanId.

func (*MockStoreMockRecorder) PutCheckpoint

func (mr *MockStoreMockRecorder) PutCheckpoint(ctx, checkpointId, checkpoint any) *MockStorePutCheckpointCall

PutCheckpoint indicates an expected call of PutCheckpoint.

func (*MockStoreMockRecorder) PutMilestone

func (mr *MockStoreMockRecorder) PutMilestone(ctx, milestoneId, milestone any) *MockStorePutMilestoneCall

PutMilestone indicates an expected call of PutMilestone.

func (*MockStoreMockRecorder) PutSpan

func (mr *MockStoreMockRecorder) PutSpan(ctx, span any) *MockStorePutSpanCall

PutSpan indicates an expected call of PutSpan.

type MockStorePutCheckpointCall

type MockStorePutCheckpointCall struct {
	*gomock.Call
}

MockStorePutCheckpointCall wrap *gomock.Call

func (*MockStorePutCheckpointCall) Do

func (c *MockStorePutCheckpointCall) Do(f func(context.Context, CheckpointId, *Checkpoint) error) *MockStorePutCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockStorePutCheckpointCall) DoAndReturn

func (c *MockStorePutCheckpointCall) DoAndReturn(f func(context.Context, CheckpointId, *Checkpoint) error) *MockStorePutCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStorePutCheckpointCall) Return

func (c *MockStorePutCheckpointCall) Return(arg0 error) *MockStorePutCheckpointCall

Return rewrite *gomock.Call.Return

type MockStorePutMilestoneCall

type MockStorePutMilestoneCall struct {
	*gomock.Call
}

MockStorePutMilestoneCall wrap *gomock.Call

func (*MockStorePutMilestoneCall) Do

func (c *MockStorePutMilestoneCall) Do(f func(context.Context, MilestoneId, *Milestone) error) *MockStorePutMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockStorePutMilestoneCall) DoAndReturn

func (c *MockStorePutMilestoneCall) DoAndReturn(f func(context.Context, MilestoneId, *Milestone) error) *MockStorePutMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStorePutMilestoneCall) Return

func (c *MockStorePutMilestoneCall) Return(arg0 error) *MockStorePutMilestoneCall

Return rewrite *gomock.Call.Return

type MockStorePutSpanCall

type MockStorePutSpanCall struct {
	*gomock.Call
}

MockStorePutSpanCall wrap *gomock.Call

func (*MockStorePutSpanCall) Do

func (c *MockStorePutSpanCall) Do(f func(context.Context, *Span) error) *MockStorePutSpanCall

Do rewrite *gomock.Call.Do

func (*MockStorePutSpanCall) DoAndReturn

func (c *MockStorePutSpanCall) DoAndReturn(f func(context.Context, *Span) error) *MockStorePutSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockStorePutSpanCall) Return

func (c *MockStorePutSpanCall) Return(arg0 error) *MockStorePutSpanCall

Return rewrite *gomock.Call.Return

type Mockreader

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

Mockreader is a mock of reader interface.

func NewMockreader

func NewMockreader(ctrl *gomock.Controller) *Mockreader

NewMockreader creates a new mock instance.

func (*Mockreader) BorStartEventID

func (m *Mockreader) BorStartEventID(ctx context.Context, tx kv.Tx, hash common.Hash, blockNum uint64) (uint64, error)

BorStartEventID mocks base method.

func (*Mockreader) Checkpoint

func (m *Mockreader) Checkpoint(ctx context.Context, tx kv.Getter, checkpointId uint64) ([]byte, error)

Checkpoint mocks base method.

func (*Mockreader) EXPECT

func (m *Mockreader) EXPECT() *MockreaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*Mockreader) EventLookup

func (m *Mockreader) EventLookup(ctx context.Context, tx kv.Getter, txnHash common.Hash) (uint64, bool, error)

EventLookup mocks base method.

func (*Mockreader) EventsByBlock

func (m *Mockreader) EventsByBlock(ctx context.Context, tx kv.Tx, hash common.Hash, blockNum uint64) ([]rlp.RawValue, error)

EventsByBlock mocks base method.

func (*Mockreader) LastCheckpointId

func (m *Mockreader) LastCheckpointId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

LastCheckpointId mocks base method.

func (*Mockreader) LastEventId

func (m *Mockreader) LastEventId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

LastEventId mocks base method.

func (*Mockreader) LastFrozenEventId

func (m *Mockreader) LastFrozenEventId() uint64

LastFrozenEventId mocks base method.

func (*Mockreader) LastFrozenSpanId

func (m *Mockreader) LastFrozenSpanId() uint64

LastFrozenSpanId mocks base method.

func (*Mockreader) LastMilestoneId

func (m *Mockreader) LastMilestoneId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

LastMilestoneId mocks base method.

func (*Mockreader) LastSpanId

func (m *Mockreader) LastSpanId(ctx context.Context, tx kv.Tx) (uint64, bool, error)

LastSpanId mocks base method.

func (*Mockreader) Milestone

func (m *Mockreader) Milestone(ctx context.Context, tx kv.Getter, milestoneId uint64) ([]byte, error)

Milestone mocks base method.

func (*Mockreader) Span

func (m *Mockreader) Span(ctx context.Context, tx kv.Getter, spanId uint64) ([]byte, error)

Span mocks base method.

type MockreaderBorStartEventIDCall

type MockreaderBorStartEventIDCall struct {
	*gomock.Call
}

MockreaderBorStartEventIDCall wrap *gomock.Call

func (*MockreaderBorStartEventIDCall) Do

func (c *MockreaderBorStartEventIDCall) Do(f func(context.Context, kv.Tx, common.Hash, uint64) (uint64, error)) *MockreaderBorStartEventIDCall

Do rewrite *gomock.Call.Do

func (*MockreaderBorStartEventIDCall) DoAndReturn

func (c *MockreaderBorStartEventIDCall) DoAndReturn(f func(context.Context, kv.Tx, common.Hash, uint64) (uint64, error)) *MockreaderBorStartEventIDCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderBorStartEventIDCall) Return

func (c *MockreaderBorStartEventIDCall) Return(arg0 uint64, arg1 error) *MockreaderBorStartEventIDCall

Return rewrite *gomock.Call.Return

type MockreaderCheckpointCall

type MockreaderCheckpointCall struct {
	*gomock.Call
}

MockreaderCheckpointCall wrap *gomock.Call

func (*MockreaderCheckpointCall) Do

func (c *MockreaderCheckpointCall) Do(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderCheckpointCall

Do rewrite *gomock.Call.Do

func (*MockreaderCheckpointCall) DoAndReturn

func (c *MockreaderCheckpointCall) DoAndReturn(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderCheckpointCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderCheckpointCall) Return

func (c *MockreaderCheckpointCall) Return(arg0 []byte, arg1 error) *MockreaderCheckpointCall

Return rewrite *gomock.Call.Return

type MockreaderEventLookupCall

type MockreaderEventLookupCall struct {
	*gomock.Call
}

MockreaderEventLookupCall wrap *gomock.Call

func (*MockreaderEventLookupCall) Do

func (c *MockreaderEventLookupCall) Do(f func(context.Context, kv.Getter, common.Hash) (uint64, bool, error)) *MockreaderEventLookupCall

Do rewrite *gomock.Call.Do

func (*MockreaderEventLookupCall) DoAndReturn

func (c *MockreaderEventLookupCall) DoAndReturn(f func(context.Context, kv.Getter, common.Hash) (uint64, bool, error)) *MockreaderEventLookupCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderEventLookupCall) Return

func (c *MockreaderEventLookupCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderEventLookupCall

Return rewrite *gomock.Call.Return

type MockreaderEventsByBlockCall

type MockreaderEventsByBlockCall struct {
	*gomock.Call
}

MockreaderEventsByBlockCall wrap *gomock.Call

func (*MockreaderEventsByBlockCall) Do

func (c *MockreaderEventsByBlockCall) Do(f func(context.Context, kv.Tx, common.Hash, uint64) ([]rlp.RawValue, error)) *MockreaderEventsByBlockCall

Do rewrite *gomock.Call.Do

func (*MockreaderEventsByBlockCall) DoAndReturn

func (c *MockreaderEventsByBlockCall) DoAndReturn(f func(context.Context, kv.Tx, common.Hash, uint64) ([]rlp.RawValue, error)) *MockreaderEventsByBlockCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderEventsByBlockCall) Return

func (c *MockreaderEventsByBlockCall) Return(arg0 []rlp.RawValue, arg1 error) *MockreaderEventsByBlockCall

Return rewrite *gomock.Call.Return

type MockreaderLastCheckpointIdCall

type MockreaderLastCheckpointIdCall struct {
	*gomock.Call
}

MockreaderLastCheckpointIdCall wrap *gomock.Call

func (*MockreaderLastCheckpointIdCall) Do

func (c *MockreaderLastCheckpointIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastCheckpointIdCall

Do rewrite *gomock.Call.Do

func (*MockreaderLastCheckpointIdCall) DoAndReturn

func (c *MockreaderLastCheckpointIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastCheckpointIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderLastCheckpointIdCall) Return

func (c *MockreaderLastCheckpointIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastCheckpointIdCall

Return rewrite *gomock.Call.Return

type MockreaderLastEventIdCall

type MockreaderLastEventIdCall struct {
	*gomock.Call
}

MockreaderLastEventIdCall wrap *gomock.Call

func (*MockreaderLastEventIdCall) Do

func (c *MockreaderLastEventIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastEventIdCall

Do rewrite *gomock.Call.Do

func (*MockreaderLastEventIdCall) DoAndReturn

func (c *MockreaderLastEventIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastEventIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderLastEventIdCall) Return

func (c *MockreaderLastEventIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastEventIdCall

Return rewrite *gomock.Call.Return

type MockreaderLastFrozenEventIdCall

type MockreaderLastFrozenEventIdCall struct {
	*gomock.Call
}

MockreaderLastFrozenEventIdCall wrap *gomock.Call

func (*MockreaderLastFrozenEventIdCall) Do

func (c *MockreaderLastFrozenEventIdCall) Do(f func() uint64) *MockreaderLastFrozenEventIdCall

Do rewrite *gomock.Call.Do

func (*MockreaderLastFrozenEventIdCall) DoAndReturn

func (c *MockreaderLastFrozenEventIdCall) DoAndReturn(f func() uint64) *MockreaderLastFrozenEventIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderLastFrozenEventIdCall) Return

func (c *MockreaderLastFrozenEventIdCall) Return(arg0 uint64) *MockreaderLastFrozenEventIdCall

Return rewrite *gomock.Call.Return

type MockreaderLastFrozenSpanIdCall

type MockreaderLastFrozenSpanIdCall struct {
	*gomock.Call
}

MockreaderLastFrozenSpanIdCall wrap *gomock.Call

func (*MockreaderLastFrozenSpanIdCall) Do

func (c *MockreaderLastFrozenSpanIdCall) Do(f func() uint64) *MockreaderLastFrozenSpanIdCall

Do rewrite *gomock.Call.Do

func (*MockreaderLastFrozenSpanIdCall) DoAndReturn

func (c *MockreaderLastFrozenSpanIdCall) DoAndReturn(f func() uint64) *MockreaderLastFrozenSpanIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderLastFrozenSpanIdCall) Return

func (c *MockreaderLastFrozenSpanIdCall) Return(arg0 uint64) *MockreaderLastFrozenSpanIdCall

Return rewrite *gomock.Call.Return

type MockreaderLastMilestoneIdCall

type MockreaderLastMilestoneIdCall struct {
	*gomock.Call
}

MockreaderLastMilestoneIdCall wrap *gomock.Call

func (*MockreaderLastMilestoneIdCall) Do

func (c *MockreaderLastMilestoneIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastMilestoneIdCall

Do rewrite *gomock.Call.Do

func (*MockreaderLastMilestoneIdCall) DoAndReturn

func (c *MockreaderLastMilestoneIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastMilestoneIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderLastMilestoneIdCall) Return

func (c *MockreaderLastMilestoneIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastMilestoneIdCall

Return rewrite *gomock.Call.Return

type MockreaderLastSpanIdCall

type MockreaderLastSpanIdCall struct {
	*gomock.Call
}

MockreaderLastSpanIdCall wrap *gomock.Call

func (*MockreaderLastSpanIdCall) Do

func (c *MockreaderLastSpanIdCall) Do(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastSpanIdCall

Do rewrite *gomock.Call.Do

func (*MockreaderLastSpanIdCall) DoAndReturn

func (c *MockreaderLastSpanIdCall) DoAndReturn(f func(context.Context, kv.Tx) (uint64, bool, error)) *MockreaderLastSpanIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderLastSpanIdCall) Return

func (c *MockreaderLastSpanIdCall) Return(arg0 uint64, arg1 bool, arg2 error) *MockreaderLastSpanIdCall

Return rewrite *gomock.Call.Return

type MockreaderMilestoneCall

type MockreaderMilestoneCall struct {
	*gomock.Call
}

MockreaderMilestoneCall wrap *gomock.Call

func (*MockreaderMilestoneCall) Do

func (c *MockreaderMilestoneCall) Do(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderMilestoneCall

Do rewrite *gomock.Call.Do

func (*MockreaderMilestoneCall) DoAndReturn

func (c *MockreaderMilestoneCall) DoAndReturn(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderMilestoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderMilestoneCall) Return

func (c *MockreaderMilestoneCall) Return(arg0 []byte, arg1 error) *MockreaderMilestoneCall

Return rewrite *gomock.Call.Return

type MockreaderMockRecorder

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

MockreaderMockRecorder is the mock recorder for Mockreader.

func (*MockreaderMockRecorder) BorStartEventID

func (mr *MockreaderMockRecorder) BorStartEventID(ctx, tx, hash, blockNum any) *MockreaderBorStartEventIDCall

BorStartEventID indicates an expected call of BorStartEventID.

func (*MockreaderMockRecorder) Checkpoint

func (mr *MockreaderMockRecorder) Checkpoint(ctx, tx, checkpointId any) *MockreaderCheckpointCall

Checkpoint indicates an expected call of Checkpoint.

func (*MockreaderMockRecorder) EventLookup

func (mr *MockreaderMockRecorder) EventLookup(ctx, tx, txnHash any) *MockreaderEventLookupCall

EventLookup indicates an expected call of EventLookup.

func (*MockreaderMockRecorder) EventsByBlock

func (mr *MockreaderMockRecorder) EventsByBlock(ctx, tx, hash, blockNum any) *MockreaderEventsByBlockCall

EventsByBlock indicates an expected call of EventsByBlock.

func (*MockreaderMockRecorder) LastCheckpointId

func (mr *MockreaderMockRecorder) LastCheckpointId(ctx, tx any) *MockreaderLastCheckpointIdCall

LastCheckpointId indicates an expected call of LastCheckpointId.

func (*MockreaderMockRecorder) LastEventId

func (mr *MockreaderMockRecorder) LastEventId(ctx, tx any) *MockreaderLastEventIdCall

LastEventId indicates an expected call of LastEventId.

func (*MockreaderMockRecorder) LastFrozenEventId

func (mr *MockreaderMockRecorder) LastFrozenEventId() *MockreaderLastFrozenEventIdCall

LastFrozenEventId indicates an expected call of LastFrozenEventId.

func (*MockreaderMockRecorder) LastFrozenSpanId

func (mr *MockreaderMockRecorder) LastFrozenSpanId() *MockreaderLastFrozenSpanIdCall

LastFrozenSpanId indicates an expected call of LastFrozenSpanId.

func (*MockreaderMockRecorder) LastMilestoneId

func (mr *MockreaderMockRecorder) LastMilestoneId(ctx, tx any) *MockreaderLastMilestoneIdCall

LastMilestoneId indicates an expected call of LastMilestoneId.

func (*MockreaderMockRecorder) LastSpanId

func (mr *MockreaderMockRecorder) LastSpanId(ctx, tx any) *MockreaderLastSpanIdCall

LastSpanId indicates an expected call of LastSpanId.

func (*MockreaderMockRecorder) Milestone

func (mr *MockreaderMockRecorder) Milestone(ctx, tx, milestoneId any) *MockreaderMilestoneCall

Milestone indicates an expected call of Milestone.

func (*MockreaderMockRecorder) Span

func (mr *MockreaderMockRecorder) Span(ctx, tx, spanId any) *MockreaderSpanCall

Span indicates an expected call of Span.

type MockreaderSpanCall

type MockreaderSpanCall struct {
	*gomock.Call
}

MockreaderSpanCall wrap *gomock.Call

func (*MockreaderSpanCall) Do

func (c *MockreaderSpanCall) Do(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderSpanCall

Do rewrite *gomock.Call.Do

func (*MockreaderSpanCall) DoAndReturn

func (c *MockreaderSpanCall) DoAndReturn(f func(context.Context, kv.Getter, uint64) ([]byte, error)) *MockreaderSpanCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockreaderSpanCall) Return

func (c *MockreaderSpanCall) Return(arg0 []byte, arg1 error) *MockreaderSpanCall

Return rewrite *gomock.Call.Return

type Request

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

type Span

type Span struct {
	Id                SpanId              `json:"span_id" yaml:"span_id"`
	StartBlock        uint64              `json:"start_block" yaml:"start_block"`
	EndBlock          uint64              `json:"end_block" yaml:"end_block"`
	ValidatorSet      valset.ValidatorSet `json:"validator_set,omitempty" yaml:"validator_set"`
	SelectedProducers []valset.Validator  `json:"selected_producers,omitempty" yaml:"selected_producers"`
	ChainID           string              `json:"bor_chain_id,omitempty" yaml:"bor_chain_id"`
}

func (*Span) CmpRange

func (s *Span) CmpRange(n uint64) int

func (*Span) Less

func (hs *Span) Less(other btree.Item) bool

type SpanId

type SpanId uint64

func SpanIdAt

func SpanIdAt(blockNum uint64) SpanId

SpanIdAt returns the corresponding span id for the given block number.

type SpanReader

type SpanReader interface {
	LastSpanId(ctx context.Context) (SpanId, bool, error)
	GetSpan(ctx context.Context, spanId SpanId) (*Span, error)
}

type SpanResponse

type SpanResponse struct {
	Height string `json:"height"`
	Result Span   `json:"result"`
}

type SpanStore

type SpanStore interface {
	SpanReader
	SpanWriter
}

type SpanWriter

type SpanWriter interface {
	PutSpan(ctx context.Context, span *Span) error
}

type StateSyncEventResponse

type StateSyncEventResponse struct {
	Height string              `json:"height"`
	Result EventRecordWithTime `json:"result"`
}

type StateSyncEventsResponse

type StateSyncEventsResponse struct {
	Height string                 `json:"height"`
	Result []*EventRecordWithTime `json:"result"`
}

type Store

type Store interface {
	SpanStore
	MilestoneStore
	CheckpointStore
}

type Waypoint

type Waypoint interface {
	fmt.Stringer
	StartBlock() *big.Int
	EndBlock() *big.Int
	RootHash() libcommon.Hash
	Timestamp() uint64
	Length() uint64
	CmpRange(n uint64) int
}

type WaypointFields

type WaypointFields struct {
	Proposer   libcommon.Address `json:"proposer"`
	StartBlock *big.Int          `json:"start_block"`
	EndBlock   *big.Int          `json:"end_block"`
	RootHash   libcommon.Hash    `json:"root_hash"`
	ChainID    string            `json:"bor_chain_id"`
	Timestamp  uint64            `json:"timestamp"`
}

func (*WaypointFields) CmpRange

func (a *WaypointFields) CmpRange(n uint64) int

func (*WaypointFields) Length

func (a *WaypointFields) Length() uint64

type Waypoints

type Waypoints []Waypoint