wz2cool / local-queue / #38

Committed 01 Feb 2025 12:36PM UTC coverage: 91.85% (-0.02%) from 91.871%

Build # #38

Build Type

push

Committed by

Commit Message

Merge pull request #6 from wz2cool/0.1.2

0.1.2

Coverage Stats

113 of 127 new or added lines in 9 files covered. (88.98%)

586 of 638 relevant lines covered (91.85%)

0.92 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

80.0

/src/main/java/com/github/wz2cool/localqueue/helper/ChronicleQueueHelper.java

package com.github.wz2cool.localqueue.helper;

import com.github.wz2cool.localqueue.model.enums.RollCycleType;
import net.openhft.chronicle.core.time.TimeProvider;
import net.openhft.chronicle.queue.DefaultCycleCalculator;
import net.openhft.chronicle.queue.RollCycle;
import net.openhft.chronicle.queue.RollCycles;

import java.util.TimeZone;

/**
 * Chronicle Queue Helper
 *
 * @author frank
 */
public class ChronicleQueueHelper {

    public static int cycle(final RollCycle rollCycle, TimeProvider timeProvider, final long timestamp) {
        long offsetMillis = System.currentTimeMillis() - timestamp;
        return DefaultCycleCalculator.INSTANCE.currentCycle(rollCycle, timeProvider, offsetMillis);
    }

    public static RollCycle getRollCycle(final RollCycleType rollCycleType) {
        switch (rollCycleType) {
            case HOURLY:
                return RollCycles.FAST_HOURLY;
            case DAILY:
                return RollCycles.FAST_DAILY;
            default:
                throw new IllegalArgumentException("rollCycleType is not support.");
        }
    }

    public static TimeProvider getTimeProvider(TimeZone timeZone) {
        return () -> {
            long currentTime = System.currentTimeMillis();
            return currentTime + timeZone.getOffset(currentTime);
        };

    }
}

1	package com.github.wz2cool.localqueue.helper;
2
3	import com.github.wz2cool.localqueue.model.enums.RollCycleType;
4	import net.openhft.chronicle.core.time.TimeProvider;
5	import net.openhft.chronicle.queue.DefaultCycleCalculator;
6	import net.openhft.chronicle.queue.RollCycle;
7	import net.openhft.chronicle.queue.RollCycles;
8
9	import java.util.TimeZone;
10
11	/**
12	* Chronicle Queue Helper
13	*
14	* @author frank
15	*/
NEW 16	public class ChronicleQueueHelper {	×
17
18	public static int cycle(final RollCycle rollCycle, TimeProvider timeProvider, final long timestamp) {
19	long offsetMillis = System.currentTimeMillis() - timestamp;	1✔
20	return DefaultCycleCalculator.INSTANCE.currentCycle(rollCycle, timeProvider, offsetMillis);	1✔
21	}
22
23	public static RollCycle getRollCycle(final RollCycleType rollCycleType) {
24	switch (rollCycleType) {	1✔
25	case HOURLY:
26	return RollCycles.FAST_HOURLY;	1✔
27	case DAILY:
28	return RollCycles.FAST_DAILY;	1✔
29	default:
NEW 30	throw new IllegalArgumentException("rollCycleType is not support.");	×
31	}
32	}
33
34	public static TimeProvider getTimeProvider(TimeZone timeZone) {
35	return () -> {	1✔
36	long currentTime = System.currentTimeMillis();	1✔
37	return currentTime + timeZone.getOffset(currentTime);	1✔
38	};
39
40	}
41	}

wz2cool / local-queue / #38

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous