dashboard

Documentation

Index

• Constants
• Variables
• func Plugin() *node.Plugin
• type FPCRecord
• type FPCRecords
• type FPCUpdate

Constants

const (
	// CfgBindAddress defines the config flag of the analysis dashboard binding address.
	CfgBindAddress = "analysis.dashboard.bindAddress"
	// CfgDev defines the config flag of the analysis dashboard dev mode.
	CfgDev = "analysis.dashboard.dev"
	// CfgBasicAuthEnabled defines the config flag of the analysis dashboard basic auth enabler.
	CfgBasicAuthEnabled = "analysis.dashboard.basic_auth.enabled"
	// CfgBasicAuthUsername defines the config flag of the analysis dashboard basic auth username.
	CfgBasicAuthUsername = "analysis.dashboard.basic_auth.username"
	// CfgBasicAuthPassword defines the config flag of the analysis dashboard basic auth password.
	CfgBasicAuthPassword = "analysis.dashboard.basic_auth.password"
	// CfgMongoDBEnabled defines the config flag of the analysis dashboard to enable mongoDB.
	CfgMongoDBEnabled = "analysis.dashboard.mongodb.enabled"
	// CfgMongoDBUsername defines the config flag of the analysis dashboard mongoDB username.
	CfgMongoDBUsername = "analysis.dashboard.mongodb.username"
	// CfgMongoDBPassword defines the config flag of the analysis dashboard mongoDB password.
	CfgMongoDBPassword = "analysis.dashboard.mongodb.password"
	// CfgMongoDBHostAddress defines the config flag of the analysis dashboard mongoDB binding address.
	CfgMongoDBHostAddress = "analysis.dashboard.mongodb.hostAddress"
	// CfgManaDashboardAddress defines the address of the mana dashboard to stream mana info from.
	CfgManaDashboardAddress = "analysis.dashboard.manaAddress"
)

const (
	// MsgTypePing defines a ping message type.
	MsgTypePing byte = iota
	// MsgTypeFPC defines a FPC update message.
	MsgTypeFPC
	// MsgTypeAddNode defines an addNode update message for autopeering visualizer.
	MsgTypeAddNode
	// MsgTypeRemoveNode defines a removeNode update message for autopeering visualizer.
	MsgTypeRemoveNode
	// MsgTypeConnectNodes defines a connectNodes update message for autopeering visualizer.
	MsgTypeConnectNodes
	// MsgTypeDisconnectNodes defines a disconnectNodes update message for autopeering visualizer.
	MsgTypeDisconnectNodes
)

const PluginName = "Analysis-Dashboard"

PluginName is the name of the dashboard plugin.

Variables

var ErrForbidden = errors.New("forbidden")

ErrForbidden defines the forbidden error.

var ErrInternalError = errors.New("internal error")

ErrInternalError defines the internal error.

var ErrInvalidParameter = errors.New("invalid parameter")

ErrInvalidParameter defines the invalid parameter error.

var ErrNotFound = errors.New("not found")

ErrNotFound defines the not found error.

Functions

func Plugin

func Plugin() *node.Plugin

Plugin gets the plugin instance

Types

type FPCRecord

type FPCRecord struct {
	// ConflictID defines the ID of the conflict.
	ConflictID string `json:"conflictid" bson:"conflictid"`
	// NodeID defines the ID of the node.
	NodeID string `json:"nodeid" bson:"nodeid"`
	// Rounds defines number of rounds performed to finalize the conflict.
	Rounds int `json:"rounds" bson:"rounds"`
	// Opinions contains the opinion of each round.
	Opinions []int32 `json:"opinions" bson:"opinions"`
	// Outcome defines final opinion of the conflict.
	Outcome int32 `json:"outcome" bson:"outcome"`
	// Time defines the time when the conflict has been finalized.
	Time primitive.DateTime `json:"datetime" bson:"datetime"`
}

FPCRecord defines the FPC record to be stored into a mongoDB.

type FPCRecords

type FPCRecords = []FPCRecord

FPCRecords defines a slice of FPCRecord

type FPCUpdate

type FPCUpdate struct {
	Conflicts conflictSet `json:"conflictset" bson:"conflictset"`
}

FPCUpdate contains an FPC update.