jetcoordinator

Documentation

Overview

Package jetcoordinator is responsible for all jet manipulations.

Package responsible for jet drops, split/merge jets, choose of validators.

Index

• func CreateJetDrop(storage storage.LedgerStorer, prevPulse, newPulse record.PulseNum) (*jetdrop.JetDrop, error)
• type JetCoordinator
  • func (jc *JetCoordinator) Pulse(newPulse record.PulseNum) error

Functions

func CreateJetDrop

func CreateJetDrop(storage storage.LedgerStorer, prevPulse, newPulse record.PulseNum) (*jetdrop.JetDrop, error)

CreateJetDrop creates new jet drop from records in storage. Previous pulse is required to calculate hash.

Types

type JetCoordinator

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

JetCoordinator is responsible for all jet interactions

func (*JetCoordinator) Pulse

func (jc *JetCoordinator) Pulse(newPulse record.PulseNum) error

Pulse creates new jet drop and ends current slot. This should be called when receiving a new pulse from pulsar.