msgcenter

package

v0.0.0-...-168a7d3 Latest Latest Go to latest Published: Aug 26, 2019 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ayachain/go-aya

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

View Source

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

View Source

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
}

Source Files ¶

View all Source files

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