beatstor

Documentation

Index

• type Memory
  • func NewInMemory(depth int) *Memory
  • func (p *Memory) AddCommittedBeat(bt beat.Beat) error
  • func (p *Memory) AddExpectedBeat(bt beat.Beat) error
  • func (p *Memory) EnsureLatestTimeBeat(bt beat.Beat) error
  • func (p *Memory) FindAnyLatestNodeSnapshot() beat.NodeSnapshot
  • func (p *Memory) FindLatestNodeSnapshot() beat.NodeSnapshot
  • func (p *Memory) GetNodeSnapshot(pn pulse.Number) (beat.NodeSnapshot, error)
  • func (p *Memory) LatestTimeBeat() (beat.Beat, error)
  • func (p *Memory) TimeBeat(pn pulse.Number) (beat.Beat, error)

Types

type Memory

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

func NewInMemory

func NewInMemory(depth int) *Memory

func (*Memory) AddCommittedBeat

func (p *Memory) AddCommittedBeat(bt beat.Beat) error

func (*Memory) AddExpectedBeat

func (p *Memory) AddExpectedBeat(bt beat.Beat) error

func (*Memory) EnsureLatestTimeBeat

func (p *Memory) EnsureLatestTimeBeat(bt beat.Beat) error

func (*Memory) FindAnyLatestNodeSnapshot

func (p *Memory) FindAnyLatestNodeSnapshot() beat.NodeSnapshot

func (*Memory) FindLatestNodeSnapshot

func (p *Memory) FindLatestNodeSnapshot() beat.NodeSnapshot

func (*Memory) GetNodeSnapshot

func (p *Memory) GetNodeSnapshot(pn pulse.Number) (beat.NodeSnapshot, error)

func (*Memory) LatestTimeBeat

func (p *Memory) LatestTimeBeat() (beat.Beat, error)

func (*Memory) TimeBeat

func (p *Memory) TimeBeat(pn pulse.Number) (beat.Beat, error)