reliabilitymanager

Documentation

Index

• Constants
• Variables
• func BuildBaseVoteDataFromEvent(event terderminttypes.Event) (voteID string, voteDeadline uint64, err error)
• type ReliabilityManager
  • func NewReliabilityManager(chainTracker *chaintracker.ChainTracker, txSender TxSender, ...) *ReliabilityManager
  • func (rm *ReliabilityManager) GetLatestBlockData(fromBlock int64, toBlock int64, specificBlock int64) (latestBlock int64, requestedHashes []*chaintracker.BlockStore, err error)
  • func (rm *ReliabilityManager) GetLatestBlockNum() int64
  • func (rm *ReliabilityManager) VoteHandler(voteParams *VoteParams, nodeHeight uint64)
• type TxSender
• type VoteData
• type VoteParams
  • func BuildVoteParamsFromDetectionEvent(event terderminttypes.Event) (*VoteParams, error)
  • func (vp *VoteParams) GetCloseVote() bool

Constants

const (
	DetectionVoteType = 0
	RevealVoteType    = 1
	CloseVoteType     = 2
)

Variables

var NoVoteDeadline = sdkerrors.New("Not Connected Error", 800, "No Connection To grpc server")

Functions

func BuildBaseVoteDataFromEvent

func BuildBaseVoteDataFromEvent(event terderminttypes.Event) (voteID string, voteDeadline uint64, err error)

Types

type ReliabilityManager

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

func NewReliabilityManager

func NewReliabilityManager(chainTracker *chaintracker.ChainTracker, txSender TxSender, publicAddress string, chainProxy chainlib.ChainProxy, chainParser chainlib.ChainParser) *ReliabilityManager

func (*ReliabilityManager) GetLatestBlockData

func (rm *ReliabilityManager) GetLatestBlockData(fromBlock int64, toBlock int64, specificBlock int64) (latestBlock int64, requestedHashes []*chaintracker.BlockStore, err error)

func (*ReliabilityManager) GetLatestBlockNum

func (rm *ReliabilityManager) GetLatestBlockNum() int64

func (*ReliabilityManager) VoteHandler

func (rm *ReliabilityManager) VoteHandler(voteParams *VoteParams, nodeHeight uint64)

type TxSender

type TxSender interface {
	SendVoteReveal(voteID string, vote *VoteData) error
	SendVoteCommitment(voteID string, vote *VoteData) error
}

type VoteData

type VoteData struct {
	RelayDataHash []byte
	Nonce         int64
	CommitHash    []byte
}

type VoteParams

type VoteParams struct {
	CloseVote      bool
	ChainID        string
	ApiURL         string
	RequestData    []byte
	RequestBlock   uint64
	Voters         []string
	ConnectionType string
	ApiInterface   string
	VoteDeadline   uint64
	VoteID         string
	ParamsType     uint
}

func BuildVoteParamsFromDetectionEvent

func BuildVoteParamsFromDetectionEvent(event terderminttypes.Event) (*VoteParams, error)

func (*VoteParams) GetCloseVote

func (vp *VoteParams) GetCloseVote() bool