replaycmd

type Clock ¶

type Clock interface {
	Sleep(ctx context.Context, duration time.Duration) error
}

Timestamps are data that come from the recording: each event.Event has a timestamp. The clock acts: replay subtracts two timestamps to get the gap and divides by --speed option and aks the clock to wait that long before rendering the next event.

type EventSink ¶

type EventSink interface {
	Write(evt event.Event)
}

EventSink shows each replayed event. → cmd/steerloop/internal/render

type Options ¶

type Options struct {
	Path    string
	Speed   float64
	MaxWait time.Duration
}

func ParseOptions(args []string, stderr io.Writer) (Options, error)

func (o Options) Validate() error

type Replay ¶

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

Replay is one recording, ready to play. NewReplay builds it.

func NewReplay(env cli.Environment, clock Clock, opts Options) (*Replay, error)

func (r *Replay) Execute(parent context.Context) int

type ReplayClock ¶

type ReplayClock struct{}

func (c *ReplayClock) Sleep(ctx context.Context, d time.Duration) error

type ReplayCommand ¶

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

Command is `steerloop replay`. It implements cli.Command.

func New(env cli.Environment) *ReplayCommand

func (c *ReplayCommand) Run(ctx context.Context, args []string) int