replayable

Documentation

Overview

Package replayable provides the EXPERIMENTAL semi-deterministic replayable policy.

Index

• Constants
• type Replayable
  • func New() *Replayable
  • func (d *Replayable) ActionChan() chan signal.Action
  • func (r *Replayable) LoadConfig(cfg config.Config) error
  • func (r *Replayable) Name() string
  • func (r *Replayable) QueueEvent(event signal.Event)
  • func (d *Replayable) SetHistoryStorage(storage historystorage.HistoryStorage) error

Constants

const Name = "replayable"

Types

type Replayable

type Replayable struct {

	// parameter "maxInterval"
	MaxInterval time.Duration

	// parameter "seed"
	Seed string
	// contains filtered or unexported fields
}

func New

func New() *Replayable

func (*Replayable) ActionChan

func (d *Replayable) ActionChan() chan signal.Action

func (*Replayable) LoadConfig

func (r *Replayable) LoadConfig(cfg config.Config) error

parameters:

• maxInterval(duration): max interval (default: 10 msecs)
• seed(string): seed for replaying (default: empty). can be overriden by NMZ_REPLAY_SEED.

should support dynamic reloading

func (*Replayable) Name

func (r *Replayable) Name() string

returns "replayable"

func (*Replayable) QueueEvent

func (r *Replayable) QueueEvent(event signal.Event)

func (*Replayable) SetHistoryStorage

func (d *Replayable) SetHistoryStorage(storage historystorage.HistoryStorage) error