Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: support manage connection #2867

Merged
merged 24 commits into from
May 27, 2024

address the comment

ca036a9
Select commit
Loading
Failed to load commit list.
Merged

feat: support manage connection #2867

address the comment
ca036a9
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded May 27, 2024 in 0s

No report found to compare against

View this Pull Request on Codecov

No report found to compare against

Annotations

Check warning on line 81 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L79-L81 

Added lines #L79 - L81 were not covered by tests

Check warning on line 84 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L83-L84 

Added lines #L83 - L84 were not covered by tests

Check warning on line 113 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L113 

Added line #L113 was not covered by tests

Check warning on line 145 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L145 

Added line #L145 was not covered by tests

Check warning on line 167 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L165-L167 

Added lines #L165 - L167 were not covered by tests

Check warning on line 193 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L187-L193 

Added lines #L187 - L193 were not covered by tests

Check warning on line 197 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L195-L197 

Added lines #L195 - L197 were not covered by tests

Check warning on line 200 in internal/io/connection/connection_pool.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/connection/connection_pool.go#L199-L200 

Added lines #L199 - L200 were not covered by tests

Check warning on line 102 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L101-L102 

Added lines #L101 - L102 were not covered by tests

Check warning on line 110 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L106-L110 

Added lines #L106 - L110 were not covered by tests

Check warning on line 117 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L116-L117 

Added lines #L116 - L117 were not covered by tests

Check warning on line 130 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L130 

Added line #L130 was not covered by tests

Check warning on line 227 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L224-L227 

Added lines #L224 - L227 were not covered by tests

Check warning on line 229 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L229 

Added line #L229 was not covered by tests

Check warning on line 239 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L236-L239 

Added lines #L236 - L239 were not covered by tests

Check warning on line 241 in internal/io/mqtt/client/client.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/client/client.go#L241 

Added line #L241 was not covered by tests

Check warning on line 72 in internal/io/mqtt/sink.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/sink.go#L70-L72 

Added lines #L70 - L72 were not covered by tests

Check warning on line 76 in internal/io/mqtt/sink.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/sink.go#L74-L76 

Added lines #L74 - L76 were not covered by tests

Check warning on line 78 in internal/io/mqtt/sink.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/sink.go#L78 

Added line #L78 was not covered by tests

Check warning on line 83 in internal/io/mqtt/sink.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/sink.go#L83 

Added line #L83 was not covered by tests

Check warning on line 118 in internal/io/mqtt/sink.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/sink.go#L114-L118 

Added lines #L114 - L118 were not covered by tests

Check warning on line 66 in internal/io/mqtt/source.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/source.go#L65-L66 

Added lines #L65 - L66 were not covered by tests

Check warning on line 71 in internal/io/mqtt/source.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/source.go#L70-L71 

Added lines #L70 - L71 were not covered by tests

Check warning on line 81 in internal/io/mqtt/source.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/source.go#L79-L81 

Added lines #L79 - L81 were not covered by tests

Check warning on line 85 in internal/io/mqtt/source.go

See this annotation in the file changed.

@codecov codecov / codecov/patch

internal/io/mqtt/source.go#L83-L85 

Added lines #L83 - L85 were not covered by tests
View more details on Codecov