pulsemanager

Documentation

Overview

Package pulsemanager is responsible for all pulse operations.

Index

• type PulseManager
  • func NewPulseManager() *PulseManager
  • func (m *PulseManager) AddDispatcher(d ...dispatcher.Dispatcher)
  • func (m *PulseManager) Set(ctx context.Context, newPulse insolar.Pulse) error
  • func (m *PulseManager) Start(ctx context.Context) error
  • func (m *PulseManager) Stop(ctx context.Context) error

Types

type PulseManager

type PulseManager struct {
	LogicRunner   insolar.LogicRunner `inject:""`
	NodeNet       network.NodeNetwork `inject:""` //nolint:staticcheck
	NodeSetter    node.Modifier       `inject:""`
	PulseAccessor pulse.Accessor      `inject:""`
	PulseAppender pulse.Appender      `inject:""`
	JetModifier   jet.Modifier        `inject:""`
	// contains filtered or unexported fields
}

PulseManager implements insolar.PulseManager.

func NewPulseManager

func NewPulseManager() *PulseManager

NewPulseManager creates PulseManager instance.

func (*PulseManager) AddDispatcher

func (m *PulseManager) AddDispatcher(d ...dispatcher.Dispatcher)

AddDispatcher adds dispatchers to handling that could be done only when Set is not happening

func (*PulseManager) Set

func (m *PulseManager) Set(ctx context.Context, newPulse insolar.Pulse) error

Set set's new pulse.

func (*PulseManager) Start

func (m *PulseManager) Start(ctx context.Context) error

Start starts pulse manager.

func (*PulseManager) Stop

func (m *PulseManager) Stop(ctx context.Context) error

Stop stops PulseManager.