mapping

type MappingDataSource interface {
	Init()
	GetType() string
	SetMappingNode(*MappingNode) error
	RetrieveKeyMapping(index big.Int) (MappingKey, error)
}

type MappingID string

type MappingIDDetails struct {
	OldEpoch int
	NewEpoch int
}

type MappingKey struct {
	Index     big.Int             `json:"index"`
	PublicKey common.Point        `json:"publicKey"`
	Threshold int                 `json:"threshold"`
	Verifiers map[string][]string `json:"verifiers"` // Verifier => VerifierID
}

type MappingKeyBroadcastMessage struct {
	MappingKey MappingKey
}

type MappingKeyID string

type MappingKeyIDToNodeDetailsIDToIntCMap struct {
	cmap.ConcurrentMap
}

type MappingKeyMessage struct {
	MappingKey MappingKey
}

type MappingKeys struct {
	SendCount *MappingKeyIDToNodeDetailsIDToIntCMap
}

type MappingMessage struct {
	Version   mappingMessageVersion `json:"version,omitempty"`
	MappingID MappingID             `json:"mappingID"`
	Method    string                `json:"method"`
	Data      []byte                `json:"data"`
}

type MappingMessageRaw struct {
	MappingID MappingID
	Method    string
	Data      []byte
}

type MappingNode struct {
	idmutex.Mutex
	NodeDetails    NodeDetails
	OldNodes       NodeNetwork
	NewNodes       NodeNetwork
	NodeIndex      int
	Transport      MappingTransport
	DataSource     MappingDataSource
	MappingSummary *MappingSummary
	MappingKeys    *MappingKeys
	IsOldNode      bool
	IsNewNode      bool
}

type MappingProposeFreezeBroadcastMessage struct {
	MappingID MappingID
}

type MappingProposeFreezeMessage struct {
	MappingID MappingID
}

type MappingSummary struct {
	SendCount           *NodeDetailsToIntCMap
	MappingSummaryStore *TransferSummaryIDToTransferSummaryCMap
	MappingSummaryCount *TransferSummaryToIntCMap
}

type MappingSummaryBroadcastMessage struct {
	TransferSummary TransferSummary
}

type MappingSummaryMessage struct {
	TransferSummary TransferSummary
}

type MappingTransport interface {
	Init()
	GetType() string
	SetMappingNode(*MappingNode) error
	Sign([]byte) ([]byte, error)
	Send(NodeDetails, MappingMessage) error
	Receive(NodeDetails, MappingMessage) error
	SendBroadcast(MappingMessage) error
	ReceiveBroadcast(MappingMessage) error
	Output(interface{})
}

type NodeDetails pcmn.Node

type NodeDetailsID string

type NodeDetailsIDToIntCMap struct {
	cmap.ConcurrentMap
}

type NodeDetailsToIntCMap struct {
	cmap.ConcurrentMap
}

type NodeNetwork struct {
	Nodes   map[NodeDetailsID]NodeDetails
	N       int
	T       int
	K       int
	EpochID int
}

type TransferSummary struct {
	LastUnassignedIndex uint `json:"last_unassigned_index"`
}

type TransferSummaryID string

type TransferSummaryIDToTransferSummaryCMap struct {
	cmap.ConcurrentMap
}

type TransferSummaryToIntCMap struct {
	cmap.ConcurrentMap
}

type VerifierIterator struct {
	pcmn.Iterator
}