2916
}
2917
2918
>
func (e *matchingEngineImpl) checkNexusEndpointsOwnership() (bool, <-chan struct{}, error) {
matching_engine.go
2919
>
// Get the channel before checking the condition to prevent the channel from being closed while we're running this
2920
>
// check.
2921
>
ch := e.nexusEndpointsOwnershipLostCh.Load().(chan struct{}) //nolint:revive // type is always chan struct{}
2922
>
self := e.hostInfoProvider.HostInfo().Identity()
2923
>
owner, err := e.serviceResolver.Lookup(nexusEndpointsTablePartitionRoutingKey)
2924
>
if err != nil {
2925
return false, nil, fmt.Errorf("cannot resolve Nexus endpoints partition owner: %w", err)
2926
}
2928
}
2929