outport

Documentation

Index

• type BlockContainerStub
  • func (bcs *BlockContainerStub) Get(headerType core.HeaderType) (block.EmptyBlockCreator, error)
• type OutportDataProviderStub
  • func (a *OutportDataProviderStub) IsInterfaceNil() bool
  • func (a *OutportDataProviderStub) PrepareOutportSaveBlockData(arg process.ArgPrepareOutportSaveBlockData) (*outportcore.OutportBlockWithHeaderAndBody, error)
• type OutportStub
  • func (as *OutportStub) Close() error
  • func (as *OutportStub) FinalizedBlock(_ *outportcore.FinalizedBlock)
  • func (as *OutportStub) HasDrivers() bool
  • func (as *OutportStub) IsInterfaceNil() bool
  • func (as *OutportStub) RevertIndexedBlock(_ *outportcore.HeaderDataWithBody) error
  • func (as *OutportStub) SaveAccounts(_ *outportcore.Accounts)
  • func (as *OutportStub) SaveBlock(args *outportcore.OutportBlockWithHeaderAndBody) error
  • func (as *OutportStub) SaveRoundsInfo(_ *outportcore.RoundsInfo)
  • func (as *OutportStub) SaveValidatorsPubKeys(validatorsPubKeys *outportcore.ValidatorsPubKeys)
  • func (as *OutportStub) SaveValidatorsRating(validatorsRating *outportcore.ValidatorsRating)
  • func (as *OutportStub) SubscribeDriver(_ outport.Driver) error
• type SenderHostStub
  • func (s *SenderHostStub) Close() error
  • func (s *SenderHostStub) IsInterfaceNil() bool
  • func (s *SenderHostStub) Send(payload []byte, topic string) error
  • func (s *SenderHostStub) SetPayloadHandler(handler websocket.PayloadHandler) error

Types

type BlockContainerStub

type BlockContainerStub struct {
	GetCalled func(headerType core.HeaderType) (block.EmptyBlockCreator, error)
}

BlockContainerStub -

func (*BlockContainerStub) Get

func (bcs *BlockContainerStub) Get(headerType core.HeaderType) (block.EmptyBlockCreator, error)

Get -

type OutportDataProviderStub

type OutportDataProviderStub struct {
	PrepareOutportSaveBlockDataCalled func(
		arg process.ArgPrepareOutportSaveBlockData,
	) (*outportcore.OutportBlockWithHeaderAndBody, error)
}

OutportDataProviderStub -

func (*OutportDataProviderStub) IsInterfaceNil

func (a *OutportDataProviderStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*OutportDataProviderStub) PrepareOutportSaveBlockData

func (a *OutportDataProviderStub) PrepareOutportSaveBlockData(
	arg process.ArgPrepareOutportSaveBlockData,
) (*outportcore.OutportBlockWithHeaderAndBody, error)

PrepareOutportSaveBlockData -

type OutportStub

type OutportStub struct {
	SaveBlockCalled             func(args *outportcore.OutportBlockWithHeaderAndBody) error
	SaveValidatorsRatingCalled  func(validatorsRating *outportcore.ValidatorsRating)
	SaveValidatorsPubKeysCalled func(validatorsPubKeys *outportcore.ValidatorsPubKeys)
	HasDriversCalled            func() bool
}

OutportStub is a mock implementation fot the OutportHandler interface

func (*OutportStub) Close

func (as *OutportStub) Close() error

Close -

func (*OutportStub) FinalizedBlock

func (as *OutportStub) FinalizedBlock(_ *outportcore.FinalizedBlock)

FinalizedBlock -

func (*OutportStub) HasDrivers

func (as *OutportStub) HasDrivers() bool

HasDrivers -

func (*OutportStub) IsInterfaceNil

func (as *OutportStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*OutportStub) RevertIndexedBlock

func (as *OutportStub) RevertIndexedBlock(_ *outportcore.HeaderDataWithBody) error

RevertIndexedBlock -

func (*OutportStub) SaveAccounts

func (as *OutportStub) SaveAccounts(_ *outportcore.Accounts)

SaveAccounts -

func (*OutportStub) SaveBlock

func (as *OutportStub) SaveBlock(args *outportcore.OutportBlockWithHeaderAndBody) error

SaveBlock -

func (*OutportStub) SaveRoundsInfo

func (as *OutportStub) SaveRoundsInfo(_ *outportcore.RoundsInfo)

SaveRoundsInfo -

func (*OutportStub) SaveValidatorsPubKeys

func (as *OutportStub) SaveValidatorsPubKeys(validatorsPubKeys *outportcore.ValidatorsPubKeys)

SaveValidatorsPubKeys -

func (*OutportStub) SaveValidatorsRating

func (as *OutportStub) SaveValidatorsRating(validatorsRating *outportcore.ValidatorsRating)

SaveValidatorsRating -

func (*OutportStub) SubscribeDriver

func (as *OutportStub) SubscribeDriver(_ outport.Driver) error

SubscribeDriver -

type SenderHostStub

type SenderHostStub struct {
	SendCalled              func(payload []byte, topic string) error
	SetPayloadHandlerCalled func(handler websocket.PayloadHandler) error
	CloseCalled             func() error
}

SenderHostStub -

func (*SenderHostStub) Close

func (s *SenderHostStub) Close() error

Close -

func (*SenderHostStub) IsInterfaceNil

func (s *SenderHostStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*SenderHostStub) Send

func (s *SenderHostStub) Send(payload []byte, topic string) error

Send -

func (*SenderHostStub) SetPayloadHandler

func (s *SenderHostStub) SetPayloadHandler(handler websocket.PayloadHandler) error

SetPayloadHandler -