state

package
v1.7.17-rc.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 8, 2022 License: BSD-3-Clause Imports: 33 Imported by: 0

Documentation

Overview

Package state is a generated GoMock package.

Package state is a generated GoMock package.

Package state is a generated GoMock package.

Package state is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrDelegatorSubset = errors.New("delegator's time range must be a subset of the validator's time range")
)

Functions

This section is empty.

Types

type BlockState added in v1.7.17

type BlockState interface {
	GetStatelessBlock(blockID ids.ID) (blocks.Block, choices.Status, error)
	AddStatelessBlock(block blocks.Block, status choices.Status)
}

type Chain

type Chain interface {
	Stakers
	UTXOAdder
	UTXOGetter
	UTXODeleter

	GetTimestamp() time.Time
	SetTimestamp(tm time.Time)
	GetCurrentSupply() uint64
	SetCurrentSupply(cs uint64)

	GetRewardUTXOs(txID ids.ID) ([]*avax.UTXO, error)
	AddRewardUTXO(txID ids.ID, utxo *avax.UTXO)
	GetSubnets() ([]*txs.Tx, error)
	AddSubnet(createSubnetTx *txs.Tx)
	GetChains(subnetID ids.ID) ([]*txs.Tx, error)
	AddChain(createChainTx *txs.Tx)
	GetTx(txID ids.ID) (*txs.Tx, status.Status, error)
	AddTx(tx *txs.Tx, status status.Status)
}

Chain collects all methods to manage the state of the chain for block execution.

type CurrentStakers

type CurrentStakers interface {
	// GetCurrentValidator returns the [staker] describing the validator on
	// [subnetID] with [nodeID]. If the validator does not exist,
	// [database.ErrNotFound] is returned.
	GetCurrentValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

	// PutCurrentValidator adds the [staker] describing a validator to the
	// staker set.
	PutCurrentValidator(staker *Staker)

	// DeleteCurrentValidator removes the [staker] describing a validator from
	// the staker set.
	DeleteCurrentValidator(staker *Staker)

	// GetCurrentDelegatorIterator returns the delegators associated with the
	// validator on [subnetID] with [nodeID]. Delegators are sorted by their
	// removal from current staker set.
	GetCurrentDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

	// PutCurrentDelegator adds the [staker] describing a delegator to the
	// staker set.
	PutCurrentDelegator(staker *Staker)

	// DeleteCurrentDelegator removes the [staker] describing a delegator from
	// the staker set.
	DeleteCurrentDelegator(staker *Staker)

	// GetCurrentStakerIterator returns stakers in order of their removal from
	// the current staker set.
	GetCurrentStakerIterator() (StakerIterator, error)
}

type Diff

type Diff interface {
	Chain

	Apply(State)
}

func NewDiff

func NewDiff(
	parentID ids.ID,
	stateVersions Versions,
) (Diff, error)

type LastAccepteder added in v1.7.17

type LastAccepteder interface {
	GetLastAccepted() ids.ID
	SetLastAccepted(blkID ids.ID)
}

type MockBlockState added in v1.7.17

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

MockBlockState is a mock of BlockState interface.

func NewMockBlockState added in v1.7.17

func NewMockBlockState(ctrl *gomock.Controller) *MockBlockState

NewMockBlockState creates a new mock instance.

func (*MockBlockState) AddStatelessBlock added in v1.7.17

func (m *MockBlockState) AddStatelessBlock(block blocks.Block, status choices.Status)

AddStatelessBlock mocks base method.

func (*MockBlockState) EXPECT added in v1.7.17

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

func (*MockBlockState) GetStatelessBlock added in v1.7.17

func (m *MockBlockState) GetStatelessBlock(blockID ids.ID) (blocks.Block, choices.Status, error)

GetStatelessBlock mocks base method.

type MockBlockStateMockRecorder added in v1.7.17

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

MockBlockStateMockRecorder is the mock recorder for MockBlockState.

func (*MockBlockStateMockRecorder) AddStatelessBlock added in v1.7.17

func (mr *MockBlockStateMockRecorder) AddStatelessBlock(block, status interface{}) *gomock.Call

AddStatelessBlock indicates an expected call of AddStatelessBlock.

func (*MockBlockStateMockRecorder) GetStatelessBlock added in v1.7.17

func (mr *MockBlockStateMockRecorder) GetStatelessBlock(blockID interface{}) *gomock.Call

GetStatelessBlock indicates an expected call of GetStatelessBlock.

type MockChain added in v1.7.17

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

MockChain is a mock of Chain interface.

func NewMockChain added in v1.7.17

func NewMockChain(ctrl *gomock.Controller) *MockChain

NewMockChain creates a new mock instance.

func (*MockChain) AddChain added in v1.7.17

func (m *MockChain) AddChain(createChainTx *txs.Tx)

AddChain mocks base method.

func (*MockChain) AddRewardUTXO added in v1.7.17

func (m *MockChain) AddRewardUTXO(txID ids.ID, utxo *avax.UTXO)

AddRewardUTXO mocks base method.

func (*MockChain) AddSubnet added in v1.7.17

func (m *MockChain) AddSubnet(createSubnetTx *txs.Tx)

AddSubnet mocks base method.

func (*MockChain) AddTx added in v1.7.17

func (m *MockChain) AddTx(tx *txs.Tx, status status.Status)

AddTx mocks base method.

func (*MockChain) AddUTXO added in v1.7.17

func (m *MockChain) AddUTXO(utxo *avax.UTXO)

AddUTXO mocks base method.

func (*MockChain) DeleteCurrentDelegator added in v1.7.17

func (m *MockChain) DeleteCurrentDelegator(staker *Staker)

DeleteCurrentDelegator mocks base method.

func (*MockChain) DeleteCurrentValidator added in v1.7.17

func (m *MockChain) DeleteCurrentValidator(staker *Staker)

DeleteCurrentValidator mocks base method.

func (*MockChain) DeletePendingDelegator added in v1.7.17

func (m *MockChain) DeletePendingDelegator(staker *Staker)

DeletePendingDelegator mocks base method.

func (*MockChain) DeletePendingValidator added in v1.7.17

func (m *MockChain) DeletePendingValidator(staker *Staker)

DeletePendingValidator mocks base method.

func (*MockChain) DeleteUTXO added in v1.7.17

func (m *MockChain) DeleteUTXO(utxoID ids.ID)

DeleteUTXO mocks base method.

func (*MockChain) EXPECT added in v1.7.17

func (m *MockChain) EXPECT() *MockChainMockRecorder

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

func (*MockChain) GetChains added in v1.7.17

func (m *MockChain) GetChains(subnetID ids.ID) ([]*txs.Tx, error)

GetChains mocks base method.

func (*MockChain) GetCurrentDelegatorIterator added in v1.7.17

func (m *MockChain) GetCurrentDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

GetCurrentDelegatorIterator mocks base method.

func (*MockChain) GetCurrentStakerIterator added in v1.7.17

func (m *MockChain) GetCurrentStakerIterator() (StakerIterator, error)

GetCurrentStakerIterator mocks base method.

func (*MockChain) GetCurrentSupply added in v1.7.17

func (m *MockChain) GetCurrentSupply() uint64

GetCurrentSupply mocks base method.

func (*MockChain) GetCurrentValidator added in v1.7.17

func (m *MockChain) GetCurrentValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

GetCurrentValidator mocks base method.

func (*MockChain) GetPendingDelegatorIterator added in v1.7.17

func (m *MockChain) GetPendingDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

GetPendingDelegatorIterator mocks base method.

func (*MockChain) GetPendingStakerIterator added in v1.7.17

func (m *MockChain) GetPendingStakerIterator() (StakerIterator, error)

GetPendingStakerIterator mocks base method.

func (*MockChain) GetPendingValidator added in v1.7.17

func (m *MockChain) GetPendingValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

GetPendingValidator mocks base method.

func (*MockChain) GetRewardUTXOs added in v1.7.17

func (m *MockChain) GetRewardUTXOs(txID ids.ID) ([]*avax.UTXO, error)

GetRewardUTXOs mocks base method.

func (*MockChain) GetSubnets added in v1.7.17

func (m *MockChain) GetSubnets() ([]*txs.Tx, error)

GetSubnets mocks base method.

func (*MockChain) GetTimestamp added in v1.7.17

func (m *MockChain) GetTimestamp() time.Time

GetTimestamp mocks base method.

func (*MockChain) GetTx added in v1.7.17

func (m *MockChain) GetTx(txID ids.ID) (*txs.Tx, status.Status, error)

GetTx mocks base method.

func (*MockChain) GetUTXO added in v1.7.17

func (m *MockChain) GetUTXO(utxoID ids.ID) (*avax.UTXO, error)

GetUTXO mocks base method.

func (*MockChain) PutCurrentDelegator added in v1.7.17

func (m *MockChain) PutCurrentDelegator(staker *Staker)

PutCurrentDelegator mocks base method.

func (*MockChain) PutCurrentValidator added in v1.7.17

func (m *MockChain) PutCurrentValidator(staker *Staker)

PutCurrentValidator mocks base method.

func (*MockChain) PutPendingDelegator added in v1.7.17

func (m *MockChain) PutPendingDelegator(staker *Staker)

PutPendingDelegator mocks base method.

func (*MockChain) PutPendingValidator added in v1.7.17

func (m *MockChain) PutPendingValidator(staker *Staker)

PutPendingValidator mocks base method.

func (*MockChain) SetCurrentSupply added in v1.7.17

func (m *MockChain) SetCurrentSupply(cs uint64)

SetCurrentSupply mocks base method.

func (*MockChain) SetTimestamp added in v1.7.17

func (m *MockChain) SetTimestamp(tm time.Time)

SetTimestamp mocks base method.

type MockChainMockRecorder added in v1.7.17

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

MockChainMockRecorder is the mock recorder for MockChain.

func (*MockChainMockRecorder) AddChain added in v1.7.17

func (mr *MockChainMockRecorder) AddChain(createChainTx interface{}) *gomock.Call

AddChain indicates an expected call of AddChain.

func (*MockChainMockRecorder) AddRewardUTXO added in v1.7.17

func (mr *MockChainMockRecorder) AddRewardUTXO(txID, utxo interface{}) *gomock.Call

AddRewardUTXO indicates an expected call of AddRewardUTXO.

func (*MockChainMockRecorder) AddSubnet added in v1.7.17

func (mr *MockChainMockRecorder) AddSubnet(createSubnetTx interface{}) *gomock.Call

AddSubnet indicates an expected call of AddSubnet.

func (*MockChainMockRecorder) AddTx added in v1.7.17

func (mr *MockChainMockRecorder) AddTx(tx, status interface{}) *gomock.Call

AddTx indicates an expected call of AddTx.

func (*MockChainMockRecorder) AddUTXO added in v1.7.17

func (mr *MockChainMockRecorder) AddUTXO(utxo interface{}) *gomock.Call

AddUTXO indicates an expected call of AddUTXO.

func (*MockChainMockRecorder) DeleteCurrentDelegator added in v1.7.17

func (mr *MockChainMockRecorder) DeleteCurrentDelegator(staker interface{}) *gomock.Call

DeleteCurrentDelegator indicates an expected call of DeleteCurrentDelegator.

func (*MockChainMockRecorder) DeleteCurrentValidator added in v1.7.17

func (mr *MockChainMockRecorder) DeleteCurrentValidator(staker interface{}) *gomock.Call

DeleteCurrentValidator indicates an expected call of DeleteCurrentValidator.

func (*MockChainMockRecorder) DeletePendingDelegator added in v1.7.17

func (mr *MockChainMockRecorder) DeletePendingDelegator(staker interface{}) *gomock.Call

DeletePendingDelegator indicates an expected call of DeletePendingDelegator.

func (*MockChainMockRecorder) DeletePendingValidator added in v1.7.17

func (mr *MockChainMockRecorder) DeletePendingValidator(staker interface{}) *gomock.Call

DeletePendingValidator indicates an expected call of DeletePendingValidator.

func (*MockChainMockRecorder) DeleteUTXO added in v1.7.17

func (mr *MockChainMockRecorder) DeleteUTXO(utxoID interface{}) *gomock.Call

DeleteUTXO indicates an expected call of DeleteUTXO.

func (*MockChainMockRecorder) GetChains added in v1.7.17

func (mr *MockChainMockRecorder) GetChains(subnetID interface{}) *gomock.Call

GetChains indicates an expected call of GetChains.

func (*MockChainMockRecorder) GetCurrentDelegatorIterator added in v1.7.17

func (mr *MockChainMockRecorder) GetCurrentDelegatorIterator(subnetID, nodeID interface{}) *gomock.Call

GetCurrentDelegatorIterator indicates an expected call of GetCurrentDelegatorIterator.

func (*MockChainMockRecorder) GetCurrentStakerIterator added in v1.7.17

func (mr *MockChainMockRecorder) GetCurrentStakerIterator() *gomock.Call

GetCurrentStakerIterator indicates an expected call of GetCurrentStakerIterator.

func (*MockChainMockRecorder) GetCurrentSupply added in v1.7.17

func (mr *MockChainMockRecorder) GetCurrentSupply() *gomock.Call

GetCurrentSupply indicates an expected call of GetCurrentSupply.

func (*MockChainMockRecorder) GetCurrentValidator added in v1.7.17

func (mr *MockChainMockRecorder) GetCurrentValidator(subnetID, nodeID interface{}) *gomock.Call

GetCurrentValidator indicates an expected call of GetCurrentValidator.

func (*MockChainMockRecorder) GetPendingDelegatorIterator added in v1.7.17

func (mr *MockChainMockRecorder) GetPendingDelegatorIterator(subnetID, nodeID interface{}) *gomock.Call

GetPendingDelegatorIterator indicates an expected call of GetPendingDelegatorIterator.

func (*MockChainMockRecorder) GetPendingStakerIterator added in v1.7.17

func (mr *MockChainMockRecorder) GetPendingStakerIterator() *gomock.Call

GetPendingStakerIterator indicates an expected call of GetPendingStakerIterator.

func (*MockChainMockRecorder) GetPendingValidator added in v1.7.17

func (mr *MockChainMockRecorder) GetPendingValidator(subnetID, nodeID interface{}) *gomock.Call

GetPendingValidator indicates an expected call of GetPendingValidator.

func (*MockChainMockRecorder) GetRewardUTXOs added in v1.7.17

func (mr *MockChainMockRecorder) GetRewardUTXOs(txID interface{}) *gomock.Call

GetRewardUTXOs indicates an expected call of GetRewardUTXOs.

func (*MockChainMockRecorder) GetSubnets added in v1.7.17

func (mr *MockChainMockRecorder) GetSubnets() *gomock.Call

