jetcoordinator

Documentation

Overview

Package jetcoordinator is responsible for all jet manipulations.

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

Index

• type JetCoordinator
  • func NewJetCoordinator(db *storage.DB) (*JetCoordinator, error)
  • func (jc *JetCoordinator) Pulse(new record.PulseNum) (*jetdrop.JetDrop, error)

Types

type JetCoordinator

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

JetCoordinator is responsible for all jet interactions

func NewJetCoordinator

func NewJetCoordinator(db *storage.DB) (*JetCoordinator, error)

NewJetCoordinator creates new coordinator instance.

func (*JetCoordinator) Pulse

func (jc *JetCoordinator) Pulse(new record.PulseNum) (*jetdrop.JetDrop, error)

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