publish

Documentation

Index

• type Strategy
  • func NewStrategy(maxWaitDuration time.Duration, quiesceDuration time.Duration, ...) *Strategy
  • func NewStrategyWithDefaults() *Strategy
  • func (s *Strategy) Close()
  • func (s *Strategy) OnChange()

Types

type Strategy

type Strategy struct {

	// Publish channel is used to trigger the publication of snapshots.
	Publish chan struct{}
	// contains filtered or unexported fields
}

Strategy is a heuristic model for deciding when to publish snapshots. It tries to detect quiesce points for events with a total bounded wait time.

func NewStrategy

func NewStrategy(
	maxWaitDuration time.Duration,
	quiesceDuration time.Duration,
	timerFrequency time.Duration) *Strategy

NewStrategy creates a new strategy with the given values.

func NewStrategyWithDefaults

func NewStrategyWithDefaults() *Strategy

NewStrategyWithDefaults creates a new strategy with default values.

func (*Strategy) Close

func (s *Strategy) Close()

func (*Strategy) OnChange

func (s *Strategy) OnChange()