assemble

type Options struct {
	BatchSize               int
	ClaimOwner              string
	ClaimLease              time.Duration
	Concurrency             int
	MaxYEncRecoveryAttempts int
	BinaryUpsertDBChunkSize int
	Lane                    string
	LaneATargetPct          int
	LaneBMinPct             int
	LaneATimeWindowMinutes  int
	TargetWindowEnabled     bool
	TargetWindowStart       string
	TargetWindowEnd         string
}

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