sum

type AggShare ¶

type AggShare = prio3.AggShare[Vec, Fp]

type Fp ¶

type Fp = fp64.Fp

type InputShare ¶

type InputShare = prio3.InputShare[Vec, Fp]

type Nonce ¶

type Nonce = prio3.Nonce

type OutShare ¶

type OutShare = prio3.OutShare[Vec, Fp]

type PrepMessage ¶

type PrepMessage = prio3.PrepMessage

type PrepShare ¶

type PrepShare = prio3.PrepShare[Vec, Fp]

type PrepState ¶

type PrepState = prio3.PrepState[Vec, Fp]

type PublicShare ¶

type PublicShare = prio3.PublicShare

type Sum ¶

type Sum struct {
	// contains filtered or unexported fields
}

Sum is a verifiable distributed aggregation function in which each measurement is an integer in the range [0, maxMeasurement], where maxMeasurement defines the largest valid measurement, the aggregated result is the sum of all the measurements.

func New(numShares uint8, maxMeasurement uint64, context []byte) (s *Sum, err error)

func (s *Sum) AggregateInit() AggShare

func (s *Sum) AggregateUpdate(aggShare *AggShare, outShare *OutShare)

func (s *Sum) Params() prio3.Params

func (s *Sum) PrepInit(
	verifyKey *VerifyKey,
	nonce *Nonce,
	aggID uint8,
	publicShare PublicShare,
	inputShare InputShare,
) (*PrepState, *PrepShare, error)

func (s *Sum) PrepNext(state *PrepState, msg *PrepMessage) (*OutShare, error)

func (s *Sum) PrepSharesToPrep(prepShares []PrepShare) (*PrepMessage, error)

func (s *Sum) Shard(measurement uint64, nonce *Nonce, rand []byte,
) (PublicShare, []InputShare, error)

func (s *Sum) Unshard(aggShares []AggShare, numMeas uint) (aggregate *uint64, err error)

type Vec ¶

type Vec = fp64.Vec

type VerifyKey ¶

type VerifyKey = prio3.VerifyKey