state_synchronization

Documentation

Index

• type ExecutionDataCIDCache
  • func NewExecutionDataCIDCache(t NewExecutionDataCIDCacheT) *ExecutionDataCIDCache
  • func (_m *ExecutionDataCIDCache) BlobRecords() uint
  • func (_m *ExecutionDataCIDCache) BlobTreeRecords() uint
  • func (_m *ExecutionDataCIDCache) Get(c cid.Cid) (state_synchronization.BlobRecord, error)
  • func (_m *ExecutionDataCIDCache) Insert(header *flow.Header, blobTree state_synchronization.BlobTree)
• type ExecutionDataRequester
  • func NewExecutionDataRequester(t NewExecutionDataRequesterT) *ExecutionDataRequester
  • func (_m *ExecutionDataRequester) AddOnExecutionDataFetchedConsumer(fn state_synchronization.ExecutionDataReceivedCallback)
  • func (_m *ExecutionDataRequester) Done() <-chan struct{}
  • func (_m *ExecutionDataRequester) OnBlockFinalized(_a0 *model.Block)
  • func (_m *ExecutionDataRequester) Ready() <-chan struct{}
  • func (_m *ExecutionDataRequester) Start(_a0 irrecoverable.SignalerContext)
• type ExecutionDataService
  • func NewExecutionDataService(t NewExecutionDataServiceT) *ExecutionDataService
  • func (_m *ExecutionDataService) Add(ctx context.Context, sd *state_synchronization.ExecutionData) (flow.Identifier, state_synchronization.BlobTree, error)
  • func (_m *ExecutionDataService) Done() <-chan struct{}
  • func (_m *ExecutionDataService) Get(ctx context.Context, rootID flow.Identifier) (*state_synchronization.ExecutionData, error)
  • func (_m *ExecutionDataService) Ready() <-chan struct{}
• type NewExecutionDataCIDCacheT
• type NewExecutionDataRequesterT
• type NewExecutionDataServiceT

Types

type ExecutionDataCIDCache

type ExecutionDataCIDCache struct {
	mock.Mock
}

ExecutionDataCIDCache is an autogenerated mock type for the ExecutionDataCIDCache type

func NewExecutionDataCIDCache

func NewExecutionDataCIDCache(t NewExecutionDataCIDCacheT) *ExecutionDataCIDCache

NewExecutionDataCIDCache creates a new instance of ExecutionDataCIDCache. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ExecutionDataCIDCache) BlobRecords

func (_m *ExecutionDataCIDCache) BlobRecords() uint

BlobRecords provides a mock function with given fields:

func (*ExecutionDataCIDCache) BlobTreeRecords

func (_m *ExecutionDataCIDCache) BlobTreeRecords() uint

BlobTreeRecords provides a mock function with given fields:

func (*ExecutionDataCIDCache) Get

func (_m *ExecutionDataCIDCache) Get(c cid.Cid) (state_synchronization.BlobRecord, error)

Get provides a mock function with given fields: c

func (*ExecutionDataCIDCache) Insert

func (_m *ExecutionDataCIDCache) Insert(header *flow.Header, blobTree state_synchronization.BlobTree)

Insert provides a mock function with given fields: header, blobTree

type ExecutionDataRequester

type ExecutionDataRequester struct {
	mock.Mock
}

ExecutionDataRequester is an autogenerated mock type for the ExecutionDataRequester type

func NewExecutionDataRequester

func NewExecutionDataRequester(t NewExecutionDataRequesterT) *ExecutionDataRequester

NewExecutionDataRequester creates a new instance of ExecutionDataRequester. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ExecutionDataRequester) AddOnExecutionDataFetchedConsumer

func (_m *ExecutionDataRequester) AddOnExecutionDataFetchedConsumer(fn state_synchronization.ExecutionDataReceivedCallback)

AddOnExecutionDataFetchedConsumer provides a mock function with given fields: fn

func (*ExecutionDataRequester) Done

func (_m *ExecutionDataRequester) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*ExecutionDataRequester) OnBlockFinalized

func (_m *ExecutionDataRequester) OnBlockFinalized(_a0 *model.Block)

OnBlockFinalized provides a mock function with given fields: _a0

func (*ExecutionDataRequester) Ready

func (_m *ExecutionDataRequester) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*ExecutionDataRequester) Start

func (_m *ExecutionDataRequester) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type ExecutionDataService

type ExecutionDataService struct {
	mock.Mock
}

ExecutionDataService is an autogenerated mock type for the ExecutionDataService type

func NewExecutionDataService

func NewExecutionDataService(t NewExecutionDataServiceT) *ExecutionDataService

NewExecutionDataService creates a new instance of ExecutionDataService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ExecutionDataService) Add

func (_m *ExecutionDataService) Add(ctx context.Context, sd *state_synchronization.ExecutionData) (flow.Identifier, state_synchronization.BlobTree, error)

Add provides a mock function with given fields: ctx, sd

func (*ExecutionDataService) Done

func (_m *ExecutionDataService) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*ExecutionDataService) Get

func (_m *ExecutionDataService) Get(ctx context.Context, rootID flow.Identifier) (*state_synchronization.ExecutionData, error)

Get provides a mock function with given fields: ctx, rootID

func (*ExecutionDataService) Ready

func (_m *ExecutionDataService) Ready() <-chan struct{}

Ready provides a mock function with given fields:

type NewExecutionDataCIDCacheT

type NewExecutionDataCIDCacheT interface {
	mock.TestingT
	Cleanup(func())
}

type NewExecutionDataRequesterT

type NewExecutionDataRequesterT interface {
	mock.TestingT
	Cleanup(func())
}

type NewExecutionDataServiceT

type NewExecutionDataServiceT interface {
	mock.TestingT
	Cleanup(func())
}