GetSubnets indicates an expected call of GetSubnets.

func (*MockChainMockRecorder) GetTimestamp added in v1.7.17

func (mr *MockChainMockRecorder) GetTimestamp() *gomock.Call

GetTimestamp indicates an expected call of GetTimestamp.

func (*MockChainMockRecorder) GetTx added in v1.7.17

func (mr *MockChainMockRecorder) GetTx(txID interface{}) *gomock.Call

GetTx indicates an expected call of GetTx.

func (*MockChainMockRecorder) GetUTXO added in v1.7.17

func (mr *MockChainMockRecorder) GetUTXO(utxoID interface{}) *gomock.Call

GetUTXO indicates an expected call of GetUTXO.

func (*MockChainMockRecorder) PutCurrentDelegator added in v1.7.17

func (mr *MockChainMockRecorder) PutCurrentDelegator(staker interface{}) *gomock.Call

PutCurrentDelegator indicates an expected call of PutCurrentDelegator.

func (*MockChainMockRecorder) PutCurrentValidator added in v1.7.17

func (mr *MockChainMockRecorder) PutCurrentValidator(staker interface{}) *gomock.Call

PutCurrentValidator indicates an expected call of PutCurrentValidator.

func (*MockChainMockRecorder) PutPendingDelegator added in v1.7.17

func (mr *MockChainMockRecorder) PutPendingDelegator(staker interface{}) *gomock.Call

PutPendingDelegator indicates an expected call of PutPendingDelegator.

func (*MockChainMockRecorder) PutPendingValidator added in v1.7.17

func (mr *MockChainMockRecorder) PutPendingValidator(staker interface{}) *gomock.Call

PutPendingValidator indicates an expected call of PutPendingValidator.

func (*MockChainMockRecorder) SetCurrentSupply added in v1.7.17

func (mr *MockChainMockRecorder) SetCurrentSupply(cs interface{}) *gomock.Call

SetCurrentSupply indicates an expected call of SetCurrentSupply.

func (*MockChainMockRecorder) SetTimestamp added in v1.7.17

func (mr *MockChainMockRecorder) SetTimestamp(tm interface{}) *gomock.Call

SetTimestamp indicates an expected call of SetTimestamp.

type MockDiff added in v1.7.17

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

MockDiff is a mock of Diff interface.

func NewMockDiff added in v1.7.17

func NewMockDiff(ctrl *gomock.Controller) *MockDiff

NewMockDiff creates a new mock instance.

func (*MockDiff) AddChain added in v1.7.17

func (m *MockDiff) AddChain(createChainTx *txs.Tx)

AddChain mocks base method.

func (*MockDiff) AddRewardUTXO added in v1.7.17

func (m *MockDiff) AddRewardUTXO(txID ids.ID, utxo *avax.UTXO)

AddRewardUTXO mocks base method.

func (*MockDiff) AddSubnet added in v1.7.17

func (m *MockDiff) AddSubnet(createSubnetTx *txs.Tx)

AddSubnet mocks base method.

func (*MockDiff) AddTx added in v1.7.17

func (m *MockDiff) AddTx(tx *txs.Tx, status status.Status)

AddTx mocks base method.

func (*MockDiff) AddUTXO added in v1.7.17

func (m *MockDiff) AddUTXO(utxo *avax.UTXO)

AddUTXO mocks base method.

func (*MockDiff) Apply added in v1.7.17

func (m *MockDiff) Apply(arg0 State)

Apply mocks base method.

func (*MockDiff) DeleteCurrentDelegator added in v1.7.17

func (m *MockDiff) DeleteCurrentDelegator(staker *Staker)

DeleteCurrentDelegator mocks base method.

func (*MockDiff) DeleteCurrentValidator added in v1.7.17

func (m *MockDiff) DeleteCurrentValidator(staker *Staker)

DeleteCurrentValidator mocks base method.

func (*MockDiff) DeletePendingDelegator added in v1.7.17

func (m *MockDiff) DeletePendingDelegator(staker *Staker)

DeletePendingDelegator mocks base method.

func (*MockDiff) DeletePendingValidator added in v1.7.17

func (m *MockDiff) DeletePendingValidator(staker *Staker)

DeletePendingValidator mocks base method.

func (*MockDiff) DeleteUTXO added in v1.7.17

func (m *MockDiff) DeleteUTXO(utxoID ids.ID)

DeleteUTXO mocks base method.

func (*MockDiff) EXPECT added in v1.7.17

func (m *MockDiff) EXPECT() *MockDiffMockRecorder

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

func (*MockDiff) GetChains added in v1.7.17

func (m *MockDiff) GetChains(subnetID ids.ID) ([]*txs.Tx, error)

GetChains mocks base method.

func (*MockDiff) GetCurrentDelegatorIterator added in v1.7.17

func (m *MockDiff) GetCurrentDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

GetCurrentDelegatorIterator mocks base method.

func (*MockDiff) GetCurrentStakerIterator added in v1.7.17

func (m *MockDiff) GetCurrentStakerIterator() (StakerIterator, error)

GetCurrentStakerIterator mocks base method.

func (*MockDiff) GetCurrentSupply added in v1.7.17

func (m *MockDiff) GetCurrentSupply() uint64

GetCurrentSupply mocks base method.

func (*MockDiff) GetCurrentValidator added in v1.7.17

func (m *MockDiff) GetCurrentValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

GetCurrentValidator mocks base method.

func (*MockDiff) GetPendingDelegatorIterator added in v1.7.17

func (m *MockDiff) GetPendingDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

GetPendingDelegatorIterator mocks base method.

func (*MockDiff) GetPendingStakerIterator added in v1.7.17

func (m *MockDiff) GetPendingStakerIterator() (StakerIterator, error)

GetPendingStakerIterator mocks base method.

func (*MockDiff) GetPendingValidator added in v1.7.17

func (m *MockDiff) GetPendingValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

GetPendingValidator mocks base method.

func (*MockDiff) GetRewardUTXOs added in v1.7.17

func (m *MockDiff) GetRewardUTXOs(txID ids.ID) ([]*avax.UTXO, error)

GetRewardUTXOs mocks base method.

func (*MockDiff) GetSubnets added in v1.7.17

func (m *MockDiff) GetSubnets() ([]*txs.Tx, error)

GetSubnets mocks base method.

func (*MockDiff) GetTimestamp added in v1.7.17

func (m *MockDiff) GetTimestamp() time.Time

GetTimestamp mocks base method.

func (*MockDiff) GetTx added in v1.7.17

func (m *MockDiff) GetTx(txID ids.ID) (*txs.Tx, status.Status, error)

GetTx mocks base method.

func (*MockDiff) GetUTXO added in v1.7.17

func (m *MockDiff) GetUTXO(utxoID ids.ID) (*avax.UTXO, error)

GetUTXO mocks base method.

func (*MockDiff) PutCurrentDelegator added in v1.7.17

func (m *MockDiff) PutCurrentDelegator(staker *Staker)

PutCurrentDelegator mocks base method.

func (*MockDiff) PutCurrentValidator added in v1.7.17

func (m *MockDiff) PutCurrentValidator(staker *Staker)

PutCurrentValidator mocks base method.

func (*MockDiff) PutPendingDelegator added in v1.7.17

func (m *MockDiff) PutPendingDelegator(staker *Staker)

PutPendingDelegator mocks base method.

func (*MockDiff) PutPendingValidator added in v1.7.17

