Versions in this module Expand all Collapse all v0 v0.2.1 Apr 23, 2024 v0.2.0 Apr 22, 2024 Changes in this version + type Coordinator coordinator.Coordinator[Event] + type Event struct v0.1.0 Mar 15, 2024 Changes in this version + func CheckTestSetup(ctx context.Context, t *testing.T, nid helium.NodeID, lt *session.TestSession, ...) + type Description struct + Cpk bool + Gks []uint64 + Rlk bool + func (sd Description) String() string + type Service struct + func NewSetupService(ownID helium.NodeID, sessions session.SessionProvider, conf ServiceConfig, ...) (s *Service, err error) + func (s *Service) AggregationOutputHandler(ctx context.Context, aggOut protocols.AggregationOutput) error + func (s *Service) GetAggregationOutput(ctx context.Context, pd protocols.Descriptor) (out *protocols.AggregationOutput, err error) + func (s *Service) GetCollectivePublicKey(ctx context.Context) (*rlwe.PublicKey, error) + func (s *Service) GetGaloisKey(ctx context.Context, galEl uint64) (*rlwe.GaloisKey, error) + func (s *Service) GetProtocolInput(ctx context.Context, pd protocols.Descriptor) (protocols.Input, error) + func (s *Service) GetRelinearizationKey(ctx context.Context) (*rlwe.RelinearizationKey, error) + func (s *Service) Incoming() <-chan protocols.Event + func (s *Service) Init(ctx context.Context, complPd, runPd []protocols.Descriptor) error + func (s *Service) Logf(msg string, v ...any) + func (s *Service) NodeID() helium.NodeID + func (s *Service) Outgoing() chan<- protocols.Event + func (s *Service) Register(nid helium.NodeID) error + func (s *Service) Run(ctx context.Context, coord protocols.Coordinator) error + func (s *Service) RunSignature(ctx context.Context, sig protocols.Signature) error + func (s *Service) Unregister(nid helium.NodeID) error + type ServiceConfig struct + Protocols protocols.ExecutorConfig + type SignatureList []protocols.Signature + func DescriptionToSignatureList(sd Description) SignatureList + func (sl SignatureList) Contains(other protocols.Signature) bool + type Transport interface + GetAggregationOutput func(context.Context, protocols.Descriptor) (*protocols.AggregationOutput, error)