pulsemanager

Documentation

Overview

Package pulsemanager is responsible for all pulse operations.

Index

• type PulseManager
  • func NewPulseManager(db *storage.DB, coordinator *jetcoordinator.JetCoordinator) (*PulseManager, error)
  • func (m *PulseManager) Current() (*core.Pulse, error)
  • func (m *PulseManager) Set(pulse core.Pulse) error

Types

type PulseManager

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

PulseManager implements core.PulseManager.

func NewPulseManager

func NewPulseManager(db *storage.DB, coordinator *jetcoordinator.JetCoordinator) (*PulseManager, error)

NewPulseManager creates PulseManager instance.

func (*PulseManager) Current

func (m *PulseManager) Current() (*core.Pulse, error)

Current returns current pulse structure.

func (*PulseManager) Set

func (m *PulseManager) Set(pulse core.Pulse) error

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