rsvp

Documentation

Index

• Constants
• type Rsvp
  • func New() *Rsvp
  • func (r *Rsvp) JumpToCheckpoint(checkpoint uint32)
  • func (r *Rsvp) JumpToEnd()
  • func (r *Rsvp) JumpToStart()
  • func (r *Rsvp) SkipBackward()
  • func (r *Rsvp) SkipFoward()
  • func (r *Rsvp) StreamNodes(input string) (<-chan node.Node, <-chan error)
• type RsvpEvent
• type RsvpState
• type RsvpStateSettings

Constants

const (
	DefaultNodesPerMinute = uint16(300)
	DefaultNodesPerCycle  = uint8(1)
)

Types

type Rsvp

type Rsvp struct {
	Settings RsvpStateSettings
	State    *reactive.State[RsvpState]
}

func New

func New() *Rsvp

func (*Rsvp) JumpToCheckpoint

func (r *Rsvp) JumpToCheckpoint(checkpoint uint32)

func (*Rsvp) JumpToEnd

func (r *Rsvp) JumpToEnd()

func (*Rsvp) JumpToStart

func (r *Rsvp) JumpToStart()

func (*Rsvp) SkipBackward

func (r *Rsvp) SkipBackward()

func (*Rsvp) SkipFoward

func (r *Rsvp) SkipFoward()

func (*Rsvp) StreamNodes

func (r *Rsvp) StreamNodes(input string) (<-chan node.Node, <-chan error)

type RsvpEvent

type RsvpEvent string

const (
	EventStateChanged RsvpEvent = "rsvp::stateChanged"
)

type RsvpState

type RsvpState struct {
	Nodes      []node.Node
	Checkpoint uint32
	IsRunning  bool
	IsFinished bool
}

type RsvpStateSettings

type RsvpStateSettings struct {
	NodesPerMinute uint16
	NodesPerCycle  uint8
}