aggregate

Documentation

Index

• type NodeMetadata
  • func (m NodeMetadata) MarshalJSON() ([]byte, error)
• type Result
• type Results
  • func Aggregate(results execute.ResultMap) Results

Types

type NodeMetadata

type NodeMetadata map[peer.ID]any

func (NodeMetadata) MarshalJSON

func (m NodeMetadata) MarshalJSON() ([]byte, error)

type Result

type Result struct {
	Result execute.RuntimeOutput `json:"result,omitempty"`
	// Peers that got this result.
	Peers []peer.ID `json:"peers,omitempty"`
	// Peers metadata
	Metadata NodeMetadata `json:"metadata,omitempty"`
	// How frequent was this result, in percentages.
	Frequency float64 `json:"frequency,omitempty"`
}

Result represents the execution result along with its aggregation stats.

type Results

type Results []Result

func Aggregate

func Aggregate(results execute.ResultMap) Results