msgcenter

Documentation

Index

• Variables
• func GetChannelTopics(chainID string, c MessageChannel) string
• type MessageCenter
  • func NewCenter(ind *core.IpfsNode, cvfs vdb.CVFS, cnf TrustedConfig, asd ASD.StatDaemon) MessageCenter
• type MessageChannel
• type ReviewMessage
  • func NewReviewMessage(content []byte, sender *im.Node, prefix string, dfunc func(hash EComm.Hash)) *ReviewMessage
  • func (msg *ReviewMessage) AddConfirmNode(confirmer *im.Node)
  • func (msg *ReviewMessage) VoteInfo() (votes uint64, scount uint, ncount uint)
• type TrustedConfig

Variables

var DefaultTrustedConfig = TrustedConfig{
	VotePercentage: 0.5,
	SuperNodeMin:   2,
	NodeTotalMin:   2,
}

var (
	ErrPublishedContentEmpty = errors.New("published content is empty")
)

Functions

func GetChannelTopics

func GetChannelTopics(chainID string, c MessageChannel) string

Types

type MessageCenter

type MessageCenter interface {
	Push(msg *pubsub.Message, prefix string)

	PublishMessage(pmsg proto.Message, topic string) error

	TrustMessage() <-chan interface{}

	Refresh()

	PowerOn(ctx context.Context, chainID string, ind *core.IpfsNode)
}

func NewCenter

func NewCenter(ind *core.IpfsNode, cvfs vdb.CVFS, cnf TrustedConfig, asd ASD.StatDaemon) MessageCenter

type MessageChannel

type MessageChannel string

const (
	Version                                  = "AyaMessageCenter V0.0.1"
	MessageChannelMiningBlock MessageChannel = "MiningBlock"
	MessageChannelMined       MessageChannel = "Mined"
	MessageChannelChainInfo   MessageChannel = "ChainInfo"
)

type ReviewMessage

type ReviewMessage struct {
	Content []byte

	Hash EComm.Hash

	Nodes []*im.Node

	MsgPrefix string
}

func NewReviewMessage

func NewReviewMessage(content []byte, sender *im.Node, prefix string, dfunc func(hash EComm.Hash)) *ReviewMessage

func (*ReviewMessage) AddConfirmNode

func (msg *ReviewMessage) AddConfirmNode(confirmer *im.Node)

func (*ReviewMessage) VoteInfo

func (msg *ReviewMessage) VoteInfo() (votes uint64, scount uint, ncount uint)

type TrustedConfig

type TrustedConfig struct {
	VotePercentage float32

	SuperNodeMin uint

	NodeTotalMin uint
}