func (m *MockDiff) PutPendingValidator(staker *Staker)

PutPendingValidator mocks base method.

func (*MockDiff) SetCurrentSupply added in v1.7.17

func (m *MockDiff) SetCurrentSupply(cs uint64)

SetCurrentSupply mocks base method.

func (*MockDiff) SetTimestamp added in v1.7.17

func (m *MockDiff) SetTimestamp(tm time.Time)

SetTimestamp mocks base method.

type MockDiffMockRecorder added in v1.7.17

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

MockDiffMockRecorder is the mock recorder for MockDiff.

func (*MockDiffMockRecorder) AddChain added in v1.7.17

func (mr *MockDiffMockRecorder) AddChain(createChainTx interface{}) *gomock.Call

AddChain indicates an expected call of AddChain.

func (*MockDiffMockRecorder) AddRewardUTXO added in v1.7.17

func (mr *MockDiffMockRecorder) AddRewardUTXO(txID, utxo interface{}) *gomock.Call

AddRewardUTXO indicates an expected call of AddRewardUTXO.

func (*MockDiffMockRecorder) AddSubnet added in v1.7.17

func (mr *MockDiffMockRecorder) AddSubnet(createSubnetTx interface{}) *gomock.Call

AddSubnet indicates an expected call of AddSubnet.

func (*MockDiffMockRecorder) AddTx added in v1.7.17

func (mr *MockDiffMockRecorder) AddTx(tx, status interface{}) *gomock.Call

AddTx indicates an expected call of AddTx.

func (*MockDiffMockRecorder) AddUTXO added in v1.7.17

func (mr *MockDiffMockRecorder) AddUTXO(utxo interface{}) *gomock.Call

AddUTXO indicates an expected call of AddUTXO.

func (*MockDiffMockRecorder) Apply added in v1.7.17

func (mr *MockDiffMockRecorder) Apply(arg0 interface{}) *gomock.Call

Apply indicates an expected call of Apply.

func (*MockDiffMockRecorder) DeleteCurrentDelegator added in v1.7.17

func (mr *MockDiffMockRecorder) DeleteCurrentDelegator(staker interface{}) *gomock.Call

DeleteCurrentDelegator indicates an expected call of DeleteCurrentDelegator.

func (*MockDiffMockRecorder) DeleteCurrentValidator added in v1.7.17

func (mr *MockDiffMockRecorder) DeleteCurrentValidator(staker interface{}) *gomock.Call

DeleteCurrentValidator indicates an expected call of DeleteCurrentValidator.

func (*MockDiffMockRecorder) DeletePendingDelegator added in v1.7.17

func (mr *MockDiffMockRecorder) DeletePendingDelegator(staker interface{}) *gomock.Call

DeletePendingDelegator indicates an expected call of DeletePendingDelegator.

func (*MockDiffMockRecorder) DeletePendingValidator added in v1.7.17

func (mr *MockDiffMockRecorder) DeletePendingValidator(staker interface{}) *gomock.Call

DeletePendingValidator indicates an expected call of DeletePendingValidator.

func (*MockDiffMockRecorder) DeleteUTXO added in v1.7.17

func (mr *MockDiffMockRecorder) DeleteUTXO(utxoID interface{}) *gomock.Call

DeleteUTXO indicates an expected call of DeleteUTXO.

func (*MockDiffMockRecorder) GetChains added in v1.7.17

func (mr *MockDiffMockRecorder) GetChains(subnetID interface{}) *gomock.Call

GetChains indicates an expected call of GetChains.

func (*MockDiffMockRecorder) GetCurrentDelegatorIterator added in v1.7.17

func (mr *MockDiffMockRecorder) GetCurrentDelegatorIterator(subnetID, nodeID interface{}) *gomock.Call

GetCurrentDelegatorIterator indicates an expected call of GetCurrentDelegatorIterator.

func (*MockDiffMockRecorder) GetCurrentStakerIterator added in v1.7.17

func (mr *MockDiffMockRecorder) GetCurrentStakerIterator() *gomock.Call

GetCurrentStakerIterator indicates an expected call of GetCurrentStakerIterator.

func (*MockDiffMockRecorder) GetCurrentSupply added in v1.7.17

func (mr *MockDiffMockRecorder) GetCurrentSupply() *gomock.Call

GetCurrentSupply indicates an expected call of GetCurrentSupply.

func (*MockDiffMockRecorder) GetCurrentValidator added in v1.7.17

func (mr *MockDiffMockRecorder) GetCurrentValidator(subnetID, nodeID interface{}) *gomock.Call

GetCurrentValidator indicates an expected call of GetCurrentValidator.

func (*MockDiffMockRecorder) GetPendingDelegatorIterator added in v1.7.17

func (mr *MockDiffMockRecorder) GetPendingDelegatorIterator(subnetID, nodeID interface{}) *gomock.Call

GetPendingDelegatorIterator indicates an expected call of GetPendingDelegatorIterator.

func (*MockDiffMockRecorder) GetPendingStakerIterator added in v1.7.17

func (mr *MockDiffMockRecorder) GetPendingStakerIterator() *gomock.Call

GetPendingStakerIterator indicates an expected call of GetPendingStakerIterator.

func (*MockDiffMockRecorder) GetPendingValidator added in v1.7.17

func (mr *MockDiffMockRecorder) GetPendingValidator(subnetID, nodeID interface{}) *gomock.Call

GetPendingValidator indicates an expected call of GetPendingValidator.

func (*MockDiffMockRecorder) GetRewardUTXOs added in v1.7.17

func (mr *MockDiffMockRecorder) GetRewardUTXOs(txID interface{}) *gomock.Call

GetRewardUTXOs indicates an expected call of GetRewardUTXOs.

func (*MockDiffMockRecorder) GetSubnets added in v1.7.17

func (mr *MockDiffMockRecorder) GetSubnets() *gomock.Call

GetSubnets indicates an expected call of GetSubnets.

func (*MockDiffMockRecorder) GetTimestamp added in v1.7.17

func (mr *MockDiffMockRecorder) GetTimestamp() *gomock.Call

GetTimestamp indicates an expected call of GetTimestamp.

func (*MockDiffMockRecorder) GetTx added in v1.7.17

func (mr *MockDiffMockRecorder) GetTx(txID interface{}) *gomock.Call

GetTx indicates an expected call of GetTx.

func (*MockDiffMockRecorder) GetUTXO added in v1.7.17

func (mr *MockDiffMockRecorder) GetUTXO(utxoID interface{}) *gomock.Call

GetUTXO indicates an expected call of GetUTXO.

func (*MockDiffMockRecorder) PutCurrentDelegator added in v1.7.17

func (mr *MockDiffMockRecorder) PutCurrentDelegator(staker interface{}) *gomock.Call

PutCurrentDelegator indicates an expected call of PutCurrentDelegator.

func (*MockDiffMockRecorder) PutCurrentValidator added in v1.7.17

func (mr *MockDiffMockRecorder) PutCurrentValidator(staker interface{}) *gomock.Call

PutCurrentValidator indicates an expected call of PutCurrentValidator.

func (*MockDiffMockRecorder) PutPendingDelegator added in v1.7.17

func (mr *MockDiffMockRecorder) PutPendingDelegator(staker interface{}) *gomock.Call

PutPendingDelegator indicates an expected call of PutPendingDelegator.

func (*MockDiffMockRecorder) PutPendingValidator added in v1.7.17

