component

Documentation

Index

• func MustKnowPreviousStatistic(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) observer.Statistic
• func MustKnowPulse(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) insolar.PulseNumber
• type Manager
  • func Prepare() *Manager
  • func (m *Manager) Start()
  • func (m *Manager) Stop()
• type RecordPosition
  • func MustKnowRecordPosition(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) RecordPosition
• type Router
  • func NewRouter(cfg *configuration.Configuration, obs *observability.Observability) *Router
  • func (r *Router) Start()
  • func (r *Router) Stop()

Functions

func MustKnowPreviousStatistic

func MustKnowPreviousStatistic(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) observer.Statistic

func MustKnowPulse

func MustKnowPulse(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) insolar.PulseNumber

Types

type Manager

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

func Prepare

func Prepare() *Manager

func (*Manager) Start

func (m *Manager) Start()

func (*Manager) Stop

func (m *Manager) Stop()

type RecordPosition

type RecordPosition struct {
	Last              insolar.PulseNumber
	RN                uint32
	ShouldIterateFrom insolar.PulseNumber
}

func MustKnowRecordPosition

func MustKnowRecordPosition(cfg *configuration.Configuration, obs *observability.Observability, db orm.DB) RecordPosition

type Router

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

func NewRouter

func NewRouter(cfg *configuration.Configuration, obs *observability.Observability) *Router

func (*Router) Start

func (r *Router) Start()

func (*Router) Stop

func (r *Router) Stop()