Skip to content

enhance: add create segment message, enable empty segment flush

Codecov / codecov/patch succeeded Nov 7, 2024 in 1s

81.88% of diff hit (target 80.00%)

View this Pull Request on Codecov

81.88% of diff hit (target 80.00%)

Annotations

Check warning on line 248 in internal/flushcommon/pipeline/flow_graph_dd_node.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/flushcommon/pipeline/flow_graph_dd_node.go#L248 

Added line #L248 was not covered by tests

Check warning on line 264 in internal/flushcommon/syncmgr/storage_serializer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/flushcommon/syncmgr/storage_serializer.go#L263-L264 

Added lines #L263 - L264 were not covered by tests

Check warning on line 275 in internal/flushcommon/syncmgr/storage_serializer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/flushcommon/syncmgr/storage_serializer.go#L275 

Added line #L275 was not covered by tests

Check warning on line 277 in internal/flushcommon/syncmgr/storage_serializer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/flushcommon/syncmgr/storage_serializer.go#L277 

Added line #L277 was not covered by tests

Check warning on line 179 in internal/proxy/task_insert_streaming.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/proxy/task_insert_streaming.go#L179 

Added line #L179 was not covered by tests

Check warning on line 187 in internal/proxy/task_insert_streaming.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/proxy/task_insert_streaming.go#L187 

Added line #L187 was not covered by tests

Check warning on line 192 in internal/proxy/task_insert_streaming.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/proxy/task_insert_streaming.go#L192 

Added line #L192 was not covered by tests

Check warning on line 44 in internal/streamingnode/server/flusher/flusherimpl/msg_handler_impl.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/flusher/flusherimpl/msg_handler_impl.go#L43-L44 

Added lines #L43 - L44 were not covered by tests

Check warning on line 52 in internal/streamingnode/server/flusher/flusherimpl/msg_handler_impl.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/flusher/flusherimpl/msg_handler_impl.go#L47-L52 

Added lines #L47 - L52 were not covered by tests

Check warning on line 123 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#L123 

Added line #L123 was not covered by tests

Check warning on line 25 in internal/streamingnode/server/wal/interceptors/redo/redo_interceptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/redo/redo_interceptor.go#L24-L25 

Added lines #L24 - L25 were not covered by tests

Check warning on line 252 in internal/streamingnode/server/wal/interceptors/segment/manager/partition_manager.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/segment/manager/partition_manager.go#L251-L252 

Added lines #L251 - L252 were not covered by tests

Check warning on line 257 in internal/streamingnode/server/wal/interceptors/segment/manager/partition_manager.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/segment/manager/partition_manager.go#L256-L257 

Added lines #L256 - L257 were not covered by tests

Check warning on line 325 in internal/streamingnode/server/wal/interceptors/segment/manager/partition_manager.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/segment/manager/partition_manager.go#L322-L325 

Added lines #L322 - L325 were not covered by tests

Check warning on line 160 in internal/streamingnode/server/wal/interceptors/segment/segment_assign_interceptor.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/interceptors/segment/segment_assign_interceptor.go#L158-L160 

Added lines #L158 - L160 were not covered by tests

Check warning on line 62 in internal/streamingnode/server/wal/utility/context.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/streamingnode/server/wal/utility/context.go#L60-L62 

Added lines #L60 - L62 were not covered by tests

Check warning on line 62 in pkg/streaming/util/message/adaptor/ts_msg_newer.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

pkg/streaming/util/message/adaptor/ts_msg_newer.go#L61-L62 

Added lines #L61 - L62 were not covered by tests
View more details on Codecov