replay

package
v0.1.9 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 30, 2020 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewReplayConfig

func NewReplayConfig(sourceID string, destinationID string, minJobID int64, maxDSIndex int64, notifyURL string) replayConfigT

Types

type ReplayProcessorT

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

func (*ReplayProcessorT) CreateReplayConfig

func (r *ReplayProcessorT) CreateReplayConfig(replayConfig replayConfigT) error

func (*ReplayProcessorT) GetReplaysToProcess

func (r *ReplayProcessorT) GetReplaysToProcess(replays []replayT) []replayT

func (*ReplayProcessorT) ProcessNewReplays

func (r *ReplayProcessorT) ProcessNewReplays(replays []replayT, minJobID int64, maxDSIndex int64) error

func (*ReplayProcessorT) Setup

func (r *ReplayProcessorT) Setup(gatewayDB *jobsdb.HandleT)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL