Versions in this module Expand all Collapse all v1 v1.0.0 May 26, 2022 Changes in this version + const TS_SOURCE_MONSTACHE + const TS_SOURCE_OPLOG + type TimestampResolver interface + GetResumeTimestamp func(candidateTs primitive.Timestamp, source string) chan primitive.Timestamp + type TimestampResolverEarliest struct + func NewTimestampResolverEarliest(connectionsTotal int, logger *log.Logger) *TimestampResolverEarliest + func (resolver *TimestampResolverEarliest) GetResumeTimestamp(candidateTs primitive.Timestamp, source string) chan primitive.Timestamp + type TimestampResolverSimple struct + func (r TimestampResolverSimple) GetResumeTimestamp(candidateTs primitive.Timestamp, source string) chan primitive.Timestamp
Go to main page