coordinator

Documentation

Overview

Package coordinator implements a generic coordinator functionality for helium nodes. The coordinator orchestrates the execution of the MHE-based MPC protocol by executing its sub-protocols and routines.

Index

• type Channel
• type Coordinator
• type EventType
• type Log
• type TestCoordinator
  • func NewTestCoordinator[T EventType](hid sessions.NodeID) *TestCoordinator[T]
  • func (tc *TestCoordinator[T]) Close()
  • func (tc *TestCoordinator[T]) Register(ctx context.Context) (evChan *Channel[T], present int, err error)

Types

type Channel

type Channel[T EventType] struct {
	Incoming <-chan T
	Outgoing chan<- T
}

type Coordinator

type Coordinator[T EventType] interface {
	Register(ctx context.Context) (evChan *Channel[T], present int, err error)
}

type EventType

type EventType any

type Log

type Log[T EventType] []T

type TestCoordinator

type TestCoordinator[T EventType] struct {
	// contains filtered or unexported fields
}

func NewTestCoordinator

func NewTestCoordinator[T EventType](hid sessions.NodeID) *TestCoordinator[T]

func (*TestCoordinator[T]) Close

func (tc *TestCoordinator[T]) Close()

func (*TestCoordinator[T]) Register

func (tc *TestCoordinator[T]) Register(ctx context.Context) (evChan *Channel[T], present int, err error)