wehub-resource-sync
498b235461
Build and test / Build and test AMD64 Ubuntu 22.04 (push) Failing after 0s
Publish Builder / amazonlinux2023 (push) Failing after 1s
Build and test / UT for Go (push) Has been skipped
Publish KRTE Images / KRTE (push) Failing after 1s
Build and test / Integration Test (push) Has been skipped
Build and test / Upload Code Coverage (push) Has been skipped
Publish Builder / rockylinux9 (push) Failing after 1s
Publish Builder / ubuntu22.04 (push) Failing after 0s
Publish Builder / ubuntu24.04 (push) Failing after 0s
Publish Gpu Builder / publish-gpu-builder (push) Failing after 1s
Publish Test Images / PyTest (push) Failing after 0s
Build and test / UT for Cpp (push) Has been cancelled
32 lines
1.2 KiB
Go
32 lines
1.2 KiB
Go
package util
|
|
|
|
import (
|
|
"github.com/milvus-io/milvus/pkg/v3/proto/streamingpb"
|
|
"github.com/milvus-io/milvus/pkg/v3/streaming/util/message"
|
|
"github.com/milvus-io/milvus/pkg/v3/util/paramtable"
|
|
"github.com/milvus-io/milvus/pkg/v3/util/replicateutil"
|
|
)
|
|
|
|
func IsReplicationRemovedByAlterReplicateConfigMessage(msg message.ImmutableMessage, replicateInfo *streamingpb.ReplicatePChannelMeta) (replicationRemoved bool) {
|
|
prcMsg := message.MustAsImmutableAlterReplicateConfigMessageV2(msg)
|
|
header := prcMsg.Header()
|
|
|
|
// Check ignore field - if true, this message should be ignored
|
|
// This is used for incomplete switchover messages that should be ignored after force promote
|
|
if header.Ignore {
|
|
return false
|
|
}
|
|
|
|
replicateConfig := header.ReplicateConfiguration
|
|
currentClusterID := paramtable.Get().CommonCfg.ClusterPrefix.GetValue()
|
|
currentCluster := replicateutil.MustNewConfigHelper(currentClusterID, replicateConfig).GetCurrentCluster()
|
|
_, err := currentCluster.GetTargetChannel(replicateInfo.GetSourceChannelName(),
|
|
replicateInfo.GetTargetCluster().GetClusterId())
|
|
if err != nil {
|
|
// Cannot find the target channel, it means that the `current->target` topology edge is removed,
|
|
// it means that the replication is removed.
|
|
return true
|
|
}
|
|
return false
|
|
}
|