parsigex

Documentation

Index

• func NewEth2Verifier(eth2Cl eth2wrap.Client, ...) (func(context.Context, core.Duty, core.PubKey, core.ParSignedData) error, error)
• func NewMemExFunc() func() core.ParSigEx
• type MemEx
  • func (s MemEx) Broadcast(ctx context.Context, duty core.Duty, set core.ParSignedDataSet) error
  • func (s MemEx) Subscribe(fn func(context.Context, core.Duty, core.ParSignedDataSet) error)
• type ParSigEx
  • func NewParSigEx(tcpNode host.Host, sendFunc p2p.SendFunc, peerIdx int, peers []peer.ID, ...) *ParSigEx
  • func (m *ParSigEx) Broadcast(ctx context.Context, duty core.Duty, set core.ParSignedDataSet) error
  • func (m *ParSigEx) Subscribe(fn func(context.Context, core.Duty, core.ParSignedDataSet) error)

Functions

func NewEth2Verifier

func NewEth2Verifier(eth2Cl eth2wrap.Client, pubSharesByKey map[core.PubKey]map[int]*bls_sig.PublicKey) (func(context.Context, core.Duty, core.PubKey, core.ParSignedData) error, error)

NewEth2Verifier returns a partial signature verification function for core workflow eth2 signatures.

func NewMemExFunc

func NewMemExFunc() func() core.ParSigEx

NewMemExFunc returns a function that itself returns in-memory exchange components that exchange partial signatures.

Types

type MemEx

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

MemEx provides an in-memory implementation of the core workflow's partial signature exchange component.

func (MemEx) Broadcast

func (s MemEx) Broadcast(ctx context.Context, duty core.Duty, set core.ParSignedDataSet) error

Broadcast broadcasts the partially signed duty data set to all peers.

func (MemEx) Subscribe

func (s MemEx) Subscribe(fn func(context.Context, core.Duty, core.ParSignedDataSet) error)

Subscribe registers a callback when a partially signed duty set is received from a peer.

type ParSigEx

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

ParSigEx exchanges partially signed duty data sets. It ensures that all partial signatures are persisted by all peers.

func NewParSigEx

func NewParSigEx(tcpNode host.Host, sendFunc p2p.SendFunc, peerIdx int, peers []peer.ID, verifyFunc func(context.Context, core.Duty, core.PubKey, core.ParSignedData) error) *ParSigEx

func (*ParSigEx) Broadcast

func (m *ParSigEx) Broadcast(ctx context.Context, duty core.Duty, set core.ParSignedDataSet) error

Broadcast broadcasts the partially signed duty data set to all peers.

func (*ParSigEx) Subscribe

func (m *ParSigEx) Subscribe(fn func(context.Context, core.Duty, core.ParSignedDataSet) error)

Subscribe registers a callback when a partially signed duty set is received from a peer. This is not thread safe, it must be called before starting to use parsigex.