pulsemanager

Documentation

Overview

Package pulsemanager is responsible for all pulse operations.

Index

• func NewpulseStoragePmMock(t minimock.Tester) *pulseStoragePmMock
• type ActiveListSwapper
• type PulseManager
  • func NewPulseManager(db *storage.DB, conf configuration.Ledger) *PulseManager
  • func (m *PulseManager) Set(ctx context.Context, newPulse core.Pulse, persist bool) error
  • func (m *PulseManager) Start(ctx context.Context) error
  • func (m *PulseManager) Stop(ctx context.Context) error

Functions

func NewpulseStoragePmMock

func NewpulseStoragePmMock(t minimock.Tester) *pulseStoragePmMock

NewpulseStoragePmMock returns a mock for github.com/insolar/insolar/ledger/pulsemanager.pulseStoragePm

Types

type ActiveListSwapper

type ActiveListSwapper interface {
	MoveSyncToActive()
}

type PulseManager

type PulseManager struct {
	LR                            core.LogicRunner                   `inject:""`
	Bus                           core.MessageBus                    `inject:""`
	NodeNet                       core.NodeNetwork                   `inject:""`
	JetCoordinator                core.JetCoordinator                `inject:""`
	GIL                           core.GlobalInsolarLock             `inject:""`
	CryptographyService           core.CryptographyService           `inject:""`
	PlatformCryptographyScheme    core.PlatformCryptographyScheme    `inject:""`
	RecentStorageProvider         recentstorage.Provider             `inject:""`
	ActiveListSwapper             ActiveListSwapper                  `inject:""`
	PulseStorage                  pulseStoragePm                     `inject:""`
	ArtifactManagerMessageHandler core.ArtifactManagerMessageHandler `inject:""`
	// contains filtered or unexported fields
}

PulseManager implements core.PulseManager.

func NewPulseManager

func NewPulseManager(db *storage.DB, conf configuration.Ledger) *PulseManager

NewPulseManager creates PulseManager instance.

func (*PulseManager) Set

func (m *PulseManager) Set(ctx context.Context, newPulse core.Pulse, persist bool) error

Set set's new pulse and closes current jet drop.

func (*PulseManager) Start

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

Start starts pulse manager, spawns replication goroutine under a hood.

func (*PulseManager) Stop

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

Stop stops PulseManager. Waits replication goroutine is done.