Documentation ¶
Index ¶
- func NewReplayConfig(sourceID string, destinationID string, minJobID int64, maxDSIndex int64, ...) replayConfigT
- type ReplayProcessorT
- func (r *ReplayProcessorT) CreateReplayConfig(replayConfig replayConfigT) error
- func (r *ReplayProcessorT) GetReplaysToProcess(replays []replayT) []replayT
- func (r *ReplayProcessorT) ProcessNewReplays(replays []replayT, minJobID int64, maxDSIndex int64) error
- func (r *ReplayProcessorT) Setup(gatewayDB *jobsdb.HandleT)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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)
Click to show internal directories.
Click to hide internal directories.