Skip to content

fix: move sync first time tick into single function

Codecov / codecov/patch failed Jul 3, 2024 in 0s

64.30% of diff hit (target 80.00%)

View this Pull Request on Codecov

64.30% of diff hit (target 80.00%)

Annotations

Check warning on line 83 in internal/streamingnode/server/wal/adaptor/scanner_adaptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/adaptor/scanner_adaptor.go#L82-L83 

Added lines #L82 - L83 were not covered by tests

Check warning on line 101 in internal/streamingnode/server/wal/adaptor/scanner_adaptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/adaptor/scanner_adaptor.go#L101 

Added line #L101 was not covered by tests

Check warning on line 24 in internal/streamingnode/server/wal/adaptor/scanner_registry.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/adaptor/scanner_registry.go#L24 

Added line #L24 was not covered by tests

Check warning on line 115 in internal/streamingnode/server/wal/adaptor/wal_adaptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/adaptor/wal_adaptor.go#L115 

Added line #L115 was not covered by tests

Check warning on line 71 in internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go#L70-L71 

Added lines #L70 - L71 were not covered by tests

Check warning on line 88 in internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go#L88 

Added line #L88 was not covered by tests

Check warning on line 110 in internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go#L110 

Added line #L110 was not covered by tests

Check warning on line 114 in internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/timetick/timetick_interceptor.go#L114 

Added line #L114 was not covered by tests

Check warning on line 15 in internal/util/streamingutil/status/checker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/checker.go#L13-L15 

Added lines #L13 - L15 were not covered by tests

Check warning on line 18 in internal/util/streamingutil/status/checker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/checker.go#L17-L18 

Added lines #L17 - L18 were not covered by tests

Check warning on line 21 in internal/util/streamingutil/status/checker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/checker.go#L20-L21 

Added lines #L20 - L21 were not covered by tests

Check warning on line 29 in internal/util/streamingutil/status/checker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/checker.go#L24-L29 

Added lines #L24 - L29 were not covered by tests

Check warning on line 46 in internal/util/streamingutil/status/checker.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/checker.go#L46 

Added line #L46 was not covered by tests

Check warning on line 25 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L23-L25 

Added lines #L23 - L25 were not covered by tests

Check warning on line 28 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L27-L28 

Added lines #L27 - L28 were not covered by tests

Check warning on line 33 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L30-L33 

Added lines #L30 - L33 were not covered by tests

Check warning on line 35 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L35 

Added line #L35 was not covered by tests

Check warning on line 41 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L39-L41 

Added lines #L39 - L41 were not covered by tests

Check warning on line 43 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L43 

Added line #L43 was not covered by tests

Check warning on line 48 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L47-L48 

Added lines #L47 - L48 were not covered by tests

Check warning on line 54 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L52-L54 

Added lines #L52 - L54 were not covered by tests

Check warning on line 58 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L56-L58 

Added lines #L56 - L58 were not covered by tests

Check warning on line 61 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L61 

Added line #L61 was not covered by tests

Check warning on line 67 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L65-L67 

Added lines #L65 - L67 were not covered by tests

Check warning on line 69 in internal/util/streamingutil/status/rpc_error.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/util/streamingutil/status/rpc_error.go#L69 

Added line #L69 was not covered by tests
View more details on Codecov