func (mr *MockDiffMockRecorder) PutPendingValidator(staker interface{}) *gomock.Call

PutPendingValidator indicates an expected call of PutPendingValidator.

func (*MockDiffMockRecorder) SetCurrentSupply added in v1.7.17

func (mr *MockDiffMockRecorder) SetCurrentSupply(cs interface{}) *gomock.Call

SetCurrentSupply indicates an expected call of SetCurrentSupply.

func (*MockDiffMockRecorder) SetTimestamp added in v1.7.17

func (mr *MockDiffMockRecorder) SetTimestamp(tm interface{}) *gomock.Call

SetTimestamp indicates an expected call of SetTimestamp.

type MockLastAccepteder added in v1.7.17

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

MockLastAccepteder is a mock of LastAccepteder interface.

func NewMockLastAccepteder added in v1.7.17

func NewMockLastAccepteder(ctrl *gomock.Controller) *MockLastAccepteder

NewMockLastAccepteder creates a new mock instance.

func (*MockLastAccepteder) EXPECT added in v1.7.17

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

func (*MockLastAccepteder) GetLastAccepted added in v1.7.17

func (m *MockLastAccepteder) GetLastAccepted() ids.ID

GetLastAccepted mocks base method.

func (*MockLastAccepteder) SetLastAccepted added in v1.7.17

func (m *MockLastAccepteder) SetLastAccepted(blkID ids.ID)

SetLastAccepted mocks base method.

type MockLastAcceptederMockRecorder added in v1.7.17

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

MockLastAcceptederMockRecorder is the mock recorder for MockLastAccepteder.

func (*MockLastAcceptederMockRecorder) GetLastAccepted added in v1.7.17

func (mr *MockLastAcceptederMockRecorder) GetLastAccepted() *gomock.Call

GetLastAccepted indicates an expected call of GetLastAccepted.

func (*MockLastAcceptederMockRecorder) SetLastAccepted added in v1.7.17

func (mr *MockLastAcceptederMockRecorder) SetLastAccepted(blkID interface{}) *gomock.Call

SetLastAccepted indicates an expected call of SetLastAccepted.

type MockStakerIterator added in v1.7.15

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

MockStakerIterator is a mock of StakerIterator interface

func NewMockStakerIterator added in v1.7.15

func NewMockStakerIterator(ctrl *gomock.Controller) *MockStakerIterator

NewMockStakerIterator creates a new mock instance

func (*MockStakerIterator) EXPECT added in v1.7.15

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

func (*MockStakerIterator) Next added in v1.7.15

func (m *MockStakerIterator) Next() bool

Next mocks base method

func (*MockStakerIterator) Release added in v1.7.15

func (m *MockStakerIterator) Release()

Release mocks base method

func (*MockStakerIterator) Value added in v1.7.15

func (m *MockStakerIterator) Value() *Staker

Value mocks base method

type MockStakerIteratorMockRecorder added in v1.7.15

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

MockStakerIteratorMockRecorder is the mock recorder for MockStakerIterator

func (*MockStakerIteratorMockRecorder) Next added in v1.7.15

Next indicates an expected call of Next

func (*MockStakerIteratorMockRecorder) Release added in v1.7.15

Release indicates an expected call of Release

func (*MockStakerIteratorMockRecorder) Value added in v1.7.15

Value indicates an expected call of Value

type MockState added in v1.7.15

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

MockState is a mock of State interface.

func NewMockState added in v1.7.15

func NewMockState(ctrl *gomock.Controller) *MockState

NewMockState creates a new mock instance.

func (*MockState) Abort added in v1.7.17

func (m *MockState) Abort()

Abort mocks base method.

func (*MockState) AddChain added in v1.7.15

func (m *MockState) AddChain(createChainTx *txs.Tx)

AddChain mocks base method.

func (*MockState) AddRewardUTXO added in v1.7.15

func (m *MockState) AddRewardUTXO(txID ids.ID, utxo *avax.UTXO)

AddRewardUTXO mocks base method.

func (*MockState) AddStatelessBlock added in v1.7.17

func (m *MockState) AddStatelessBlock(block blocks.Block, status choices.Status)

AddStatelessBlock mocks base method.

func (*MockState) AddSubnet added in v1.7.15

func (m *MockState) AddSubnet(createSubnetTx *txs.Tx)

AddSubnet mocks base method.

func (*MockState) AddTx added in v1.7.15

func (m *MockState) AddTx(tx *txs.Tx, status status.Status)

AddTx mocks base method.

func (*MockState) AddUTXO added in v1.7.15

func (m *MockState) AddUTXO(utxo *avax.UTXO)

AddUTXO mocks base method.

func (*MockState) Close added in v1.7.15

func (m *MockState) Close() error

Close mocks base method.

func (*MockState) Commit added in v1.7.17

func (m *MockState) Commit() error

Commit mocks base method.

func (*MockState) CommitBatch added in v1.7.17

func (m *MockState) CommitBatch() (database.Batch, error)

CommitBatch mocks base method.

func (*MockState) DeleteCurrentDelegator added in v1.7.15

func (m *MockState) DeleteCurrentDelegator(staker *Staker)

DeleteCurrentDelegator mocks base method.

func (*MockState) DeleteCurrentValidator added in v1.7.15

func (m *MockState) DeleteCurrentValidator(staker *Staker)

DeleteCurrentValidator mocks base method.

func (*MockState) DeletePendingDelegator added in v1.7.15

func (m *MockState) DeletePendingDelegator(staker *Staker)

DeletePendingDelegator mocks base method.

func (*MockState) DeletePendingValidator added in v1.7.15

func (m *MockState) DeletePendingValidator(staker *Staker)

DeletePendingValidator mocks base method.

func (*MockState) DeleteUTXO added in v1.7.15

func (m *MockState) DeleteUTXO(utxoID ids.ID)

DeleteUTXO mocks base method.

func (*MockState) EXPECT added in v1.7.15

func (m *MockState) EXPECT() *MockStateMockRecorder

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

func (*MockState) GetChains added in v1.7.15

func (m *MockState) GetChains(subnetID ids.ID) ([]*txs.Tx, error)

GetChains mocks base method.

func (*MockState) GetCurrentDelegatorIterator added in v1.7.15

func (m *MockState) GetCurrentDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

GetCurrentDelegatorIterator mocks base method.

func (*MockState) GetCurrentStakerIterator added in v1.7.15

func (m *MockState) GetCurrentStakerIterator() (StakerIterator, error)

GetCurrentStakerIterator mocks base method.

func (*MockState) GetCurrentSupply added in v1.7.15

func (m *MockState) GetCurrentSupply() uint64

GetCurrentSupply mocks base method.

func (*MockState) GetCurrentValidator added in v1.7.15

func (m *MockState) GetCurrentValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

GetCurrentValidator mocks base method.

func (*MockState) GetLastAccepted added in v1.7.15

func (m *MockState) GetLastAccepted() ids.ID

GetLastAccepted mocks base method.

func (*MockState) GetPendingDelegatorIterator added in v1.7.15

func (m *MockState) GetPendingDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

GetPendingDelegatorIterator mocks base method.

func (*MockState) GetPendingStakerIterator added in v1.7.15

func (m *MockState) GetPendingStakerIterator() (StakerIterator, error)

GetPendingStakerIterator mocks base method.

func (*MockState) GetPendingValidator added in v1.7.15

func (m *MockState) GetPendingValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

GetPendingValidator mocks base method.

func (*MockState) GetRewardUTXOs added in v1.7.15

func (m *MockState) GetRewardUTXOs(txID ids.ID) ([]*avax.UTXO, error)

GetRewardUTXOs mocks base method.

func (*MockState) GetStartTime added in v1.7.15

func (m *MockState) GetStartTime(nodeID ids.NodeID) (time.Time, error)

GetStartTime mocks base method.

func (*MockState) GetStatelessBlock added in v1.7.17

func (m *MockState) GetStatelessBlock(blockID ids.ID) (blocks.Block, choices.Status, error)

GetStatelessBlock mocks base method.

func (*MockState) GetSubnets added in v1.7.15

func (m *MockState) GetSubnets() ([]*txs.Tx, error)

GetSubnets mocks base method.

func (*MockState) GetTimestamp added in v1.7.15

func (m *MockState) GetTimestamp() time.Time

GetTimestamp mocks base method.

func (*MockState) GetTx added in v1.7.15

func (m *MockState) GetTx(txID ids.ID) (*txs.Tx, status.Status, error)

GetTx mocks base method.

func (*MockState) GetUTXO added in v1.7.15

func (m *MockState) GetUTXO(utxoID ids.ID) (*avax.UTXO, error)

GetUTXO mocks base method.

func (*MockState) GetUptime added in v1.7.15

func (m *MockState) GetUptime(nodeID ids.NodeID) (time.Duration, time.Time, error)

GetUptime mocks base method.

func (*MockState) GetValidatorWeightDiffs added in v1.7.15

func (m *MockState) GetValidatorWeightDiffs(height uint64, subnetID ids.ID) (map[ids.NodeID]*ValidatorWeightDiff, error)

GetValidatorWeightDiffs mocks base method.

func (*MockState) PutCurrentDelegator added in v1.7.15

func (m *MockState) PutCurrentDelegator(staker *Staker)

PutCurrentDelegator mocks base method.

func (*MockState) PutCurrentValidator added in v1.7.15

func (m *MockState) PutCurrentValidator(staker *Staker)

PutCurrentValidator mocks base method.

func (*MockState) PutPendingDelegator added in v1.7.15

func (m *MockState) PutPendingDelegator(staker *Staker)

PutPendingDelegator mocks base method.

func (*MockState) PutPendingValidator added in v1.7.15

func (m *MockState) PutPendingValidator(staker *Staker)

PutPendingValidator mocks base method.

func (*MockState) SetCurrentSupply added in v1.7.15

func (m *MockState) SetCurrentSupply(cs uint64)

SetCurrentSupply mocks base method.

func (*MockState) SetHeight added in v1.7.17

func (m *MockState) SetHeight(height uint64)

SetHeight mocks base method.

func (*MockState) SetLastAccepted added in v1.7.15

func (m *MockState) SetLastAccepted(blkID ids.ID)

SetLastAccepted mocks base method.

func (*MockState) SetTimestamp added in v1.7.15

func (m *MockState) SetTimestamp(tm time.Time)

SetTimestamp mocks base method.

func (*MockState) SetUptime added in v1.7.15

func (m *MockState) SetUptime(nodeID ids.NodeID, upDuration time.Duration, lastUpdated time.Time) error

SetUptime mocks base method.

func (*MockState) UTXOIDs added in v1.7.15

func (m *MockState) UTXOIDs(addr []byte, previous ids.ID, limit int) ([]ids.ID, error)

UTXOIDs mocks base method.

func (*MockState) ValidatorSet added in v1.7.15

func (m *MockState) ValidatorSet(subnetID ids.ID) (validators.Set, error)

ValidatorSet mocks base method.

type MockStateMockRecorder added in v1.7.15

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

MockStateMockRecorder is the mock recorder for MockState.

func (*MockStateMockRecorder) Abort added in v1.7.17

func (mr *MockStateMockRecorder) Abort() *gomock.Call

Abort indicates an expected call of Abort.

func (*MockStateMockRecorder) AddChain added in v1.7.15

func (mr *MockStateMockRecorder) AddChain(createChainTx interface{}) *gomock.Call

AddChain indicates an expected call of AddChain.

func (*MockStateMockRecorder) AddRewardUTXO added in v1.7.15

func (mr *MockStateMockRecorder) AddRewardUTXO(txID, utxo interface{}) *gomock.Call

AddRewardUTXO indicates an expected call of AddRewardUTXO.

func (*MockStateMockRecorder) AddStatelessBlock added in v1.7.17

func (mr *MockStateMockRecorder) AddStatelessBlock(block, status interface{}) *gomock.Call

AddStatelessBlock indicates an expected call of AddStatelessBlock.

func (*MockStateMockRecorder) AddSubnet added in v1.7.15

func (mr *MockStateMockRecorder) AddSubnet(createSubnetTx interface{}) *gomock.Call

AddSubnet indicates an expected call of AddSubnet.

func (*MockStateMockRecorder) AddTx added in v1.7.15

func (mr *MockStateMockRecorder) AddTx(tx, status interface{}) *gomock.Call

AddTx indicates an expected call of AddTx.

func (*MockStateMockRecorder) AddUTXO added in v1.7.15

func (mr *MockStateMockRecorder) AddUTXO(utxo interface{}) *gomock.Call

AddUTXO indicates an expected call of AddUTXO.

func (*MockStateMockRecorder) Close added in v1.7.15

func (mr *MockStateMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockStateMockRecorder) Commit added in v1.7.17

func (mr *MockStateMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit.

func (*MockStateMockRecorder) CommitBatch added in v1.7.17

func (mr *MockStateMockRecorder) CommitBatch() *gomock.Call

CommitBatch indicates an expected call of CommitBatch.

func (*MockStateMockRecorder) DeleteCurrentDelegator added in v1.7.15

func (mr *MockStateMockRecorder) DeleteCurrentDelegator(staker interface{}) *gomock.Call

DeleteCurrentDelegator indicates an expected call of DeleteCurrentDelegator.

func (*MockStateMockRecorder) DeleteCurrentValidator added in v1.7.15

func (mr *MockStateMockRecorder) DeleteCurrentValidator(staker interface{}) *gomock.Call

DeleteCurrentValidator indicates an expected call of DeleteCurrentValidator.

func (*MockStateMockRecorder) DeletePendingDelegator added in v1.7.15

func (mr *MockStateMockRecorder) DeletePendingDelegator(staker interface{}) *gomock.Call

DeletePendingDelegator indicates an expected call of DeletePendingDelegator.

func (*MockStateMockRecorder) DeletePendingValidator added in v1.7.15

func (mr *MockStateMockRecorder) DeletePendingValidator(staker interface{}) *gomock.Call

DeletePendingValidator indicates an expected call of DeletePendingValidator.

func (*MockStateMockRecorder) DeleteUTXO added in v1.7.15

func (mr *MockStateMockRecorder) DeleteUTXO(utxoID interface{}) *gomock.Call

DeleteUTXO indicates an expected call of DeleteUTXO.

func (*MockStateMockRecorder) GetChains added in v1.7.15

func (mr *MockStateMockRecorder) GetChains(subnetID interface{}) *gomock.Call

GetChains indicates an expected call of GetChains.

func (*MockStateMockRecorder) GetCurrentDelegatorIterator added in v1.7.15

func (mr *MockStateMockRecorder) GetCurrentDelegatorIterator(subnetID, nodeID interface{}) *gomock.Call

GetCurrentDelegatorIterator indicates an expected call of GetCurrentDelegatorIterator.

func (*MockStateMockRecorder) GetCurrentStakerIterator added in v1.7.15

func (mr *MockStateMockRecorder) GetCurrentStakerIterator() *gomock.Call

GetCurrentStakerIterator indicates an expected call of GetCurrentStakerIterator.

func (*MockStateMockRecorder) GetCurrentSupply added in v1.7.15

func (mr *MockStateMockRecorder) GetCurrentSupply() *gomock.Call

GetCurrentSupply indicates an expected call of GetCurrentSupply.

func (*MockStateMockRecorder) GetCurrentValidator added in v1.7.15

func (mr *MockStateMockRecorder) GetCurrentValidator(subnetID, nodeID interface{}) *gomock.Call

GetCurrentValidator indicates an expected call of GetCurrentValidator.

func (*MockStateMockRecorder) GetLastAccepted added in v1.7.15

func (mr *MockStateMockRecorder) GetLastAccepted() *gomock.Call

GetLastAccepted indicates an expected call of GetLastAccepted.

func (*MockStateMockRecorder) GetPendingDelegatorIterator added in v1.7.15

func (mr *MockStateMockRecorder) GetPendingDelegatorIterator(subnetID, nodeID interface{}) *gomock.Call

GetPendingDelegatorIterator indicates an expected call of GetPendingDelegatorIterator.

func (*MockStateMockRecorder) GetPendingStakerIterator added in v1.7.15

func (mr *MockStateMockRecorder) GetPendingStakerIterator() *gomock.Call

GetPendingStakerIterator indicates an expected call of GetPendingStakerIterator.

func (*MockStateMockRecorder) GetPendingValidator added in v1.7.15

func (mr *MockStateMockRecorder) GetPendingValidator(subnetID, nodeID interface{}) *gomock.Call

GetPendingValidator indicates an expected call of GetPendingValidator.

func (*MockStateMockRecorder) GetRewardUTXOs added in v1.7.15

func (mr *MockStateMockRecorder) GetRewardUTXOs(txID interface{}) *gomock.Call

GetRewardUTXOs indicates an expected call of GetRewardUTXOs.

func (*MockStateMockRecorder) GetStartTime added in v1.7.15

func (mr *MockStateMockRecorder) GetStartTime(nodeID interface{}) *gomock.Call

GetStartTime indicates an expected call of GetStartTime.

func (*MockStateMockRecorder) GetStatelessBlock added in v1.7.17

func (mr *MockStateMockRecorder) GetStatelessBlock(blockID interface{}) *gomock.Call

GetStatelessBlock indicates an expected call of GetStatelessBlock.

func (*MockStateMockRecorder) GetSubnets added in v1.7.15

func (mr *MockStateMockRecorder) GetSubnets() *gomock.Call

GetSubnets indicates an expected call of GetSubnets.

func (*MockStateMockRecorder) GetTimestamp added in v1.7.15

func (mr *MockStateMockRecorder) GetTimestamp() *gomock.Call

GetTimestamp indicates an expected call of GetTimestamp.

func (*MockStateMockRecorder) GetTx added in v1.7.15

func (mr *MockStateMockRecorder) GetTx(txID interface{}) *gomock.Call

GetTx indicates an expected call of GetTx.

func (*MockStateMockRecorder) GetUTXO added in v1.7.15

func (mr *MockStateMockRecorder) GetUTXO(utxoID interface{}) *gomock.Call

GetUTXO indicates an expected call of GetUTXO.

func (*MockStateMockRecorder) GetUptime added in v1.7.15

func (mr *MockStateMockRecorder) GetUptime(nodeID interface{}) *gomock.Call

GetUptime indicates an expected call of GetUptime.

func (*MockStateMockRecorder) GetValidatorWeightDiffs added in v1.7.15

func (mr *MockStateMockRecorder) GetValidatorWeightDiffs(height, subnetID interface{}) *gomock.Call

GetValidatorWeightDiffs indicates an expected call of GetValidatorWeightDiffs.

func (*MockStateMockRecorder) PutCurrentDelegator added in v1.7.15

func (mr *MockStateMockRecorder) PutCurrentDelegator(staker interface{}) *gomock.Call

PutCurrentDelegator indicates an expected call of PutCurrentDelegator.

func (*MockStateMockRecorder) PutCurrentValidator added in v1.7.15

func (mr *MockStateMockRecorder) PutCurrentValidator(staker interface{}) *gomock.Call

PutCurrentValidator indicates an expected call of PutCurrentValidator.

func (*MockStateMockRecorder) PutPendingDelegator added in v1.7.15

func (mr *MockStateMockRecorder) PutPendingDelegator(staker interface{}) *gomock.Call

PutPendingDelegator indicates an expected call of PutPendingDelegator.

func (*MockStateMockRecorder) PutPendingValidator added in v1.7.15

func (mr *MockStateMockRecorder) PutPendingValidator(staker interface{}) *gomock.Call

PutPendingValidator indicates an expected call of PutPendingValidator.

func (*MockStateMockRecorder) SetCurrentSupply added in v1.7.15

func (mr *MockStateMockRecorder) SetCurrentSupply(cs interface{}) *gomock.Call

SetCurrentSupply indicates an expected call of SetCurrentSupply.

func (*MockStateMockRecorder) SetHeight added in v1.7.17

func (mr *MockStateMockRecorder) SetHeight(height interface{}) *gomock.Call

SetHeight indicates an expected call of SetHeight.

func (*MockStateMockRecorder) SetLastAccepted added in v1.7.15

func (mr *MockStateMockRecorder) SetLastAccepted(blkID interface{}) *gomock.Call

SetLastAccepted indicates an expected call of SetLastAccepted.

func (*MockStateMockRecorder) SetTimestamp added in v1.7.15

func (mr *MockStateMockRecorder) SetTimestamp(tm interface{}) *gomock.Call

SetTimestamp indicates an expected call of SetTimestamp.

func (*MockStateMockRecorder) SetUptime added in v1.7.15

func (mr *MockStateMockRecorder) SetUptime(nodeID, upDuration, lastUpdated interface{}) *gomock.Call

SetUptime indicates an expected call of SetUptime.

func (*MockStateMockRecorder) UTXOIDs added in v1.7.15

func (mr *MockStateMockRecorder) UTXOIDs(addr, previous, limit interface{}) *gomock.Call

UTXOIDs indicates an expected call of UTXOIDs.

func (*MockStateMockRecorder) ValidatorSet added in v1.7.15

func (mr *MockStateMockRecorder) ValidatorSet(subnetID interface{}) *gomock.Call

ValidatorSet indicates an expected call of ValidatorSet.

type MockVersions added in v1.7.15

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

MockVersions is a mock of Versions interface.

func NewMockVersions added in v1.7.15

func NewMockVersions(ctrl *gomock.Controller) *MockVersions

NewMockVersions creates a new mock instance.

func (*MockVersions) EXPECT added in v1.7.15

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

func (*MockVersions) GetState added in v1.7.15

func (m *MockVersions) GetState(arg0 ids.ID) (Chain, bool)

GetState mocks base method.

type MockVersionsMockRecorder added in v1.7.15

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

MockVersionsMockRecorder is the mock recorder for MockVersions.

func (*MockVersionsMockRecorder) GetState added in v1.7.15

func (mr *MockVersionsMockRecorder) GetState(arg0 interface{}) *gomock.Call

GetState indicates an expected call of GetState.

type PendingStakers

type PendingStakers interface {
	// GetPendingValidator returns the Staker describing the validator on
	// [subnetID] with [nodeID]. If the validator does not exist,
	// [database.ErrNotFound] is returned.
	GetPendingValidator(subnetID ids.ID, nodeID ids.NodeID) (*Staker, error)

	// PutPendingValidator adds the [staker] describing a validator to the
	// staker set.
	PutPendingValidator(staker *Staker)

	// DeletePendingValidator removes the [staker] describing a validator from
	// the staker set.
	DeletePendingValidator(staker *Staker)

	// GetPendingDelegatorIterator returns the delegators associated with the
	// validator on [subnetID] with [nodeID]. Delegators are sorted by their
	// removal from pending staker set.
	GetPendingDelegatorIterator(subnetID ids.ID, nodeID ids.NodeID) (StakerIterator, error)

	// PutPendingDelegator adds the [staker] describing a delegator to the
	// staker set.
	PutPendingDelegator(staker *Staker)

	// DeletePendingDelegator removes the [staker] describing a delegator from
	// the staker set.
	DeletePendingDelegator(staker *Staker)

	// GetPendingStakerIterator returns stakers in order of their removal from
	// the pending staker set.
	GetPendingStakerIterator() (StakerIterator, error)
}

type Priority added in v1.7.15

type Priority byte
const (
	// First subnet delegators are removed from the current validator set,
	SubnetDelegatorCurrentPriority Priority = iota + 1
	// then subnet validators,
	SubnetValidatorCurrentPriority
	// then primary network delegators,
	PrimaryNetworkDelegatorCurrentPriority
	// then primary network validators.
	PrimaryNetworkValidatorCurrentPriority
)
const (
	// First primary network delegators are moved from the pending to the
	// current validator set,
	PrimaryNetworkDelegatorPendingPriority Priority = iota + 1
	// then primary network validators,
	PrimaryNetworkValidatorPendingPriority
	// then subnet validators,
	SubnetValidatorPendingPriority
	// then subnet delegators.
	SubnetDelegatorPendingPriority
)

type Staker added in v1.7.15

type Staker struct {
	TxID            ids.ID
	NodeID          ids.NodeID
	SubnetID        ids.ID
	Weight          uint64
	StartTime       time.Time
	EndTime         time.Time
	PotentialReward uint64

	// NextTime is the next time this staker will be moved from a validator set.
	// If the staker is in the pending validator set, NextTime will equal
	// StartTime. If the staker is in the current validator set, NextTime will
	// equal EndTime.
	NextTime time.Time

	// Priority specifies how to break ties between stakers with the same
	// NextTime. This ensures that stakers created by the same transaction type
	// are grouped together. The ordering of these groups is documented in
	// [priorities.go] and depends on if the stakers are in the pending or
	// current validator set.
	Priority Priority
}

Staker contains all information required to represent a validator or delegator in the current and pending validator sets.

func NewPrimaryNetworkStaker added in v1.7.15

func NewPrimaryNetworkStaker(txID ids.ID, vdr *validator.Validator) *Staker

func NewSubnetStaker added in v1.7.15

func NewSubnetStaker(txID ids.ID, vdr *validator.SubnetValidator) *Staker

func (*Staker) Less added in v1.7.15

func (s *Staker) Less(thanIntf btree.Item) bool

A *Staker is considered to be less than another *Staker when:

  1. If its NextTime is before the other's.
  2. If the NextTimes are the same, the *Staker with the lesser priority is the lesser one.
  3. If the priorities are also the same, the one with the lesser txID is lesser.

Invariant: [thanIntf] is a *Staker.

type StakerDiffIterator added in v1.7.15

type StakerDiffIterator interface {
	Next() bool
	// Returns:
	// - The staker that is changing
	// - True if the staker is being added to the current staker set, false if
	//   the staker is being removed from the current staker set
	Value() (*Staker, bool)
	Release()
}

StakerDiffIterator is an iterator that iterates over the events that will be performed on the current staker set.

There are two event types affecting current staker set, removal of an existing staker and addition of a new staker from the pending set.

The ordering of operations is:

  • Staker operations are performed in order of their [NextTime].
  • If operations have the same [NextTime], stakers are first added to the current staker set, then removed.
  • Further ties are broken by *Staker.Less(), returning the lesser staker first.

func NewStakerDiffIterator added in v1.7.15

func NewStakerDiffIterator(currentIterator, pendingIterator StakerIterator) StakerDiffIterator

type StakerIterator added in v1.7.15

type StakerIterator interface {
	// Next attempts to move the iterator to the next staker. It returns false
	// once there are no more stakers to return.
	Next() bool

	// Value returns the current staker. Value should only be called after a
	// call to Next which returned true.
	Value() *Staker

	// Release any resources associated with the iterator. This must be called
	// after the interator is no longer needed.
	Release()
}

StakerIterator defines an interface for iterating over a set of stakers.

var EmptyIterator StakerIterator = emptyIterator{}

EmptyIterator contains no stakers.

func NewMaskedIterator added in v1.7.15

func NewMaskedIterator(parentIterator StakerIterator, maskedStakers map[ids.ID]*Staker) StakerIterator

NewMaskedIterator returns a new iterator that skips the stakers in [parentIterator] that are present in [maskedStakers].

func NewMergedIterator added in v1.7.15

func NewMergedIterator(stakers ...StakerIterator) StakerIterator

Returns an iterator that returns all of the elements of [stakers] in order.

func NewTreeIterator added in v1.7.15

func NewTreeIterator(tree *btree.BTree) StakerIterator

NewTreeIterator returns a new iterator of the stakers in [tree] in ascending order.

type Stakers

type Stakers interface {
	CurrentStakers
	PendingStakers
}

type State

type State interface {
	LastAccepteder
	Chain
	BlockState
	uptime.State
	avax.UTXOReader

	GetValidatorWeightDiffs(height uint64, subnetID ids.ID) (map[ids.NodeID]*ValidatorWeightDiff, error)

	// Return the current validator set of [subnetID].
	ValidatorSet(subnetID ids.ID) (validators.Set, error)

	SetHeight(height uint64)

	// Discard uncommitted changes to the database.
	Abort()

	// Commit changes to the base database.
	Commit() error

	// Returns a batch of unwritten changes that, when written, will be commit
	// all pending changes to the base database.
	CommitBatch() (database.Batch, error)

	Close() error
}

func New

func New(
	db database.Database,
	genesisBytes []byte,
	metrics prometheus.Registerer,
	cfg *config.Config,
	ctx *snow.Context,
	localStake prometheus.Gauge,
	totalStake prometheus.Gauge,
	rewards reward.Calculator,
) (State, error)

type UTXOAdder

type UTXOAdder interface {
	AddUTXO(utxo *avax.UTXO)
}

type UTXODeleter

type UTXODeleter interface {
	DeleteUTXO(utxoID ids.ID)
}

type UTXOGetter

type UTXOGetter interface {
	GetUTXO(utxoID ids.ID) (*avax.UTXO, error)
}

type ValidatorWeightDiff

type ValidatorWeightDiff struct {
	Decrease bool   `serialize:"true"`
	Amount   uint64 `serialize:"true"`
}

func (*ValidatorWeightDiff) Add added in v1.7.15

func (v *ValidatorWeightDiff) Add(negative bool, amount uint64) error

type Versions added in v1.7.15

type Versions interface {
	GetState(blkID ids.ID) (Chain, bool)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL