mock

Documentation

Index

• type BatchStore
  • func New(opts ...Option) *BatchStore
  • func (bs *BatchStore) Exists(id []byte) (bool, error)
  • func (bs *BatchStore) Get(id []byte) (*postage.Batch, error)
  • func (bs *BatchStore) GetChainState() *postage.ChainState
  • func (bs *BatchStore) GetReserveState() *postage.ReserveState
  • func (bs *BatchStore) IsWithinStorageRadius(swarm.Address) bool
  • func (bs *BatchStore) Iterate(f func(*postage.Batch) (bool, error)) error
  • func (bs *BatchStore) PutChainState(cs *postage.ChainState) error
  • func (bs *BatchStore) Reset() error
  • func (bs *BatchStore) ResetCalls() int
  • func (bs *BatchStore) Save(batch *postage.Batch) error
  • func (bs *BatchStore) SetBatchExpiryHandler(eh postage.BatchExpiryHandler)
  • func (bs *BatchStore) SetStorageRadius(f func(uint8) uint8) error
  • func (bs *BatchStore) SetStorageRadiusSetter(r postage.StorageRadiusSetter)
  • func (bs *BatchStore) StorageRadius() uint8
  • func (bs *BatchStore) Unreserve(_ postage.UnreserveIteratorFn) error
  • func (bs *BatchStore) Update(batch *postage.Batch, newValue *big.Int, newDepth uint8) error
• type MockEventUpdater
  • func NewNotReady() *MockEventUpdater
  • func NewWithError(err error) *MockEventUpdater
  • func (s *MockEventUpdater) GetSyncStatus() (isDone bool, err error)
• type Option
  • func WithAcceptAllExistsFunc() Option
  • func WithBatch(b *postage.Batch) Option
  • func WithChainState(cs *postage.ChainState) Option
  • func WithExistsFunc(f func([]byte) (bool, error)) Option
  • func WithGetErr(err error, delayCnt int) Option
  • func WithIsWithinStorageRadius(b bool) Option
  • func WithReserveState(rs *postage.ReserveState) Option
  • func WithUpdateErr(err error, delayCnt int) Option

Types

type BatchStore

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

BatchStore is a mock BatchStorer

func New

func New(opts ...Option) *BatchStore

New creates a new mock BatchStore

func (*BatchStore) Exists

func (bs *BatchStore) Exists(id []byte) (bool, error)

Exists reports whether batch referenced by the give id exists.

func (*BatchStore) Get

func (bs *BatchStore) Get(id []byte) (*postage.Batch, error)

Get mocks the Get method from the BatchStore.

func (*BatchStore) GetChainState

func (bs *BatchStore) GetChainState() *postage.ChainState

GetChainState mocks the GetChainState method from the BatchStore

func (*BatchStore) GetReserveState

func (bs *BatchStore) GetReserveState() *postage.ReserveState

func (*BatchStore) IsWithinStorageRadius

func (bs *BatchStore) IsWithinStorageRadius(swarm.Address) bool

func (*BatchStore) Iterate

func (bs *BatchStore) Iterate(f func(*postage.Batch) (bool, error)) error

Iterate mocks the Iterate method from the BatchStore

func (*BatchStore) PutChainState

func (bs *BatchStore) PutChainState(cs *postage.ChainState) error

PutChainState mocks the PutChainState method from the BatchStore

func (*BatchStore) Reset

func (bs *BatchStore) Reset() error

func (*BatchStore) ResetCalls

func (bs *BatchStore) ResetCalls() int

func (*BatchStore) Save

func (bs *BatchStore) Save(batch *postage.Batch) error

Save mocks the Save method from the BatchStore.

func (*BatchStore) SetBatchExpiryHandler

func (bs *BatchStore) SetBatchExpiryHandler(eh postage.BatchExpiryHandler)

func (*BatchStore) SetStorageRadius

func (bs *BatchStore) SetStorageRadius(f func(uint8) uint8) error

func (*BatchStore) SetStorageRadiusSetter

func (bs *BatchStore) SetStorageRadiusSetter(r postage.StorageRadiusSetter)

func (*BatchStore) StorageRadius

func (bs *BatchStore) StorageRadius() uint8

func (*BatchStore) Unreserve

func (bs *BatchStore) Unreserve(_ postage.UnreserveIteratorFn) error

func (*BatchStore) Update

func (bs *BatchStore) Update(batch *postage.Batch, newValue *big.Int, newDepth uint8) error

Update mocks the Update method from the BatchStore.

type MockEventUpdater

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

func NewNotReady

func NewNotReady() *MockEventUpdater

func NewWithError

func NewWithError(err error) *MockEventUpdater

func (*MockEventUpdater) GetSyncStatus

func (s *MockEventUpdater) GetSyncStatus() (isDone bool, err error)

type Option

type Option func(*BatchStore)

Option is an option passed to New.

func WithAcceptAllExistsFunc

func WithAcceptAllExistsFunc() Option

func WithBatch

func WithBatch(b *postage.Batch) Option

WithBatch will set batch to the one provided by user. This will be returned in the next Get.

func WithChainState

func WithChainState(cs *postage.ChainState) Option

WithChainState will set the initial chainstate in the ChainStore mock.

func WithExistsFunc

func WithExistsFunc(f func([]byte) (bool, error)) Option

func WithGetErr

func WithGetErr(err error, delayCnt int) Option

WithGetErr will set the get error returned by the ChainStore mock. The error will be returned on each subsequent call after delayCnt calls to Get have been made.

func WithIsWithinStorageRadius

func WithIsWithinStorageRadius(b bool) Option

func WithReserveState

func WithReserveState(rs *postage.ReserveState) Option

WithReserveState will set the initial reservestate in the ChainStore mock.

func WithUpdateErr

func WithUpdateErr(err error, delayCnt int) Option

WithUpdateErr will set the put error returned by the ChainStore mock. The error will be returned on each subsequent call after delayCnt calls to Update have been made.